本文介绍如何利用 mono.expand() 将依赖前序结果的单次异步操作（如数据库分页查询）安全、高效地转化为连续的响应式数据流（flux），避免阻塞调用与深层嵌套，真正发挥 project reactor 的非阻塞优势。
本文介绍如何利用 mono.expand() 将依赖前序结果的单次异步操作（如数据库分页查询）安全、高效地转化为连续的响应式数据流（flux），避免阻塞调用与深层嵌套，真正发挥 project reactor 的非阻塞优势。
在响应式编程中，当后续请求必须基于前一次响应结果动态生成时（例如：根据上一页最后 ID 查询下一页、递归获取树形结构、或实现状态驱动的轮询逻辑），直接使用 Flux.generate + block() 会破坏响应式链路，导致线程阻塞和资源浪费；而手动在 generate 中返回 Mono 并配合 flatMap 链式调用，则易引发栈溢出风险或难以控制的嵌套深度。
此时，Mono.expand() 是专为此类场景设计的核心操作符：它以初始 Mono
以下是一个典型实现：
private Mono<Integer> calculateNext(Integer value) {
return Mono.defer(() -> Mono.just(value + 1))
.delayElement(Duration.ofSeconds(1L)); // 模拟异步延迟（如 DB 查询）
}
private Flux<Integer> generateSequence(int start, int endInclusive) {
return calculateNext(start)
.expand(next -> next < endInclusive ? calculateNext(next) : Mono.empty())
.takeUntil(i -> i >= endInclusive);
}关键点说明：
- ✅ 非阻塞递归：expand 内部通过调度器自动管理订阅生命周期，无需 block() 或手动 subscribe()；
- ✅ 终止可控：使用 Mono.empty() 终止递归（如示例中 next
- ✅ 错误传播自然：任一 calculateNext 抛出异常，整个 Flux 将立即以 onError 终止，符合响应式契约；
- ⚠️ 注意循环风险：务必确保递归条件终将不满足，否则会导致无限流（可添加 timeout() 或 limitRate() 防御）；
- ⚠️ 慎用副作用：expand 的 mapper 函数应为纯函数或明确管理副作用（如日志、缓存），避免状态污染。
实际使用时，可无缝集成至 WebFlux 或 R2DBC 流程中：
@GetMapping("/sequence")
public Flux<Integer> getSequence(@RequestParam int from, @RequestParam int to) {
return generateSequence(from, to)
.doOnNext(i -> LOG.debug("Emitting: {}", i))
.doOnError(e -> LOG.error("Stream failed", e));
}总结：面对“结果驱动下一次请求”的响应式迭代需求，Mono.expand() 是语义清晰、性能可靠、工程安全的首选方案。它取代了易出错的手动递归 flatMap 链与反模式的 block()，是 Project Reactor 中被低估却极为强大的高阶组合子。
