网站建设应列入啥费用,免费企业网站哪个好,学做花蛤的网站,手机自建网站sentinel有多种规则#xff0c;包括#xff1a;降级、限流、热点等等规则#xff0c;这些规则均会涉及到时间因素#xff0c;既在单位时间内的请求量满足各种条件之后的各种动作。
这里我们一起来探针一下sentinel中滑动窗口的实现 如上是一个滑动窗口的示意图。 这里先不…sentinel有多种规则包括降级、限流、热点等等规则这些规则均会涉及到时间因素既在单位时间内的请求量满足各种条件之后的各种动作。
这里我们一起来探针一下sentinel中滑动窗口的实现 如上是一个滑动窗口的示意图。 这里先不说sentinel中滑动窗口的实现代码咱们想清楚一个问题为后续阅读滑动窗口代码梳理清楚思路 使用滑动窗口来解决什么问题
我们使用滑动窗口是为了统计在一个时间单位里面的数据 要统计一各时间单位就涉及到时间单位的定义(是1秒还是100ms)统计数据就需要一个容器来装载数据同时为了避免在某个时间节点的数据激增减少统计的误差可能还需要把一个单位时间做更小的切分
涉及的类
com.alibaba.csp.sentinel.slots.statistic.base.LeapArray
LeapArray是sentinel中滑动时间窗口的基类首先看下该类的类定义 涉及到3个基本属性和一个引用类型
其中windowLengthInMs、sampleCount、intervalInMs和我们上面说的单位时间和单位时间的切割有关系array是用来存放数据有的既单位时间内的数据存放容器
其中WindowWrapper顾名思意就是时间窗口数据的包装类 LeapArray的构造器 看完如上两段之后我们做如下假设需要统计在1000ms内的数据假设我们把1000ms这个单位时间分成两段每段500ms每段的数据存储在一个windowWrapper中
那当某个时间点我们有个数据需要存储时
1 需要计算出该时间节点属于哪个时间窗口(2个500ms的段)
2 需要计算出该时间节点的对应的是哪个windowWrap 以下两个方法就可以解决如上两个问题 试想以下当时间节点来到1001时此时计算出来的start位置(calculateWindowStart方法计算结果)就是1000,1002计算出的起始位置也是1000。同时1001和1002计算出来数据落在数组的位置(calculateTimeIdx的结果)也是一样的均是0
由此不难看出如上2个方法把我们需要的关键数据已经计算出来了时间窗口的开始位置(因为窗口长度一样结束位置肯定也是一样的)时间窗口对应的容器 所以如果我们要获取当前时间节点的数据和在当前时间节点添加数据的计算方法 首先计算出两个关键数据容器下标idx,时间窗口起始位置windowStart 当从数据中去那容器数据时为空创建新容器存入数组。当然这里涉及到乐观锁的运用 当不为空且当前时间和老容器的其实位置相同时该事件节点和之前某次操作的时间差在500ms以内使用同一个容器存储数据 如果当前时间节点比上次操作的时间节点超过了500ms(甚至更久),修改容器中的时间起始位置重置容器的数据(涉及悲观锁的运用)
以上就是sentinel的滑动时间窗口的核心逻辑 当我们需要统计当前时间节点所在的1个单位时间内的数据时 也就是当我们需要获取当前时间节点的数据时直接读取数组中的数据如果数组中的数据windowWrap的时间起点和当前时间的时间起点不超过intervalInMs(在一个时间单位中)就取出 当需要往容器中添加数据时我们在LeayArray的子类(OccupiableBucketLeapArray)找到了实现 以上就是:sentinel的滑动时间窗口的实现核心逻辑
