Node.js 定时任务与队列处理实战：node-schedule 和 async 详解

 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');

// 每分钟的第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());
 }
 });

//每周一的下午15：03：30触发，其它组合可以根据我代码中的注释参数名自由组合
nodeTimer.scheduleTimer({hour: 15, minute: 3, second: 30},function(err){
 if(!err){
 console.log('scheduleTimer:' + new Date());
 }
 });

var date = new Date(2019, 01, 07, 15, 03, 30);
nodeTimer.scheduleTimer(date,function(err){
 if(!err){
  console.log('scheduleTimer:' + new Date());
 }
 });

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());
 }
 });

// 取消定时器
// 调用 定时器对象的cancl()方法即可
nodeTimer.scheduleCancel = () => {
 // 定时器取消
 cancelTimer.cancel();
 console.log('定时器成功取消');
}

 nodeTimer.scheduleCancel()

 npm install --save async

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,'个')
  }
 })
 };