快捷導(dǎo)航

Nodejs回調(diào)加超時(shí)限制兩種實(shí)現(xiàn)方法

更新時(shí)間：2017年06月09日 11:47:05 作者：小水熊

這篇文章主要介紹了Nodejs回調(diào)加超時(shí)限制兩種實(shí)現(xiàn)方法的相關(guān)資料,需要的朋友可以參考下

Nodejs回調(diào)加超時(shí)限制兩種實(shí)現(xiàn)方法

Nodejs下的IO操作都是異步的，有時(shí)候異步請求返回太慢，不想無限等待回調(diào)怎么辦呢？我們可以給回調(diào)函數(shù)加一個(gè)超時(shí)限制，到一定時(shí)間還沒有回調(diào)就表示失敗，繼續(xù)后面的步驟。

方案1：用async的parallel實(shí)現(xiàn)

在這里我用到了async的parallel方法，parallel可以讓若干個(gè)異步回調(diào)的方法并行執(zhí)行，正常情況下，所有回調(diào)函數(shù)都完成后會(huì)匯集到parallel最終的回調(diào)函數(shù)里，但是有一種例外，如果其中一個(gè)步驟有錯(cuò)誤拋出并直接調(diào)用parallel最終的回調(diào)函數(shù)，利用這個(gè)特點(diǎn)就可以實(shí)現(xiàn)我們要的功能。

我封裝了一個(gè)函數(shù)asyncWrapper，邏輯比較簡單，直接看代碼：

async-timer.js

const async = require('async');

const asyncWrapper = (fn, interval, ...args) =>{
  let final_callback = args[args.length-1];
  async.parallel([
    function(callback){
      args[args.length - 1] = callback;
      fn.apply(this, args);
    },
    function(callback){
      setTimeout(function(){
        callback(408);
      }, interval);
    }
  ],
  function(err, results){
    if(err==408 && results[0])err = null;
    final_callback.apply(this,[err].concat([results[0]]));
  });
}

if(module.parent){
  exports.asyncWrapper = asyncWrapper;
}else{
  let myfn = (arg_1, arg_2, callback) => {
    setTimeout(function(){
      callback(null,'value 1: '+arg_1,'value 2: '+arg_2);
    }, 1000);
  }
  asyncWrapper(myfn, 2000, 10, 20, (err, values)=>{
    console.log(`${err}, ${values}`);
  });
}

你可以直接運(yùn)行這個(gè)js看看效果：

node async-timer.js

模塊調(diào)用方法：

const asyncWrapper = require('./async-timer.js').asyncWrapper


const fn = (arg1, arg2, callback) => {
   //...假設(shè)這里過程很漫長，有可能超時(shí)
   callback(null, result_1, result_2);
}

asyncWrapper(
   fn,//異步函數(shù)
   10000,//超時(shí)時(shí)間
   'arg1_value',//異步函數(shù)的參數(shù)1
   'arg2_value',//異步函數(shù)的參數(shù)2，有多個(gè)參數(shù)就在后面繼續(xù)加
   (err, results)=>{
    //results : [result_1, result_2]
    //最后的回調(diào),results比較特殊，fn有多個(gè)返回值時(shí)，results會(huì)以數(shù)組的形式返回給你
   }
);

這種方案的好處是對node沒有最低版本要求，引入async庫就可以用，缺陷是最終返回的值都是在一個(gè)參數(shù)里面以數(shù)組的形式呈現(xiàn)。

方案2：用Promise實(shí)現(xiàn)

在promise里面加settimeout，超過時(shí)間就reject。

promise-timer.js

const promiseWrapper = (fn, interval, ...args) =>{
 let final_callback = args[args.length-1];
 new Promise((resolve, reject)=>{
 args[args.length - 1] = (err, ...vals)=>{
  if(err)reject(err);
  else resolve(vals);
 };
    fn.apply(this, args);
    setTimeout(_=>{
     reject('Promise time out');
    }, interval);
 })
 .then(
 result => {
  final_callback.apply(this, [null].concat(result));
 }
 )
  .catch(err=>{
   final_callback(err);
  })
}


if(module.parent){
  exports.promiseWrapper = promiseWrapper;
}else{
  let myfn = (arg_1, arg_2, callback) => {
    setTimeout(function(){
      callback(null,'value 1: '+arg_1,'value 2: '+arg_2);
    }, 1000);
  }
  promiseWrapper(myfn, 1000, 10, 20, (err, value_1, value_2)=>{
    console.log(`${err}, value 1: ${value_1} ... value 2: ${value_2}`);
  });
}

模塊調(diào)用方法：

const asyncWrapper = require('./promise-timer.js').promiseWrapper


const fn = (arg1, arg2, callback) => {
   //...假設(shè)這里過程很漫長，有可能超時(shí)
   callback(null, result_1, result_2);
}

promiseWrapper(
   fn,//異步函數(shù)
   10000,//超時(shí)時(shí)間
   'arg1_value',//異步函數(shù)的參數(shù)1
   'arg2_value',//異步函數(shù)的參數(shù)2，有多個(gè)參數(shù)就在后面繼續(xù)加
   (err, result_1, result_2)=>{
    //最后的回調(diào)
   }
);

這種方案要求nodejs版本高于5.0，支持Promise。

感謝閱讀，希望能幫助到大家，謝謝大家對本站的支持！

您可能感興趣的文章: