如何避免Spring Boot多Pod部署下重复触发定时邮件事件

针对多Pod部署导致同一条记录触发两次邮件的问题，可通过以下几种方案解决：

1. 分布式锁控制 #

借助Redis等中间件实现分布式锁，确保同一时间只有一个Pod能执行定时任务逻辑：

• 推荐使用Redisson实现可重入的分布式锁，自带锁超时自动释放机制，避免死锁。
• 示例代码：

  @Autowired
  private RedissonClient redissonClient;
  
  @Scheduled(cron = "0 */2 * * * ?")
  public void processEmailTasks() {
      RLock lock = redissonClient.getLock("email-scheduler-lock");
      try {
          // 尝试获取锁，最多等待10秒，锁有效期30秒（覆盖任务执行时长）
          if (lock.tryLock(10, 30, TimeUnit.SECONDS)) {
              // 执行记录匹配、邮件发送逻辑
              matchRecordsAndSendEmails();
          }
      } catch (InterruptedException e) {
          Thread.currentThread().interrupt();
      } finally {
          // 仅释放当前线程持有的锁
          if (lock.isHeldByCurrentThread()) {
              lock.unlock();
          }
      }
  }
  

• 若任务可拆分，也可为单条记录加锁，提升并行效率。

2. 数据库状态标记（乐观锁思路） #

在业务表中新增状态字段，通过数据库原子操作确保记录仅被一个Pod处理：

1. 新增task_status字段，可选值：PENDING（待处理）、PROCESSING（处理中）、COMPLETED（已完成）
2. 定时任务执行时，先原子更新符合条件的记录状态为PROCESSING：

   UPDATE business_table 
   SET task_status = 'PROCESSING', update_time = NOW()
   WHERE trigger_time <= NOW() 
     AND task_status = 'PENDING'
   LIMIT 50; -- 批量处理，避免锁表
   

3. 查询当前Pod更新成功的记录（task_status = 'PROCESSING'且update_time在1分钟内），执行邮件发送
4. 处理完成后更新状态为COMPLETED，若处理失败可重置为PENDING

3. 任务分片执行 #

将待处理记录按规则分片，每个Pod仅处理对应分片的任务：

• 给每个Pod配置唯一索引（通过环境变量POD_INDEX传入）和总Pod数（POD_TOTAL）
• 定时任务中过滤出对应分片的记录：

  @Value("${pod.index:0}")
  private int podIndex;
  @Value("${pod.total:2}")
  private int podTotal;
  
  @Scheduled(cron = "0 */2 * * * ?")
  public void processShardedTasks() {
      // 按记录ID取模分片，仅处理当前Pod负责的记录
      List<BusinessRecord> records = recordRepository.findNeedProcess(LocalDateTime.now(), podIndex, podTotal);
      records.forEach(this::sendEmail);
  }
  

• 此方案无需额外中间件，但Pod数量变更时需同步调整分片配置。

4. 引入单点调度中心 #

将定时任务从应用中剥离，使用专业调度中心（如XXL-JOB、Elastic-Job）统一管理：

• 调度中心负责任务的分发与执行节点调度，确保同一任务仅在一个节点触发
• 应用只需提供任务执行的API，无需再内嵌@Scheduled注解

内容的提问来源于stack exchange，提问作者Asha