本文介绍如何避免阻塞调用（如 block()）和深层 flatMap 嵌套，通过 Mono.expand() 高效、非阻塞地将依赖前序结果的 Mono 调用序列转化为连续的 Flux 流。

本文介绍如何避免阻塞调用（如 block()）和深层 flatmap 嵌套，通过 `mono.expand()` 高效、非阻塞地将依赖前序结果的 mono 调用序列转化为连续的 flux 流。

在响应式编程中，当后续操作需基于前一次异步结果动态生成（例如分页查询、树形遍历、状态机推进或数据库递归查询），直接使用 Flux.generate + block() 会破坏响应式流的非阻塞特性，而盲目链式 flatMap 则易引发栈膨胀与资源失控风险。此时，Mono.expand() 是专为此类“递归式异步展开”场景设计的优雅解法。

Mono.expand() 接收一个 Function>，对初始 Mono 的每个成功值，自动将其作为输入触发下一次 Mono 计算，并将所有中间结果（含初始值）按顺序合并为一个 Flux。它内部采用尾递归优化与背压感知调度，全程无阻塞、无手动线程切换，天然支持取消与错误传播。

以下是一个典型实现示例：

private Mono<integer> calculateNext(Integer value) {
    return Mono.defer(() -> Mono.just(value + 1))
               .delayElement(Duration.ofSeconds(1L)); // 模拟耗时异步操作
}

private Flux<integer> generateSequence(int start, int limit) {
    return calculateNext(start)
            .expand(current -> {
                if (current >= limit) {
                    return Mono.empty(); // 终止条件：达到上限时返回空 Mono
                }
                return calculateNext(current);
            })
            .takeUntil(i -> i > limit); // 双重保障：确保不超过 limit
}</integer></integer>

调用方式简洁安全：

generateSequence(0, 5)
    .doOnNext(i -> LOG.info("Emitting: {}", i))
    .subscribeOn(Schedulers.boundedElastic()) // 仅在必要时指定线程池（如 I/O 密集型）
    .blockLast(); // 仅测试/终端场景使用；生产中应链式处理（如 map/flatMap/filter）

输出结果为：1 → 2 → 3 → 4 → 5 → 6（注意 start=0 时首项为 calculateNext(0)=1）。

⚠️ 关键注意事项：

• expand() 不会自动终止，必须显式提供退出逻辑（如 Mono.empty() 或条件判断），否则可能造成无限递归；
• 若 calculateNext() 可能失败，expand() 会自然传播异常，建议配合 .onErrorResume() 或 .retry() 增强健壮性；
• expand() 返回的 Flux 默认继承上游 Mono 的调度器，无需额外 subscribeOn —— 除非 calculateNext() 内部涉及真实阻塞调用（此时应在该方法内完成线程切换）；
• 与 flatMapMany 的“扇出”不同，expand() 是严格“线性展开”，适合单路径依赖场景；若需并行探索多分支（如图遍历），应选用 flatMap + expand 组合。

总结而言，Mono.expand() 是 Project Reactor 中处理“结果驱动型递归异步流”的首选工具：它语义清晰、实现轻量、资源可控，真正践行了响应式编程“异步非阻塞、声明式编排”的核心原则。