Spring Boot WebFlux处理N个Mono调用 替代Mono.zip的最优方案咨询

针对N个Mono<String>批量合并的场景，可直接使用Reactor提供的无参数数量限制的API实现，具体按是否需要保证结果顺序选择对应方案：

场景1：不需要严格保证结果顺序和输入Mono顺序一致 #

把所有Mono存入集合后用Flux.merge合并再收集结果即可，所有请求会并行执行：

// 把所有需要执行的Mono<String>存入集合
List<Mono<String>> monoList = List.of(mono1, mono2, mono3, ..., monoN);
// 合并所有Mono，最终收集所有执行结果为List<String>
Mono<List<String>> resultMono = Flux.merge(monoList)
        .collectList();

注意：merge会按照Mono实际完成的先后顺序输出结果，和monoList的输入顺序不一定对齐

场景2：需要严格保证结果顺序和输入Mono顺序一致 #

使用Mono.zip的可变参数重载，配合自定义聚合函数即可突破8个参数的限制，结果顺序和输入顺序完全对齐：

List<Mono<String>> monoList = List.of(mono1, mono2, mono3, ..., monoN);
// 第二个参数为聚合函数，所有Mono的结果会按输入顺序存入Object数组，可自行转换为所需类型
Mono<List<String>> resultMono = Mono.zip(monoList, objects -> 
        Arrays.stream(objects)
                .map(String.class::cast)
                .toList()
);

拿到汇总后的List<String>后，即可按照业务逻辑把结果对应赋值到POJO属性中。

额外优化点 #

如果需要容忍单个Mono请求失败不影响整体结果，可给每个Mono添加异常兜底逻辑：

// 给单个Mono添加异常兜底，避免单个请求失败导致整个合并操作报错
Mono<String> safeMono = mono1.onErrorResume(e -> Mono.just("自定义默认值"));

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