摘要：是一個(gè)靈活的系統(tǒng)負(fù)載控制框架，通過控制接口和方法的調(diào)用來保證系統(tǒng)負(fù)載不會(huì)過大，維持正常響應(yīng)速度。創(chuàng)建一個(gè)項(xiàng)目首先創(chuàng)建一個(gè)空的項(xiàng)目，加上的依賴。編寫控制規(guī)則將控制規(guī)則包裝為類。超過這個(gè)閾值則會(huì)拒絕調(diào)用該方法。

Alibaba Sentinel 是一個(gè)靈活的系統(tǒng)負(fù)載控制框架，通過控制接口和方法的調(diào)用來保證系統(tǒng)負(fù)載不會(huì)過大，維持正常響應(yīng)速度。

該項(xiàng)目的地址是 https://github.com/alibaba/Se... 。但是阿里的文檔一貫看起來一頭霧水，所以本文介紹如何用一個(gè)最簡(jiǎn)單的項(xiàng)目來上手。如果你熟悉 Spring Boot，那么幾分鐘就可以搞定。

首先創(chuàng)建一個(gè)空的 Maven 項(xiàng)目，加上 Spring Boot 的依賴。pom.xml 看起來是下面的樣子，你可以直接拿來用：

  4.0.0

  com.demo
  sentinel-test
  1.0-SNAPSHOT

  
    1.8
    1.8
    UTF-8
  

  
    
      
        org.springframework.boot
        spring-boot-dependencies
        2.1.3.RELEASE
        pom
        import
      
    
  

這里沒有將 Spring Boot 作為 parent 項(xiàng)目，而是使用 ，但效果是一樣的。

在 pom.xml 中，首先添加 Spring Boot 依賴：

  org.springframework.boot
  spring-boot-starter

然后添加 Sentinel。在這個(gè)例子當(dāng)中，我們將用 注解 來實(shí)現(xiàn)負(fù)載控制，所以添加 sentinel-annotation-aspectj 依賴：

  com.alibaba.csp
  sentinel-annotation-aspectj
  1.5.1

添加了這兩個(gè)依賴就 OK 了。

Spring Boot 項(xiàng)目需要一個(gè) main() 方法來啟動(dòng)，我們命名這個(gè)類為 com.demo.SentinelTestApplication，其內(nèi)容如下：

@SpringBootApplication
public class SentinelTestApplication {
  public static void main(String[] args) throws Exception {
    SpringApplication.run(SentinelTestApplication.class, args);
  }
}

目前這個(gè)類還沒有具體的內(nèi)容，但我們應(yīng)該先運(yùn)行一下，確保前面做的事情沒有出錯(cuò)，然后再添加內(nèi)容。

我們?cè)?com.demo 包下創(chuàng)建一個(gè)名為 DemoService 的類，這個(gè)類包含一個(gè)需要做訪問控制的 call() 方法：

@Service
public class DemoService {

  private int counter;

  @SentinelResource(value = "DemoService.call", blockHandler = "callBlocked")
  public void call() {
    System.out.println("Hello (" + ++counter + ")");
  }

  public void callBlocked(BlockException ex) {
    System.err.println("Blocked (" + ++counter + ") : " + ex.toString());
  }
}

所謂訪問控制就是當(dāng)某個(gè)方法調(diào)用過于頻繁時(shí)，拒絕掉一部分調(diào)用。什么才叫過于頻繁，我們可以通過自定義控制規(guī)則的方式來告訴 Sentinel。定義控制規(guī)則的部分放在后面介紹，我們現(xiàn)在先關(guān)注業(yè)務(wù)本身，也就是 DemoService 類。

這個(gè)類包含兩個(gè)方法，其中 call() 方法是主角，正常的業(yè)務(wù)會(huì)調(diào)用這個(gè)方法；而 callBlocked() 則會(huì)在 call() 方法被拒絕掉時(shí)調(diào)用。

