快速学习-Sentinel 工作主流程

5、Sentinel 工作主流程

5.1 Overview

在Sentinel 里面，所有的资源都对应一个资源名称以及一个Entry。Entry 要么通过对默认的主流框架的适配自动创建，要么通过调用API 显式创建；每一个Entry 创建的时候，同时也会创建一系列插槽。这些插槽有不同的职责，例如:

NodeSelectorSlot 负责收集资源的路径，并将这些资源的调用路径，以树状结构存储起来，用于根据调用路径来限流降级；
ClusterBuilderSlot 则用于存储资源的统计信息以及调用者信息，例如该资源的RT, QPS, thread count 等等，这些信息将用作为多维度限流，降级的依据；
StatistcSlot 则用于记录，统计不同纬度的runtime 信息；
FlowSlot 则用于根据预设的限流规则，以及前面slot 统计的状态，来进行限流；
AuthorizationSlot 则根据黑白名单，来做黑白名单控制；
DegradeSlot 则通过统计信息，以及预设的规则，来做熔断降级；
SystemSlot 则通过系统的状态，例如load1 等，来控制总的入口流量；您也可以通过添加基于以下3 个基本插槽的插槽来定制自己的逻辑。总体的框架如下:

5.2 NodeSelectorSlot

这个slot 主要负责收集资源的路径，并将这些资源的调用路径，以树状结构存储起来，用于根据调用路径来限流降级。

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

上述代码通过ContextUtil.enter() 创建了一个名为entrance1 的上下文，同时指定调用发起者为appA；接着通过SphU.entry()请求一个token，如果该方法顺利执行没有抛BlockException，表明token 请求成功。以上代码将在内存中生成以下结构：

machine-root
/
/
EntranceNode1
/
/
DefaultNode(nodeA)

注意：每个DefaultNode 由资源ID 和输入名称来标识。换句话说，一个资源ID可以有多个不同入口的DefaultNode。

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

以上代码将在内存中生成以下结构：

上面的结构可以通过调用curl http://localhost:8719/tree?type=root 来显示：

EntranceNode: machine-root(t:0 pq:1 bq:0 tq:1 rt:0 prq:1 1mp:0 1mb:0 1mt:0)
-EntranceNode1: Entrance1(t:0 pq:1 bq:0 tq:1 rt:0 prq:1 1mp:0 1mb:0 1mt:0)
--nodeA(t:0 pq:1 bq:0 tq:1 rt:0 prq:1 1mp:0 1mb:0 1mt:0)
-EntranceNode2: Entrance1(t:0 pq:1 bq:0 tq:1 rt:0 prq:1 1mp:0 1mb:0 1mt:0)
--nodeA(t:0 pq:1 bq:0 tq:1 rt:0 prq:1 1mp:0 1mb:0 1mt:0)
t:threadNum pq:passQps bq:blockedQps tq:totalQps rt:averageRt prq:
passRequestQps 1mp:1m-passed 1mb:1m-blocked 1mt:1m-total

5.3 ClusterBuilderSlot

此插槽保持资源运行统计信息（响应时间，QPS，线程，计数，例外）以及原始调用者统计信息列表。源调用者的名字由Context.enter(entryname，origin) 中的origin 标记，可通过如下命令查看某个资源不同调用者的访问情况：curl

http://localhost:8719/origin?id=caller：
id: nodeA
idx origin threadNum passedQps blockedQps totalQps aRt 1m-passed 1m-blocked
1m-total
1 caller1 0 0 0 0 0 0 0 0
2 caller2 0 0 0 0 0 0 0 0

5.4 StatisticSlot

clusterNode：资源唯一标识的ClusterNode 的runtime 统计
origin：根据来自不同调用者的统计信息
defaultnode: 根据上下文条目名称和资源ID 的runtime 统计入口的统计

5.5 FlowSlot

这个slot 主要根据预设的资源的统计信息，按照固定的次序，依次生效。如果一个资源对应两条或者多条规则，则会根据如下次序依次检验，直到全部通过或者有一个规则生效为止:

指定应用生效的规则，即针对调用方限流的；
调用方为other 的规则；
调用方为default 的规则。

5.6 DegradeSlot

这个slot 主要针对资源的运行RT 以及预设规则（平均RT 模式或异常比率模式），来决定资源是否在接下来的时间被自动降级掉。

5.7 SystemSlot

这个slot 会根据对于当前系统的整体情况，对入口的资源进行调配。其原理是让入口的API 和当前系统的API 达到一个动态平衡。注意这个功能的两个限制:

只对入口流量起作用（调用类型为EntryType.IN），对出口流量无效。可通过SphU.entry()指定调用类型，如果不指定，默认是EntryType.OUT。Entry entry = SphU.entry("resourceName"，EntryType.IN);
只在Unix-like 的操作系统上生效