Reactors 如何串联执行两个 Mono 并保存结果

本文深入解析了在 Reactor 响应式编程中如何安全、高效地串联执行两个 Mono 操作并持久化结果，重点强调绝对禁止在非阻塞线程（如 reactor-http-nio）中调用 `block()`——否则将引发运行时异常并严重损害系统吞吐能力；文章通过真实场景（先发事件再查实体并保存）详解了 `then()` 与 `flatMap()` 的精准分工：`then()` 用于无数据依赖的顺序触发，`flatMap()` 用于数据透传与异步转换，并警示阻塞式数据库操作必须切换线程池或改用响应式驱动，最终揭示响应式开发的本质——用声明式链式表达替代命令式等待，才能真正释放 Reactor 的高性能与弹性扩展潜力。

在 Reactor 响应式编程中，禁止在非阻塞线程（如 reactor-http-nio）中调用 block()；应使用 then() 链式组合 Mono，并通过 map() 或 flatMap() 实现后续异步操作与数据持久化。

在 Reactor 响应式编程中，禁止在非阻塞线程（如 reactor-http-nio）中调用 `block()`；应使用 `then()` 链式组合 Mono，并通过 `map()` 或 `flatMap()` 实现后续异步操作与数据持久化。

在响应式 Spring WebFlux 或 Project Reactor 应用中，常见需求是：先执行一个无返回值的异步操作（如发送事件），待其成功完成后，再触发另一个有返回值的异步操作（如查询实体），并将结果存入数据库。此时若错误地使用 block() 强制等待，会触发 IllegalStateException: block() is not supported in thread reactor-http-nio-X 异常——因为 Reactor 的 I/O 线程（如 reactor-http-nio-2）被设计为非阻塞、高并发的，任何同步阻塞行为都会破坏其调度模型与吞吐能力。

正确的做法是完全拥抱响应式链式表达：利用 Mono.then(Mono) 操作符。该操作符语义明确——忽略上游 Mono 的完成信号（不关心其“值”，只关心“完成”），并将其转换为下游 Mono 的执行起点。它天然支持异步顺序编排，且全程无阻塞。

以下是推荐实现：

return spi.messageEvent(message)
    .then(spi.getPersonById(evt.getVictimId()))  // ✅ 顺序触发：messageEvent 完成后执行 getPersonById
    .flatMap(victim -> repository.save(victim)); // ✅ 使用 flatMap 处理保存（返回 Mono）

⚠️ 注意事项：

• 若 repository.save(victim) 返回的是 Mono（如 Spring Data R2DBC / MongoDB Reactive），请务必使用 flatMap 而非 map，否则会嵌套 Mono>；
• 若 save() 是阻塞式（如 JPA CrudRepository），则不可直接使用——需通过 publishOn(Schedulers.boundedElastic()) 切换至弹性线程池执行，或改用响应式数据访问层；
• then(Mono) 会丢弃上游数据，因此它适用于“仅需触发时机、无需传递数据”的场景；若需将前序结果透传给后续步骤（例如同时记录日志或组合多个字段），应改用 flatMap：

  return spi.messageEvent(message)
      .flatMap(ignored -> spi.getPersonById(evt.getVictimId()))
      .flatMap(victim -> repository.save(victim));

总结：响应式编程的核心原则之一是避免阻塞，用声明式链代替命令式等待。then() 是处理“无值依赖型串行流程”的标准工具；而 block() 仅应在测试、命令行工具或主函数等非响应式上下文中临时使用。坚守这一原则，才能充分发挥 Reactor 的性能与可扩展性优势。

今天关于《Reactors 如何串联执行两个 Mono 并保存结果》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！