nodejs定时任务

news2024/11/29 12:46:25

项目需求：

每5秒执行一次，多个定时任务错开，即cron表达式中斜杆前带数字，例如 ‘1/5 * * * * *’
定时任务准时，延误低

搜索了nodejs的定时任务，其实不多，找到了以下三个常用的：

node-cron
node-schedule
cron

1 node-cron

示例代码

const nodeCron = require('node-cron');
// 每5秒执行一次
const cron = '*/5 * * * * *';
// 自带验证cron的有效性
const valid = nodeCron.validate(cron)
if(!valid) {
    console.log(cron,' ===> Cron 无效');
    return;
}
nodeCron.schedule(cron, () => {
    console.log(dayjs().format('HH:mm:ss'))
    // todo: do task
});

优点：运行稳定，自带校验方法 validate
缺点：cron表达式不支持斜杆前面带数字，例如从第2秒开始每5秒执行一次，即 ‘2/5 * * * * *’

2 node-schedule

最早用了 node-schedule
每天定时截图然后自动发送邮件，以达到自动巡检的目的，每天一次，已经运行2年了，没什么问题。

示例代码：

const nodeSchedule= require('node-schedule')
// 工作日的8:55:00
const rule = {hour:8, minute:55, second:0, dayOfWeek:[1,2,3,4,5]};
nodeSchedule.scheduleJob(rule, async () => {
    const res = await doScreenshot();
  })
  
// 截图任务
const doScreenshot = ()=>{
  // todo: return new Promise...
}

// 当进程退出时优雅结束任务
process.on('SIGINT', function () {
    console.log('========= SIGINT')
    nodeSchedule.gracefulShutdown().then(() => process.exit(0))
})

然而，在另外一个项目里面使用了cron表达式，在执行较为复杂的任务时，发现偶发在某个整点里面触发2次

// 每5秒执行一次
const cron = '*/5 * * * * *';
nodeSchedule.scheduleJob(cron,()=>{
    console.log(dayjs().format('HH:mm:ss'))
    // todo: do task
})

优点：支持cron表达式斜杆前面带数字，弥补了 node-cron 缺点，自带优雅结束所有任务方法，rule规则还支持对象文本语法
缺点：当使用cron表达式，频繁执行复杂任务时，任务时间会出现错乱，整点还会偶发触发2次，比较适合时间间隔比较大的而无阻塞的任务

3 cron

最后选择这个，刚好满足项目需求。

示例代码

const CronJob = require('cron').CronJob;
const validator = require('cron-validator')

const createCronJob = (cron) => {
    const isValid = validator.isValidCron(cron, { seconds: true, allowBlankDay: true, alias: true, allowSevenAsSunday: true })
    if (!isValid) {
        console.log(cron, ' ===> Cron 无效');
        return;
    }
    
	const job = new CronJob(
	    cron.replace('?', '*'),  // 不支持问号，则将cron的问号转成*
	    function () {
	        console.log(dayjs().format('HH:mm:ss'))
	        // todo: do task
	    },
	    (e) => { console.log('complete ', e) },
	    true,
	    'Asia/Shanghai'
	);
	console.log('job cron: ',job.cronTime.source)
	return job;
}

createCronJob('*/5 * * * * *')