本文介绍如何在 Project Reactor 中避免阻塞调用（如 .block()）和过度嵌套 flatMap，通过 Mono.expand() 安全、高效地将依赖前序结果的异步操作（如链式数据库查询）转换为连续的 Flux 数据流。
本文介绍如何在 project reactor 中避免阻塞调用（如 `.block()`）和过度嵌套 `flatmap`，通过 `mono.expand()` 安全、高效地将依赖前序结果的异步操作（如链式数据库查询）转换为连续的 `flux` 数据流。
在响应式编程中，当后续操作必须基于前一次异步结果（例如“根据上一条记录 ID 查询下一条”）时，常见的误区是滥用 Flux.generate 配合 block()，或构造深度嵌套的 flatMap 链——前者破坏了非阻塞原则，后者易引发栈膨胀与内存压力，且难以控制终止条件。
正确的解法是利用 Reactor 提供的 递归展开操作符 Mono.expand()：它接受一个 Function
以下是一个典型实现示例：
private Mono<Integer> calculateNext(Integer value) {
return Mono.defer(() -> Mono.just(value + 1))
.delayElement(Duration.ofSeconds(1L)); // 模拟异步延迟
}
private Flux<Integer> generateSequence(int start, int endInclusive) {
return calculateNext(start)
.expand(current -> {
if (current >= endInclusive) {
return Mono.empty(); // 终止递归
}
return calculateNext(current);
})
.takeUntil(item -> item > endInclusive); // 双重保险：显式终止
}调用方式简洁清晰：
generateSequence(0, 5)
.doOnNext(i -> LOG.info("Emitting: {}", i))
.blockLast(); // 仅用于测试；生产环境应链式订阅或转为 WebFlux 返回值输出：1, 2, 3, 4, 5, 6（注意：因起始调用 calculateNext(0) 得 1，故序列从 1 开始）
✅ 关键优势说明：
- 零阻塞：全程不调用 block() 或 get()，严格遵循响应式契约；
- 栈安全：expand() 内部采用尾递归优化（基于 Schedulers.parallel() 调度），不会导致 StackOverflowError；
- 可控终止：既可通过返回 Mono.empty() 主动结束递归，也可结合 takeUntil() / takeWhile() 等操作符增强健壮性；
- 错误传播自然：任一 calculateNext() 抛出异常，整个 Flux 将立即以 onError 终止，符合 Reactor 错误处理规范。
⚠️ 注意事项：
- 避免在 expand 的 mapper 函数中执行同步耗时逻辑（如数据库直连、文件读取），应确保其返回的是真正的异步 Mono；
- 若需限流或添加超时，可在 calculateNext() 内部或 expand() 后链式添加 .timeout() 或 onErrorResume()；
- 对于需要状态累积（如累计计数、聚合上下文）的场景，建议封装为 Mono
> 并在 expand 中解构更新，而非依赖外部变量。
综上，Mono.expand() 是处理“结果驱动型递归异步流程”的首选工具——它语义明确、实现简洁、性能可靠，真正体现了响应式编程“声明式编排异步事件流”的核心思想。
