Spring Cloud Alibaba 的學習之熔斷篇

什麼是服務雪崩

在微服務架構中，根據業務來拆分成一個個的服務，服務與服務之間可以通過 HTTP/RPC 互相調用，在 Spring Cloud 中可以用 RestTemplate + LoadBalanceClient 和 Feign 來調用。為了保證其高可用，單個服務通常會叢集部署。由于網絡原因或者自身的原因，服務并不能保證 100% 可用，如果單個服務出現問題，調用這個服務就會出現線程阻塞，此時若有大量的請求湧入，Servlet 容器的線程資源會被消耗完畢，導緻服務癱瘓。服務與服務之間的依賴性，故障會傳播，會對整個微服務系統造成災難性的嚴重後果，這就是服務故障的 “雪崩” 效應。為了解決這個問題，業界提出了熔斷器模型。

Sentinel

阿裡巴巴開源了 Sentinel 元件，實作了熔斷器模式，Spring Cloud 對這一元件進行了整合。在微服務架構中，一個請求需要調用多個服務是非常常見的。較底層的服務如果出現故障，會導緻連鎖故障。當對特定的服務的調用的不可用達到一個閥值熔斷器将會被打開，熔斷器打開後，為了避免連鎖故障，通過 fallback 方法可以直接傳回一個固定值。

Sentinel 的特征

豐富的應用場景： Sentinel 承接了阿裡巴巴近 10 年的雙十一大促流量的核心場景，例如秒殺（即突發流量控制在系統容量可以承受的範圍）、消息削峰填谷（對于突然到來的大量請求，您可以配置流控規則，以穩定的速度逐漸處理這些請求，進而避免流量突刺造成系統負載過高）、叢集流量控制、實時熔斷下遊不可用應用等
完備的實時監控： Sentinel 同時提供實時的監控功能。您可以在控制台中看到接入應用的單台機器秒級資料，甚至 500 台以下規模的叢集的彙總運作情況
廣泛的開源生态： Sentinel 提供開箱即用的與其它開源架構 / 庫的整合子產品，例如與 Spring Cloud、Dubbo、gRPC 的整合。您隻需要引入相應的依賴并進行簡單的配置即可快速地接入 Sentinel
完善的 SPI 擴充點： Sentinel 提供簡單易用、完善的 SPI 擴充接口。您可以通過實作擴充接口來快速地定制邏輯。例如定制規則管理、适配動态資料源等

Spring Cloud Alibaba 的學習之熔斷篇

Sentinel控制台

從官方 GitHub Release 頁面頁面下載下傳最新版本的控制台 JAR 包。

啟動

注意：啟動 Sentinel 控制台需要 JDK 版本為 1.8 及以上版本

java -Dserver.port=8080 -Dcsp.sentinel.dashboard.server=localhost:8080 -Dproject.name=sentinel-dashboard -jar sentinel-dashboard-1.6.3.jar

其中 -Dserver.port=8080 用于指定 Sentinel 控制台端口為 8080

注意：從 Sentinel 1.6.0 起，Sentinel 控制台引入基本的登入功能，預設使用者名和密碼都是 sentinel

鑒權

使用者可以通過如下參數進行配置

-Dsentinel.dashboard.auth.username=sentinel 用于指定控制台的登入使用者名為 sentinel
-Dsentinel.dashboard.auth.password=123456 用于指定控制台的登入密碼為 123456；如果省略這兩個參數，預設使用者和密碼均為 sentinel
-Dserver.servlet.session.timeout=7200 用于指定 Spring Boot 服務端 session 的過期時間，如 7200 表示 7200 秒；60m 表示 60 分鐘，預設為 30 分鐘
驗證安裝是否成功

通過浏覽器通路 http://localhost:8080/#/login

賬号： sentinel

密碼： sentinel

用戶端接入

POM:

<dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
        </dependency>

YML:

spring:
 application:
   name: consumer-reset

 cloud:
   nacos:
     discovery:
       server-addr: 192.168.233.150:8848
       # 熔斷限流
   sentinel:
     transport:
       dashboard: localhost:8888
#開啟 Feign 對 Sentinel 的支援
feign:
 sentinel:
   enabled: true
server:
 port: 12000

management:
 endpoints:
   web:
     exposure:
       include: "*"

配置熔斷類

編寫一個 Feign 接口的實作類并增加 @Component 注解

@Component
public class ResetServiceFallback implements ResetService {
    @Override
    public List initPuzzle() {
        return Arrays.asList("500");
    }
}

修改 Feign 接口

在 @FeignClient 接口上增加 fallback 屬性指定熔斷類即可

@FeignClient(value = "puzzle-provider",fallback = ResetServiceFallback.class)
public interface ResetService {
    @GetMapping(value = "init")
    List initPuzzle();
}

測試熔斷

啟動 consumer-reset服務并停止 puzzle-provider 服務，通過浏覽器通路http://localhost:12000/reset