MongoDB 事务如何通过 Java 异步驱动实现_使用 Reactor 模式操作事务会话-MongoDB-PHP中文网

reactor驱动下必须显式开启clientsession才能使用事务，所有操作需通过session.withtransaction()包裹并传入session实例，不可复用、不可跨订阅链、不可手动commit/abort。

mongodb 事务如何通过 java 异步驱动实现_使用 reactor 模式操作事务会话

Reactor 驱动下必须显式开启 `ClientSession` 才能使用事务

Reactor 版 MongoDB Java 驱动（mongodb-driver-reactivestreams + spring-boot-starter-data-mongodb-reactive）不支持自动事务上下文传播。你不能像 Spring 的 @Transactional 那样直接标注方法——事务生命周期完全由 ClientSession 控制，且必须手动传入每个操作。

常见错误是漏掉 withTransaction 或误用 startTransaction() 后忘记 commitTransaction() / abortTransaction()，导致会话卡住、连接泄漏或数据不一致。

ClientSession 是线程绑定的，不可跨 Mono/Flux 订阅边界复用（比如在 flatMap 里重复用同一个 session 实例）
事务内所有集合操作（insertOne、updateOne 等）必须通过 session.withTransaction() 包裹的 lambda 执行，不能单独调用
Spring Data Reactive 不提供 @Transactional 支持，强行加注解无效

`withTransaction()` 是唯一安全的事务入口，别手写 commit/abort 流程

驱动内部已封装重试逻辑和异常分类：只有抛出非 RuntimeException（如网络超时、主节点切换）才会触发自动重试；而业务校验失败（如 IllegalArgumentException）应主动 throw，让驱动 abort 并返回原始异常。

手写 session.startTransaction() → 操作 → session.commitTransaction() 是高危操作，一旦中间发生异常，commit 不会执行，但 session 可能仍处于 open 状态，后续请求会卡死或报 IllegalStateException: Session is in transaction。

react-best-practices

重要：对 React 或 Next.js 代码的任何更改必须先阅读本技能。Vercel 工程团队的 React 与 Next.js 指南，涵盖可视化...

下载

始终用 session.withTransaction(txBody)，其中 txBody 是 Function<clientsession mono>></clientsession>
txBody 内所有数据库操作必须调用带 ClientSession 参数的重载方法，例如：collection.insertOne(doc, options).publishOn(scheduler) ❌；正确写法是 collection.insertOne(session, doc, options) ✅
事务内不能混合使用同步驱动操作或非 session 绑定的 reactive 操作

事务超时和读关注需在 `TransactionOptions` 中显式配置

MongoDB 默认事务超时为 60 秒，但 Reactive 驱动不会自动应用这个值——它只作用于服务端，客户端仍需配合设置操作级超时，否则长时间阻塞会拖垮整个事件循环。

另外，事务默认读关注（readConcern）是 "local"，若需要强一致性（比如读自己刚写的文档），必须设为 "majority"；同时要配匹配的写关注（writeConcern），否则事务可能因多数节点未确认而失败。

创建 TransactionOptions 时用 TransactionOptions.builder() 显式指定：.readConcern(ReadConcern.MAJORITY)、.writeConcern(WriteConcern.MAJORITY)
在 withTransaction() 外层套 timeout(Duration.ofSeconds(30))，防止事务卡死影响 reactor 线程
避免在事务中调用外部 HTTP 请求或阻塞 I/O，这会冻结整个 Netty event loop

嵌套 Mono/Flux 导致事务失效的典型场景

事务 session 无法穿透 flatMap、concatMap 或 zip 的订阅链。例如你在事务 lambda 里写 userService.findById(id).flatMap(u -> orderService.create(...))，第二个 service 调用若没把 session 透传进去，就会脱离事务上下文。

根本原因是 Reactor 的异步链不携带隐式上下文，ClientSession 是普通对象，不会自动“粘”在 Context 里（除非你自己用 contextWrite() 注入并提取，但驱动不支持）。

所有参与事务的操作必须在同一 withTransaction lambda 内完成，且每个操作都显式传入该 session 实例
不要试图把 session 存进 ThreadLocal 或 Context 后跨链路取用——Reactor 的调度可能切换线程，且驱动 API 不读取这些上下文
复杂流程建议拆成原子事务块，用最终一致性+补偿代替长事务

事务真正难的不是语法，而是 Reactive 场景下对「上下文不可传递性」的适应：session 是个一次性凭证，用完即弃，没法像 Servlet 线程那样靠 ThreadLocal 偷懒。任何想绕过显式传参的设计，最后都会在并发或错误恢复时暴露问题。