一,介绍与需求
1.1,介绍
定时任务(node-schedule),是针对Node.js的一种灵活的cron-like和not-cron-like作业调度程序。它允许您使用可选的递归规则将作业(任意函数)安排在特定日期执行。它在任何给定的时间只使用一个计时器(而不是每秒钟/分钟重新评估即将到来的作业)。
Async是一个实用模块,它为异步JavaScript提供了直接、强大的功能。async流程控制器--queue(队列),queue流程控制器是一个并行的流程控制器,但是它与parallel的区别在于queue可以控制一次执行几个函数,而parallel只是让所有函数并行执行.
1.2,需求
实际开发项目中,会遇到很多定时任务的工作。比如:定时导出某些数据、定时发送消息或邮件给用户、定时备份什么类型的文件等等。在当时给用户发送消息时,可能要发送的用户就不只有一两个,二是多个,这是可能就会用到队列顺序执行。
二,定时器
第一步:安装node-schedule
npm install node-schedule --save
第二步:封装定时器模块
const schedule = require('node-schedule');//定时器 const nodeTimer = {}; let cancelTimer = '' /** *Cron风格定时器/对象文本语法定时器 * @param executionTime :定时器字符串'30 * * * * *'/定时器对象{hour: 16, minute: 11, dayOfWeek: 1} * @param callback :回调函数 */ nodeTimer.scheduleTimer = (executionTime = '30 * * * * *', callback) => { // 每分钟的第30秒触发: '30 * * * * *' // 每小时的1分30秒触发 :'30 1 * * * *' // 每天的凌晨1点1分30秒触发 :'30 1 1 * * *' // 每月的1日1点1分30秒触发 :'30 1 1 1 * *' // 2016年的1月1日1点1分30秒触发 :'30 1 1 1 2016 *' // 每周1的1点1分30秒触发 :'30 1 1 * * 1' cancelTimer = schedule.scheduleJob(executionTime, () => { if (typeof callback === 'function') { callback() } }); } module.exports = nodeTimer;
第三步:调用
在回调函数中写入要执行的任务代码,一个定时器就完成了!
引入定时器模块:
const nodeTimer = require('./node_timer.js');
1,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)
6个占位符从左到右分别代表:秒、分、时、日、月、周几
*表示通配符,匹配任意,当秒是*时,表示任意秒数都触发,其它类推
// 每分钟的第30秒触发: '30 * * * * *' // 每小时的1分30秒触发 :'30 1 * * * *' // 每天的凌晨1点1分30秒触发 :'30 1 1 * * *' // 每月的1日1点1分30秒触发 :'30 1 1 1 * *' // 2016年的1月1日1点1分30秒触发 :'30 1 1 1 2016 *' // 每周1的1点1分30秒触发 :'30 1 1 * * 1' // 每分钟的1-10秒都会触发,其它通配符依次类推 :'1-10 * * * * *'
调用定时器:
nodeTimer.scheduleTimer('30 * * * * *',function(err){ if(!err){ console.log('scheduleTimer:' + new Date()); } });
效果:
2、对象文本语法定时器
- second (0-59)
- minute (0-59)
- hour (0-23)
- date (1-31)
- month (0-11)
- year
- dayOfWeek (0-6) Starting with Sunday
//每周一的下午15:03:30触发,其它组合可以根据我代码中的注释参数名自由组合 nodeTimer.scheduleTimer({hour: 15, minute: 3, second: 30},function(err){ if(!err){ console.log('scheduleTimer:' + new Date()); } });
效果:
3、基于日期的定时器
var date = new Date(2019, 01, 07, 15, 03, 30); nodeTimer.scheduleTimer(date,function(err){ if(!err){ console.log('scheduleTimer:' + new Date()); } });
4、递归规则定时器
参数与对象文本语法定时器的参数类似
var rule = new schedule.RecurrenceRule(); rule.dayOfWeek = [0, new schedule.Range(4, 6)];//每周四,周五,周六执行 rule.hour = 15; rule.minute = 0; nodeTimer.scheduleTimer(rule,function(err){ if(!err){ console.log('scheduleTimer:' + new Date()); } });
5、取消定时器
// 取消定时器 // 调用 定时器对象的cancl()方法即可 nodeTimer.scheduleCancel = () => { // 定时器取消 cancelTimer.cancel(); console.log('定时器成功取消'); }
调用:
nodeTimer.scheduleCancel()
效果:
三,队列
第一步:安装async
npm install --save async
第二步:封装方法
queue相当于一个加强版的parallel,主要是限制了worker数量,不再一次性全部执行。当worker数量不够用时,新加入的任务将会排队等候,直到有新的worker可用。
该函数有多个点可供回调,如worker用完时、无等候任务时、全部执行完时等。
const async = require('async'); /** *队列 * @param obj :obj对象 包含执行时间 * @param callback :回调函数 */ const nodeQueue = async.queue(function (obj, callback) { setTimeout(function () { // 需要执行的代码的回调函数 if(typeof callback==='function'){ callback(); } }, obj.time) }, 1) // worker数量将用完时,会调用saturated函数 nodeQueue.saturated = function() { console.log('all workers to be used'); } // 当最后一个任务交给worker执行时,会调用empty函数 nodeQueue.empty = function() { console.log('no more tasks wating'); } // 当所有任务都执行完时,会调用drain函数 nodeQueue.drain = function() { console.log('all tasks have been processed'); } module.exports = nodeQueue;
第三步:调用方法
const nodeQueue = require('./node_queue.js'); for (let i = 0; i < 10; i++) { nodeQueue.push({ name: 1, time: 2000 }, function (err) { console.log('队列执行错误信息==',err); if(!err){ // 需要执行的代码或函数 console.log('需要执行的代码或函数第',i+1,'个') } }) };
效果:
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对的支持。
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件! 如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
稳了!魔兽国服回归的3条重磅消息!官宣时间再确认!
昨天有一位朋友在大神群里分享,自己亚服账号被封号之后居然弹出了国服的封号信息对话框。
这里面让他访问的是一个国服的战网网址,com.cn和后面的zh都非常明白地表明这就是国服战网。
而他在复制这个网址并且进行登录之后,确实是网易的网址,也就是我们熟悉的停服之后国服发布的暴雪游戏产品运营到期开放退款的说明。这是一件比较奇怪的事情,因为以前都没有出现这样的情况,现在突然提示跳转到国服战网的网址,是不是说明了简体中文客户端已经开始进行更新了呢?
更新日志
- 小骆驼-《草原狼2(蓝光CD)》[原抓WAV+CUE]
- 群星《欢迎来到我身边 电影原声专辑》[320K/MP3][105.02MB]
- 群星《欢迎来到我身边 电影原声专辑》[FLAC/分轨][480.9MB]
- 雷婷《梦里蓝天HQⅡ》 2023头版限量编号低速原抓[WAV+CUE][463M]
- 群星《2024好听新歌42》AI调整音效【WAV分轨】
- 王思雨-《思念陪着鸿雁飞》WAV
- 王思雨《喜马拉雅HQ》头版限量编号[WAV+CUE]
- 李健《无时无刻》[WAV+CUE][590M]
- 陈奕迅《酝酿》[WAV分轨][502M]
- 卓依婷《化蝶》2CD[WAV+CUE][1.1G]
- 群星《吉他王(黑胶CD)》[WAV+CUE]
- 齐秦《穿乐(穿越)》[WAV+CUE]
- 发烧珍品《数位CD音响测试-动向效果(九)》【WAV+CUE】
- 邝美云《邝美云精装歌集》[DSF][1.6G]
- 吕方《爱一回伤一回》[WAV+CUE][454M]