Nodejs回調加超時限制兩種實現方法
更新時間：2017年06月09日 11:47:05 作者：小水熊
這篇文章主要介紹了Nodejs回調加超時限制兩種實現方法的相關資料,需要的朋友可以參考下
Nodejs回調加超時限制兩種實現方法
Nodejs下的IO操作都是異步的，有時候異步請求返回太慢，不想無限等待回調怎么辦呢？我們可以給回調函數加一個超時限制，到一定時間還沒有回調就表示失敗，繼續(xù)后面的步驟。
方案1：用async的parallel實現
在這里我用到了async的parallel方法，parallel可以讓若干個異步回調的方法并行執(zhí)行，正常情況下，所有回調函數都完成后會匯集到parallel最終的回調函數里，但是有一種例外，如果其中一個步驟有錯誤拋出并直接調用parallel最終的回調函數，利用這個特點就可以實現我們要的功能。
我封裝了一個函數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}`);
});
}
你可以直接運行這個js看看效果：
node async-timer.js
模塊調用方法：
const asyncWrapper = require('./async-timer.js').asyncWrapper
const fn = (arg1, arg2, callback) => {
//...假設這里過程很漫長，有可能超時
callback(null, result_1, result_2);
}
asyncWrapper(
fn,//異步函數
10000,//超時時間
'arg1_value',//異步函數的參數1
'arg2_value',//異步函數的參數2，有多個參數就在后面繼續(xù)加
(err, results)=>{
//results : [result_1, result_2]
//最后的回調,results比較特殊，fn有多個返回值時，results會以數組的形式返回給你
}
);
這種方案的好處是對node沒有最低版本要求，引入async庫就可以用，缺陷是最終返回的值都是在一個參數里面以數組的形式呈現。
方案2：用Promise實現
在promise里面加settimeout，超過時間就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}`);
});
}
模塊調用方法：
const asyncWrapper = require('./promise-timer.js').promiseWrapper
const fn = (arg1, arg2, callback) => {
//...假設這里過程很漫長，有可能超時
callback(null, result_1, result_2);
}
promiseWrapper(
fn,//異步函數
10000,//超時時間
'arg1_value',//異步函數的參數1
'arg2_value',//異步函數的參數2，有多個參數就在后面繼續(xù)加
(err, result_1, result_2)=>{
//最后的回調
}
);
這種方案要求nodejs版本高于5.0，支持Promise。
感謝閱讀，希望能幫助到大家，謝謝大家對本站的支持！
相關文章
這篇文章介紹了Node.js中fs模塊的使用方法，文中通過示例代碼介紹的非常詳細。對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-06-06
這篇文章主要給大家介紹了如何在Node.js項目中使用 Swagger 來自動生成 API接口文檔,使用生成方式有很多種,本文基于swagger-jsdoc+swagger-ui-express快速實現,文中通過代碼示例介紹的非常詳細,需要的朋友可以參考下2024-01-01
這里只是熟悉nodejs中的http模塊的API，一般在開發(fā)過程中使用的是第三方的框架，比如說Express。其中封裝了更為簡單的構建http服務器的API。2015-01-01
最近使用NodeJs搭建的小型web應用,所以下面這篇文章主要給大家介紹了關于使用node搭建一個小頁面的相關資料,文中通過圖文介紹的非常詳細,需要的朋友可以參考下2022-11-11
這篇文章主要介紹了nodejs獲取微信小程序帶參數二維碼實現代碼的相關資料,需要的朋友可以參考下2017-04-04
這篇文章主要介紹了使用nvm安裝|更新|切換|nodejs的命令詳解,有了nvm就可以簡單操作node版本的切換、安裝、查看等，需要的朋友可以參考下2022-07-07
這篇文章主要介紹了node.js中的fs.statSync方法使用說明,本文介紹了fs.statSync的方法說明、語法、接收參數、使用實例和實現源碼,需要的朋友可以參考下2014-12-12
這篇文章主要介紹了Node.js安裝教程和NPM包管理器使用詳解,安裝部分講解了Windows、和MAC OS下的安裝圖解,并介紹了Linux下的源碼安裝方法,最后對NPM包管理器做了詳細介紹,需要的朋友可以參考下2014-08-08
這篇文章主要介紹了Node.js中防止錯誤導致的進程阻塞的方法，非常不錯，具有參考借鑒價值，需要的朋友可以參考下2016-08-08
Node.js如何使用Diffie-Hellman密鑰交換算法詳解
Deffie-Hellman(簡稱 DH) 密鑰交換是最早的密鑰交換算法之一，它使得通信的雙方能在非安全的信道中安全的交換密鑰，用于加密后續(xù)的通信消息。下面這篇文章主要給大家介紹了關于Node.js如何使用DiffieHellman密鑰交換算法的相關資料，需要的朋友可以參考下。2017-09-09