《一起学sentinel》四、Slot的子类及实现之LogSlot和StatisticSlot
一、概述
在 Sentinel 里面,所有的资源都对应一个资源名称(resourceName
),每次资源调用都会创建一个 Entry
对象。Entry 可以通过对主流框架的适配自动创建,也可以通过注解的方式或调用 SphU
API 显式创建。Entry 创建的时候,同时也会创建一系列功能插槽(slot chain),这些插槽有不同的职责,例如:
-
NodeSelectorSlot
负责收集资源的路径,并将这些资源的调用路径,以树状结构存储起来,用于根据调用路径来限流降级; -
ClusterBuilderSlot
则用于存储资源的统计信息以及调用者信息,例如该资源的 RT, QPS, thread count 等等,这些信息将用作为多维度限流,降级的依据; LogSlot
则用于记录用于记录块异常,为故障排除提供具体的日志StatisticSlot
则用于记录、统计不同纬度的 runtime 指标监控信息;-
FlowSlot
则用于根据预设的限流规则以及前面 slot 统计的状态,来进行流量控制; -
AuthoritySlot
则根据配置的黑白名单和调用来源信息,来做黑白名单控制; -
DegradeSlot
则通过统计信息以及预设的规则,来做熔断降级; -
SystemSlot
则通过系统的状态,例如 load1 等,来控制总的入口流量;
下面是关系结构图
二、LogSlot分析
1.LogSlot介绍
官方文档是这样描述LogSlot的:用于记录块异常,为故障排除提供具体的日志
2.源码解读
@Override
public void entry(Context context, ResourceWrapper resourceWrapper, DefaultNode obj, int count, boolean prioritized, Object... args)
throws Throwable {
try {
fireEntry(context, resourceWrapper, obj, count, prioritized, args);
} catch (BlockException e) {
EagleEyeLogUtil.log(resourceWrapper.getName(), e.getClass().getSimpleName(), e.getRuleLimitApp(),
context.getOrigin(), count);
throw e;
} catch (Throwable e) {
RecordLog.warn("Unexpected entry exception", e);
}
}
@Override
public void exit(Context context, ResourceWrapper resourceWrapper, int count, Object... args) {
try {
fireExit(context, resourceWrapper, count, args);
} catch (Throwable e) {
RecordLog.warn("Unexpected entry exit exception", e);
}
}
1.在entry阶段这个slot没有什么业务逻辑,主要就是拦截了业务异常和Throwable级别的错误
2.如果是com.alibaba.csp.sentinel.slots.block.BlockException的异常,则将异常信息用LogSlot专用的EagleEyeLogUtil记录。
3.在exit阶段,出现的日志是没有记录在EagleEyeLogUtil里面的,因为没有关于com.alibaba.csp.sentinel.slots.block.BlockException的异常的捕获和拦截,直接为一个Throwable级别的catch。
作为sentinel
执行序号第三的slot
,和之前的NodeSelectorSlot
,ClusterBuilderSlot
最大的不同是,这个时候已经初始化好了必要的DefaultSlot
和ClusterSlot
,功能基本完备,处于sentinle
的业务处理阶段,由于责任链的调用模式,这里拦截的信息多为BlockException
,我们可以理解为已识别的业务(sentinel的能力域逻辑)异常。所以使用了一个简单粗暴的方式,直接catch
住了下面所有slot
的异常返回。
多个相同的resource
(name),对应着不同的context
(name),那么我们就可以快速统计出某个资源的总统计信息。对应着多个(归属于同一个resource的)DefaultNode
对应同一个ClusterNode
。
三、StatisticSlot分析
1.StatisticSlot介绍
官方文档是这样描述StatisticSlot的:用于存储资源的统计信息以及调用者信息,例如该资源的 RT, QPS, thread count 等等,这些信息将用作为多维度限流,降级的依据,指的就是ClusterNode;
2.源码解读
@Override
public void entry(Context context, ResourceWrapper resourceWrapper, DefaultNode node, int count, boolean prioritized, Object... args) throws Throwable {
if (clusterNode == null) {
synchronized (lock) {
if (clusterNode == null) {//1
// Create the cluster node.
clusterNode = new ClusterNode(resourceWrapper.getName(), resourceWrapper.getResourceType());
HashMap<ResourceWrapper, ClusterNode> newMap = new HashMap<>(Math.max(clusterNodeMap.size(), 16));
newMap.putAll(clusterNodeMap);
newMap.put(node.getId(), clusterNode);//2
clusterNodeMap = newMap;
}
}
}
node.setClusterNode(clusterNode);
/*
* if context origin is set, we should get or create a new {@link Node} of
* the specific origin.
*/
if (!"".equals(context.getOrigin())) {//3
Node originNode = node.getClusterNode().getOrCreateOriginNode(context.getOrigin());
context.getCurEntry().setOriginNode(originNode);
}
fireEntry(context, resourceWrapper, node, count, prioritized, args);
}
1.判断clusterNode
是否需要创建,需要就根据rocourceName
创建一个
2.将clusterNode
插入clusterNodeMap
3.如果指定了origin
还会创造来源维度的node
,作为origin
级别的统计
项目的resource
共享了相同的ProcessorSlotChain
,无论在关联了哪个上下围,信息都被收集在resource
对应的ClusterNode
中,clusterNodeMap
则存储了所有resource
的统计信息。
四、小结
本期我们讲述了Slot的子类LogSlot
和StatisticSlot
的基本实现原理。
现在建立我们的知识树
实例化DefaultNode和ClusterNode,创建结构树
创建上下文时,首先会在NodeSelectorSlot
中判断是否有DefaultNode
。
如果没有则新增一个基于resource
的DefaultNode
,然后执行下一个slot
。
下一个slot
是ClusterBuilderSlot
,ClusterBuilderSlot
会判断是否有对应的ClusterNode
,如果没有则新增一个基于resource的ClusterNode
并继续下一个流程(slot
)。
总结来说,这个两个slot
奠定了一个基于resource
进行全局控制的基调。
进行信息收集
LogSlot
在DefaultNode
和ClusterNode
初始化后,作为业务实例模块的分界点,收集全局异常并处理。
StatisticSlot
作为全局统计的实例,依托于ClusterNode
,将全局的RT
, QPS
, thread
count
等等信息存放在clusterNodeMap
里面。
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 我的小工具,java版串口读写卡测试工具
- Java|什么是多态
- 解密BGPaaS代理是如何工作的
- java 版DES和MAC算法
- 前端|手风琴--抽屉式网页特效
- python 版DES和MAC算法
- ANSI-X99MAC算法和PBOC的3DES MAC算法
- 数据分析(EDA)学习总结!
- web.py 0.3 新手指南
- 详解一道字节跳动的二面题目,它太经典了!
- 使用R语言进行时间序列(arima,指数平滑)分析
- 用python多线程抓取网站图片,速度极快
- 偏最小二乘回归(PLSR)和主成分回归(PCR)
- R语言使用特征工程泰坦尼克号数据分析应用案例
- Rust FFI 编程 - Rust导出共享库04