使用node-cron实现Node.js定时任务
1. 简介
node-cron
是一个轻量级的Node.js库,用于在指定时间或间隔执行任务。它是Unix系统cron工具的JavaScript实现,适用于需要定时执行脚本的场景(如数据备份、定期爬虫等)。
2. 安装
npm install node-cron
# 或
yarn add node-cron
3. 基础用法
import cron from 'node-cron';// 每分钟执行
cron.schedule('* * * * *', () => {console.log('每分钟触发');
});
4. Cron表达式详解
表达式由5个字段组成:
* * * * *
┬ ┬ ┬ ┬ ┬
│ │ │ │ │
│ │ │ │ └── 星期几 (0 - 7) (0和7代表周日)
│ │ │ └────── 月份 (1 - 12)
│ │ └────────── 日期 (1 - 31)
│ └────────────── 小时 (0 - 23)
└─────────────────── 分钟 (0 - 59)
常用示例:
表达式 | 说明 |
---|---|
*/5 * * * * | 每5分钟 |
0 * * * * | 每小时整点 |
0 0 * * * | 每天午夜 |
0 9 * * 1-5 | 工作日早上9点 |
30 3 15 * * | 每月15日凌晨3:30 |
5. 高级功能
5.1 带参数配置
const task = cron.schedule('*/10 * * * *', () => {console.log('每10分钟执行');
}, {scheduled: true, // 是否立即启动timezone: 'Asia/Shanghai' // 时区设置
});
5.2 任务控制
// 暂停任务
task.stop();// 恢复任务
task.start();// 检查任务状态
console.log(task.getStatus()); // 返回 'running' 或 'stopped'
6. 实际应用示例
示例1:每日数据清理
import cron from 'node-cron';
import cleanupDatabase from './cleanup.js';// 每天凌晨3点清理
cron.schedule('0 3 * * *', () => {console.log('开始数据库清理...');cleanupDatabase();
});
示例2:API定时请求
import axios from 'axios';// 每30分钟获取天气数据
cron.schedule('*/30 * * * *', async () => {const res = await axios.get('https://api.weather.com/data');console.log('天气数据:', res.data);
});
7. 注意事项
- 精度问题:Node.js事件循环可能导致最多几毫秒的延迟
- 错误处理:务必在任务函数中添加try/catch
- 长任务:避免任务执行时间超过间隔时间
- 集群环境:在多进程部署时需要额外处理防止重复执行
8. 替代方案
node-schedule
:更复杂的调度规则bull
:分布式任务队列- 系统级cron:通过
child_process
调用
🚀 提示:在生产环境中建议添加日志记录和监控,可以使用
winston
或bunyan
记录任务执行情况。
参考资料:
- node-cron官方文档:https://github.com/node-cron/node-cron
- Cron表达式标准:IEEE Std 1003.1
点个收藏,关注前端结城,一起用代码点亮前端世界!🚀