聊聊限流的一些事儿

一、背景

最近几年,随着微服务的流行,服务与服务之间依赖越来越强,调用也越来越复杂,服务间的稳定性变突显出来。特别是在遇到突发请求时,常常需要通过缓存、限流、熔断降级、负载均衡等多种方式保证服务的稳定性。其中限流是不可或缺的一环。一般每一个对外提供的接口都需要做流量控制,这与保险丝的原理一样。当接口的流量请求超过核定值时就得对请求进行引流或者直接拒绝等操作。特别是在系统应对大流量,高并发的访问时,限流算法可以很好地控制流量,从而避免系统负载过高而崩溃。

二、限流算法

下面介绍的限流方式主要是窗口算法和桶算法,各有优势。

  • 窗口算法实现简单,逻辑清晰,可以很直观的得到当前的 QPS 情况,但是会有时间窗口的临界突变问题,而且不像桶一样有队列可以缓冲;另外,在细粒度上难以对流量曲线进行调整,即不能实现削峰填谷的效果,这可能对某些需要平滑流量的场景造成问题。限流简单暴力,对于C端产品来说,这可能不是一种友好的选择。
  • 桶算法虽然稍微复杂,不好统计 QPS 情况,但是桶算法也有优势所在。
    • 漏桶模式消费速率恒定,可以很好的保护自身系统,可以对流量进行整形,但是面对突发流量不能快速响应。应用场景:自身服务调用第三方服务时,第三方服务需要我们来限制速度。
    • 令牌桶模式可以面对突发流量,但是启动时会有缓慢加速的过程,不过常见的开源工具中已经对此优化。应用场景:别人调用自身服务时可以使用(毕竟对自身服务qps有一定的了解)。

限流算法

原理

优点

缺点

使用场景

流量整形

处理延时

滑动窗口

窗口在时间轴上滑动,记录请求次数

实时控制,流量较均匀

难以实现流量曲线整形,无法削峰填谷

单机或单点网关限流

漏桶

流入请求如水流入桶,满则丢弃

能够控制突发流量(主要看容量)

流出速率恒定,对突发流量反应不够快速

瞬时高并发流量场景或调第三方服务

令牌桶

以一定速率产生令牌,请求需拿令牌

可动态调整处理速度,允许突发流量在一定程序上得到满足

实现复杂,以及令牌的数量控制

别人调用自身服务控制量级

2.1 漏桶算法

漏桶算法主要目的是控制请求速率,平滑网络上的突发流量。如上图示例,固定速率流出请求,流入请求速率任意,请求是否被处理看桶中的令牌是否足够。它常用于限制网络流量、控制数据传输率等场景,但是无法应用突发的高流量。

JSF不使用此类算法的原因:

1、由于漏桶出口速度固定,不能灵活应对后端能力的提升,如后端服务动态扩容后,漏桶没有办法。

2、无法有效利用资源,服务器处理能力并不是均衡绝对的,即任意时间都是固定的,如服务处理能力为1kqps,可能前6s为2k,后面时间为500,即一小段时间服务器资源是可以承受这段请求压力的,但是漏桶算法在这种情况下会丢弃一部分请求。

2.2 令牌桶算法

令牌桶算法是另一种经典的限流算法,它的原理是将请求放入一个令牌桶中。然后按照一定速度不断地放出令牌。只有在令牌桶中有令牌时,才能够发出令牌。令牌桶算法可以控制单位时间内的请求速率,同时可以应对突发流量(累积令牌)如后端能力的提升,因为只有在足够多的令牌,才可以放请求过去。

这里思考一个问题,令牌是如何添加的?如果按照指定时间间隔添加令牌,则需要开一个线程去定时添加,当有多个接口需要限流时,线程数就会随之增加,这显然不是一个好的办法。在Guava的RateLimiter是这样做的——每次令牌获取时计算令牌是否足够:它通过存储的下一个令牌生成的时间,和当前获取令牌的时间差,再结合阈值,去计算令牌是否足够,同时再记录下一个令牌的生成时间以便下一次调用。

下面是 Guava 中 RateLimiter 类的子类 SmoothRateLimiter 的resync()方法的代码分析,可以看到其中的令牌计算逻辑。

void resync(long nowMicros) { // 当前微秒时间// 当前时间是否大于下一个令牌生成时间if (nowMicros > this.nextFreeTicketMicros) { // 可生成的令牌数 newPermits = (当前时间 - 下一个令牌生成时间)/ 令牌生成时间间隔。// 如果 QPS 为2,这里的 coolDownIntervalMicros 就是 500000.0 微秒(500ms)doublenewPermits= (double)(nowMicros - this.nextFreeTicketMicros) / this.coolDownIntervalMicros();// 更新令牌库存 storedPermits。this.storedPermits = Math.min(this.maxPermits, this.storedPermits + newPermits);// 更新下一个令牌生成时间 nextFreeTicketMicrosthis.nextFreeTicketMicros = nowMicros;}
}

