本文详解如何在 Spring WebFlux 中并行调用两个下游服务，并在任一调用失败时不中断整体流程，仍能构造部分填充的组合响应对象——核心是规避 Mono.zip() 对错误/空值的短路行为，改用 Optional 封装可空结果。
本文详解如何在 Spring WebFlux 中并行调用两个下游服务，并在任一调用失败时不中断整体流程，仍能构造部分填充的组合响应对象——核心是规避 `Mono.zip()` 对错误/空值的短路行为，改用 `Optional` 封装可空结果。
在响应式编程中，Mono.zip() 是组合多个 Mono 的常用操作符。但其默认语义是严格短路：任一源 Mono 发生错误或以空（empty）完成，整个 zip 就会立即终止，其余仍在进行的订阅将被取消，导致你无法获取已成功返回的结果——这与传统 RxJava 中 Single.just(null) 的宽容行为截然不同。而 Reactor 明确禁止 null 值，因此直接返回 null 会触发 NullPointerException，不可行。
✅ 正确解法：用 Optional 承载“可空性”
Optional 是 Java 8 引入的容器类，天然表达“存在或不存在”的语义，且完全兼容 Reactor 类型系统（Mono
1. 改造服务层：返回 Mono>
class FirstService {
private final WebClient webClient;
Mono<optional>> get() {
return webClient.get()
.uri("https://api.example.com/first")
.retrieve()
.bodyToMono(FirstResponse.class)
.map(Optional::of) // 成功 → Optional.of(response)
.onErrorReturn(Optional.empty()); // 失败 → Optional.empty()
}
}
class SecondService {
private final WebClient webClient;
Mono<optional>> get() {
return webClient.get()
.uri("https://api.example.com/second")
.retrieve()
.bodyToMono(SecondResponse.class)
.map(Optional::of)
.onErrorReturn(Optional.empty());
}
}</optional></optional>
⚠️ 注意：onErrorReturn(Optional.empty()) 比 onErrorResume(e -> Mono.just(Optional.empty())) 更简洁高效，且语义更明确。
2. 控制器层：安全组合与构建
@RestController
@RequestMapping("/api")
class CombinationController {
private final FirstService firstService;
private final SecondService secondService;
@GetMapping("/combined")
Mono<combinedresponse> getCombined() {
return Mono.zip(
firstService.get(),
secondService.get()
)
.map(tuple -> {
Optional<firstresponse> firstOpt = tuple.getT1();
Optional<secondresponse> secondOpt = tuple.getT2();
// 安全解包：不存在则为 null，符合 CombinedResponse 设计
FirstResponse first = firstOpt.orElse(null);
SecondResponse second = secondOpt.orElse(null);
return new CombinedResponse(first, second);
});
}
}</secondresponse></firstresponse></combinedresponse>
3. 响应模型保持简洁
public class CombinedResponse {
private final FirstResponse first;
private final SecondResponse second;
public CombinedResponse(FirstResponse first, SecondResponse second) {
this.first = first;
this.second = second;
}
// getters...
}
? 关键优势与注意事项
- 真正并行执行：firstService.get() 与 secondService.get() 独立订阅，互不干扰；一个失败不会取消另一个。
- 语义清晰：Optional 显式表达了字段的“可选性”，比魔法 null 或占位对象（如 new FirstResponse()）更具可读性和契约性。
- 零副作用：onErrorReturn 不会传播异常，避免控制器层额外的 try-catch。
- 扩展友好：若未来需添加第三个服务，只需扩展 Mono.zip 参数列表及 tuple 解包逻辑，模式完全一致。
- 性能提示：避免在 map 中做阻塞 I/O 或复杂计算；若需 fallback 逻辑（如失败时调用缓存），应使用 onErrorResume + Mono.defer 组合。
✅ 总结
当 WebFlux 场景要求“尽最大努力聚合多个非关键依赖结果”时，放弃对 null 的幻想，拥抱 Optional 是最符合 Reactor 哲学的实践。它既绕过了框架对 null 的限制，又保留了业务逻辑对“缺失值”的精确控制权，最终让 CombinedResponse 的构造变得健壮、透明且易于维护。
