spring cloud alibaba系列(二)Sentinel應用的限流管理

限流組件Sentinel

• Sentinel是把流量做爲切入點，從流量控制、熔斷降級、系統負載保護等多個維度保護服務的穩定性。
• 默認支持 Servlet、Feign、RestTemplate、Dubbo 和 RocketMQ 限流降級功能的接入，能夠在運行時經過控制檯實時修改限流降級規則，還支持查看限流降級 Metrics 監控。
• 自帶控臺動態修改限流策略。可是每次服務重啓後就丟失了。因此它也支持ReadableDataSource 目前支持file, nacos, zk, apollo 這4種類型

接入Sentinel

建立項目cloud-sentinel

• 1 引入 Sentinel starter

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
複製代碼

• 2 application.properties配置以下

server.port=18084
spring.application.name=service-sentinel

#Sentinel 控制檯地址
spring.cloud.sentinel.transport.dashboard=localhost:8080
#取消Sentinel控制檯懶加載
spring.cloud.sentinel.eager=true
複製代碼

接入限流埋點

Sentinel 默認爲全部的 HTTP 服務提供了限流埋點。引入依賴後自動完成全部埋點。只須要在控制配置限流規則便可

• 註解埋點 若是須要對某個特定的方法進行限流或降級，能夠經過 @SentinelResource 註解來完成限流的埋點

@SentinelResource("resource")
@RequestMapping("/sentinel/hello")
public Map<String,Object> hello(){
        Map<String,Object> map=new HashMap<>(2);
        map.put("appName",appName);
        map.put("method","hello");
        return map;
}
複製代碼

部署Sentinel控制檯

安裝

Sentinel下載

啓動控制檯

執行 Java 命令 java -jar sentinel-dashboard.jar 默認的監聽端口爲 8080

訪問

打開http://localhost:8080 便可看到控制檯界面

說明cloud-sentinel已經成功和Sentinel完成率通信

配置限流規則

若是控制檯沒有找到本身的應用，能夠先調用一下進行了 Sentinel 埋點的 URL 或方法或着禁用Sentinel 的賴加載spring.cloud.sentinel.eager=true

配置 URL 限流規則

控制器隨便添加一個普通的http方法

/** * 經過控制檯配置URL 限流 * @return */
    @RequestMapping("/sentinel/test")
    public Map<String,Object> test(){
        Map<String,Object> map=new HashMap<>(2);
        map.put("appName",appName);
        map.put("method","test");
        return map;
    }

複製代碼

點擊新增流控規則。爲了方便測試閥值設爲 1

瀏覽器重複請求 http://localhost:18084/sentinel/test 若是超過閥值就會出現以下界面

整個URL限流就完成了。可是返回的提示不夠友好。

配置自定義限流規則(@SentinelResource埋點)

自定義限流規則就不是添加方法的訪問路徑。 配置的是@SentinelResource註解中value的值。好比@SentinelResource("resource")就是配置路徑爲resource

• 訪問：http://localhost:18084/sentinel/hello
• 經過@SentinelResource註解埋點配置的限流規則若是沒有自定義處理限流邏輯，當請求到達限流的閥值時就返回404頁面

  

自定義限流處理邏輯

@SentinelResource 註解包含如下屬性：

• value: 資源名稱，必需項（不能爲空）
• entryType: 入口類型，可選項（默認爲 EntryType.OUT）
• blockHandler:blockHandlerClass中對應的異常處理方法名。參數類型和返回值必須和原方法一致
• blockHandlerClass：自定義限流邏輯處理類

//經過註解限流並自定義限流邏輯
 @SentinelResource(value = "resource2", blockHandler = "handleException", blockHandlerClass = {ExceptionUtil.class})
 @RequestMapping("/sentinel/test2")
    public Map<String,Object> test2() {
        Map<String,Object> map=new HashMap<>();
        map.put("method","test2");
        map.put("msg","自定義限流邏輯處理");
        return  map;
    }

public class ExceptionUtil {

    public static Map<String,Object> handleException(BlockException ex) {
        Map<String,Object> map=new HashMap<>();
        System.out.println("Oops: " + ex.getClass().getCanonicalName());
        map.put("Oops",ex.getClass().getCanonicalName());
        map.put("msg","經過@SentinelResource註解配置限流埋點並自定義處理限流後的邏輯");
        return  map;
    }
}
複製代碼

控制檯新增resource2的限流規則並設置閥值爲1。訪問http://localhost:18084/sentinel/test2 請求到達閥值時機會返回自定義的異常消息

基本的限流處理就完成了。 可是每次服務重啓後 以前配置的限流規則就會被清空由於是內存態的規則對象.因此下面就要用到Sentinel一個特性ReadableDataSource 獲取文件、數據庫或者配置中心是限流規則

讀取文件的實現限流規則

一條限流規則主要由下面幾個因素組成：

• resource：資源名，即限流規則的做用對象
• count: 限流閾值
• grade: 限流閾值類型（QPS 或併發線程數）
• limitApp: 流控針對的調用來源，若爲 default 則不區分調用來源
• strategy: 調用關係限流策略
• controlBehavior: 流量控制效果（直接拒絕、Warm Up、勻速排隊） SpringCloud alibaba集成Sentinel後只須要在配置文件中進行相關配置，便可在 Spring 容器中自動註冊 DataSource，這點很方便。配置文件添加以下配置

#經過文件讀取限流規則
spring.cloud.sentinel.datasource.ds1.file.file=classpath: flowrule.json
spring.cloud.sentinel.datasource.ds1.file.data-type=json
spring.cloud.sentinel.datasource.ds1.file.rule-type=flow
複製代碼

在resources新建一個文件 好比flowrule.json 添加限流規則

[
  {
    "resource": "resource",
    "controlBehavior": 0,
    "count": 1,
    "grade": 1,
    "limitApp": "default",
    "strategy": 0
  },
  {
    "resource": "resource3",
    "controlBehavior": 0,
    "count": 1,
    "grade": 1,
    "limitApp": "default",
    "strategy": 0
  }
]

複製代碼

從新啓動項目。出現以下日誌說明文件讀取成功

[Sentinel Starter] DataSource ds1-sentinel-file-datasource start to loadConfig
 [Sentinel Starter] DataSource ds1-sentinel-file-datasource load 2 FlowRule
複製代碼

刷新Sentinel 控制檯 限流規則就會自動添加進去

Sentinel的配置

spring.cloud.sentinel.enabled              #Sentinel自動化配置是否生效
spring.cloud.sentinel.eager               #取消Sentinel控制檯懶加載
spring.cloud.sentinel.transport.dashboard   #Sentinel 控制檯地址
spring.cloud.sentinel.transport.heartbeatIntervalMs        #應用與Sentinel控制檯的心跳間隔時間
spring.cloud.sentinel.log.dir            #Sentinel 日誌文件所在的目錄
複製代碼

• 源碼：github.com/a870439570/…
• 我的博客：blog.qinxuewu.club/