如何在Docker部署多副本Nest.js服务时避免Cron定时任务重复执行

问题本质是无状态多副本部署时，每个实例会独立触发本地 Cron 任务，需要通过协调机制保证同一时间仅一个实例执行任务。

以下是四种可落地的实现方案，无需调整现有3副本的部署配置： #

方案1：基于 Redis 分布式锁实现（最常用，改动最小） #

思路：任务执行前先尝试抢占分布式锁，仅抢到锁的实例执行业务逻辑，锁过期时间略大于任务最大执行时长即可。

实现步骤 #

1. 安装依赖：
   npm install redlock ioredis
2. 改造原有 Cron 方法：

import Redlock from 'redlock';
import Redis from 'ioredis';
import { Logger } from '@nestjs/common';
import { Cron, CronExpression } from '@nestjs/schedule';

// 初始化Redis连接，配置从环境变量读取
const redis = new Redis({
  host: process.env.REDIS_HOST,
  port: parseInt(process.env.REDIS_PORT || '6379'),
  password: process.env.REDIS_PASSWORD,
});

// 初始化分布式锁配置，抢锁失败不重试
const redlock = new Redlock([redis], {
  driftFactor: 0.01,
  retryCount: 0,
  retryDelay: 200,
});

@Cron(CronExpression.EVERY_5_MINUTES)
async runBiEventProcessor() {
  const lockKey = 'lock:bi-event-processor:execution';
  // 锁过期时间设为6分钟，略大于5分钟的执行间隔，避免任务重叠
  const lockTtl = 6 * 60 * 1000;

  let lock;
  try {
    lock = await redlock.lock(lockKey, lockTtl);
    // 仅抢到锁的实例执行业务逻辑
    const calculationDate = new Date();
    Logger.log(`Bi Event Processor started at ${calculationDate}`);
    // 原有业务逻辑写在此处
  } catch (e) {
    // 抢锁失败直接跳过，说明其他实例正在执行任务
    return;
  } finally {
    // 任务执行完成主动释放锁
    if (lock) {
      await lock.unlock().catch(err => Logger.error('分布式锁释放失败', err));
    }
  }
}

方案2：定时任务与业务服务分离部署 #

思路：将所有 Cron 定时任务抽离为独立的专属服务，该服务仅部署1个副本，原有3个副本仅处理业务接口请求。两个服务之间通过 RPC 或者消息队列交互传递数据。
优势：逻辑完全隔离，无锁竞争风险，适合定时任务数量多、执行逻辑重的场景。 #

方案3：环境变量控制任务开关 #

思路：在部署配置中为其中一个副本单独添加ENABLE_CRON=true的环境变量，代码中判断仅当该变量存在时才注册定时任务。
示例代码：

import { Module } from '@nestjs/common';
import { ScheduleModule } from '@nestjs/schedule';
import { BiTaskService } from './bi-task.service';

@Module({
  imports: [
    // 仅开启 Cron 开关的实例加载调度模块
    process.env.ENABLE_CRON === 'true' ? ScheduleModule.forRoot() : []
  ],
  providers: [BiTaskService],
})
export class AppModule {}

优势：代码改动极小，无额外依赖；劣势：若开启 Cron 的实例宕机，定时任务会暂停执行，适合对任务可用性要求不高的场景。 #

方案4：接入分布式调度中心 #

思路：使用 XXL-JOB、Elastic-Job 等分布式调度组件统一管理定时任务，取消本地 Cron 注解，仅提供任务执行的HTTP/RPC接口，调度中心每次触发任务时只会调用其中一个副本的接口执行。
优势：支持任务监控、失败重试、动态调整执行时间等高级能力，适合大规模微服务集群场景。

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