ResourceWrapper
sentinel 控制的对象即为资源,调用entry方法的时候会new 一个资源对象,资源由一个全局唯一的资源名称标识。
Context
sentinel 的处理的上下文,包含了上下文名称,一个调用链一个context,可以显示创建或者在调用entry的时候隐式创建。
Node
持有运行时的资源的各种统计数据。
- 一个 resource 在同一个Context 中有且仅有一个DefaultNode 与之对应
- 一个 resource 全局有且仅有一个ClusterNode
Entry
代表一次对资源的访问,每访问一个资源都会创建一个Entry,在context中以一个双向链表存在。
必须调用exit()
方法的原因就在于这个链表:exit方法中会判断上下文的当前 entry 是不是 this,此时其他entry掉用exit会发现不想等,从而抛出异常。
ProcessorSlot
处理插槽,资源的各种控制都通过不同的 Slot 实现类去完成,包括
// com.alibaba.csp.sentinel.slots.DefaultSlotChainBuilder#build()
// 一个资源(不区分context)对应一个 chain
ProcessorSlotChain chain = new DefaultProcessorSlotChain();
// 构建资源的调用路径,并将这些资源的调用路径,以树状结构存储起来,用于根据调用路径来限流降级
// 每个结点是一个DefaultNode(区分context)
chain.addLast(new NodeSelectorSlot());
// 构建一个 ClusterNode(不区分context) 用于存储资源的统计信息以及调用者信息,跟 DefaultNode 的区别在于前者统计同一个资源的所有信息,而后者会区分 context 进行统计
chain.addLast(new ClusterBuilderSlot());
// 通过一个try语句捕捉后续slot中的异常
chain.addLast(new LogSlot());
// 执行统计操作,真正统计是在这一步,包括 线程数、pass/success request、block/exception qps、rt 等信息
chain.addLast(new StatisticSlot());
// 判断系统是否过高,线程数、qps、rt、load
chain.addLast(new SystemSlot());
// 鉴权
chain.addLast(new AuthoritySlot());
// 限流
chain.addLast(new FlowSlot());
// 降级
chain.addLast(new DegradeSlot());
服务中会存在三种类型的统计:
- 同一个资源区分 context 的
DefaultNode
- 同一个资源不区分 context 的
ClusterNode·
- 全局统计
Cluster Node
, 用于系统负载的保护
ProcessorSlotChain
由各个处理插槽组成的链表,每个资源在整个服务中对应一个处理链,内容见 ProcesserSlot
Rule
用户定义的各种规则
RuleManager
加载并管理Rule
异步操作
前面提到必须调用exit()方法,对于资源的访问一般以下面的方式发起:
Entry entry = null;
try {
entry = SphU.entry(KEY);
// do something (1)
} catch (BlockException e1) {
// todo handle BlockException
} catch (Exception e2) {
// todo handle biz exception
} finally {
if (entry != null) {
entry.exit();
}
}
这个过程中会隐式创建一个ThreadLocal 的 Context ,假如我们想通过一个异步的操作去执行 do something
,这个过程线程会切换,导致exit操作不在同一个上下文。
Sentinel 上周提供了对异步的支持,增加了SphU.asyncEntry
方法创建一个AsyncEntry,在entry方法的finally语句块中会马上将其移出entry链表,后续需要将此AsyncEntry传入到异步方法中,执行exit 统计操作。