溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
Nodejs回調加超時限制兩種實現方法
Nodejs下的IO操作都是異步的，有時候異步請求返回太慢，不想無限等待回調怎么辦呢？我們可以給回調函數加一個超時限制，到一定時間還沒有回調就表示失敗，繼續后面的步驟。
方案1：用async的parallel實現
在這里我用到了async的parallel方法，parallel可以讓若干個異步回調的方法并行執行，正常情況下，所有回調函數都完成后會匯集到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，有多個參數就在后面繼續加
(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，有多個參數就在后面繼續加
(err, result_1, result_2)=>{
//最后的回調
}
);
這種方案要求nodejs版本高于5.0，支持Promise。
感謝閱讀，希望能幫助到大家，謝謝大家對本站的支持！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
