spring cloud微服務快速教程之(九) Spring Cloud Alibaba--sentinel-限流、熔斷降級


0、前言

  sentinel的限流、降級功能強大,可以在控制面板中任意制定規則,然后推送到微服務中;

  可以根據URL單獨制定規則,也可以根據資源名批量制定規則;

  需要注意的地方是:1、GITHUB文件在國外的亞馬遜服務器已經徹底被牆,無法下載,只能想法找國內的分享,自求多福

           2、控制面板制定的規則只保存在內存中,重啟就會消失,需要配合其他方式實現持久化存儲規則,這點在生產環境中需要注意

1、運行sentinel

  sentinel只是一個JAR包,下載下來后,直接命令運行該JAR就行,默認的端口是8080,可以自己制定其他端口運行,如下指定8849端口運行:

java  -Dserver.port=8849  -jar   sentinel-dashboard-1.6.3.jar

 

2、項目集成

  這里需要先搞清楚:

    限流:就是請求多了,對請求進行定制的快速響應處理,應用在服務提供者本身

    降級:就是熔斷了,再簡單點說就相當於服務斷開了、服務不可用了,服務崩潰了,

         所以降級邏輯應該應用在消費者(調用者)那里,加在服務提供者本身是毫無意義的,因為服務已經斷開了

  一般我們在項目中:

    1、限流和熔斷都可以直接在網關統一處理,不需要在微服務本身做限流處理,

    2、但在微服務調用其他微服務時,還是需要增加熔斷處理的,這其實是兩個層級API調用的熔斷;

    3、所以,一般情況下,網關spring cloud gateway 中做限流和一級熔斷,在微服務內部調用時hystrix做二級熔斷;

    4、不是項目比較龐大,需要控制比較細致的話,sentinel其實比較雞肋,用處不大,用hystrix更方便更實用,如果是大型電商,要對每個API都就精確細致控制,那可以考慮sentinel,否則,個人還是不建議使用的,使用以上組合更貼合實際;

 

2-1、限流

2-1-1、添加依賴

        <!-- 集成sentinel -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
            <version>2.0.1.RELEASE</version>
        </dependency>

2-1-2、添加配置

  這里需要注意:項目集成sentinel,會占用一個端口開啟http服務,用來發送心跳檢測以檢測健康狀態,

  sentinel控制台默認占用的是8719;集成的項目中,會在8719端口以后自動需找一個可用的端口,比如8720,8720不可用就會找8721,以此順序往下找;

  有些人直接在配置文件中指定該HTTP服務端口:如sentinel.port=8720;這種方式很不推薦,因為我們的系統包含很多服務,沒個服務又會啟動很多實例,如果要指定的話那那么多個實例都要一一配置,還要避免端口沖突,工作量大很繁瑣,且容易混亂;

  所以,不要認為指定該端口,讓系統自動去找可用端口即可,並且我們在端口分配時,可以避開8700-8800這兩個段的端口,應對大型集群,留給它預留好了,端口多的是

server:
  port: 8761
spring:
  application:
    name: nacos-user
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848

    sentinel:
      transport:
        dashboard: localhost:8849
      eager: true

 

2-1-3、controller中增加限流

   在方法上增加@SentinelResource注解,
  value是資源名稱,對應sentinel中指定的一個規則,多個方法可以使用同一個名稱,也就是批量應用規則
  blockHandler是限流后執行的方法名;
   @RequestMapping("/hello")
    @SentinelResource(value = "userblock1",blockHandler = "BlockHello")  //sentinel限流
    public  String Hello()
    {
        return  ("hello world" +serviceUtil.getPort());
    }

    //-----------限流、降級的handler-----------------
    public  String BlockHello(BlockException exception)   //1、限流
    {
        return  ("少年,限流了 --Port:" +serviceUtil.getPort());
    }
    //---------------------------------------------

 

2-1-4、運行測試

   1、運行程序,執行一次user/hello方法

   2、在sentinel控制面板中,增加userblock1的限流規則,再次運行/user/hello,就可以看到效果:

 

 

 

 

 

 2-2、熔斷降級(feign的方式)

2-2-1、添加依賴

        <!-- 集成sentinel -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
            <version>2.0.1.RELEASE</version>
        </dependency>

        <!-- 集成feign -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>

 

2-2-2、增加配置

server:
  port: 8765
spring:
  application:
    name: nacos-order
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848
    sentinel:
      transport:
        dashboard: localhost:8849
      eager: true
feign:
  sentinel:
    enabled: true #打開sentinel對feign的支持

 

2-2-3、實現

 增加feign接口

@FeignClient(name = "nacos-user",fallback = UserFallbackService.class)
public interface UserClient
{
    @RequestMapping("/user/hello")
    String hello();
}

 增加實現類

@Component
public class UserFallbackService implements UserClient
{
    @Override
    public String hello()
    {
        String rt="";
        rt="少年,服務被降級停用了,等等再來吧!!";
        return  rt;
    }
}

controller注入使用

    @Autowired
    private UserClient userClient;

    @RequestMapping("/order2")
    public  String order2()
    {
        return userClient.hello();
    }

 

2-2-4、運行測試

啟動order,不啟動user,運行order/order2,可以看到運行結果

 

sentinel就是這么簡單靈活, 持久化和集群處理后續再來探討

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM