Zip三种不同类型的单声道

Question

我已经开始了一个使用SpringWebFlux的新项目，我对这种反应式编码范式还相当陌生。所以像新手一样提前道歉。

我的控制器方法将响应返回为Mono

Mono<CustomObject> customMono = serivce1.method();
Mono<Boolean> booleanMono = service2.method();
Mono<String> stringMono = service3.method();

因此，为了准备响应（Mono

Mono.zip(customMono, booleanMono, stringMono, (customData, booleanData, stringData) -> {
------
return Mono.just(ResponseEntity.ok().body("-----"));
});

问题是，没有这样的zip方法将3Mono和一个函数作为参数。我已经找到了这个-https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Mono.html#zip-reactor.core.publisher.Mono-reactor.core.publisher.Mono-java.util.function.BiFunction-

但这不符合我的要求。那么我面临的问题是什么呢

• 我不能使用Mono.mergewith或Mono.concawith方法，因为我的Mono对象是不同的类型。
• 我可以平面映射/映射每个Mono并创建一个链。但是我希望service2在一个单独的线程中被并行调用，因为它不依赖于service1调用。但是service3调用依赖于service1响应。

总之，我需要做的是：

• 首先拨打服务1电话
• 在不同的线程上分别调用service2
• 拨打依赖于服务1呼叫数据的服务3呼叫
• 生成最终响应对象（Mono）

提前谢谢。作为一名新手，任何建议都将受到赞赏。




Answer 1

对于您的特定条件，您需要Mono.zip当（）这将确保您的第三次服务调用将从服务调用1的响应中获得所需的数据

Mono.zip(monoResponse1,monoResponse2).zipWhen(data ->serviceCall3(data.getT1())).flatMap(response ->{
    response.getT1().getT1();//response from mono1
    response.getT1().getT2();//response from mono 2
    response.getT2();//response from mono 3
    return {create your mono response here};
} );

Answer 2

每当你压缩两个mono时，第三个参数将是BiFunction，但如果有三个参数，它将返回tuple的flatmap，然后在tuple中你将得到其他mono的响应。您需要按以下方式修改代码。

Mono.zip(customMono, booleanMono, stringMono).flatMap(data->{
 data.getT1();
 data.getT2();
 data.getT3();
 return <your_response_object>;
});

现在，什么是getT1（），getT2（）和getT3（）的返回类型？

通常情况下，这取决于你的回报。

希望它能帮助你。