本文详解如何在 Project Reactor 中构建分阶段重试链，确保 getKeys() 最多重试 3 次失败后终止流程，仅在其成功后才执行 fetchData() 并独立重试 3 次，避免跨阶段重复触发，提升响应式服务的健壮性与可预测性。
本文详解如何在 project reactor 中构建分阶段重试链，确保 `getkeys()` 最多重试 3 次失败后终止流程，仅在其成功后才执行 `fetchdata()` 并独立重试 3 次，避免跨阶段重复触发，提升响应式服务的健壮性与可预测性。
在响应式编程中，将多个异步操作串联（如“先获取密钥，再用密钥调用外部服务”）时，若直接对整个链调用 .retry(n)，会导致错误传播不可控——例如 getKeys() 第二次重试成功后，fetchData() 抛异常，却会回溯重新执行 getKeys()，违背“阶段隔离重试”的业务逻辑。
正确的做法是分层封装、逐级重试：每个逻辑阶段独立承担自己的容错责任，失败不向上传染，成功才向下流转。
✅ 正确实现：分阶段重试链
以下代码严格遵循你的三阶段语义：
- getKeys() 最多重试 3 次；失败则立即终止整个流，进入 handleError；
- 仅当 getKeys() 成功返回 key 后，才以该 key 为输入调用 client.fetchData(key)，并对其单独重试 3 次；
- fetchData() 的任何失败（含重试耗尽）均不会触发 getKeys() 再次执行。
@Scheduled
void fetchDataFromExternalService() {
// 阶段1：独立重试获取 key（最多3次）
Mono<String> keyMono = Mono.defer(() -> getKeys()).retry(3);
// 阶段2：定义带重试的数据获取函数（注意：不立即执行！）
Function<String, Mono<String>> fetchDataWithRetry = key ->
client.fetchData(key).retry(3); // ← retry 作用于 fetchData 单一调用
// 阶段3：串接 + 后处理
keyMono
.flatMap(fetchDataWithRetry) // 成功 key → 触发 fetchData（带自身重试）
.map(this::processResponse)
.doOnError(this::handleError)
.subscribe();
}? 关键点解析：
- Mono.defer(() -> getKeys()) 确保每次重试都重新执行 getKeys() 方法体（避免闭包捕获旧状态）；
- .retry(3) 应用于 keyMono，仅控制 key 获取阶段；
- flatMap(...) 中传入的是 Function 对象，而非 Mono 实例——这保证了 fetchData() 的执行时机和重试边界完全由 flatMap 内部调度决定，与外层 keyMono.retry() 完全解耦；
- 若 getKeys() 3 次全失败，流直接 onError 终止，fetchData() 永不执行；
- 若 fetchData() 在任意一次调用中失败，其 .retry(3) 会接管并重试该次调用，但绝不会“倒带”去重试 getKeys()。
⚠️ 常见误区与注意事项
❌ 错误写法：Mono.defer(() -> getKeys()).flatMap(key -> client.fetchData(key)).retry(3)
→ 此处 .retry(3) 作用于整个 flatMap 结果流，导致 getKeys() 和 fetchData() 被捆绑重试，违反阶段隔离原则。-
✅ 类型安全建议：将 getKeys() 返回类型显式声明为 Mono
（而非裸 Mono），增强可读性与编译期检查： Mono<String> getKeys() { /* ... */ } ⚠️ 异常分类处理（进阶）：若需对网络超时、业务异常等区别对待（如仅对 TimeoutException 重试），可使用 retryWhen() 配合 Retry.backoff() 实现指数退避+条件过滤。
? 订阅管理提醒：@Scheduled 方法中使用 subscribe() 是合理的，但请确保 handleError 中妥善记录日志或告警——切勿在 doOnError 中抛出新异常，否则可能中断 Spring Scheduler 线程。
✅ 总结
分阶段重试的本质是职责分离：每个异步步骤应封装自己的错误恢复策略。通过 Mono.defer().retry() 控制前置依赖，再以 flatMap 注入带重试的后续操作，即可构建清晰、可控、符合业务语义的响应式流水线。这种模式不仅适用于密钥加载场景，也广泛适用于认证令牌刷新、配置热加载、多级服务调用等需要精细化错误边界的微服务交互场景。
