Mono.expand 构建响应式 Flux 的方法

本文深入解析了响应式编程中处理依赖前序结果的异步递归调用这一经典难题，揭示了 `Mono.expand()` 如何以声明式、非阻塞且资源友好的方式替代危险的 `block()` 阻塞调用和易失控的深层 `flatMap` 嵌套——无论是分页拉取、树形结构遍历、状态机演进还是递归数据库查询，它都能将一连串动态生成的 Mono 自然“展开”为平滑、背压感知的 Flux 流，真正释放 Project Reactor 的响应式潜力。

本文介绍如何避免阻塞调用（如 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 calculateNext(Integer value) {
    return Mono.defer(() -> Mono.just(value + 1))
               .delayElement(Duration.ofSeconds(1L)); // 模拟耗时异步操作
}

private Flux 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
}

调用方式简洁安全：

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 中处理“结果驱动型递归异步流”的首选工具：它语义清晰、实现轻量、资源可控，真正践行了响应式编程“异步非阻塞、声明式编排”的核心原则。

今天带大家了解了的相关知识，希望对你有所帮助；关于文章的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~