流控神器Sentinel指南:浅析Sentinel中的抽象概念

2024-03-28 15:38

本文主要是介绍流控神器Sentinel指南:浅析Sentinel中的抽象概念,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

上篇文章中介绍了Sentinel的一些使用方式,从这篇文章开始叙述Sentinel的一些高级用法和底层的实现原理。

1. Sentinel中的抽象概念

解读源码之前我们需要认识Sentinel中的抽象概念。比较重要的概念为:Resource、Entry、Solt、Rule、context、Node、Metric等

下面我们一一分析

2 Resource

资源可以是任何东西,比如一段代码,一个方法。通常用以NAME来区分别的资源。在sentinel中具体表示资源的类是:ResourceWrapper类图如下:

sentinel

ResourceWrapper 有两个属性,name标识了唯一性,而entryType标识该资源被访问的类型。
即标识资源是入站或出站方法。 这用于标记在系统不稳定时是否可以阻止它,SystemRule只可以阻止入站流量。

它有两个实现类,分别是:StringResourceWrapperMethodResourceWrapper,前者和ResourceWrapper基本没区别,后者稍微有点不同,它多一个Method
字段,它其实表示对一个方法资源的包装。我们看一下的它的构造方法就明白了:

public MethodResourceWrapper(Method method, EntryType type) {this.method = method;// 通过反射获取到一个方法的唯一名称,重载/重写的的方法获取的结果不同this.name = MethodUtil.getMethodName(method);this.type = type;
}
3. Entry

代表一次对资源的访问,每访问一个资源都会创建一个Entry。每次执行 SphU.entry()都会返回一个Entry给调用者。如果发生限流抛出BlockExcetion,SphO.entry()的返回值是true/flase。
Entry的类图如下:

sentinel

Eentry中保存了本次执行访问资源的一些基本信息,包括:

  • createTime:当前Entry的创建时间,主要用来后期计算rt
  • curNode:当前Entry所关联的node,该node主要是记录了当前context下该资源的统计信息
  • originNode:当前Entry的调用来源,通常是调用方的应用名称,在ClusterBuilderSlot.entry()方法中设置的
  • resourceWrapper:当前Entry访问的资源

当在一个上下文中多次调用了SphU.entry()方法时,就会创建一棵树,节点之间是通过parent和child关系维持的。

前面所说的一个上下文指比较抽象,看下面代码:

ContextUtil.enter("entrance1", "appA");Entry entry = SphU.entry("resource1");if (entry != null) {entry.exit();}ContextUtil.exit();

ContextUtil.enter() 创建了一个名为 entrance1 的上下文,同时指定调用发起者为 appA;接着通过 SphU.entry()请求资源。代码将在内存中生成以下结构:

     machine-root//EntranceNode1()//DefaultNode(entry)
4. Context

上一小节提到了上下文。Context即上下文,一个上下文只能通过两种方式创建,一是暴露出来的ContextUtil.enter() 方式,而是内部ContextUtil的一个子类创建,这是默认的内部创建方式,为一次访问资源创建上下文。Context是保存在ThradLocal中。可以把Conetext理解当一次访问资源的过程。Context中维护着当前调用链的元数据。属性如下:

    // Context nameprivate final String name;// 当前调用链的入口节点,即最外层的entryprivate DefaultNode entranceNode;// 调用链的当前节点private Entry curEntry;// 当前调用链的调用源private String origin = "";
5. Node

node中保存了资源的实时统计数据,如:passQps,blockQps,rt等实时数据。正是有了这些统计数据后,sentinel才能进行限流、降级等一系列的操作。

sentinel

entranceNode是每个上下文的入口,该节点是直接挂在root下的,是全局唯一的,跟entry没有关系,内部自动生成的。每一个context都会对应一个entranceNode,当然多个context可能对应一个相同的entranceNode。如果没有使用ContextUtil.enter("entrancexxx", "appA");,则context会指向默认的第一个entranceNode。

defaultNode是记录某一个资源调用的实时数据的,entry的curNode指向一个defaultNode。一个资源可能有被多个defaultNode关联。每个defaultNode都关联着一个资源和clusterNode,有着相同资源的defaultNode关联着同一个clusterNode。
关系图如下:
sentienl

6. Slot

slot为“插槽”的意思,显然它会有多个,Sentinel中的功能是通过每一个插槽来实现的。槽对应的接口为ProcessorSlot,多个槽通过链表来连接。这个链表称为ProcessorSlotChain。
槽的多个实现有,摘一段初始化代码:

public class DefaultSlotChainBuilder implements SlotChainBuilder {@Overridepublic ProcessorSlotChain build() {ProcessorSlotChain chain = new DefaultProcessorSlotChain();chain.addLast(new NodeSelectorSlot());chain.addLast(new ClusterBuilderSlot());chain.addLast(new LogSlot());chain.addLast(new StatisticSlot());chain.addLast(new SystemSlot());chain.addLast(new AuthoritySlot());chain.addLast(new FlowSlot());chain.addLast(new DegradeSlot());return chain;}
}

