随着最新的 Spring Data Lovelace Milestone 2 版本的发布，MongoDB 模块正在积累新功能，这些功能将在不久的将来提供给您。正如您可能在新闻中看到的那样，MongoDB 4 将为文档存储带来 ACID 事务。最新的 MongoDB 3.6 服务器版本已经包含了主要构建模块，即 客户端会话。

您可以在 MongoDB 参考文档中阅读有关 隔离级别和因果一致性 的所有信息。简而言之，会话允许您按照尊重其因果关系顺序执行操作。

通过 Spring Data MongoDB，ClientSession 触手可及，无论是在命令式还是响应式领域，因为我们已将它们整合到已有的 MongoOperations 和 ReactiveMongoOperations 中。为了给您提供最大的控制权和足够的便利性，ClientSession 生命周期由您管理，而模板负责将会话正确地传递给驱动程序。以下示例展示了如何创建 ClientSession。

ClientSessionOptions sessionOptions = ClientSessionOptions.builder()
    .causallyConsistent(true)
    .build();

ClientSession session = client.startSession(sessionOptions);

一旦从 MongoDB Java Driver 获取了会话，您只需将其添加到模板中即可检索会话绑定的操作，并在完成后 close() 会话，如下例所示。

MongoOperations sessionBound = template.withSession(session);

Query query = query(where("name").is("Durzo Blint")
Person durzo = sessionBound.findOne(query), Person.class);

Person kylar = new Person("Kylar Stern");
kylar.setMaster(durzo);

sessionBound.insert(kylar);

session.close();

使用反应式编程模型，上面的例子看起来有点不同，因为我们将要获得一个会话 Publisher，并且希望确保在实际订阅之前不解析它。因此，我们没有获得会话范围内的 ReactiveMongoTemplate，而是获得了 ReactiveSessionScoped 的实例，该实例持有对会话 Publisher 的引用，并提供执行和关闭句柄，以便我们可以确保在返回的 Flux 的 finally 块中关闭 ClientSession，如下例所示。

ClientSessionOptions sessionOptions = ClientSessionOptions.builder()
    .causallyConsistent(true)
    .build();

// obtain a session, but do not subscribe to it
Publisher<ClientSession> session = client.startSession(sessionOptions);

template.withSession(session)
    .execute(action -> {

        Query query = query(where("name").is("Durzo Blint"));
        return action.findOne(query, Person.class)
            .flatMap(durzo -> {

                Person kylar = new Person("Kylar Stern");
                kylar.setMaster(durzo);

                return action.insert(kylar);
            });
    }, ClientSession::close) // make sure we close the session when finished
    .subscribe();

到目前为止，一切都很好，但是我们不是在本文的开头提到事务了吗？

是的，事务将成为 MongoDB 4.0 的一部分，是的，我们将为此做好准备。如果您想关注我们对事务支持的努力，请确保 关注开发。以下是您可以期待的快速一览。

MongoTransactionManager 将是众所周知的事务支持的入口，允许应用程序使用 Spring 的 托管事务 功能。MongoTransactionManager 将创建 ClientSession 并将其绑定到线程。事务启动、提交或中止，而 MongoTemplate 自动检测现有 ClientSession 并相应地对其进行操作，如下例所示。

@Configuration
public class Config extends AbstractMongoConfiguration {

  @Bean
  MongoTransactionManager transactionManager(MongoDbFactory dbFactory) {
    return new MongoTransactionManager(dbFactory);
  }

  // ...
}

@Service
public class NightAngel {

  @Autowired PersonRepository repository;

  @Transactional
  public void trainAzoth() {

    Person durzo = repository.findByName("Durzo Blint");

    Person kylar = new Person("Kylar Stern");
    kylar.setMaster(durzo);

    repository.save(kylar);    
  }
}