sentinel核心流程源码解析

sentinel的处理槽(ProcessorSlot)

可以说,sentinel实现的各种功能就是由各处理槽完成的 ,ProcessorSlot定义了四个方法:

当进入该处理槽时触发该方法

处理完 entry方法之后触发该方法

退出该处理槽时触发该方法

exit方法处理完成时触发该方法

 sentinel的核心处理槽

 其中:FlowSlot是处理流控规则的处理槽,DegradeSlot是处理降级规则的处理槽。。。。以此类推

sentinel的处理槽链---DefaultProcessorSlotChain

 

从 DefaultProcessorSlotChain类继承图上和构造器上看,DefaultProcessorSlotChain使用装饰器模式在内部构造了一个AbstractLinkedProcessorSlot的单向链表

同时查看AbstractLinkedProcessorSlot的相关代码可以发现:

 AbstractLinkedProcessorSlot实现了两个fire方法,均是触发自身关联的下一个节点(Slot)的相关动作

以上是关于sentinel核心流程的最核心源码知识储备,有了以上基础之后,我们开始最核心的流程源码分析,请记住:sentinel的各种功能是由各个slot完成的,DefaultProcessorSlotChain是一个由AbstractLinkedProcessorSlot组成的单项链表,AbstractLinkednProcessorSlot的两个fire方法均是触发自身关联的下个slot的对应方法调用

sentinel的数据装载容器Node

看一下sentinel的Node类继承图:

 Node只有一个直接子类:StatisticNode,其他的node均是StatisticNode的直接子类或者间接子类

Node中定义了各种数据统计的接口方法:

 重头戏:StatisticNode

首先看一下类属性:

在StatisticNode中有2个关键的 ArrayMetric,是数据统计的关键

ArrayMetric的属性截图如下:

 ArrayMetric有个关键属性

LeapArray<MetricBucket> data = new OccupiableBucketLeapArray(sampleCount, intervalInMs);

这个在上一篇关于sentinel---滑动窗口的实现原理_昱宸星光的博客-CSDN博客有专门分析过。

所以到现在为止可以这样理解:

StatisticNode对象包含属性:ArrayMetric,而ArrayMetric对象包含:LeapArray<MetricBucket>对象,也就是说:StatisticNode可以通过LeapArray的滑动窗口数据统计特性完成数据收集,进而完成数据统计的功能

从一段简单的代码开始

以上代码就是sentinel实现限流的最简单的demo。源码分析就从这里开始:

FlowRule的类继承图:

 FlowRule定义的属性:

private int grade = RuleConstant.FLOW_GRADE_QPS; // 限流类型,默认是QPSprivate double count; // 限流阈值
private int strategy = RuleConstant.STRATEGY_DIRECT; // 限流策略 默认是直接抛异常

以上是几个关键的属性

FlowRuleManager#loadRules 做了哪些操作

 从类源码上看,FlowManager定义了一个Map,存储的是资源名和FlowRule列表的映射

还有一个FlowPropertyListener流控规则监听器

还有一个SentinelProperty对象,并且在SentinelProperty对象上添加了监听器FlowPropertyListener

SentinelProperty是DynamicSentinelProperty子类,DynamicSentinelProperty对象当属性变化时会调用监听器对象

所以:

当FlowManager#loadRules时,

 会调用DynamicSentinelProperty#updateValue

 最终会调用到FlowPropertyListener的ConfigUpdate方法完成规则的装载

 此时:flowRules会构建出一个:资源名和限流规则列表的映射map

SphU.entry("AddUser") 源码跟踪

 SphU#entry调用到Env.sph.entry

 相当于最终是由CtSph#entry完成功能,当然这里还有一段static静态代码块,静态代码块完成的功能等到后面再揭晓!继续往下

代码一路跟踪,最后到达:CtSph#entryWithPriority方法:

 

 从entryWithPriority方法看:

1 首先构造一个Context上下文

2 构建处理槽链

3 进入处理槽链处理逻辑

先看核心逻辑:构建处理槽链

通过SlotChainProvider#newSlotChain完成处理槽链的生成,然后放入到一个map中

