sentinel---滑动窗口的实现原理

这篇具有很好参考价值的文章主要介绍了sentinel---滑动窗口的实现原理。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

sentinel有多种规则,包括:降级、限流、热点等等规则,这些规则均会涉及到时间因素,既在单位时间内的请求量满足各种条件之后的各种动作。

这里我们一起来探针一下sentinel中滑动窗口的实现

sentinel---滑动窗口的实现原理,sentinel源码解析,sentinel

 如上是一个滑动窗口的示意图。

这里先不说sentinel中滑动窗口的实现代码,咱们想清楚一个问题,为后续阅读滑动窗口代码梳理清楚思路

 使用滑动窗口来解决什么问题?

我们使用滑动窗口是为了:统计在一个时间单位里面的数据

要统计一各时间单位,就涉及到时间单位的定义(是1秒还是100ms),统计数据,就需要一个容器来装载数据,同时为了避免在某个时间节点的数据激增,减少统计的误差,可能还需要把一个"单位时间"做更小的切分

涉及的类

com.alibaba.csp.sentinel.slots.statistic.base.LeapArray

LeapArray是sentinel中滑动时间窗口的基类,首先看下该类的类定义:

sentinel---滑动窗口的实现原理,sentinel源码解析,sentinel

 涉及到3个基本属性和一个引用类型

其中:windowLengthInMs、sampleCount、intervalInMs和我们上面说的单位时间和单位时间的切割有关系,array是用来存放数据的,既:单位时间内的数据存放容器

其中WindowWrap顾名思意:就是时间窗口数据的包装类

LeapArray的构造器:

sentinel---滑动窗口的实现原理,sentinel源码解析,sentinel

 看完如上两段之后,我们做如下假设:需要统计在1000ms内的数据,假设我们把1000ms这个单位时间分成两段,每段500ms,每段的数据存储在一个windowWrapper中

那当某个时间点,我们有个数据需要存储时:

1  需要计算出该时间节点属于哪个时间窗口(2个500ms的段)

2  需要计算出该时间节点的对应的是哪个windowWrap

以下两个方法就可以解决如上两个问题: 

sentinel---滑动窗口的实现原理,sentinel源码解析,sentinel

试想以下:当时间节点来到1001时:此时计算出来的start位置(calculateWindowStart方法计算结果)就是:1000,1002计算出的起始位置也是:1000。同时1001和1002计算出来数据落在数组的位置(calculateTimeIdx的结果)也是一样的,均是:0

由此不难看出,如上2个方法把我们需要的关键数据已经计算出来了:时间窗口的开始位置(因为窗口长度一样,结束位置肯定也是一样的),时间窗口对应的容器

所以,如果我们要获取当前时间节点的数据和在当前时间节点添加数据的计算方法:

sentinel---滑动窗口的实现原理,sentinel源码解析,sentinel

首先,计算出两个关键数据:容器下标:idx,时间窗口起始位置:windowStart

sentinel---滑动窗口的实现原理,sentinel源码解析,sentinel

 当从数据中去那容器数据时为空,创建新容器,存入数组。当然这里涉及到乐观锁的运用

sentinel---滑动窗口的实现原理,sentinel源码解析,sentinel

 当不为空,且当前时间和老容器的其实位置相同时:该事件节点和之前某次操作的时间差在500ms以内,使用同一个容器存储数据

sentinel---滑动窗口的实现原理,sentinel源码解析,sentinel

 如果当前时间节点比上次操作的时间节点超过了500ms(甚至更久),修改容器中的时间起始位置,重置容器的数据(涉及悲观锁的运用)

以上就是sentinel的滑动时间窗口的核心逻辑

当我们需要统计当前时间节点所在的1个单位时间内的数据时:

sentinel---滑动窗口的实现原理,sentinel源码解析,sentinel

 sentinel---滑动窗口的实现原理,sentinel源码解析,sentinel

也就是:当我们需要获取当前时间节点的数据时:直接读取数组中的数据,如果数组中的数据windowWrap的时间起点和当前时间的时间起点不超过intervalInMs(在一个时间单位中),就取出

当需要往容器中添加数据时:我们在LeayArray的子类(OccupiableBucketLeapArray)找到了实现:

sentinel---滑动窗口的实现原理,sentinel源码解析,sentinel

以上就是:sentinel的滑动时间窗口的实现核心逻辑文章来源地址https://www.toymoban.com/news/detail-634273.html

