WebClient响应式调用链中如何复用flatMap上游user、x等响应对象？

方案1（嵌套flatMap）合理性说明 #

• 作用域问题：不存在问题。user是外层flatMap的入参，属于lambda捕获的有效变量，只要user本身是不可变的，内部嵌套的异步逻辑可以安全访问，不会出现并发问题。
• 副作用问题：不属于违规副作用。webclient.call返回的是冷Publisher，本身是惰性执行的，整个调用逻辑完全纳入响应式流的调度管理，不是游离于流水线之外的主动执行操作，符合响应式编程规范。
• 适用场景：仅当你不需要host2调用返回的Y对象，只需要保留X给下游使用时，这个写法完全可行，代码也比较简洁。
• 注意修正你代码里的小问题：最后一步用map(x -> webclient.call(...))是错误的，webclient.call返回Publisher类型，应该改用flatMap，否则下游会拿到Mono对象而不是接口返回的执行结果。

方案2（自定义包装类）合理性说明 #

这个方案是工业界常用的规范写法，缺点是需要额外定义包装类，如果你不想自定义，完全可以用Reactor内置的Tuple（元组）类替代，无需额外编码：

// 引入Reactor自带的Tuple工具类
import reactor.util.function.Tuples;

...
.flatMap(user -> webclient.call("host1", user.getId())
        // 封装User和X为二元组向下传递
        .map(x -> Tuples.of(user, x))
)
.flatMap(tuple -> {
    User user = tuple.getT1();
    X x = tuple.getT2();
    return webclient.call("host2", user.getName())
            // 封装User、X、Y为三元组向下传递
            .map(y -> Tuples.of(user, x, y));
})
// 下游直接取需要的参数即可
.flatMap(tuple -> webclient.call("host3", tuple.getT2().getDeviceNo()))

这个写法既不需要自定义包装类，也能保证流水线是扁平结构，可读性比深层嵌套更好，适合后续需要用到多个上游返回值的场景。

性能优化可选方案 #

如果你的业务逻辑中host1和host2的调用没有依赖关系，还可以用zip操作符并行调用提升性能：

.flatMap(user -> Mono.zip(
        webclient.call("host1", user.getId()),
        webclient.call("host2", user.getName())
).map(tuple -> Tuples.of(user, tuple.getT1(), tuple.getT2())))

内容的提问来源于stack exchange，提问作者Chieu Van Vuong