快捷導(dǎo)航

Sentinel 整合SpringCloud的詳細(xì)教程

更新時(shí)間：2021年10月31日 09:40:06 作者：Vermeer

Spring Cloud Alibaba Sentinel 是阿里巴巴提供的，致力于提供微服務(wù)一站式解決方案，這篇文章主要介紹了Sentinel 之整合SpringCloud的相關(guān)知識(shí),需要的朋友可以參考下

Spring Cloud Alibaba Sentinel 是阿里巴巴提供的，致力于提供微服務(wù)一站式解決方案，Spring Cloud Alibaba 默認(rèn)為 Sentinel 整合了，ServeLet、RestTemplate、FeignClient 和 Spring Flux。在 Spring 的生態(tài)中不僅不全了 Hystrix 在 ServeLet 和 RestTemplate 這一塊的空白，而且還完美的兼容了 Hystrix 在 Feign 中的限流降級(jí)用法，并支持運(yùn)行時(shí)靈活的配置和調(diào)整限流降級(jí)規(guī)則。

引入依賴：

<!--Sentinel 整合SpringCloud 的依賴-->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-alibaba-sentinel</artifactId>
    <version>2.2.0.RELEASE</version>
</dependency>

配置文件：

（入門使用中，應(yīng)用名稱使用的 JVM 參數(shù)設(shè)置的，整合 SpringCloud 就不需要那樣了,配置文件中配置了應(yīng)用的名稱后，Sentinel 會(huì)自動(dòng)加載）

# 設(shè)置應(yīng)用的名稱
spring:
  application:
    name: springCloudSentinel
  cloud:
    sentinel:
      transport:
 
        #設(shè)置Sentinel控制臺(tái)的主機(jī)地址和端口號(hào)
        dashboard: localhost:9000

編寫測(cè)試 Controller ，控制臺(tái)添加 Sentinel_Cloud 資源限流測(cè)試

@SentinelResource(value = "Sentinel_Cloud",blockHandler = "exceptionHandler")
@GetMapping("/sentinelCloud")
public String sentinelCloud(){
    //使用限流規(guī)則
    return "Sentinel_Cloud,成功調(diào)用";
}

限流時(shí)調(diào)用的方法：

/**
 * 定義降級(jí) / 限流 的處理函數(shù)
 *
 * @param exception
 * @return
 */
public String exceptionHandler(BlockException exception) {
    exception.printStackTrace();
    return "Sentinel_Cloud,訪問(wèn)限流";
}

Sentinel整合Feign （OpenFeign）

Sentinel適配了Feign組件。如果想要使用，除了引用spring-cloud-starter-alibaba-sentinel的依賴，還需要兩個(gè)步驟：

配置打開Sentinel對(duì)Feign的支持：feign.sentinel.enable=true

加入spring-cloud-starter-openfeign依賴使Sentinel starter自動(dòng)化配置類生效。

# 設(shè)置應(yīng)用的名稱
spring:
  application:
    name: springCloudSentinel
  cloud:
    sentinel:
      transport:
 
        #設(shè)置Sentinel控制臺(tái)的主機(jī)地址和端口號(hào)
        dashboard: localhost:9000
 
# 開啟 Sentinel 對(duì) Feign 的支持
feign:
  sentinel:
    enabled: true

服務(wù)端調(diào)用方Controller

@GetMapping("/feignHello")
public String feignHello(){
    return feignClient.feignHello();
}

服務(wù)提供方 FeignClient

@FeignClient(contextId = "testFeignClient", value = "注冊(cè)中心中服務(wù)的名稱", fallback = FeignFallbackService.class)
public interface TestFeignClient {
 
   /**
    * OpenFeign 遠(yuǎn)程調(diào)用的方法
    *
    * @return
    */
   @GetMapping("/test/feignHello")
   String feignHello();
}

提供一個(gè) FeignClient 接口的實(shí)現(xiàn)類，作為限流的處理方法

@Service
public class FeignFallbackService  implements TestFeignClient{
   @Override
   public String feignHello() {
      return "Feign 遠(yuǎn)程調(diào)用限流了";
   }
}

Sentinel 控制臺(tái)添加限流規(guī)則：

請(qǐng)求方式：http://服務(wù)模塊注冊(cè)中心名稱/test/feignHello