到了这里,关于sentinel---滑动窗口的实现原理的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • LeetCode 周赛 342(2023/04/23)容斥原理、计数排序、滑动窗口、子数组 GCB

    本文已收录到 AndroidFamily,技术和职场问题,请关注公众号 [彭旭锐] 提问。 大家好,我是小彭。 前天刚举办 2023 年力扣杯个人 SOLO 赛,昨天周赛就出了一场 Easy - Easy - Medium - Medium 的水场,不得不说 LeetCode 是懂礼数的 😁。 接下来,请你跟着小彭的思路,一步步将问题做难,

    2023年04月24日
    浏览(29)
  • 【华为OD机试真题 C++ Java Python】1、滑动窗口最大值 | 机试真题+思路参考+代码解析

    🍂个人博客首页: KJ.JK   🍂专栏介绍: 定期更新华为OD各个时间阶段的机试真题,每日定时更新,本专栏每篇的文章都会将使用C++、Python、Java三种语言进行更新解答,每个题目的思路分析都非常详细,超过百字欢迎大家订阅学习,代码可以直接运行使用 🎃题目描述 有一个

    2024年02月08日
    浏览(33)
  • Redis--Zset使用场景举例(滑动窗口实现限流)

    前言 在Redis–Zset的语法和使用场景举例(朋友圈点赞,排行榜)一文中,提及了redis数据结构zset的指令语法和一些使用场景,今天我们使用zset来实现滑动窗口限流,详见下文。 什么是滑动窗口 滑动窗口是一种流量控制策略,用于控制一定时间内请求的访问数量。 其原理是

    2024年01月19日
    浏览(44)
  • 基于 TiDB + Flink 实现的滑动窗口实时累计指标算法

    作者:李文杰 在不少的支付分析场景里,大部分累计值指标可以通过 T+n 的方式计算得到 。随着行业大环境由增量市场转为存量市场,产品的运营要求更加精细化、更快速反应,这对各项数据指标的实时性要求已经越来越高。产品如果能实时把握应用的整体运行情况或特征用

    2024年02月03日
    浏览(27)
  • 深入理解Java线程池ThreadPoolExcutor实现原理、数据结构和算法(源码解析)

    什么是线程池?         线程池主要是为了解决执行新任务执行时,应用程序为减少为任务创建一个新线程和任务执行完毕时销毁线程所带来的开销。通过线程池,可以在项目初始化时就创建一个线程集合,然后在需要执行新任务时重用这些线程而不是每次都新建一个线

    2024年02月07日
    浏览(34)
  • UE4 Unlua源码解析9 - 静态绑定和动态绑定的实现原理

    先说明白什么是静态绑定,什么是动态绑定 静态绑定就是继承了UnluaInterface的类,会在对象创建的时候绑定Lua对象 动态绑定就是没有继承UnluaInterface的类,会在Lua端通过\\\"NewObject\\\"和\\\"SpawnActor\\\"创建的时候,主动进行绑定 静态绑定 UE对象和Lua对象的时机在什么时候呢?就在UE对象

    2023年04月12日
    浏览(35)
  • 滑动窗口最大值 | 单调队列解题思路与实现,前 K 个高频元素

    学习LeetCode 239与347题目的解题思路与实现方法,包括单调队列与优先级队列(堆)的应用。掌握滑动窗口的最大值与前K个高频元素的解决方案。

    2024年02月13日
    浏览(34)
  • 精确掌控并发:滑动时间窗口算法在分布式环境下并发流量控制的设计与实现

    这是《百图解码支付系统设计与实现》专栏系列文章中的第(15)篇,也是流量控制系列的第(2)篇。点击上方关注,深入了解支付系统的方方面面。 上一篇介绍了固定时间窗口算法在支付渠道限流的应用以及使用redis实现的核心代码。 本篇重点讲清楚滑动时间窗口算法原理

    2024年01月22日
    浏览(48)
  • 255.【华为OD机试】最小矩阵宽度(滑动窗口算法-Java&Python&C++&JS实现)

    🚀点击这里可直接跳转到本专栏,可查阅顶置最新的华为OD机试宝典~ 本专栏所有题目均包含优质解题思路,高质量解题代码(JavaPythonC++JS分别实现),详细代码讲解,助你深入学习,深度掌握!

    2024年03月13日
    浏览(55)
  • SpringCloud Alibaba - Sentinel 高级玩法,修改 Sentinel-dashboard 源码,实现 push 模式

    目录 一、规则持久化 1.1、什么是规则持久化 1.1.1、使用背景 1.1.2、规则管理的三种模式 a)原始模式 b)pull 模式 c)push 模式 1.2、实现 push 模式 1.2.1、修改 order-service 服务,使其监听 Nacos 配置中心 1.2.2、修改 Sentinel-dashboard 源码,配置 nacos 数据源 1.2.3、修改 Sentinel-dashboard

    2024年02月07日
    浏览(26)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包