2.3 滑动窗口限流

滑动窗口限流将单位时间周期分为n个小周期,分别记录每个小周期内接口的访问次数,并且根据时间滑动删除过期的小周期,每个小周期都有自己独立的计数器。

当滑动窗口的格子周期划分的越多,滑动窗口滚动就越平滑。滑动窗口算法虽然解决了固定窗口的临界问题,但一旦达到限流后,请求都会直接暴力被拒绝的。对于C端产品来说,这可能不是一种友好的选择。

三、解决方案

在介绍完目前主流的限流算法及其优缺点之后,让我们探讨一个实际场景:接口提供方已设定限流策略(限流算法为令牌桶算法),而接口调用方在整点前后实施了降级措施(暂不考虑降级是否必要)。在降级恢复时,我们注意到突发流量在第一秒内超过了预设的限流阈值。

前面已经对令牌桶算法有了深入的讲解,这里超出限流阈值的原因就不在过多介绍,接下来讲讲解决方案。

3.1 计算阈值

限流阈值再怎么设置,总会出现由于所有请求都是消耗资源很多的请求可能导致应用承受不住负载而崩溃。那如何计算阈值呢?总体上思路有几个,看服务的观测数据、借鉴、手动计算、压测。

看服务的性能数据属于常规解法,如基于完善的监控查看峰值期间的QPS。不过我个人觉得,最好的方式应该是线上执行全链路压测,选择响应时间稳定不变对应的压测QPS。

尽管设置了限流阈值,但仍然可能出现由于所有请求都消耗大量资源而导致应用负载过高并崩溃的情况。针对这种情况,我们可以采用以下几种方法来计算阈值:

  1. 借鉴:参考类似服务的阈值设置经验。
  2. 手动计算:根据业务需求和预期负载进行估算。
  3. 线上执行全链路压测:这是最理想的解决方案,通过选择响应时间稳定不变的压测QPS,能够更准确地评估系统的承载能力。

当然,基于完善的监控系统观察服务的性能数据也是常规的解决方法,例如查看峰值期间的QPS。然而,我认为线上执行全链路压测是最佳的选择,因为它能直接模拟真实环境下的负载情况,从而得出更加精确的阈值。

3.2 选择限流算法

选择适当的限流算法需要根据具体的应用场景和需求进行评估。例如,对于注重历史流量参考价值的场景,滑动窗口算法可能更为适用;而对于需要平滑流量的场景,则更适合使用漏桶算法;而对于既要平滑流量又需要处理突发流量的场景,令牌桶算法则可能是最佳选择。

对于上面提供的场景,令牌桶算法与滑动窗口算法都是可选择的,只不过前者需要自身应用应对突发流量,而后者在流量超出最大阈值时直接拒绝。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/bicheng/21943.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

C++命名空间(详解)

C基础语法 C基于C语言的改进:c在C语言的基础上引入并扩充了面向对象的概念 C基础概念:C是基于C语言而产生的,它即可以进行C语言的过程化程序设计,又可以进行以抽象数据类型为特点的基于对象的程序设计,还可以进行面向对象的程序设计 在1998年 出现C98…

爱普生差分晶振在光模块中的重要角色

光模块是现代通信设备中的重要组成部分,主要用于实现光电转换和信号传输,它是一种将光信号转换为电信号,或者将电信号转换为光信号的设备。在光纤通信中,光模块扮演着至关重要的角色。 光模块的主要组成部分包括光源、光接收器、…

OSPF学习笔记(状态机)

1、邻居关系 OSPF设备启动后,会通过OSPF接口向外发送Hello报文,收到Hello报文的OSPF设备会检查报文中所定义的参数,如果双方一致就会形成邻居关系,两端设备互为邻居 2、邻接关系 形成邻居关系后,如果两端设备成功交…

【代码随想录】【算法训练营】【第27天】 [39]组合总和 [40] 组合总和II [131]分割回文串

前言 思路及算法思维,指路 代码随想录。 题目来自 LeetCode。 day26, 休息的周末~ day 27,周一,库存没了,哭死~ 题目详情 [39] 组合总和 题目描述 39 组合总和 解题思路 前提:组合的子集问题&…

C# :IQueryable IEnumerable

文章目录 1. IEnumerable2. IQueryable3. LINQ to SQL4. IEnumerable & IQueryable4.1 Expression4.2 Provider 1. IEnumerable namespace System.Collections: public interface IEnumerable {public IEnumerator GetEnumerator (); }public interface IEnumerator {pubi…

气泡式水位计施工技术要求

1、气泡式水位计压力气管出气口应安装并固定在最低水位处,其压力气管也应固定,有条件的可用金属管或塑料管保护。气泡式水位计安装示意图见附图。 2、安装要求 1)检查气泡式水位计气管外观有无破损及变形; 2)旋开带有…