SlotChainProvider#newSlotChain

 这里通过sentinel的SPI机制完成默认SlotChainBuilder的加载,默认情况下回返回:DefaultSlotChainBuilder的实例,最终会调用DefaultSlotChainBuilder#build会构建一个DefaultProcessorSlotChain返回,再前面的基础知识储备已经说过,DefaultProcessorSlotChain包含一个AbstractLinkedProcessSlot的单项链表,是后续sentinel各种功能的核心基础

 

通过调试,发现此时通过SPI机制,将各功能的Slot均实例化出来,形成一个单项链表

 到这里,sentinel的主流核心逻辑基本已经分析完毕。

即:通过SPI机制,将各功能的SLot构建成一个单向链表,后续在做请求时,依次经过该带向链表做各自规则的判断,如果触发相应的规则,就抛出:BlockException

 其中:FlowException、DegradeException、AuthorityException、SystemBlockException均是BlockException的子类

各Slot的核心功能源码分析

FlowSlot:流控规则处理槽

 是否限流委托给了checker#checkFlow做判断

最终的限流逻辑是交由: TrafficShapingController#canPass判断的

 这个TrafficShapingController是FlowRule里面的一个属性,在之前通过FlowRuleManager构建资源和规则列表时,有提到默认是创建的DefaultController类

查看DefaultController#canPass方法

 从代码逻辑上看,最核心的计算由方法avgUsedTokens(node)计算得出,而该方法既是取node中已有的数据?那node的数据又是从哪里来的呢?一路追踪,在之前的DefaultProcessorSlotChain中会构建一个slot链表,其中有个StatisticSlot。这个slot就是专门做数据统计的,看下StatisticSlot

的代码:

 StatisticSlot是一个关于统计的slot,先触发后续slot的调用,如果能成功返回到该方法,说明后续的处理没有抛出异常,就把成功数和总数都+count,如果在后续的slot处理过程中抛出异常,会被该slot捕获,根据捕获的异常不同做不同的逻辑处理

 到这里,似乎sentinel限流、降级、熔断等功能的实现逻辑都已经完全梳理清楚了。但是:

有个疑问:不管是限流还是降级熔断等,均是在一个时间段内统计数据,而StatisticSlot在统计的时候是通过node加数据完成的,那node和时间单位是怎么联系起来的?换句话说:StatisticSlot里面的node是怎么做到在把数据按照单位时间统计的,而且后续代码在取数据时也是取到该时间单位内的数据的?

在上面说DefaultProcessorSlotChain时,忽略了部分细节,通过调试,我们发现构建的DefaultProcessorSlotChain的单向链表的顺序是:

1 NodeSelectorSlot   2 ClusterBuilderSlot  3 StatisticSlot  4 AuthoritySlot 

5 SystemSlot  6 FlowSlot  7 DegradeSlot 

跟踪代码调用逻辑,在StatisticSlot中通过node.pass()统计通过的数据,而此处的Node是ClusterNode,而ClusterNode是StatisticNode的直接子类。在上面的基础知识储备中有提到:StatisticNode通过属性ArrayMetric->LeapArray完成滑动窗口统计数据。换句话说:StatisticSlot通过StatisticNode完成滑动窗口统计数据,包括:通过数据,异常数据,总数据等等

至此:流控规则的完整调用链路,逻辑已全部梳理完成

sentinel通过构建DefaultProcessorSlotChain将全部的slot组装成一个单项链表,链表顺序是:

NodeSelectorSlot --》ClusterBuilderSlot -》StatisticSlot -》AuthoritySlot 

-》SystemSlot-》FlowSlot-》DegradeSlot

在FlowSlot中处理限流逻辑,限流是通过Slot中的StatisticNode做滑动窗口计数统计完成。而计数统计发生在StatisticSlot中 

以上就是通过分析限流规则梳理的Sentinel的核心流程,在此过程中还遗留了不少细节方面的未关注处理。

如果感兴趣的同学可以自行跟踪DegradSlot的处理流程完成降级规则的处理逻辑梳理

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

【MySQL安装】卸载与安装MySQL 5.7.X版本

