快捷導(dǎo)航

NodeJs入門教程之定時(shí)器和隊(duì)列

更新時(shí)間：2019年03月08日 08:32:42 作者：jackson影琪

這篇文章主要給大家介紹了關(guān)于NodeJs入門教程之定時(shí)器和隊(duì)列的相關(guān)資料，文中通過(guò)示例代碼以及圖文介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

一,介紹與需求

1.1,介紹

定時(shí)任務(wù)（node-schedule)，是針對(duì)Node.js的一種靈活的cron-like和not-cron-like作業(yè)調(diào)度程序。它允許您使用可選的遞歸規(guī)則將作業(yè)(任意函數(shù))安排在特定日期執(zhí)行。它在任何給定的時(shí)間只使用一個(gè)計(jì)時(shí)器(而不是每秒鐘/分鐘重新評(píng)估即將到來(lái)的作業(yè))。

Async是一個(gè)實(shí)用模塊，它為異步JavaScript提供了直接、強(qiáng)大的功能。async流程控制器--queue(隊(duì)列),queue流程控制器是一個(gè)并行的流程控制器,但是它與parallel的區(qū)別在于queue可以控制一次執(zhí)行幾個(gè)函數(shù),而parallel只是讓所有函數(shù)并行執(zhí)行.

1.2,需求

實(shí)際開(kāi)發(fā)項(xiàng)目中，會(huì)遇到很多定時(shí)任務(wù)的工作。比如：定時(shí)導(dǎo)出某些數(shù)據(jù)、定時(shí)發(fā)送消息或郵件給用戶、定時(shí)備份什么類型的文件等等。在當(dāng)時(shí)給用戶發(fā)送消息時(shí),可能要發(fā)送的用戶就不只有一兩個(gè),二是多個(gè),這是可能就會(huì)用到隊(duì)列順序執(zhí)行。

二,定時(shí)器

第一步:安裝node-schedule

 npm install node-schedule --save

第二步:封裝定時(shí)器模塊

const schedule = require('node-schedule');//定時(shí)器
const nodeTimer = {};
let cancelTimer = ''
/**
 *Cron風(fēng)格定時(shí)器/對(duì)象文本語(yǔ)法定時(shí)器
 * @param executionTime ：定時(shí)器字符串'30 * * * * *'/定時(shí)器對(duì)象{hour: 16, minute: 11, dayOfWeek: 1}
 * @param callback ：回調(diào)函數(shù)
 */
nodeTimer.scheduleTimer = (executionTime = '30 * * * * *', callback) => {
 // 每分鐘的第30秒觸發(fā)： '30 * * * * *'
 // 每小時(shí)的1分30秒觸發(fā) ：'30 1 * * * *'
 // 每天的凌晨1點(diǎn)1分30秒觸發(fā) ：'30 1 1 * * *'
 // 每月的1日1點(diǎn)1分30秒觸發(fā) ：'30 1 1 1 * *'
 // 2016年的1月1日1點(diǎn)1分30秒觸發(fā) ：'30 1 1 1 2016 *'
 // 每周1的1點(diǎn)1分30秒觸發(fā) ：'30 1 1 * * 1'
 
 cancelTimer = schedule.scheduleJob(executionTime, () => {
 if (typeof callback === 'function') {
 callback()
 }
 });

}
module.exports = nodeTimer;

第三步:調(diào)用

在回調(diào)函數(shù)中寫(xiě)入要執(zhí)行的任務(wù)代碼，一個(gè)定時(shí)器就完成了！

引入定時(shí)器模塊：

 const nodeTimer = require('./node_timer.js');

1,Cron風(fēng)格定時(shí)器

規(guī)則參數(shù)講解 *代表通配符

*   *    *     *    *    *
┬    ┬    ┬    ┬    ┬    ┬
│    │    │    │    │    │
│    │    │    │    │    └ 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個(gè)占位符從左到右分別代表：秒、分、時(shí)、日、月、周幾

*表示通配符，匹配任意，當(dāng)秒是*時(shí)，表示任意秒數(shù)都觸發(fā)，其它類推

