本文讲解如何在 spring webflux 的 reactive 链中，避免使用 `block()` 而安全、响应式地持久化错误信息（如邮件发送失败记录），保持整个流的非阻塞特性。
在响应式编程中，调用 .block() 是反模式（anti-pattern）——它会阻塞当前线程，破坏 WebFlux 的异步、事件驱动本质，不仅降低吞吐量，还可能导致线程池耗尽或请求超时。尤其在 onErrorResume 中调用 block()，更会中断错误处理链，丧失背压控制与可观测性。
正确的做法是：将副作用（如数据库保存）本身建模为一个 Mono，并通过组合操作符（如 flatMap、thenReturn 或 handle）无缝融入原有流中。以下是优化后的实现：
public Mono
关键改进说明：
- ✅ mailFailureRepository.save(...).then(Mono.error(error))：then() 在上游 Mono
完成后，不透传其值，而是触发 Mono.error(error)，确保错误语义不变，且全程无订阅阻塞。 - ✅ 移除 block()：所有操作均在 Reactor 调度器（如 elastic 或 boundedElastic）上异步执行，符合响应式契约。
- ✅ 职责分离：buildFailureEmail 提取为独立方法，增强可读性与可测试性；参数显式传递 ex，避免作用域混淆（原答案中 ex 在 lambda 外不可用，存在编译错误，已修正）。
注意事项：
- 确保 mailFailureRepository.save(...) 返回的是 Mono extends S>（如 Mono
），而非阻塞式 CompletableFuture 或 void 方法。 - 若需记录保存失败的兜底逻辑（例如日志告警），可用 doOnError 或 onErrorResume 嵌套：
.onErrorResume(saveFailureMono -> { log.warn("Failed to persist MailFailure", saveFailureMono); return Mono.empty(); // 忽略保存失败，继续抛出原始业务错误 }) - 推荐学习资源：
- Project Reactor Reference Guide — Error Handling
- Spring WebFlux Documentation — Exception Handling
- 《Reactive Programming with RxJava》（虽为 RxJava，但核心思想通用）
通过这种方式，你既完成了关键的错误审计能力，又坚守了响应式编程的“非阻塞”与“声明式组合”原则。
