位置: 编程技术 - 正文

浅谈Koa服务限流方法实践(服务器限制流量)

编辑:rootadmin

推荐整理分享浅谈Koa服务限流方法实践(服务器限制流量),希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:如何实现服务限流,限制端口流量,如何实现服务限流,服务端限流,如何实现服务限流,如何实现服务限流,服务器限流,服务端限流,内容如对您有帮助,希望把文章链接给更多的朋友!

最近接了一个需求,很简单,就是起一个server,收到请求时调用某个提供好的接口,然后把结果返回。因为这个接口的性能问题,同时在请求的不能超过特定数目,要在服务中进行限流。

限流的要求是,限制同时执行的数目,超出这个数目后要在一个队列中进行缓存。

koa 中间件不调用 next

最初的想法是在 koa 中间件中进行计数,超过6个时将next函数缓存下来。等正在进行中的任务结束时,调用next继续其他请求。

之后发现 koa 中间件中,不执行next函数请求并不会停下,而是不再调用之后的中间件,直接返回内容。

以上代码首先在控制台打出 ‘middleware 1' => 浏览器收到 ‘hello' => 控制台打出 ‘middleware 2'。

这里还有一个要注意的地方,就是一个请求已经结束(finish)后,他的next方法还是可以继续调用,之后的middleware还是继续运行的(但是对ctx的修改不会生效,因为请求已经返回了)。同样,关闭的请求(close)也是同样的表现。

使用 await 让请求进行等待

延迟next函数执行不能达到目的。接下来自然想到的就是使用await让当前请求等待。await的函数返回一个Promise,我们将这个Promise中的resolve函数存储到队列中,延迟调用。

上面这段代码,在delay函数中返回一个Promise,Promise的resolve函数存入队列中。设置定时3s后执行队列中的resolve函数,使请求继续执行。

针对路由进行限流,还是针对请求进行限流?

限流的基本原理实现后,下面一个问题就是限流代码该写在哪里?基本上,有两个位置:

浅谈Koa服务限流方法实践(服务器限制流量)

针对接口进行限流

由于我们的需求中,限流是因为要请求接口的性能有限。所以我们可以单独针对这个请求进行限流:

下面还有一个方便复用的版本。

针对路由进行限流

这种方式是写一个koa中间件,在中间件中进行限流:

之后针对不同路由在router中使用这个中间件就好了:

比较

实现了针对接口进行限流,觉得逻辑有些乱,于是改用了针对路由进行限流,一切运行的很完美。

直到我又接了个需求,是要请求三次这个接口返回三次请求的结果数组。现在问题来了,我们不能直接调用接口,因为要限流。也不能直接调用请求接口的函数因为我们的限流是以路由为单位的。那怎么办呢?我们只有请求这个路由了,自己请求自己。。。

需要注意的地方

监听close事件,将请求从队列中移出已经存储在队列中的请求,有可能遇到用户取消的情况。前面说过koa中即使请求取消,之后的中间件还是会运行,也就是还会执行需要限流的接口,造成浪费。

可以监听close事件来达到这个目的,每个请求我们需要用hash值来标记:

设置超时时间

为了防止用户等待过长时间,需要设置超时时间,这在koa中很容易实现:

当前队列已经过长

如果当前队列已经过长了,即使加入队列中也会超时。因此我们还需要处理队列过长的情况:

标签: 服务器限制流量

本文链接地址:https://www.jiuchutong.com/biancheng/379473.html 转载请保留说明!

上一篇:node文件批量重命名的方法示例(nodejs重命名文件)

下一篇:nodejs中安装ghost出错的原因及解决方法(nodejs ghost)

  • 外商投资企业要实缴资本么
  • 支付城镇土地使用税会计科目
  • 人力资源公司劳务外包
  • 个体户和公司的经营范围有区别吗
  • 办公费专票怎么做账
  • 发票遗失如何报销
  • 民间非营利性组织收到个税手续费返还
  • 营改增后还有企业所得税吗?
  • 公司销售家电并购案例
  • 个人独资公司需要报税吗
  • 车辆购置税多缴了能退吗
  • 电子设备税费
  • 发票冲红重开摘要如何写合适?
  • 出口发票税率是怎么算的
  • 固定资产清理增加记哪一方
  • 特殊销售方式下销售额的确定
  • 不含税的营业收入是什么意思
  • 基建账的年终结转
  • 电话费发票可以重新开吗
  • 小微企业季度所得税和企业所得税怎么处理
  • 小微企业减免所得税优惠政策
  • 会务费抵扣限额
  • 财务费用的借方和贷方
  • 企业购入新能源电车需要缴纳印花税吗
  • 小规模公司税控盘维护费会计分录
  • 主办会计工作主要做什么
  • 以前年度多计提的税金怎么调整
  • 个人二手车转让协议书免费
  • 公司的贷款过桥怎么办
  • win10怎么找应用程序
  • windows10什么时候上市
  • php数组函数输出《咏雪》里有多少"片"字
  • 准备金要求定义
  • 日本的萤火虫
  • 若依项目制作饼状图和柱状图
  • 企业所得税汇算清缴账务处理
  • 销售汇总怎么做分录
  • 预付装修费的会计处理分录
  • php实现base64图片上传方式实例代码
  • 建筑业预缴的个人所得税怎么在申报表体现
  • is not defined at HTMLInputElement.onclick
  • 应付票据帐务处理
  • 资产处置损益是什么类
  • phpcms v9安装教程
  • php自动压缩图片
  • 清卡操作流程
  • 没有发票的费用支出怎么入账
  • 员工食堂买菜账务流程
  • 进口货物如何支付外汇
  • PostgreSQL教程(十七):客户端命令(1)
  • 房屋租赁税缴纳时间
  • 收到住宿费普通发票会计分录
  • 收到成本发票如何记账
  • 建筑公司支付给农民工的工资需要取得发票吗
  • 这个营业外支出怎么算
  • 今年成立的公司需要申报残疾人保障金吗
  • 进项税转出补缴增值税 城建税及两费
  • 土地增值税怎么预交税款
  • 每月发票认证时间
  • 总资产周转率多少算正常
  • mysql双主复制
  • sqlserver索引类型区别
  • Ubuntu 12.04安装Xen常见问题及解决方法汇总
  • linux小技巧
  • unity判断点击ui
  • nodejs读取json文件,并返回列表
  • 数据库多表连接的几种方式
  • My Magic Android Tour —— 处女作
  • shell脚本编程100例
  • python运行py文件没反应
  • javascript 基础篇2 数据类型,语句,函数
  • jQuery ajax MD5实现用户注册即时验证功能
  • jquery 异步请求
  • 基于Android的人脸门禁系统
  • pythion
  • 关于草丛:单局游戏内
  • 成都高新区办理社保在哪里?
  • ca证书网上申请
  • 山东2022新生儿数量统计表
  • 注销的卡补回来还能恢复以前的套餐吗
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设