SpringDataMongoDB多文档事务的实现

@configuration

static class config extends abstractmongoconfiguration {

   @bean

   mongotransactionmanager transactionmanager(mongodbfactory dbfactory) {

     return new mongotransactionmanager(dbfactory);

   }

   // ...

}

<context:property-placeholder location= "classpath:mongo.properties" ignore-unresolvable= "true"

   file-encoding= "utf-8" />

<!--

   重点配置

   1 .安全配置：credentials= "${mongo.user}:${mongo.password}@${mongo.database}"

   2 .单机配置：host= "${mongo.host}" port= "${mongo.port}"

   3 .副本集配置：replica-set= "${mongo.replset}"

-->

<mongo:mongo-client id= "mongoclient" replica-set= "${mongo.replset}" >

   <mongo:client-options min-connections-per-host= "${mongo.minconnectionsperhost}"

     write-concern= "safe"

     read-preference= "nearest"

     threads-allowed-to-block- for -connection-multiplier= "${mongo.threadsallowedtoblockforconnectionmultiplier}"

     connect-timeout= "${mongo.connecttimeout}" max-wait-time= "${mongo.maxwaittime}"

     socket-keep-alive= "${mongo.socketkeepalive}" socket-timeout= "${mongo.sockettimeout}"

     max-connection-idle-time= "${mongo.maxconnectionidletime}"

     max-connection-life-time= "${mongo.maxconnectionlifetime}"

     heartbeat-socket-timeout= "${mongo.heartbeatsockettimeout}"

     heartbeat-connect-timeout= "${mongo.heartbeatconnecttimeout}"

     min-heartbeat-frequency= "${mongo.minheartbeatfrequency}"

     heartbeat-frequency= "${mongo.heartbeatfrequency}" />

</mongo:mongo-client>

<mongo:db-factory id= "mongodbfactory" dbname= "${mongo.database}"

   mongo-ref= "mongoclient" />

<bean id= "mappingcontext"

   class = "org.springframework.data.mongodb.core.mapping.mongomappingcontext" />

<bean id= "defaultmongotypemapper"

   class = "org.springframework.data.mongodb.core.convert.defaultmongotypemapper" >

   <constructor-arg name= "typekey" >

     < null />

   </constructor-arg>

</bean>

<bean id= "mappingmongoconverter"

   class = "org.springframework.data.mongodb.core.convert.mappingmongoconverter" >

   <constructor-arg name= "mongodbfactory" ref= "mongodbfactory" />

   <constructor-arg name= "mappingcontext" ref= "mappingcontext" />

   <property name= "typemapper" ref= "defaultmongotypemapper" />

</bean>

<bean id= "mongotemplate" class = "org.springframework.data.mongodb.core.mongotemplate" >

   <constructor-arg name= "mongodbfactory" ref= "mongodbfactory" />

   <constructor-arg name= "mongoconverter" ref= "mappingmongoconverter" />

</bean>

<!-- 重点配置 -->

<bean id= "mongotransactionmanager" class = "org.springframework.data.mongodb.mongotransactionmanager" >

   <constructor-arg name= "dbfactory" ref= "mongodbfactory" />

</bean>

<tx:annotation-driven transaction-manager= "mongotransactionmanager" proxy-target- class = "true" />

@service

public class stateservice {

   @autowired

   private mongotemplate teplate;

   @transactional

   void somebusinessfunction(step step) {                

     template.insert(step);

     log.debug( 1 / 0 );

   };

});

mongo.host= 192.168 . 1.66

mongo.port= 27017

mongo.replset= 192.168 . 1.66 : 2000 , 192.168 . 1.66 : 2001 , 192.168 . 1.66 : 2002

mongo.minconnectionsperhost= 10

mongo.threadsallowedtoblockforconnectionmultiplier= 4

mongo.connecttimeout= 30000

mongo.maxwaittime= 3000

mongo.socketkeepalive= false

mongo.sockettimeout= 30000

mongo.maxconnectionidletime= 0

mongo.maxconnectionlifetime= 0

mongo.heartbeatsockettimeout= 20000

mongo.heartbeatconnecttimeout= 10000

mongo.minheartbeatfrequency= 3000

mongo.heartbeatfrequency= 5000

mongo.database=labsta