Sentinel核心类解读：Node

news2024/11/17 12:56:39

基本介绍

Sentinel中的簇点链路是由一个个的Node组成的，Node是一个接口。Node中保存了对资源的实时数据的统计，Sentinel中的限流或者降级等功能就是通过Node中的数据进行判断的。

Sentinel中是这样描述Node的：

Holds real-time statistics for resources.

保存资源的实时统计信息。

Node继承结构体系图：

所有的节点都可以记录对资源的访问统计数据，所以都是StatisticNode的子类。

按照作用分为两类Node：

DefaultNode：代表链路树中的每一个资源，一个资源出现在不同链路中时，会创建不同的DefaultNode节点。而树的入口节点叫EntranceNode，是一种特殊的DefaultNode
ClusterNode：代表资源，一个资源不管出现在多少链路中，只会有一个ClusterNode。记录的是当前资源被访问的所有统计数据之和。

DefaultNode记录的是资源在当前链路中的访问数据，用来实现基于链路模式的限流规则。

ClusterNode记录的是资源在所有链路中的访问数据，实现默认模式、关联模式的限流规则。

链路模式：只针对从指定链路访问到本资源的请求做统计，判断是否超过阈值。

StatisticNode

StatisticNode实现了Node接口，其他的Node都继承了该接口。所以这个Node是一个最基础的Node，StatisticNode中保存了资源的实时统计数据（基于滑动时间窗口机制），通过这些统计数据，sentinel才能进行限流、降级等一系列操作。StatisticNode属性如下：

public class StatisticNode implements Node {
    /**
     * 秒级的滑动时间窗口（时间窗口单位500ms）
     */
    private transient volatile Metric rollingCounterInSecond = new ArrayMetric(SampleCountProperty.SAMPLE_COUNT,
        IntervalProperty.INTERVAL);
    /**
     * 分钟级的滑动时间窗口（时间窗口单位1s）
     */
    private transient Metric rollingCounterInMinute = new ArrayMetric(60, 60 * 1000, false);
    /**
     * The counter for thread count. 
 * 线程个数用户触发线程数流控
     */
    private LongAdder curThreadNum = new LongAdder();
}
public class ArrayMetric implements Metric {
    private final LeapArray<MetricBucket> data;
}
public class MetricBucket {
// 保存统计值
    private final LongAdder[] counters;
// 最小rt
    private volatile long minRt;
}

在Sentinel中单独使用StatisticNode来作为统计节点的地方是统计来源节点相关的指标的时候，来源节点创建则是在ClusterBuilderSlot中。

DefaultNode

DefaultNode 由俩个类EntranceNode跟DefaultNode继承

EntranceNode：该类的创建是在初始化Context时完成的（ContextUtil.trueEnter方法），注意该类是针对Context维度的，也就是一个context有且仅有一个EntranceNode。
DefaultNode：该类的创建是在NodeSelectorSlot.entry完成的，当不存在context.name对应的DefaultNode时会新建（new DefaultNode(resourceWrapper, null)，对应resouce）并保存到本地缓存（NodeSelectorSlot中private volatile Map<String, DefaultNode> map）；获取到context.name对应的DefaultNode后会将该DefaultNode设置到当前context的curEntry.curNode属性，也就是说，在NodeSelectorSlot中是一个context有且仅有一个DefaultNode。

DefaultNode结构如下：

public class DefaultNode extends StatisticNode {
    private ResourceWrapper id;
    /**
     * The list of all child nodes.
     * 子节点集合
     */
    private volatile Set<Node> childList = new HashSet<>();
    /**
     * Associated cluster node.
     */
    private ClusterNode clusterNode;
}

DefaultNode持有指定的Context和指定的Resource的统计数据，意味着DefaultNode是以Context和Resource为维度的统计节点。这一点非常的重要，因为如果想对某个Context中某个Resource的进行限流等操作，就需要使用DefaultNode类型的节点来统计数据。源码中还描述到，多次在同一个上下文中获取资源，会产生一些子节点，这些子节点保存在DefaultNode的childList中。