Sentinel内部帮我们已经添加好了,并且顺序固定。这些插槽有不同的职责:

  • NodeSelectorSlot 负责收集资源的路径,并将这些资源的调用路径,以树状结构存储起来,用于根据调用路径来限流降级;
  • ClusterBuilderSlot 则用于存储资源的统计信息以及调用者信息,例如该资源的 RT, QPS, thread count 等等,这些信息将用作为多维度限流,降级的依据;
  • StatisticSlot 则用于记录、统计不同纬度的 runtime 指标监控信息;
  • FlowSlot 则用于根据预设的限流规则以及前面 slot 统计的状态,来进行流量控制;
  • AuthoritySlot 则根据配置的黑白名单和调用来源信息,来做黑白名单控制;
  • DegradeSlot 则通过统计信息以及预设的规则,来做熔断降级;
  • SystemSlot 则通过系统的状态,例如 load1 等,来控制总的入口流量;
7. Metric

metric是sentinel中用来进行实时数据统计的度量接口,node就是通过metric来进行数据统计的。

8. Rule

Sentinel有流量控制规则、熔断降级规则、系统保护规则 以及授权规则。类图如下:
sentinel
每种规则都有对应的管理工具类,比如DegradeRuleManager.loadRules(rules)将降级规则加载到内存。

Sentinel中相对抽象的概念基本就是以上这些,这些基本知识对深入解读底层原理至关重要。

这篇关于流控神器Sentinel指南:浅析Sentinel中的抽象概念的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/856011

相关文章

浅析Rust多线程中如何安全的使用变量

《浅析Rust多线程中如何安全的使用变量》这篇文章主要为大家详细介绍了Rust如何在线程的闭包中安全的使用变量,包括共享变量和修改变量,文中的示例代码讲解详细,有需要的小伙伴可以参考下... 目录1. 向线程传递变量2. 多线程共享变量引用3. 多线程中修改变量4. 总结在Rust语言中,一个既引人入胜又可

Python使用qrcode库实现生成二维码的操作指南

《Python使用qrcode库实现生成二维码的操作指南》二维码是一种广泛使用的二维条码,因其高效的数据存储能力和易于扫描的特点,广泛应用于支付、身份验证、营销推广等领域,Pythonqrcode库是... 目录一、安装 python qrcode 库二、基本使用方法1. 生成简单二维码2. 生成带 Log

高效管理你的Linux系统: Debian操作系统常用命令指南

《高效管理你的Linux系统:Debian操作系统常用命令指南》在Debian操作系统中,了解和掌握常用命令对于提高工作效率和系统管理至关重要,本文将详细介绍Debian的常用命令,帮助读者更好地使... Debian是一个流行的linux发行版,它以其稳定性、强大的软件包管理和丰富的社区资源而闻名。在使用

Ubuntu系统怎么安装Warp? 新一代AI 终端神器安装使用方法

《Ubuntu系统怎么安装Warp?新一代AI终端神器安装使用方法》Warp是一款使用Rust开发的现代化AI终端工具,该怎么再Ubuntu系统中安装使用呢?下面我们就来看看详细教程... Warp Terminal 是一款使用 Rust 开发的现代化「AI 终端」工具。最初它只支持 MACOS,但在 20

macOS怎么轻松更换App图标? Mac电脑图标更换指南

《macOS怎么轻松更换App图标?Mac电脑图标更换指南》想要给你的Mac电脑按照自己的喜好来更换App图标?其实非常简单,只需要两步就能搞定,下面我来详细讲解一下... 虽然 MACOS 的个性化定制选项已经「缩水」,不如早期版本那么丰富,www.chinasem.cn但我们仍然可以按照自己的喜好来更换

Python使用Pandas库将Excel数据叠加生成新DataFrame的操作指南

《Python使用Pandas库将Excel数据叠加生成新DataFrame的操作指南》在日常数据处理工作中,我们经常需要将不同Excel文档中的数据整合到一个新的DataFrame中,以便进行进一步... 目录一、准备工作二、读取Excel文件三、数据叠加四、处理重复数据(可选)五、保存新DataFram

使用JavaScript将PDF页面中的标注扁平化的操作指南

《使用JavaScript将PDF页面中的标注扁平化的操作指南》扁平化(flatten)操作可以将标注作为矢量图形包含在PDF页面的内容中,使其不可编辑,DynamsoftDocumentViewer... 目录使用Dynamsoft Document Viewer打开一个PDF文件并启用标注添加功能扁平化

电脑显示hdmi无信号怎么办? 电脑显示器无信号的终极解决指南

《电脑显示hdmi无信号怎么办?电脑显示器无信号的终极解决指南》HDMI无信号的问题却让人头疼不已,遇到这种情况该怎么办?针对这种情况,我们可以采取一系列步骤来逐一排查并解决问题,以下是详细的方法... 无论你是试图为笔记本电脑设置多个显示器还是使用外部显示器,都可能会弹出“无HDMI信号”错误。此消息可能

如何安装 Ubuntu 24.04 LTS 桌面版或服务器? Ubuntu安装指南

《如何安装Ubuntu24.04LTS桌面版或服务器?Ubuntu安装指南》对于我们程序员来说,有一个好用的操作系统、好的编程环境也是很重要,如何安装Ubuntu24.04LTS桌面... Ubuntu 24.04 LTS,代号 Noble NumBAT,于 2024 年 4 月 25 日正式发布,引入了众

IDEA中的Kafka管理神器详解

《IDEA中的Kafka管理神器详解》这款基于IDEA插件实现的Kafka管理工具,能够在本地IDE环境中直接运行,简化了设置流程,为开发者提供了更加紧密集成、高效且直观的Kafka操作体验... 目录免安装:IDEA中的Kafka管理神器!简介安装必要的插件创建 Kafka 连接第一步:创建连接第二步:选