极光实时监听怎么调用_源码分析 Sentinel 实时数据采集实现原理(图文并茂)

本篇将重点关注 Sentienl 实时数据收集，即 Sentienl 具体是如何收集调用信息，以此来判断是否需要触发限流或熔断。

Sentienl 实时数据收集的入口类为 StatisticSlot。

我们先简单来看一下 StatisticSlot 该类的注释，来看一下该类的整体定位。

StatisticSlot，专用于实时统计的 slot。在进入一个资源时，在执行 Sentienl 的处理链条中会进入到该 slot 中，需要完成如下计算任务：

集群维度计算资源的总统计信息，用于集群限流，后续文章将详细探讨。

来自不同调用方/来源的群集节点的统计信息。

特定调用上下文环境的统计信息。

统计所有入口的统计信息。

接下来用源码分析的手段来详细分析 StatisticSlot 的实现原理。

1、源码分析 StatisticSlot

1.1 StatisticSlot entry 详解

StatisticSlot#entry

代码@1：首先调用 fireEntry，先调用 Sentinel Slot Chain 中其他的处理器，执行完其他处理器的逻辑，例如 FlowSlot、DegradeSlot，因为 StatisticSlot 的职责是收集统计信息。

代码@2：如果后续处理器成功执行，则将正在执行线程数统计指标加一，并将通过的请求数量指标增加对应的值。下文会对 Sentinel Node 体系进行详细的介绍，在 Sentinel 中使用 Node 来表示调用链中的某一个节点，每个节点关联一个资源，资源的实时统计信息就存储在 Node 中，故该部分也是调用 DefaultNode 的相关方法来改变线程数等，将在下文会向详细介绍。

代码@3：如果上下文环境中保存了调用的源头(调用方)的节点信息不为空，则更新该节点的统计数据：线程数与通过数量。

代码@4：如果资源的进入类型为 EntryType.IN，表示入站流量，更新入站全局统计数据(集群范围 ClusterNode)。

代码@5：执行注册的进入Handler，可以通过 StatisticSlotCallbackRegistry 的 addEntryCallback 注册相关监听器。

代码@6：如果捕获到 PriorityWaitException ，则认为是等待过一定时间，但最终还是算通过，只需增加线程的个数，但无需增加节点通过的数量，具体原因我们在详细分析限流部分时会重点讨论，也会再次阐述 PriorityWaitException 的含义。

代码@7：如果捕获到 BlockException，则主要增加阻塞的数量。

代码@8：如果是系统异常，则增加异常数量。

我想上面的代码应该不难理解，但涉及到统计指标数据的变化，都是调用 DefaultNode node 相关的方法，从这里也可以看出，Node 将是实时统计数据的直接持有者，那毋容置疑接下来将重点来学习 Node，为了知识体系的完备性，我们先来看一下 StatisticSlot 的 exit 方法。

1.2 StatisticSlot exit 详解

StatisticSlot#exit

代码@1：成功执行，则重点关注响应时间，其实现亮点如下：

计算本次响应时间，将本次响应时间收集到 Node 中。

将当前活跃线程数减一。

代码@2：执行退出时的 callback。可以通过 StatisticSlotCallbackRegistry 的 addExitCallback 方法添加退出回调函数。

代码@3：传播 exit 事件。

接下来我们将重点介绍 DefaultNode，即 Sentinel 的 Node 体系，持有资源的实时调用信息。

2、Sentienl Node 体系

2.1 Node 类体系图

我们先简单介绍一下上述核心类的作用与核心接口或核心属性的含义。

OccupySupport
支持抢占未来的时间窗口，有点类似借用“未来”的令牌。其核心方法如下：
1)long tryOccupyNext(long currentTime, int acquireCount, double threshold)
尝试抢占未来的令牌，返回值为调用该方法的线程应该 sleep 的时间。
1、long currentTime
当前时间。
2、int acquireCount
本次需要申请的令牌个数。
3、double threshold
设置的阔值。
2)long waiting()
获取当前已申请的未来的令牌的个数。
3)void addWaitingRequest(long futureTime, int acquireCount)
申请未来时间窗口中的令牌。
4)void addOccupiedPass(int acquireCount)
增加申请未来令牌通过的个数。
5)double occupiedPassQps()
当前抢占未来令牌的QPS。

Node
持有实时统计信息的节点。定义了收集统计信息与获取统计信息的接口，上面方法根据方法名称即可得知其含义，故这里就不一一罗列了。

StatisticNode
实现统计信息的默认实现类。

DefaultNode
用于在特定上下文环境中保存某一个资源的实时统计信息。

ClusterNode
实现基于集群限流模式的节点，将在集群限流模式部分详细介绍。

EntranceNode
用来表示调用链入口的节点信息。

本文将详细介绍 DefaultNode 与 StatisticNode，重点阐述调用树与实时统计信息。DefaultNode 是 StatisticNode 的子类，我们先从 StatisticNode 开始 Node 体系的探究。

3、StatisticNode 详解

3.1 核心类图

我们对其核心属性进行一一解读：

Metric rollingCounterInSecond = new ArrayMetric(SampleCountProperty.SAMPLE_COUNT, IntervalProperty.INTERVAL)
每秒的实时统计信息，使用 ArrayMetric 实现，即基于滑动窗口实现，正是上篇文章详细介绍的，默认1s 采样 2次。即一个统计周期中包含两个滑动窗口。