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。
感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!
华山资源网 Design By www.eoogi.com
广告合作:本站广告合作请联系QQ:858582 申请时备注:广告合作(否则不回)
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
华山资源网 Design By www.eoogi.com
暂无评论...
更新日志
2024年09月25日
2024年09月25日
- 纯音入心系列纯音乐《天籁古筝》1CD[MP3][331MB]
- 男女对唱典藏天碟《发烧对唱·那个季节里的歌DSD》10CD[WAV]
- 群星2010-歌林精选辑[歌林][WAV+CUE]
- TrioZimbalist-PianoTriosofWeinberg,Auerbach,Dvorak(2024)[24-44,1]wav
- 群星.1992-滚石第一流台湾歌·12王牌大车拼【滚石】【WAV+CUE】
- 林子祥.1984-创作歌集【华纳】【WAV+CUE】
- 周汤豪.2010-周汤豪【华纳】【FLAC分轨】
- Mozart-TheStringQuintets-AmadeusQuartet,CecilAronowitz(2017)[24-44,1][WAV+CUE]
- JamesWilliamsDennisIrwin-Focus(2024,Red)[24-48]FLAC
- 藤泽麻衣《空みあげて》[WAV]
- 纯音入心系列纯音乐《中国古筝经典名曲》1CD[MP3][1.3GB]
- 纯音入心系列纯音乐《古筝新奏:岁月静好与筝语,细水流年与筝同》1CD[MP3][846.9MB]
- 670《脆弱敏感小女生》[320K/MP3][27.53MB]
- 曾琳.2011-好好爱我【南方】【WAV+CUE】
- 范晓萱.1995-RAIN【福茂】【WAV+CUE】