如何在Project Reactor中处理Mono.zip的部分失败场景？

我正在构建一个响应式Java应用，通过如下方式使用Mono.zip组合funA()、funB()和funC()三个方法：

Mono<Type> combined = Mono.zip(funA(), funB(), funC())
                          .flatMap(...)

我希望能根据A、B、C的错误情况控制响应，例如当A和B失败但C成功时，仅返回C的成功结果，仅当三者全部失败时才返回错误。请问是否可以通过Project Reactor实现该需求？

解决方案 #

当然可以实现，核心思路是避免单个Mono的错误直接终止整个组合流程，先捕获每个Mono的错误并转换为占位标识，再在组合后筛选有效结果、判断全局错误情况。

实现步骤 #

1. 为每个Mono添加错误兜底处理
   用onErrorReturn或onErrorResume捕获单个Mono的错误，返回一个代表“失败”的占位值（比如null或自定义空对象，注意避免空指针风险）：

   Mono<Type> safeA = funA().onErrorReturn(null);
   Mono<Type> safeB = funB().onErrorReturn(null);
   Mono<Type> safeC = funC().onErrorReturn(null);
   

2. 组合后筛选结果并判断全局状态
   用Mono.zip组合三个“安全”的Mono，在flatMap中提取非空的成功结果，根据结果数量决定返回成功值还是全局错误：

   import java.util.Arrays;
   import java.util.Objects;
   import java.util.stream.Collectors;
   
   Mono<Type> combined = Mono.zip(safeA, safeB, safeC)
       .flatMap(tuple -> {
           // 提取三个操作的结果
           Type resultA = tuple.getT1();
           Type resultB = tuple.getT2();
           Type resultC = tuple.getT3();
           
           // 筛选出所有成功的结果
           var successfulResults = Arrays.asList(resultA, resultB, resultC)
               .stream()
               .filter(Objects::nonNull)
               .collect(Collectors.toList());
           
           if (successfulResults.isEmpty()) {
               // 三者全失败，返回全局错误
               return Mono.error(new RuntimeException("All operations failed"));
           } else {
               // 返回第一个成功结果，若需要返回所有成功结果可改为Flux
               return Mono.just(successfulResults.get(0));
           }
       });
   

3. 进阶：保留错误信息（可选）
   如果需要记录失败操作的错误详情，可以自定义包装类封装结果或错误：

   class OperationResult<T> {
       private T data;
       private Throwable error;
   
       // 静态构造方法
       public static <T> OperationResult<T> success(T data) {
           OperationResult<T> result = new OperationResult<>();
           result.data = data;
           return result;
       }
   
       public static <T> OperationResult<T> failure(Throwable error) {
           OperationResult<T> result = new OperationResult<>();
           result.error = error;
           return result;
       }
   
       // getter方法
       public T getData() { return data; }
       public Throwable getError() { return error; }
   }
   

   之后将每个Mono转换为包装类型：

   Mono<OperationResult<Type>> safeA = funA()
       .map(OperationResult::success)
       .onErrorResume(e -> Mono.just(OperationResult.failure(e)));
   // safeB、safeC同理
   

   组合后即可同时获取成功数据和失败错误，方便日志记录或后续业务处理。

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