最近由于各种原因&#xff0c;需要重新安装MySQL。之前我的版本是8.0版本&#xff0c;现在装的5.7版本。记录一下自己的安装过程。 目录 1、卸载MySQL8.0 2、安装MySQL5.7 1、卸载MySQL8.0 如何彻底卸载MySQL_mysql 完全卸载_m0小麦麦的博客-CSDN博客相信不少小伙伴们在安装…

ddia(3)----Chapter3. Storage and Retrieval

However, first we’ll start this chapter by talking about storage engines that are used in the kinds of databases that you’re probably familiar with: traditional relational databases, and also most so-called NoSQL databases. We will examine two families o…

捕捉时刻:将PDF文件中的图像提取为个性化的瑰宝(从pdf提取图像)

应用场景&#xff1a; 该功能的用途是从PDF文件中提取图像。这在以下情况下可能会很有用&#xff1a; 图片提取和转换&#xff1a;可能需要将PDF文件中的图像提取出来&#xff0c;并保存为单独的图像文件&#xff0c;以便在其他应用程序中使用或进行进一步处理。例如&#xff…

pdf怎么压缩到1m?这样做压缩率高!

PDF是目前使用率比较高的一种文档格式&#xff0c;因为它具有很高的安全性&#xff0c;还易于传输等&#xff0c;但有时候当文件体积过大时&#xff0c;会给我们带来不便&#xff0c;这时候简单的解决方法就是将其压缩变小。 想要将PDF文件压缩到1M&#xff0c;也要根据具体的情…

QGIS开发五:VS使用QT插件创建UI界面

前面我们说了在创建项目时创建的是一个空项目&#xff0c;即不使用 Qt 提供的综合开发套件 Qt Creator&#xff0c;也不使用 Qt Visual Studio Tools 这类工具。 但是后面发现&#xff0c;如果我想要有更加满意的界面布局&#xff0c;还是要自己写一个UI文件&#xff0c;如果不…

世微AP2400 电动车 摩托车灯照明 汽车灯照明 手电筒照明LED灯降压恒流驱动IC

PCB 布板参考 1. 大电流路径走线要粗&#xff0c;铺铜走线比较好。 2. 大电路回路面积以最短、最宽路径完成比较好。 3. 开关切换连接点&#xff1a;电感 L、开关管漏级与续流肖特基二极管&#xff0c;走线要短与粗&#xff0c;铺铜走线比较好&#xff0c;但同时需要适当面积作…

MySQL索引3——Explain关键字和索引使用规则(SQL提示、索引失效、最左前缀法则)

目录 Explain关键字 索引性能分析 Id ——select的查询序列号 Select_type——select查询的类型 Table——表名称 Type——select的连接类型 Possible_key ——显示可能应用在这张表的索引 Key——实际用到的索引 Key_len——实际索引使用到的字节数 Ref ——索引命…

机器学习深度学习——注意力提示、注意力池化(核回归)

&#x1f468;‍&#x1f393;作者简介&#xff1a;一位即将上大四&#xff0c;正专攻机器学习的保研er &#x1f30c;上期文章&#xff1a;机器学习&&深度学习——常见循环神经网络结构&#xff08;RNN、LSTM、GRU&#xff09; &#x1f4da;订阅专栏&#xff1a;机器…

SqlServer基础之(触发器)

概念&#xff1a; 触发器&#xff08;trigger&#xff09;是SQL server 提供给程序员和数据分析员来保证数据完整性的一种方法&#xff0c;它是与表事件相关的特殊的存储过程&#xff0c;它的执行不是由程序调用&#xff0c;也不是手工启动&#xff0c;而是由事件来触发&#x…

JVM G1垃圾回收机制介绍

G1(Garbage First)收集器 (标记-整理算法)&#xff1a; Java堆并行收集器&#xff0c;G1收集器是JDK1.7提供的一个新收集器&#xff0c;G1收集器基于“标记-整理”算法实现&#xff0c;也就是说不会产生内存碎片。此外&#xff0c;G1收集器不同于之前的收集器的一个重要特点是&…

