WebFlux Spring Boot@与反应式MongoDB的事务性

Question

WebFlux Spring Boot事务性注释是否适用于反应式MongoDB？

我将WebFlux Spring Boot与反应式MongoDB配合使用，如：

    id 'org.springframework.boot' version '2.6.7'
    ...
    implementation 'org.springframework.boot:spring-boot-starter-webflux'
    implementation 'org.springframework.boot:spring-boot-starter-data-mongodb-reactive'
    ...

我标记了我的一个方法@Transactional进行测试。但似乎注释对我不起作用。如果此方法内部发生错误，那么它仍然会向我的mongoDB数据库添加原始数据。

      import org.springframework.transaction.annotation.Transactional;

      ...

      @Transactional
      public Mono<Chat> createChat(Chat chat) {
        return chatRepository
            .save(chat)
            .map(
                c-> {
                  if (true) {
                    throw new RuntimeException();
                  }
                  return c;
                });
      }

我是否错过了一些东西，或者Spring Boot事务性注释无法与反应式MongoDB配合使用？

我使用MongoDB v5.0.8

Answer 1

反应式MongoDB的Spring数据似乎需要显式设置一个特殊的bean，即transactionManager。当我将这个bean添加到反应式MongoDB的配置中后，事务性注释就开始工作了。因此，如果方法内部发生错误，我问题中发布的示例方法不再向数据库添加新的raw。

下面是我对transactionManager bean的配置：

@Configuration
@EnableReactiveMongoRepositories
@AllArgsConstructor
public class ReactiveMongoConfiguration extends AbstractReactiveMongoConfiguration {

  private final MongoProperties mongoProperties;

  @Override
  public MongoClient reactiveMongoClient() {
    return MongoClients.create();
  }

  @Override
  protected String getDatabaseName() {
    return mongoProperties.getDatabase();
  }

  @Bean
  ReactiveMongoTransactionManager transactionManager(ReactiveMongoDatabaseFactory reactiveMongoDatabaseFactory) {
    return new ReactiveMongoTransactionManager(reactiveMongoDatabaseFactory);
  }

P、 事实证明，定义transactionManager bean不足以在反应式MongoDB中启用事务。MongoDB的服务器也应该配置复制。我遵循这些步骤，这对我很有效。