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 擴展接口。您可以通過實現擴展接口來快速地定制邏輯。例如定制規則管理、適配動態數據源等
  

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