钓鱼攻击:相似域名识别及如何有效预防攻击

网络犯罪分子很乐意劫持目标公司或其供应商或业务合作伙伴的官方域名&#xff0c;但在攻击的早期阶段&#xff0c;他们通常没有这种选择。相反&#xff0c;在有针对性的攻击之前&#xff0c;他们会注册一个与受害组织的域名相似的域名 - 他们希望您不会发现其中的差异。此类技术…

SpringBoot 的自动装配特性

1. Spring Boot 的自动装配特性 Spring Boot 的自动装配&#xff08;Auto-Configuration&#xff09;是一种特性&#xff0c;它允许您在应用程序中使用默认配置来自动配置 Spring Framework 的各种功能和组件&#xff0c;从而减少了繁琐的配置工作。通过自动装配&#xff0c;您…

TepeScript 问题记录

问题 对object的所有属性赋值或清空&#xff0c;提示类型错误不能赋值 type VoiceParams {_id?: string | undefined;name: string;sex: string;vc_id: string;model_url: string;preview_url: string;isPrivate: boolean;visible: boolean; }const formData reactive<V…

【Minecraft】Fabric Mod开发完整流程2 - 创造模式物品栏与第一个方块

创造模式物品栏 添加到当前已有物品栏 再添加自定义的创造模式物品栏之前&#xff0c;请确保你的确有这个需求&#xff01;否则建议直接添加到当前已有的物品栏内部 创建新文件&#xff1a;com/example/item/ModItemGroup.java package com.example.item;import net.fabricmc.…

出于网络安全考虑,印度启用本土操作系统”玛雅“取代Windows

据《印度教徒报》报道&#xff0c;印度将放弃微软系统&#xff0c;选择新的操作系统和端点检测与保护系统。 备受期待的 "玛雅操作系统 "将很快用于印度国防部的数字领域&#xff0c;而新的端点检测和保护系统 "Chakravyuh "也将一起面世。 不过&#xf…

2024考研408-计算机网络 第五章-传输层学习笔记

文章目录 前言一、传输层提供的服务1.1、传输层的功能1.2、传输层的两个协议&#xff08;TCP、UDP&#xff09;1.3、传输层的寻址与端口&#xff08;常见端口介绍&#xff09; 二、UDP协议2.1、认识UDP功能和特点2.2、UDP首部格式2.3、UDP伪首部字段分析2.4、伪首部校验UDP用户…

【24择校指南】南京大学计算机考研考情分析

南京大学(A) 考研难度&#xff08;☆☆☆☆☆&#xff09; 内容&#xff1a;23考情概况&#xff08;拟录取和复试分数人数统计&#xff09;、院校概况、23初试科目、23复试详情、参考书目、各科目考情分析、各专业考情分析。 正文2178字&#xff0c;预计阅读&#xff1a;6分…

网络原理(JavaEE初阶系列11)

目录 前言&#xff1a; 1.网络原理的理解 2.应用层 2.1自定义协议的约定 2.1.1确定要传输的信息 2.1.2确定数据的格式 3.传输层 3.1UDP 3.1.1UDP报文格式 3.2TCP 3.2.1确认应答 3.2.2超时重传 3.2.3连接管理 3.2.3.1三次握手 3.2.3.2四次挥手 3.2.4滑动窗口 3.…

【JavaEE】Spring Boot - 配置文件

【JavaEE】Spring Boot 开发要点总结&#xff08;2&#xff09; 文章目录 【JavaEE】Spring Boot 开发要点总结&#xff08;2&#xff09;1. 配置文件的两种格式2. .properties 文件2.1 基本语法2.2 注释2.3 配置项2.4 主动读取配置文件的键值2.5 数据库的连接时的需要的信息配…

ChatGPT访问流量下降的原因分析

​自从OpenAI的ChatGPT于11月问世以来&#xff0c;这款聪明的人工智能聊天机器人就席卷了全世界&#xff0c;人们在试用该工具的同时也好奇该技术到底将如何改变我们的工作和生活。 但近期Similarweb表示&#xff0c;自去ChatGPT上线以来&#xff0c;该网站的访问量首次出现下…