Nodejs回调加超时限制两种实现方法
时间:2019-03-30
本文章向大家介绍Nodejs回调加超时限制两种实现方法,主要包括Nodejs回调加超时限制两种实现方法使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
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。
感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!
- Contact Manager Web API 示例[2] Web API Routing
- Android一些关于分辨率和布局的设置
- log4net 中错误 System.Web.HttpException (0x80004005): 文件不存在
- Contact Manager Web API 示例[2] Web API Routing
- Python内置函数
- NET实现微信公共平台上传下载多媒体文件
- css3基础知识——回顾
- Contact Manager Web API 示例[3] 分页和查询(Paging and Querying)
- @font-face css3自定义个性化字体
- 你不知道的javaScript笔记(7)
- Contact Manager Web API 示例[4] 异常处理(Exception Handling)
- 你不知道的javaScript笔记(6)
- 创建支持多种屏幕尺寸的Android应用
- 封装多线程处理大量数据操作
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- Linux基础之xargs命令的入门实例
- CentOS 7.4下安装Oracle 11.2.0.4数据库的方法
- CentOS桌面环境中网卡启动失败的解决方法
- 浅谈Linux vfork与fork简单对比分析
- Linux定时任务Crontab的使用方法
- linux虚拟网络设备之vlan配置详解
- Centos7安装完后无法联网的解决方法
- Linux静态链接库与模板类的处理方式
- 深入研究RocketMQ消费者是如何获取消息的
- CentOS7下 Apache的安装配置方法
- expect命令在linux下实现批量ssh免密
- 学习Vim合并行的方法和技巧
- 九种查找算法
- 代码防御性编程的十条技巧
- Ubuntu终端多窗口分屏Terminator