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.data }\" 
    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.data }\"
    mongo-ref=\"mongoClient\" />

  <bean id=\"mappingContext\"
    class=\"org.spring work.data.mongodb.core.mapping.MongoMappingContext\" />

  <bean id=\"defaultMongoTypeMapper\"
    class=\"org.spring work.data.mongodb.core.convert.DefaultMongoTypeMapper\">
    <constructor-arg name=\"typeKey\">
      <null />
    </constructor-arg>
  </bean>

  <bean id=\"mappingMongoConverter\"
    class=\"org.spring work.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.spring work.data.mongodb.core.MongoTemplate\">
    <constructor-arg name=\"mongoDbFactory\" ref=\"mongoDbFactory\" />
    <constructor-arg name=\"mongoConverter\" ref=\"mappingMongoConverter\" />
  </bean>

  <!-- 重点配置 -->

  <bean id=\"mongoTransactionManager\" class=\"org.spring work.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.data =labsta