Java Project Reactor：如何用不同参数异步组合同一个Mono函数两次

你的思路方向是对的，zip就是干这个的——合并多个异步执行的Mono，等所有任务完成后统一处理结果。问题出在原来的写法有误，下面是正确的实现方式：

return serviceA.getRequestParams()
    .flatMap(params -> {
        // 用获取到的参数构建两个请求对象
        Request request1 = buildRequest1(params);
        Request request2 = buildRequest2(params);
        
        // 发起两个异步调用，它们会并行执行
        Mono<Response> responseMono1 = serviceB.doSomething(request1);
        Mono<Response> responseMono2 = serviceB.doSomething(request2);
        
        // 使用zip合并两个Mono，等待两者都完成后拿到结果对
        return Mono.zip(responseMono1, responseMono2);
    })
    .flatMap(responseTuple -> {
        // 从Tuple中取出两个响应结果
        Response response1 = responseTuple.getT1();
        Response response2 = responseTuple.getT2();
        
        // 在这里处理两个响应的业务逻辑，比如合并结果、校验等
        // 示例：返回处理后的最终响应（假设process方法返回Mono<FinalResponse>）
        return processTwoResponses(response1, response2);
    });

关键要点说明： #

• 异步并行执行：两个serviceB.doSomething调用会被Reactor框架调度为异步执行，无需手动管理线程池（只要doSomething内部是非阻塞的，或者已经正确指定了调度器）。
• flatMap的作用：这里不能用map，因为我们需要从参数生成新的Mono（即zip的结果），flatMap能将流中的元素转换为另一个Publisher并展开其流。
• Mono.zip的特性：它会等待所有输入的Mono都成功完成，才会发射包含所有结果的Tuple；如果任意一个Mono出错，整个zip流会直接进入错误状态。

如果需要处理单个调用的错误，可以给每个doSomething的Mono加上onErrorResume或onErrorReturn，比如：

Mono<Response> responseMono1 = serviceB.doSomething(request1)
    .onErrorResume(e -> Mono.just(defaultResponse1()));

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