本文讲解如何在 project reactor 中避免在 `map` 操作中错误使用 `subscribe` 导致副作用失效的问题，通过 `flatmap` + `collectlist`（或 `reduce`）实现内层 flux 数据的可靠收集与外层对象构造。
在使用 Project Reactor 编写响应式流时，一个常见误区是：在 map 或 flatMap 等转换操作中，对内层 Flux 调用 subscribe() 手动消费数据，并试图通过外部变量（如 A.setVal(val)）修改对象状态。这种做法不仅违背响应式编程的无状态、声明式原则，更会导致副作用不可靠——因为 subscribe() 是异步触发的，且 map 中的 lambda 是纯函数上下文，其局部变量生命周期与流执行不一致，A 实例可能在 setVal 被调用前已被丢弃，或因并发/调度导致值丢失或覆盖。
正确的做法是将内层 Flux 的数据“拉取”为确定性结果（如 List
以下是一个推荐的重构模式：
Flux outsideFlux = groupedFlux .flatMap(element -> { // 1. 获取内层 Flux（例如调用异步服务） FluxinsideFlux = someOtherCallThatReturnsThisFluxOfDouble(element); // 2. 将内层 Flux 聚合为确定性数据（如 List） return insideFlux.collectList() // 3. 基于聚合结果构造 A 对象（同步、可预测） .map(doubleList -> new A(doubleList)); });
✅ 关键优势：
- collectList() 返回 Mono
- >，确保内层所有元素完成后再触发后续逻辑；
- flatMap 自动处理嵌套流的扁平化与背压，无需手动管理订阅生命周期；
- new A(doubleList) 在数据就绪后立即执行，A 的状态完全由输入决定，无竞态风险。
⚠️ 注意事项：
- 若 insideFlux 可能为空，collectList() 会返回空 List，可结合 defaultIfEmpty() 或 switchIfEmpty() 处理默认值；
- 若只需单个值（如首个、最大值），优先使用 next()、reduce() 或 singleOrEmpty()，避免不必要的内存累积；
- 切勿在 map 中调用 block() 或 toStream().collect(...) —— 这会阻塞线程，破坏响应式非阻塞特性；
- A 类应尽量设计为不可变（如通过构造函数注入数据），增强线程安全性与可测试性。
总结：Reactor 的核心范式是“组合而非订阅”。当需要将子流结果注入父对象时，始终选择 flatMap + 聚合操作符（collectList, reduce, next 等）的声明式链式调用，让框架自动协调时序与资源，这才是真正安全、可维护的响应式实践。
