本文介绍如何在 7:00–9:00 时间窗口内，对依赖外部服务的计算方法实现「成功即停」的重试逻辑：每 10 分钟尝试一次，一旦获取到有效数据即终止后续重试，并确保最终只保存一次合法结果。
本文介绍如何在 7:00–9:00 时间窗口内，对依赖外部服务的计算方法实现「成功即停」的重试逻辑：每 10 分钟尝试一次，一旦获取到有效数据即终止后续重试，并确保最终只保存一次合法结果。
在 Spring 应用中，为定时任务（如 @Scheduled）添加可控重试机制，需兼顾时间窗口约束、失败感知与成功退出三重目标。你当前的代码存在两个关键问题：一是 @Scheduled 每 10 分钟强制触发，无法在首次成功后主动“暂停”后续执行；二是 catch 块仅记录异常却未阻断无效值写入，导致空列表场景下仍可能保存默认 0.0。
✅ 正确思路不是让调度器“重试”，而是让单次调度任务内部完成带等待的轮询——即：在 dailyComputeValue() 方法体内，通过循环 + 睡眠 + 条件退出，实现在 7:00–9:00 窗口内最多等待至 9:00 的智能重试。
以下是推荐实现（已优化健壮性与可读性）：
@Scheduled(cron = "0 0 7-8 * * MON-FRI") // 每小时整点触发（7:00, 8:00），覆盖7-9点窗口
public void dailyComputeValue() {
final String product = "your-product-id";
final ZonedDateTime startTime = ZonedDateTime.now();
final ZonedDateTime deadline = startTime.withHour(9).withMinute(0).withSecond(0).withNano(0);
Double result = null;
int attempt = 0;
while (result == null && ZonedDateTime.now().isBefore(deadline)) {
attempt++;
try {
result = computeValue(product);
if (result != null) {
log.info("✅ Successfully computed value on attempt #{} at {}", attempt, ZonedDateTime.now());
break; // 成功！立即退出循环
}
} catch (Exception ex) {
log.warn("⚠️ Attempt #{} failed: {}", attempt, ex.getMessage());
}
// 若未成功且未超时，休眠 10 分钟后重试
if (result == null && ZonedDateTime.now().isBefore(deadline)) {
try {
log.info("⏳ Waiting 10 minutes before next attempt (current time: {})", ZonedDateTime.now());
Thread.sleep(Duration.ofMinutes(10).toMillis());
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
log.error("❌ Retry interrupted", e);
return;
}
}
}
// 仅当获得有效结果时才持久化
if (result != null) {
valueRepository.save(result);
log.info("? Saved final value: {}", result);
} else {
log.warn("❌ Gave up after deadline (9:00) — no valid record retrieved");
}
}
public Double computeValue(String product) {
List<Pair<ZonedDateTime, Double>> records = externalService.getRecord();
if (records == null || records.isEmpty()) {
return null; // ✅ 显式返回 null 表示暂无数据，避免抛异常干扰控制流
}
// 执行实际业务计算（例如取最新记录的 value）
return records.get(records.size() - 1).getValue();
}? 关键设计说明：
- 不依赖异常驱动重试：computeValue() 返回 null 而非抛异常，使流程更清晰、更易测试；
- 硬性截止时间保障：使用 ZonedDateTime 判断是否超过 9:00，防止无限等待；
- 日志可追溯：记录尝试次数、时间戳与状态，便于运维排查；
- 线程安全休眠：捕获 InterruptedException 并恢复中断状态，符合最佳实践；
- 调度策略优化：Cron 改为 0 0 7-8 * * MON-FRI（7:00 和 8:00 各触发一次），确保即使 7:00 未成功，8:00 仍有机会启动新轮询，同时避免高频调度（如 */10 每10分钟）造成资源浪费。
? 进阶建议：若项目已引入 Spring Retry，可结合 @Retryable + @Recover 实现声明式重试，但需配合 TimeLimiter 或自定义 RetryPolicy 控制总耗时，且仍需在 @Scheduled 外层做窗口兜底判断——因此对于本场景，手动轮询仍是更简洁、更可控的选择。
最终效果：该任务在工作日 7:00 启动，若 externalService.getRecord() 首次返回非空，则立刻计算并落库，后续不再等待；若为空，则每 10 分钟重试，最晚坚持到 9:00，之后自动放弃。
