动态CronJob重复触发问题：K8s多Pod环境下任务执行三次

你的问题本质是多Pod实例各自独立运行了调度器：本地只有一个应用进程，任务仅触发一次；部署到K8s后三个Pod各自启动了独立的调度服务，每个Pod都执行了创建CronJob的代码，相当于同时注册了三个完全相同的定时任务，到时间自然会各自触发一次，导致三次重复执行。哪怕你在某个Pod里移除了自身注册表的任务，另外两个Pod的任务依然存在，所以无法解决重复触发的问题。

方案一：改用K8s原生CronJob（推荐） #

直接用K8s自带的CronJob资源定义定时任务，K8s会自动管理任务的调度与执行，默认保证同一时间只有一个Pod执行任务（可通过concurrencyPolicy配置），从根源避免多实例重复触发。

示例YAML配置：

apiVersion: batch/v1
kind: CronJob
metadata:
  name: email-sender-job
spec:
  schedule: "*/10 * * * *"  # 替换为你需要的调度时间，若要一次性执行可计算对应仅触发一次的cron表达式
  jobTemplate:
    spec:
      template:
        spec:
          containers:
          - name: email-sender
            image: 你的应用镜像
            command: ["node", "send-email-script.js"]  # 指定执行发送邮件的脚本
          restartPolicy: OnFailure
  concurrencyPolicy: Forbid  # 禁止并发执行，彻底避免重复触发

如果是需要在未来某个时间点一次性执行的任务，也可以用K8s的Job配合延迟启动逻辑，或直接生成仅执行一次的cron表达式。

方案二：添加分布式锁（应用层解决） #

如果必须在应用内部维护调度逻辑，需要给任务加分布式锁，确保同一时间只有一个Pod能获取锁并执行任务。可以用Redis实现锁逻辑，或借助K8s的ConfigMap/Secret作为锁资源。

示例代码（结合你的现有逻辑，基于Redis实现）：

const date = dateFns.addMinutes(new Date(), 10);
const job = new CronJob({
  cronTime: date,
  start: true,
  onTick: async () => {
    // 用任务唯一标识作为锁的key
    const lockKey = 'job01-lock';
    // 尝试获取锁：有效期30秒（根据任务实际执行时长调整），仅当key不存在时设置
    const lockAcquired = await redis.set(lockKey, 'locked', 'EX', 30, 'NX');
    
    if (!lockAcquired) {
      console.log('其他Pod已获取锁，跳过本次执行');
      return;
    }

    try {
      await this.sendEmail(params);
    } finally {
      // 任务执行完成后释放锁
      await redis.del(lockKey);
    }
  }
});
this.schedulerRegistry.addCronJob('job01', job);

注意要根据任务的实际执行时长调整锁的有效期，避免锁提前过期导致的重复执行。

方案三：单实例部署（不推荐） #

如果业务对可用性要求较低，可以将调度服务部署为单实例（Deployment的replicas: 1），这样只有一个Pod运行调度器，自然不会出现重复触发。但这种方式一旦Pod故障，任务会直接中断，可用性差，不建议用于生产环境。

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