Sentinel源码阅读（一）

本文包括一些高可用服务的概念讲解、Sentinel整体流程的源码解析。

第一次写源码解析，写的不好多多包涵。个人理解，写的不对多多指正。

reference：GitHub - alibaba/Sentinel: A powerful flow control component enabling reliability, resilience and monitoring for microservices、(面向云原生微服务的高可用流控防护组件)

概念讲解

在微服务架构中，远程调用用来替代本地调用，而远程调用是不可控的，我们的服务需要应对上下游的不可控流量。因此我们需要通过对上游流量控制、对下游流量熔断降级隔离等，来保障服务等高可用性（Availability）。正如Sentinel的官方文档中所说，Sentinel就是用来做这些事的。

As distributed systems are becoming increasingly popular, the reliability between services is becoming more important than ever before、Sentinel is a powerful flow control component that takes "flow" as the breakthrough point and covers multiple fields including flow control, concurrency limiting, circuit breaking, and adaptive system protection to guarantee the reliability of microservices.

下面理解一下这些概念：

限流：当某个消费者（consumer）流量飙升时，会占用生产者（provider）的大部分资源导致其他可能更重要的消费者失败，甚至拖垮整个服务。因此我们需要对流量进行控制，如根据消费者的重要程度进行限流、直接限流、排队等。

降级：指对弱依赖的下游provider，当其不可用时用某种方式（如使用固定值）替换provider的response，否则弱依赖的下游服务不可用也会导致整个脸露的不可用。

熔断：熔断其实一般总是与降级一起讲的。目的是为了防止consumer不断地尝试可能超时和失败的服务。可以理解为一段时间内的直接降级。例如Sentinel中触发一次降级后，一段时间内都不再请求下游服务，而是直接降级处理。这个过程就是熔断。

隔离：与降级对应，隔离是处理强以来的。强依赖是主流程必须的，无法降级，但是当强依赖处理过慢时，会拖住你掉用的线程池，导致应用中其他业务也受影响。所以我们可以对需要的强依赖设置隔离策略（如最大线程数设置），来保护其他的代码。

源码解析

Sentinel的repo其实有很多module

sentinel-core

sentinel-adapter

sentinel-benchmark

sentinel-cluster

sentinel-dashboard

sentinel-logging

sentinel-extension

从命名也能看出来是做什么的，由于时间有限，我们只看核心部分，也就是sentinel-core部分的代码。

翻看QuickStart，最简单的接入方式是这样的

Entry entry = null;​try {    entry = SphU.entry("HelloWorld");    // BIZ logic being protected  System.out.println("hello world");} catch (BlockException e) {  // handle block logic} finally {  // make sure that the exit() logic is called  if (entry != null) {    entry.exit(); }}

Sentinel用try-catch-finally的方式包围需要被保护的代码，Entry这个类基本就表示对资源的一次操作（这里插一句，Sentinel保护的是资源，资源可以表示远程调用、本地调用、数据库请求等等，我们就理解为某个方法即可）。在这个例子中，`我们保护了 System.out.println("hello world"); 这一段代码，如果触发了流量控制规则，则会抛出BlockException，我们可以捕获这个异常，做对应的的处理，exit方法中则会进行流量数据的统计。那么关键入口就是SphU.entry()。点进函数最终执行的是CtSph的entryWithPriority方法，返回的类是CtEntry。这边Ct应该是current的意思，表示同步的资源，与异步对应。

解析下这个方法，中文是我补充的。

private Entry entryWithPriority(ResourceWrapper resourceWrapper, int count, boolean prioritized, Object..、args)    throws BlockException {    // 获取上下文，ContextUtil中以ThreadLocal形式存在    Context context = ContextUtil.getContext();    if (context instanceof NullContext) {        // The {@link NullContext} indicates that the amount of context has exceeded the threshold,        // so here init the entry only、No rule checking will be done.        return new CtEntry(resourceWrapper, null, context);   }​    if (context == null) {        // Using default context.        context = InternalContextUtil.internalEnter(Constants.CONTEXT_DEFAULT_NAME);   }​    // Global switch is close, no rule checking will do.    if (!Constants.ON) {        return new CtEntry(resourceWrapper, null, context);   }    // 关键函数，构建责任链    ProcessorSlot