在 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
以下是推荐实现：
return spi.messageEvent(message)
.then(spi.getPersonById(evt.getVictimId())) // ✅ 顺序触发：messageEvent 完成后执行 getPersonById
.flatMap(victim -> repository.save(victim)); // ✅ 使用 flatMap 处理保存（返回 Mono<SavedVictim>）⚠️ 注意事项：
- 若 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 的性能与可扩展性优势。
