Spring Boot响应式项目调用20个外部API：并行还是异步？

结论：必须并行调用，而非仅异步 #

在Flux/Mono的响应式模型里，只做异步串行调用完全浪费了响应式的优势——总耗时会是20个API调用时间的总和，而并行调用能把总耗时压缩到最慢那个API的响应时间左右，这对聚合接口的性能提升是决定性的。

并行调用的资源风险与应对方案 #

并行确实可能带来资源压力，但响应式框架本身提供了足够的手段来控制：

• 限制并发数：别直接发起20个并行请求，用flatMap的重载方法指定并发上限（比如flatMap(apiCall, 10)），避免本地连接池被占满，也防止对外部API造成流量冲击。
• 优化连接池配置：给WebClient配置合理的连接池参数，比如最大连接数、空闲超时、连接存活时间，复用连接比每次新建更高效。
• 超时与熔断兜底：给每个API调用加上超时（timeout(Duration.ofSeconds(5))），再用Resilience4j实现熔断降级——某个API挂了别影响整个聚合流程，返回兜底数据就行。
• 依赖背压机制：响应式框架的背压会自动调节流量，避免请求堆积导致内存溢出，不用自己手动处理。

别混淆异步和并行 #

很多人搞不清这俩的区别：

• 异步串行：比如用Mono.then()链式调用，本质还是一个接一个执行，只是不阻塞主线程，总耗时没变化。
• 并行调用：通过Flux.zip、Flux.merge或者带并发参数的flatMap同时发起多个请求，真正实现多任务并行，这才是响应式提升性能的正确姿势。

代码示例 #

用Flux.zip实现全量聚合（等待所有API返回） #

// 先把所有API调用封装成Mono列表
List<Mono<ApiResult>> apiMonos = Arrays.asList(
    fetchUserInfo(), fetchOrderHistory(), fetchProductRecommendations(), ... // 共20个
);

// 并行调用，全部完成后组装结果
Mono<AggregatedResponse> aggregatedResponse = Flux.zip(apiMonos, results -> {
    AggregatedResponse response = new AggregatedResponse();
    response.setUserInfo((ApiResult) results[0]);
    response.setOrderHistory((ApiResult) results[1]);
    // 依次处理剩下的18个结果
    return response;
}).single();

用flatMap控制并发数（适合允许部分先返回的场景） #

// 生成20个API调用任务，限制并发数为10
Flux<ApiResult> parallelCalls = Flux.range(1, 20)
    .flatMap(apiIndex -> callExternalApi(apiIndex), 10)
    .collectList()
    .map(results -> buildAggregatedResponse(results));

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