当前位置：首页 > article >正文

Node.js 定时任务详解：从基础到高级调度策略

article 2025/3/23 8:20:05

在 Node.js 中处理定时任务有多种方式，可以根据任务的需求选择不同的实现方法。以下是一些常见的用于执行定时任务的技术和库，以及它们的使用场景和示例代码。

1. 使用 `setTimeout` 和 `setInterval`

这是最基本的定时任务实现方式，适用于简单的、不需要持久化或复杂调度的任务。

示例：使用 `setTimeout`

// 在5秒后执行一次任务
setTimeout(() => {
    console.log('This will run after 5 seconds');
}, 5000);

示例：使用 `setInterval`

// 每隔2秒执行一次任务
const intervalId = setInterval(() => {
    console.log('This will run every 2 seconds');
}, 2000);

// 停止间隔任务
setTimeout(() => {
    clearInterval(intervalId);
    console.log('Interval stopped');
}, 10000); // 总共运行5次后停止

2. 使用 `node-cron`

对于需要按照特定时间规则（如每天凌晨2点）执行的任务，可以使用 node-cron 库。它允许你定义类似于 Unix cron 表达式的调度规则。

首先安装 node-cron：

npm install node-cron

示例：使用 `node-cron`

const cron = require('node-cron');

// 每分钟的第一秒执行任务
cron.schedule('* * * * *', () => {
    console.log('Running a task every minute at the start of the minute');
});

// 每天凌晨2点执行任务
cron.schedule('0 2 * * *', () => {
    console.log('Running a task every day at 2:00 AM');
});

3. 使用 `agenda`

agenda 是一个基于 MongoDB 的轻量级作业调度器，非常适合需要持久化的定时任务。

首先安装 agenda 和 MongoDB：

npm install agenda

确保 MongoDB 已经启动，并配置你的 Agenda 实例：

示例：使用 `agenda`

const Agenda = require('agenda');
const mongoConnectionString = 'mongodb://127.0.0.1/agenda';

const agenda = new Agenda({db: {address: mongoConnectionString}});

agenda.define('greet someone', (job, done) => {
    console.log(`Hello ${job.attrs.data.name}!`);
    done();
});

agenda.on('ready', () => {
    agenda.every('1 minute', 'greet someone', {name: 'John Doe'});
    agenda.start();
});

4. 使用 `bull`

如果你的应用程序需要处理大量异步任务并且对任务队列的管理要求较高，可以考虑使用 bull。它是一个功能强大的 Redis-backed 队列系统。

首先安装 bull 和 Redis：

npm install bull

确保 Redis 已经启动，并创建你的 Bull 队列实例：

示例：使用 `bull`

const Queue = require('bull');

const myQueue = new Queue('myQueueName', 'redis://127.0.0.1:6379');

async function addJob() {
    await myQueue.add({
        foo: 'bar'
    }, {
        delay: 5000 // 延迟5秒执行
    });
}

myQueue.process(async job => {
    console.log(job.data.foo); // 输出 'bar'
});

addJob();