嘿，我来帮你搞定这个问题！在WebFlux里合并两个异步非阻塞调用的结果其实很简单，核心就是利用Mono.zip()方法来把两个Mono的结果组合到一起。不过先给你提个关键的点：你当前的方法返回的是CombinedResults，这是同步的返回方式，完全违背了WebFlux的响应式非阻塞编程模型，所以我们得把返回类型改成Mono<CombinedResults>，这样才能保证整个调用链都是非阻塞的。

第一步：确认你的CombinedResults结构 #

首先假设你的CombinedResults类是用来封装两个SearchResponse结果的，大概长这样：

public class CombinedResults {
    private SearchResponse fhResults;
    private SearchResponse esResults;

    // 构造方法
    public CombinedResults(SearchResponse fhResults, SearchResponse esResults) {
        this.fhResults = fhResults;
        this.esResults = esResults;
    }

    // 这里记得加上getter和setter，或者用Lombok简化代码
}

第二步：修改Controller方法，实现结果合并 #

接下来把你的Controller方法改成响应式的，用Mono.zip()来合并两个WebClient调用的结果：

@GetMapping("/search") // 用@GetMapping更贴合REST风格，也可以保留原有的@RequestMapping
public Mono<CombinedResults> performSearch(@RequestParam final String searchTerm) {
    // 发起两个非阻塞的WebClient调用
    Mono<SearchResponse> fasMono = searchService.getSearchResults(searchTerm, "fh");
    Mono<SearchResponse> esMono = searchService.getSearchResults(searchTerm, "es");

    // 合并两个Mono的结果：zip会并行等待两个调用完成，然后返回组合后的元组
    return Mono.zip(fasMono, esMono)
            // 把元组转换成你的CombinedResults对象
            .map(tuple -> new CombinedResults(tuple.getT1(), tuple.getT2()));
}

关键细节解释 #

• 并行执行：Mono.zip()会让两个WebClient调用同时发起（而非串行），充分利用非阻塞IO的优势，提升接口的响应速度。
• 错误处理（可选）：如果担心其中一个调用失败导致整个接口报错，可以给对应的Mono添加错误兜底逻辑：

  // 给fasMono添加错误处理，返回默认值
  Mono<SearchResponse> fasMono = searchService.getSearchResults(searchTerm, "fh")
          .onErrorResume(error -> {
              // 比如返回空结果或者自定义默认响应
              return Mono.just(new SearchResponse());
          });
  

  这样即使其中一个服务不可用，你的接口依然能返回合并后的结果，而不是直接抛出异常。

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