一句话概括
响应式流中错误是终止事件——发生错误后流会停止发射。Reactor 提供了声明式的操作符来优雅容错、重试恢复,以及通过背压让下游控制上游的发射速率。
1. 错误处理策略
在响应式编程中,try-catch 不再适用。Reactor 用操作符代替了异常捕获:
onErrorReturn — 返回默认值
Mono.<String>error(new RuntimeException("oops"))
.onErrorReturn("fallback");
// → "fallback"
// 按异常类型区分
Flux.just("valid", "invalid")
.map(this::parse)
.onErrorReturn(IllegalArgumentException.class, "default");
2026/7/16大约 3 分钟