call() 方法上面的 @SentinelResource 注解標(biāo)明了該方法是需要進(jìn)行訪問控制的。Sentinel 將需要進(jìn)行訪問控制的方法都稱作資源。這個(gè)注解有兩個(gè)屬性，value 屬性表示該資源的名稱，我們通過名稱為不同的資源制定不同的控制規(guī)則。blockHandler 屬性表示方法被拒絕時(shí)應(yīng)該調(diào)用哪個(gè)替代方法，這個(gè)替代方法必須在同一個(gè)類當(dāng)中，且參數(shù)列表要在原方法參數(shù)列表的基礎(chǔ)上再添加一個(gè) BlockException 類型的參數(shù)。

Sentinel 將控制規(guī)則包裝為 com.alibaba.csp.sentinel.slots.block.flow.FlowRule 類。它包含下面幾個(gè)屬性：

resource : 該規(guī)則針對(duì)哪個(gè)資源；

grade : 從哪個(gè)方面進(jìn)行度量，如該方法的每秒調(diào)用次數(shù)，或同時(shí)調(diào)用該方法的線程數(shù)等等。

count : 度量閾值。超過這個(gè)閾值則會(huì)拒絕調(diào)用該方法。

strategy : 多個(gè)規(guī)則之間的搭配策略，具體參考這里。

下面我們?cè)?SentinelTestApplication 類里面添加一個(gè)創(chuàng)建規(guī)則的方法，同時(shí)在 main() 方法里面初始化它：

  private static void initRules() throws Exception {
    FlowRule rule1 = new FlowRule();
    rule1.setResource("DemoService.call");
    rule1.setGrade(RuleConstant.FLOW_GRADE_QPS);
    rule1.setCount(5);   // 每秒調(diào)用最大次數(shù)為 5 次

    List rules = new ArrayList<>();
    rules.add(rule1);
    
    // 將控制規(guī)則載入到 Sentinel
    com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager.loadRules(rules);  
  }

  public static void main(String[] args) throws Exception {
    initRules();  // Sentinel 載入規(guī)則不一定非要在 Spring 初始化之前，在這之后也可以。
    SpringApplication.run(SentinelTestApplication.class, args);
  }

這樣 Sentinel 的規(guī)則就設(shè)置完畢。

Spring 提供 AOP 機(jī)制來實(shí)現(xiàn)方法調(diào)用的攔截，這是 Sentinel 實(shí)現(xiàn)控制規(guī)則的原理。Sentinel 提供 com.alibaba.csp.sentinel.annotation.aspectj.SentinelResourceAspect 類，我們要在 Spring 容器中加入這個(gè) bean 才能讓 @SentinelResource 注解起作用。我們需要在 SentinelTestApplication 類里面添加下面的代碼：

  @Bean
  public SentinelResourceAspect sentinelResourceAspect() {
    return new SentinelResourceAspect();
  }

當(dāng)然，在實(shí)際項(xiàng)目里面這一步可以放到自動(dòng)配置當(dāng)中。

最后我們寫一個(gè)方法來測(cè)試控制規(guī)則是否起作用，同樣是在 SentinelTestApplication 類里面：

  @Autowired
  private DemoService demoService;

  @PostConstruct
  public void run() {
    for (int i = 0; i < 10; i++) {
      demoService.call();
    }
  }

實(shí)際運(yùn)行 main() 方法時(shí)，你將會(huì)看到這樣的輸出：

Hello (1)
Hello (2)
Hello (3)
Hello (4)
Hello (5)
Blocked (6) : com.alibaba.csp.sentinel.slots.block.flow.FlowException
Blocked (7) : com.alibaba.csp.sentinel.slots.block.flow.FlowException
Blocked (8) : com.alibaba.csp.sentinel.slots.block.flow.FlowException
Blocked (9) : com.alibaba.csp.sentinel.slots.block.flow.FlowException
Blocked (10) : com.alibaba.csp.sentinel.slots.block.flow.FlowException

通過這個(gè)例子，你應(yīng)該大概了解 Sentinel 運(yùn)作的機(jī)制了。在這個(gè)基礎(chǔ)上，Sentinel 還能實(shí)現(xiàn)控制規(guī)則的實(shí)時(shí)修改、遠(yuǎn)程配置、狀態(tài)監(jiān)控等等，它是個(gè)非常強(qiáng)大的框架。