Java应用中无新增基础设施处理Webhook请求接收方停机策略

public void createAndSendWebhook(String taskId, String payload, String targetUrl) {
    // 1. 将任务持久化到数据库
    WebhookTask task = new WebhookTask(taskId, payload, targetUrl, WebhookStatus.NOT_CALLED);
    webhookTaskRepository.save(task);

    // 2. 尝试立即发送
    try {
        sendWebhook(task);
        task.setCallStatus(WebhookStatus.COMPLETE);
    } catch (Exception e) {
        // 如果立即发送失败，更新状态为WIP，等待重试机制处理
        task.setCallStatus(WebhookStatus.WIP);
        task.setLastRetryTs(LocalDateTime.now());
        task.setRetryCount(task.getRetryCount() + 1);
        // 记录错误日志
    } finally {
        webhookTaskRepository.save(task); // 更新任务状态
    }
}

private void sendWebhook(WebhookTask task) throws Exception {
    // 实际的HTTP请求发送逻辑
    // 使用HttpClient或RestTemplate发送POST请求到task.getTargetUrl()
    // 检查HTTP响应码，非2xx视为失败
    System.out.println("Sending webhook for task: " + task.getTaskId() + " to " + task.getTargetUrl());
    // 模拟网络请求和响应
    // if (Math.random() > 0.5) throw new RuntimeException("Simulated network error");
}

import java.time.LocalDateTime;
import java.util.List;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

public class WebhookRetryScheduler {

    private final WebhookTaskRepository webhookTaskRepository; // 假设这是数据库操作接口
    private final ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();
    private final long retryIntervalSeconds = 30; // 初始重试间隔
    private final int maxRetries = 10; // 最大重试次数

    public WebhookRetryScheduler(WebhookTaskRepository webhookTaskRepository) {
        this.webhookTaskRepository = webhookTaskRepository;
    }

    public void start() {
        // 每隔一定时间执行一次重试逻辑
        scheduler.scheduleAtFixedRate(this::processPendingWebhooks, 0, 10, TimeUnit.SECONDS);
    }

    private void processPendingWebhooks() {
        // 查询所有未完成且未达到最大重试次数的任务
        List<WebhookTask> pendingTasks = webhookTaskRepository.findPendingTasks(LocalDateTime.now().minusSeconds(retryIntervalSeconds));

        for (WebhookTask task : pendingTasks) {
            if (task.getRetryCount() >= maxRetries) {
                task.setCallStatus(WebhookStatus.FAILED);
                webhookTaskRepository.save(task);
                // 记录任务最终失败的日志，可能需要人工介入
                continue;
            }

            try {
                task.setCallStatus(WebhookStatus.WIP); // 标记为正在处理
                webhookTaskRepository.save(task); // 更新状态以避免并发问题

                sendWebhook(task); // 尝试发送Webhook
                task.setCallStatus(WebhookStatus.COMPLETE); // 成功则标记为完成
                task.setLastRetryTs(LocalDateTime.now());
                webhookTaskRepository.save(task);
                System.out.println("Webhook for task " + task.getTaskId() + " successfully sent on retry.");
            } catch (Exception e) {
                // 发送失败，更新重试信息
                task.setLastRetryTs(LocalDateTime.now());
                task.setRetryCount(task.getRetryCount() + 1);
                task.setCallStatus(WebhookStatus.WIP); // 仍为WIP，等待下次重试
                webhookTaskRepository.save(task);
                System.err.println("Webhook for task " + task.getTaskId() + " failed, retrying later. Error: " + e.getMessage());
            }
        }
    }

    public void shutdown() {
        scheduler.shutdown();
    }
}

// 假设的WebhookTask和WebhookStatus枚举
class WebhookTask { /* ... 包含上面提到的字段和getter/setter */ }
enum WebhookStatus { NOT_CALLED, WIP, COMPLETE, FAILED }
interface WebhookTaskRepository {
    WebhookTask save(WebhookTask task);
    List<WebhookTask> findPendingTasks(LocalDateTime lastRetryBefore); // 查询WIP或NOT_CALLED的任务
}