Spring Flux多数据源组装对象：如何确保数据全部填充完成？

嘿，我来帮你理清楚这个问题——你的代码现在的问题在于误用了subscribe，这会导致你返回的MyObject还没填充好数据就被返回了。让我一步步给你讲清楚怎么修复：

为什么你的当前代码不工作？ #

当你调用someService.getSomeData().subscribe(...)时，你只是触发了异步请求，但当前线程不会等待这个请求完成，而是直接继续执行后面的代码，直到返回Mono.just(myObject)。这时候myObject里的字段大概率还是空的，因为subscribe的回调是在其他线程异步执行的，主线程早就走完了。

在Reactor的响应式编程模型里，我们应该避免在业务逻辑中手动调用subscribe（除非是在应用的入口点，比如main方法或者Web框架的端点），而是通过操作符来组合、转换数据流，让框架来处理异步和等待逻辑。

正确的解决方案：用Mono.zip组合多个数据流 #

因为你的两个数据源是独立的（不需要彼此依赖），最适合的操作符就是Mono.zip——它会等待所有输入的Mono都完成，然后把它们的结果打包成一个元组，你可以用这个元组来同步组装你的MyObject。

修改后的代码如下：

public Mono<MyObject> createMyObject() {
    // 先获取两个数据源的Mono（此时还不会触发请求，只是构建数据流）
    Mono<SomeData> someDataMono = someService.getSomeData();
    Mono<List<MoreData>> moreDataListMono = oneMoreService.getMoreData();
    
    // 使用zip组合两个Mono，等待两者都完成后再组装对象
    return Mono.zip(someDataMono, moreDataListMono)
            .map(tuple -> {
                MyObject myObject = new MyObject();
                // 从元组中取出第一个Mono的结果
                myObject.setData(tuple.getT1());
                // 取出第二个Mono的结果，填充更多字段
                List<MoreData> moreDataList = tuple.getT2();
                myObject.setMoreData(moreDataList);
                // 这里可以添加其他字段的填充逻辑
                return myObject;
            });
}

怎么确保下游拿到完整的对象？ #

现在createMyObject()返回的Mono<MyObject>只有在两个数据源都成功返回结果后，才会emit组装好的MyObject。这样当你调用doSomeBusinessStuff时，就能确保拿到的是完整填充的对象了。

如果你需要调用doSomeBusinessStuff，建议在数据流中用map操作符处理（而不是把Mono传递进去）：

// 响应式风格的调用（比如在WebFlux控制器中）
public Mono<Result> handleBusinessLogic() {
    return createMyObject()
            .map(this::doSomeBusinessStuff); // 这里会在MyObject准备好后执行
}

// 修改doSomeBusinessStuff接受MyObject而不是Mono<MyObject>
public Result doSomeBusinessStuff(MyObject myObject) {
    // 使用someData和moreData执行其他计算
}

如果你是在非响应式环境下（比如测试代码），可以用block()来等待结果：

Result result = createMyObject()
        .map(this::doSomeBusinessStuff)
        .block();

关键要点总结 #

• 不要在业务逻辑中手动subscribe：这会破坏响应式流的链式结构，导致异步问题。
• 用Mono.zip处理多个独立数据源：它会自动等待所有流完成，再组合结果。
• 构建数据流管道：让Reactor框架来处理异步、等待和线程调度，你只需要关注数据的转换和组合。

内容的提问来源于stack exchange，提问作者Aleksey Kozel