本文详解如何在 Spring WebFlux 或 Project Reactor 的响应式流水线中，串行执行两个强依赖的操作：先插入主表获取主键，再将该主键作为参数插入从表，避免 Mono.zip() 并行调用导致的数据依赖失效问题。
本文详解如何在 spring webflux 或 project reactor 的响应式流水线中，**串行执行两个强依赖的操作**：先插入主表获取主键，再将该主键作为参数插入从表，避免 `mono.zip()` 并行调用导致的数据依赖失效问题。
在响应式编程中，当后续操作必须依赖前序操作的输出结果（如主键 ID）时，绝不能使用 Mono.zip() —— 因为其设计目标是并行组合多个独立信号，无法建立数据流的前后依赖关系。正确做法是利用 flatMap（推荐）或 map 操作符构建链式响应流。
✅ 正确方案：按需选择 flatMap 或 map
-
若两个仓库均为响应式（返回 Mono
） → 必须使用 flatMap
flatMap 可将上游 Mono的输出映射为一个新的 Mono ，并自动“展平”嵌套结构，确保异步、非阻塞且顺序执行：
reactiveRepository.saveToMainTable("order-data")
.flatMap(mainId ->
reactiveRepository.saveToSecondaryTable(mainId, "order-item-data")
)
.doOnSuccess(result -> log.info("主从表插入成功"))
.onErrorResume(e -> {
log.error("插入失败", e);
return Mono.error(new RuntimeException("事务回滚", e));
})
.subscribe();
- 若底层是阻塞式 JDBC 仓库（返回普通对象） → 可用 map + fromCallable 包装，但需指定线程调度器避免阻塞主线程：
Mono.fromCallable(() -> repository.saveToMainTable("order-data"))
.subscribeOn(Schedulers.boundedElastic()) // 关键：切至弹性线程池
.map(mainId -> repository.saveToSecondaryTable(mainId, "order-item-data"))
.doOnSuccess(v -> log.info("同步插入完成"))
.subscribe();
⚠️ 注意事项：
React Native For Android 源码编译 中文WORD版下载本文档主要讲述的是React Native For Android 源码编译；希望对大家会有帮助；感兴趣的朋友可以过来看看
- ❌ 禁用 zip()、combineWith() 等并行组合操作符处理有依赖关系的步骤；
- ✅ flatMap 是响应式链式调用的黄金标准，天然支持异步依赖传递；
- ✅ 阻塞调用务必通过 subscribeOn(Schedulers.boundedElastic()) 脱离事件循环线程；
- ✅ 生产环境建议结合 doOnSuccess/doOnError 做可观测性埋点，并用 onErrorResume 或 retryWhen 增强容错能力。
总之，把握一个核心原则：数据依赖 = 流式串联 = flatMap（响应式）或 map + 线程隔离（阻塞式）。这既是 Reactor 编程范式的基石，也是保障业务逻辑原子性与一致性的关键实践。