// 每分鐘的第30秒觸發(fā)： '30 * * * * *'
// 每小時(shí)的1分30秒觸發(fā) ：'30 1 * * * *'
// 每天的凌晨1點(diǎn)1分30秒觸發(fā) ：'30 1 1 * * *'
// 每月的1日1點(diǎn)1分30秒觸發(fā) ：'30 1 1 1 * *'
// 2016年的1月1日1點(diǎn)1分30秒觸發(fā) ：'30 1 1 1 2016 *'
// 每周1的1點(diǎn)1分30秒觸發(fā) ：'30 1 1 * * 1'
// 每分鐘的1-10秒都會(huì)觸發(fā)，其它通配符依次類推 ：'1-10 * * * * *'

調(diào)用定時(shí)器：

 nodeTimer.scheduleTimer('30 * * * * *',function(err){
 if(!err){
 console.log('scheduleTimer:' + new Date());
 }
 });

效果：

2、對(duì)象文本語(yǔ)法定時(shí)器

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觸發(fā)，其它組合可以根據(jù)我代碼中的注釋參數(shù)名自由組合
nodeTimer.scheduleTimer({hour: 15, minute: 3, second: 30},function(err){
 if(!err){
 console.log('scheduleTimer:' + new Date());
 }
 });

效果:

3、基于日期的定時(shí)器

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

4、遞歸規(guī)則定時(shí)器

參數(shù)與對(duì)象文本語(yǔ)法定時(shí)器的參數(shù)類似

var rule = new schedule.RecurrenceRule();
rule.dayOfWeek = [0, new schedule.Range(4, 6)];//每周四，周五，周六執(zhí)行
rule.hour = 15;
rule.minute = 0;
nodeTimer.scheduleTimer(rule,function(err){
 if(!err){
  console.log('scheduleTimer:' + new Date());
 }
 });

5、取消定時(shí)器

// 取消定時(shí)器
// 調(diào)用 定時(shí)器對(duì)象的cancl()方法即可
nodeTimer.scheduleCancel = () => {
 // 定時(shí)器取消
 cancelTimer.cancel();
 console.log('定時(shí)器成功取消');
}

調(diào)用：

 nodeTimer.scheduleCancel()

效果：

三,隊(duì)列

第一步：安裝async

 npm install --save async

第二步：封裝方法

queue相當(dāng)于一個(gè)加強(qiáng)版的parallel，主要是限制了worker數(shù)量，不再一次性全部執(zhí)行。當(dāng)worker數(shù)量不夠用時(shí)，新加入的任務(wù)將會(huì)排隊(duì)等候，直到有新的worker可用。

該函數(shù)有多個(gè)點(diǎn)可供回調(diào)，如worker用完時(shí)、無(wú)等候任務(wù)時(shí)、全部執(zhí)行完時(shí)等。

const async = require('async');
 /**
 *隊(duì)列
 * @param obj ：obj對(duì)象 包含執(zhí)行時(shí)間
 * @param callback ：回調(diào)函數(shù)
 */
const nodeQueue = async.queue(function (obj, callback) {
 setTimeout(function () {
 // 需要執(zhí)行的代碼的回調(diào)函數(shù)
 if(typeof callback==='function'){
  callback();
 }
 }, obj.time)
}, 1)

// worker數(shù)量將用完時(shí)，會(huì)調(diào)用saturated函數(shù)
nodeQueue.saturated = function() { 
 console.log('all workers to be used'); 
}
 
// 當(dāng)最后一個(gè)任務(wù)交給worker執(zhí)行時(shí)，會(huì)調(diào)用empty函數(shù)
nodeQueue.empty = function() { 
 console.log('no more tasks wating'); 
}
 
// 當(dāng)所有任務(wù)都執(zhí)行完時(shí)，會(huì)調(diào)用drain函數(shù)
nodeQueue.drain = function() { 
 console.log('all tasks have been processed'); 
}
module.exports = nodeQueue;

第三步：調(diào)用方法

const nodeQueue = require('./node_queue.js');
 for (let i = 0; i < 10; i++) {
 nodeQueue.push({ name: 1, time: 2000 }, function (err) {
  console.log('隊(duì)列執(zhí)行錯(cuò)誤信息==',err);
  if(!err){
  // 需要執(zhí)行的代碼或函數(shù)
  console.log('需要執(zhí)行的代碼或函數(shù)第',i+1,'個(gè)')
  }
 })
 };

效果：