【sentinel】深入浅出之原理篇实体模型

在 Sentinel中，有一些概念需要搞懂，不然很多点理解起来比较困难。
这里写得很粗，详细可看逅弈大佬的Sentinel 原理-实体类

• Resource
  资源，具体代表被限流的方法或者字符串，屏蔽了具体的细节，可以是方法名，或者是url，也可以自定义对应的名称
• Node
  保存节点数据请求参数，QPS等其他信息
• Entry
  入口凭证，拿到Entry代表未限流
• Context
  上下文，执行环境

Resource说明

resource定义主要声明了资源的名称和类型，类型有两种，IN，OUT，分别代表调入或者调出。例如：A->B->C,对于B来讲，A的请求类型为IN，C的请求为OUT。
在Sentinel中，resource实现有两种

• MethodResourceWrapper
  方法的资源包装类，对应资源是Method
• StringResourceWrapper
  字符串的资源包装类，对应资源为String

public abstract class ResourceWrapper {
  protected String name;
  protected EntryType type = EntryType.OUT;

public class MethodResourceWrapper extends ResourceWrapper {

    private transient Method method;

    public MethodResourceWrapper(Method method, EntryType type) {
        this.method = method;
        this.name = MethodUtil.resolveMethodName(method);
        this.type = type;
    }
}

public class StringResourceWrapper extends ResourceWrapper {

    public StringResourceWrapper(String name, EntryType type) {
        if (name == null) {
            throw new IllegalArgumentException("Resource name cannot be null");
        }
        this.name = name;
        this.type = type;
    }
}

Node说明

Node 中保存了资源的实时统计数据，例如：passQps，blockQps，rt等实时数据。正是有了这些统计数据后， Sentinel 才能进行限流、降级等一系列的操作。

public interface Node {
    long totalRequest();
    long totalSuccess();
    long blockRequest();
    long totalException();
    long passQps();
    long blockQps();
    long totalQps();
    long successQps();
    long maxSuccessQps();
    long exceptionQps();
    long avgRt();
    long minRt();
    int curThreadNum();
    long previousBlockQps();
    long previousPassQps();
    Map<Long, MetricNode> metrics();
    void addPassRequest(int count);
    void addRtAndSuccess(long rt, int success);
    void increaseBlockQps(int count);
    void increaseExceptionQps(int count);
    void increaseThreadNum();
    void decreaseThreadNum();
    void reset();
    void debug();
}

而Node的实现类有以下四种：

• StatisticNode
  基础节点
• DefaultNode
  默认Node节点
• ClusterNode
• EntranceNode
  Node入口节点，上下文初始化的时候加载出来的，作为入口初始化的Node，全局唯一。
  node.png

Entry说明

入口凭证，在SphU#entry()调用后，就会返回一个Entry，代表可以请求。Entry包含一个 Resource资源,originNode原始节点,curNode当前节点,createTime创建时间

public abstract class Entry implements AutoCloseable {
   private static final Object[] OBJECTS0 = new Object[0];
   private long createTime;
   private Node curNode;
   private Node originNode;
   private Throwable error;
   protected ResourceWrapper resourceWrapper;
}

实现类CtEntry

class CtEntry extends Entry {
    protected Entry parent = null;
    protected Entry child = null;
    protected ProcessorSlot<Object> chain;
    protected Context context;
}

Context上下文

上下文，记录当前执行环境的一些配置和执行情况。

public class Context {

   private final String name;

   private DefaultNode entranceNode;//当前调用链的入口节点

   private Entry curEntry;//当前调用链的当前entry

   private String origin = "";//当前调用链的调用源

   private final boolean async;
}

Metric度量信息 主要是滑动窗口实现，统计数据

public interface Metric {
    long success();
    long maxSuccess();
    long exception();
    long block();
    long pass();
    long rt();
    long minRt();
    List<MetricNode> details();
    MetricBucket[] windows();
    void addException(int n);
    void addBlock(int n);
    void addSuccess(int n);
    void addPass(int n);
    void addRT(long rt);
    double getWindowIntervalInSec();
    int getSampleCount();
    void debugQps();
    long previousWindowBlock();
    long previousWindowPass();
}

实现类:

public class ArrayMetric implements Metric {
    private final MetricsLeapArray data;
}