GKE三节点环境下Node.js定时任务重复执行问题求助

你用cluster.isMaster的方法无效，因为GKE的每个节点上运行的是独立的Pod，每个Pod都是一个完整的Node.js进程，不存在单机器内的主/从进程关系，所以每个Pod都会进入cluster.isMaster分支执行定时任务，导致重复发送。

下面是几种可行的解决方案：

方案1：用Kubernetes CronJob替代node-cron #

直接把定时发送邮件的逻辑抽成独立脚本，用K8s原生的CronJob来调度执行，K8s会自动确保同一时间只有一个Pod执行该任务（默认并发策略为Forbid），从根源避免重复。

示例CronJob配置：

apiVersion: batch/v1
kind: CronJob
metadata:
  name: daily-email-sender
spec:
  schedule: "0 9 * * *" # 每天9点执行，时区默认是集群时区，可通过timeZone字段指定
  concurrencyPolicy: Forbid # 禁止并发执行，防止前一次任务未完成又启动新的
  jobTemplate:
    spec:
      template:
        spec:
          containers:
          - name: email-sender
            image: 你的应用镜像地址:标签
            command: ["node", "send-daily-email.js"] # 执行独立的发邮件脚本
          restartPolicy: OnFailure # 任务失败时重启Pod

方案2：用分布式锁实现单Pod执行 #

如果不想拆分逻辑，要在原应用内保留node-cron，可以通过分布式锁让只有一个Pod能获取锁并执行任务，其他Pod跳过。常用的实现方式是Redis锁：

示例代码（基于redis包）：

const cron = require('node-cron');
const redis = require('redis');
const client = redis.createClient({ url: process.env.REDIS_URL }); // 从环境变量获取Redis地址
client.connect();

async function sendDailyEmail() {
  // 这里写你的发送邮件逻辑
}

async function initScheduleFunctions() {
  cron.schedule('0 9 * * *', async () => {
    const lockKey = 'daily-email-task-lock';
    const lockValue = `${process.env.POD_NAME}-${Date.now()}`; // 用Pod名称+时间戳做锁值，防止误删锁

    // 尝试获取锁，设置5分钟过期时间，避免Pod挂掉导致死锁
    const lockAcquired = await client.set(lockKey, lockValue, {
      NX: true,
      EX: 300
    });

    if (lockAcquired) {
      try {
        console.log('获取到锁，开始执行每日邮件任务');
        await sendDailyEmail();
      } catch (err) {
        console.error('发送邮件失败:', err);
      } finally {
        // 释放锁前先验证锁值，确保是自己持有的锁
        const currentLockValue = await client.get(lockKey);
        if (currentLockValue === lockValue) {
          await client.del(lockKey);
          console.log('任务完成，释放锁');
        }
      }
    } else {
      console.log('已有Pod在执行邮件任务，本次跳过');
    }
  });
}

// 直接调用初始化，不用cluster判断
initScheduleFunctions();

注意：需要在GKE集群里部署Redis服务，或者用GCP的Cloud Memorystore（托管Redis）。

方案3：指定固定Pod执行定时任务 #

通过K8s的节点亲和性或Pod标签，让只有特定的一个Pod执行定时任务：

1. 在Deployment中给其中一个Pod添加专属标签和节点约束：

apiVersion: apps/v1
kind: Deployment
metadata:
  name: your-app-deployment
spec:
  replicas: 3
  selector:
    matchLabels:
      app: your-app
  template:
    metadata:
      labels:
        app: your-app
    spec:
      affinity:
        nodeAffinity:
          requiredDuringSchedulingIgnoredDuringExecution:
            nodeSelectorTerms:
            - matchExpressions:
              - key: kubernetes.io/hostname
                operator: In
                values:
                - gke-your-cluster-node-xxx # 指定某个节点名称
      containers:
      - name: your-app-container
        image: 你的应用镜像地址:标签
        env:
        - name: IS_CRON_EXECUTOR
          value: "true" # 通过环境变量标记该Pod为定时任务执行者

2. 在Node.js代码中判断环境变量，只有标记的Pod才执行定时任务：

function initScheduleFunctions() {
  cron.schedule('0 9 * * *', () => {
    // 执行发送邮件逻辑
  });
}

// 只在标记为执行器的Pod中初始化定时任务
if (process.env.IS_CRON_EXECUTOR === 'true') {
  initScheduleFunctions();
}

这种方式的缺点是如果指定的节点或Pod挂了，定时任务会失效，需要结合Pod的自动恢复机制，或者用StatefulSet来管理固定Pod。

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