在Node.js中实现任务调度与执行

在Node.js中实现任务调度与执行

作者:chszs,未经博主允许不得转载。经许可的转载需注明作者和博客主页:http://blog.csdn.net/chszs

批处理是业务开发中经常会遇到的需求,比如银行对账单的处理,又比如广告邮件的推送。

Node.js在批处理方面也有一些优秀的库,node-schedule就是其中之一。

node-schedule是一个轻量级的、基于Node.js的、类似于cron的调度器工具。其介绍可查看: https://www.npmjs.com/package/node-schedule

node-schedule允许在指定的日期时间调度执行任意任务(任意的函数),还支持循环规则。node-schedule内部只使用了单个计时器。

node-schedule是基于时间的调度器,而不是基于时间间隔的调度器。假如你有这样的需求“每隔5分钟运行某个函数一次”,你会觉得使用基于时间间隔的调度方式更适合,比如setInterval(),使用非常方便。假如你的需求是“每小时的第5分钟和第50分钟运行某个函数一次”,那么你会觉得基于时间的调度方式更适合。

还要注意,与cron不同,node-schedule在Windows系统也能得到完美的支持。

需要注意的是,node-schedule的设计目标是用于进程间的调度,也即调度的作业在调度时会运行相关脚本,当脚本执行完成后调度将消失。如果希望在脚本未运行的时候持续调度作业,那么最好还是使用cron。

在node-schedule中,每一个被调度的作业都是使用Job对象来描述的。可以手动创建Job,然后执行schedule()方法来应用调度,或使用scheduleJob()。

Job对象是EventEmitter的,在每一次调度执行时发出一个运行事件。在调度的时间到来时,它还会发出被调度的事件。当调度开始之前,要取消调度,可以发取消事件。这些事件都接收JavaScript的日期对象作为参数。

要注意,作业在首次调度时是立即执行的,因此如果你使用scheduleJob()创建作业,会失去首次立即调度的事件。
还要注意,取消事件是canceled,表达方式采用了美国英语。

要安装node-schedule很简单,执行:

npm install node-schedule

如果你用过cron,了解cron表达式的格式,使用它则更简单。

Cron风格的调度

cron格式的组成如下:

*    *    *    *    *    *
┬    ┬    ┬    ┬    ┬    ┬
│    │    │    │    │    |
│    │    │    │    │    └ day of week (0 - 7) (0 or 7 is Sun)
│    │    │    │    └───── month (1 - 12)
│    │    │    └────────── day of month (1 - 31)
│    │    └─────────────── hour (0 - 23)
│    └──────────────────── minute (0 - 59)
└───────────────────────── second (0 - 59, OPTIONAL)

下面来看一个例子:

var scheduler = require('node-schedule');
var montlyJob = scheduler.scheduleJob('0 0 1 * *', function(){
    console.log('I run the first day of the month');
});

还有使用JavaScript对象的方法:

var scheduler = require('node-schedule');
var rule = new scheduler.RecurrenceRule();
rule.hour = 7
rule.dayOfWeek = new scheduler.Range(0,6)
var dailyJob = scheduler.scheduleJob(date, function(){
    console.log('I run on days at 7:00');
});
scheduler.scheduleJob(rule,task);

还可以跳过指定日期来调度任务:

var scheduler = require('node-schedule');
var date = new Date(2017, 1, 1, 0, 0, 0);
var newYearJob = scheduler.scheduleJob(date, function() {
    console.log("Happy new year");
});

要取消调度的作业也很简单,这样:

newYearJob.cancel();
CAN长字节DM1报文是指在CAN总线上传输的长度超过8个字节的DM1报文。根据引用\[1\],当要传输的数据长度超过8个字节时,首先使用TPCM进行广播,广播内容包含即将传输报文的PGN、总的数据包长度等信息,然后使用TP.DT进行数据传输。相邻两个TP.DT之间的时间间隔是50ms到200ms。根据引用\[2\],当字节数大于8时,将会使用多帧传输参数组。根据引用\[3\],DM1报文是Diagnostic Message 1, Active Diagnostic Trouble Codes的缩写,用于点亮故障指示灯、红色停机灯等,并周期性播报控制器中处于激活状态的故障码。DM1报文的格式包括各个字节的定义,如故障指示灯、红色停机灯、琥珀色警告指示灯等。因此,CAN长字节DM1报文是指在CAN总线上传输的长度超过8个字节的DM1报文,用于传输更多的故障码信息。 #### 引用[.reference_title] - *1* [车载通信——J1939 DM1](https://blog.csdn.net/weixin_64064747/article/details/130193432)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^control_2,239^v3^insert_chatgpt"}} ] [.reference_item] - *2* [J1939广播DM1报文](https://blog.csdn.net/mengdeguodu_/article/details/108173263)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^control_2,239^v3^insert_chatgpt"}} ] [.reference_item] - *3* [J1939商用车在线诊断DM1报文](https://blog.csdn.net/traveller93/article/details/120735912)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^control_2,239^v3^insert_chatgpt"}} ] [.reference_item] [ .reference_list ]
评论
添加红包

请填写红包祝福语或标题

红包个数最小为10个

红包金额最低5元

当前余额3.43前往充值 >
需支付:10.00
成就一亿技术人!
领取后你会自动成为博主和红包主的粉丝 规则
hope_wisdom
发出的红包
实付
使用余额支付
点击重新获取
扫码支付
钱包余额 0

抵扣说明:

1.余额是钱包充值的虚拟货币,按照1:1的比例进行支付金额的抵扣。
2.余额无法直接购买下载,可以购买VIP、付费专栏及课程。

余额充值