特征工程技巧—Bert

前段时间在参加比赛,发现有一些比赛上公开的代码,其中的数据预处理步骤值得我们参考。 平常我们见到的都是数据预处理,现在我们来讲一下特征工程跟数据预处理的区别。 数据预处理是指对原始数据进行清洗、转换、缩放等操作,以便为…

Blackwell未来发展之路究竟如何?

英伟达Blackwell如何重塑AI计算的未来? 前言 台湾大学演讲 就在6月2日,英伟达CEO黄仁勋在中国台湾大学综合体育馆发表了最新的演讲。这次黄仁勋的演讲依旧重磅,更值得注意的是这次演讲中还透露了Blackwell今后的发展之路。 介绍Blackwell 介绍…

MongoDB CRUD操作:地理位置查询

MongoDB CRUD操作:地理位置查询 文章目录 MongoDB CRUD操作:地理位置查询地理空间数据GeoJSON对象传统坐标对通过数组指定(首选)通过嵌入文档指定 地理空间索引2dsphere2d 地理空间查询地理空间查询运算符地理空间聚合阶段 地理空…

拿笔记下来!产品采购制造类合同怎样写比较稳妥?

拿笔记下来!产品采购制造类合同怎样写比较稳妥? 近日,几经波折,泰中两国终于完成了潜艇采购谈判!你知道吗?产品制造类合同或协议在起草前如果没有充分考虑各种因素,可能会导致一系列问题和不利…

C语言学习:数据类型

一、 为什么要引入数据类型 • 计算机中每个字节都有一个地址(类似门牌号) • CPU通过 地址 来访问这个字节的空间 0x20001103 1 0 0 1 0 0 1 1 0x20001102 1 1 1 0 1 1 1 0 0x20001101 1 1 1 1 0 1 0 1 0x20001100 0 …

无人监控视频输出卡顿状态

设计思路,如下: 1.通过采集卡将视频信号输出到个人PC中 2.PC按设置好的时间,视频属性分片保存 3.将步骤2中的视频,按预处理要求,得到待计算的视频片段 4.使用SSIM算法计算预处理后的视频,将计算得到的数据存…

聊天机器人的实践过程

一、语聊机器人 OpenAI 的爆火,到如今也才一年多的时间,然而在过去的一年中,生成式AI的落地场景几乎 80%都是 ChatBot 的形式,那么今天这篇文章我们就来聊一下,生成式AI和IM能擦出怎么样的火花?以及各种场…

p13idea的其他操作

1 导入模块 错误示范: 正确示范: 2 删除模块 必须用delete才能删除干净,用remove删了之后还要回到文件里面把它删除掉

有钱还系统源码 人人还众筹还钱模式还贷系统源码

盈利模式: 1.系统里直推400 2.间推得200 3.升级是隔代匹配200 4.漏单直接设置归系统 5.九级匹配不到直接归平台 有钱还平台新注册会员,即新入的负债者要分9次分别资助先来的11名负债者每人200元,这笔资助不是一次性给到对方&#xff0c…

Mybatis的一级缓存

缓存 MyBatis 包含一个非常强大的查询缓存特性,它可以非常方便地配置和定制。MyBatis 3 中的缓存实现的很多改进都已经实现了,使得它更加强大而且易于配置。 Mybatis和Hibernate一样,也有一级和二级缓存,同样默认开启的只有一级缓存,二级缓…

脑部磁共振成像肿瘤分割方法(MATLAB 2018)

近年脑肿瘤发病率呈上升趋势,约占全身肿瘤的5%,占儿童肿瘤的70%。CT、MRI等多种影像检查方法可用于检测脑肿瘤,其中MRI应用于脑肿瘤成像效果最佳。精准的脑肿瘤分割是病情诊断、手术规划及后期治疗的必备条件,既往研究者对脑部肿瘤…

Python知识点12---Python的I/O操作

提前说一点:如果你是专注于Python开发,那么本系列知识点只是带你入个门再详细的开发点就要去看其他资料了,而如果你和作者一样只是操作其他技术的Python API那就足够了。 Python的流(I/O)操作,最简单的其实就是输入和输出&#x…

工厂的精益生产如此重要

什么是工厂的精益生产 精益生产(Lean Manufacturing)是一种起源于20世纪50年代日本丰田汽车公司的生产管理哲学。它的核心理念是通过消除生产过程中的浪费,优化流程,提高效率,从而实现成本降低和质量提升。精益生产不仅…

VRTK4.0学习——(二)

手柄绑定以及显示 1.导入CameraRigs.UnityXRPluginFramework 和 CameraRigs.TrackedAlias 预设,将CameraRigs.UnityXRPluginFramework拖入CameraRigs.TrackedAlias的Elements中即可,运行软件后即可看到手柄了 注:如果无法看到手柄&#xff…