本文详解如何在 reactive（如 mono）流水线中实现“先保存主表并获取主键，再用该主键保存关联表”的串行异步调用，重点对比 map 与 flatmap 的适用场景，并提供可直接运行的代码示例。
本文详解如何在 reactive（如 mono）流水线中实现“先保存主表并获取主键，再用该主键保存关联表”的串行异步调用，重点对比 map 与 flatmap 的适用场景，并提供可直接运行的代码示例。
在响应式编程中，确保操作严格串行且前序结果能作为后续操作输入，是常见但关键的需求。例如：API 接收请求后，需先向主表插入记录并获取生成的主键（如 Integer），再将该主键与业务数据一同插入映射表。此时若误用 Mono.zip()，会导致两个操作并发执行，无法传递中间结果——这正是问题的核心痛点。
正确解法取决于底层数据访问层是否为响应式：
✅ 若使用阻塞式 Repository（如 JdbcTemplate、MyBatis 同步接口）：
需借助 Mono.fromCallable() 将同步调用转为非阻塞任务，并用 map() 进行同步转换（因第二步仍是阻塞调用）：
Mono.fromCallable(() -> repository.saveToMainTable("main data"))
.map(mainTableId -> repository.saveToSecondaryTable(mainTableId, "secondary data"))
.subscribeOn(Schedulers.boundedElastic()) // 必须指定线程池，避免阻塞事件循环
.doOnSuccess(result -> log.info("Mapping inserted: {}", result))
.onErrorResume(e -> {
log.error("Failed to persist mapping", e);
return Mono.empty();
})
.subscribe();⚠️ 注意：map() 仅适用于返回普通对象（非 Mono）的同步操作；且必须搭配 subscribeOn(Schedulers.boundedElastic())，否则会阻塞 Reactor 的默认单线程事件循环。
✅ 若使用响应式 Repository（如 R2DBC、Spring Data R2DBC）：
应使用 flatMap()，它能将上游 Mono<T> 的输出映射为一个新的 Mono<R>，并自动订阅、扁平化嵌套流：
reactiveRepository.saveToMainTable("main data")
.flatMap(mainTableId ->
reactiveRepository.saveToSecondaryTable(mainTableId, "secondary data")
.doOnSuccess(success -> log.info("Successfully linked main ID: {}", mainTableId))
)
.onErrorMap(DataAccessException.class, e ->
new BusinessException("Database operation failed", e))
.subscribe();? flatMap() 是响应式链式调用的基石——它既保证顺序性，又维持全程非阻塞，且天然支持错误传播与组合。
? 关键总结：
- ❌ 避免 zip()：它用于并行聚合多个独立信号，不满足“依赖前序输出”的串行场景；
- ✅ map() → 同步计算，返回普通值；
- ✅ flatMap() → 异步转换，返回新的 Mono/Flux，是响应式流水线的“标准串联方式”；
- ⚠️ 混合阻塞/非阻塞时，务必通过 subscribeOn() 显式调度线程，否则将破坏响应式背压与性能优势。
掌握 map 与 flatMap 的语义差异，是写出清晰、健壮、高性能响应式服务的关键一步。
