Spring Cloud（二十三）：Sentinel流控规则

不念不忘少年蓝@ 2022-11-16 10:38 183阅读 0赞

## 1. 概述 ##

官网：https://github.com/alibaba/Sentinel  
中文：https://github.com/alibaba/Sentinel/wiki/%E4%BB%8B%E7%BB%8D

![在这里插入图片描述][2021040621265590.png]

下载：https://github.com/alibaba/Sentinel/releases

**能干嘛**  
![在这里插入图片描述][20210406212748170.png]

**使用**  
https://spring-cloud-alibaba-group.github.io/github-pages/greenwich/spring-cloud-alibaba.html\#\_spring\_cloud\_alibaba\_sentinel

**服务使用中的各种问题**

*  服务雪崩
 *  服务降级
 *  服务熔断
 *  服务限流

## 2. 安装Sentinel控制台 ##

**sentinel组件由2部分组成**

*  核心库（JAVA客户端）不依赖任何框架/库，能够运行与所有JAVA运行时环境，同时对Dubbo/Spring Cloud 等框架也有较好的支持
 *  控制台（Dashboard）基于Spring Boot开发，打包后可以直接运行，不需要额外的Tomcat等应用容器。

**下载**  
https://github.com/alibaba/Sentinel/releases  
![在这里插入图片描述][20210406213252978.png]

**运行命令**  
前提

*  java8环境
 *  8080端口不能被占用

命令

java -jar sentinel-dashboard-1.7.0.jar

访问sentinel管理界面：http://localhost:8080

登录账号密码均为sentinel

## 3. 初始化演示工程 ##

启动Nacos8848

**新建Module**  
cloudalibaba-sentinel-service8401

**POM**

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <parent>
            <artifactId>spring-cloud-demo</artifactId>
            <groupId>com.lele.springcloud</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>cloudalibaba-sentinel-service8401</artifactId>
    
        <dependencies>
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            </dependency>
            
            <dependency>
                <groupId>com.alibaba.csp</groupId>
                <artifactId>sentinel-datasource-nacos</artifactId>
            </dependency>
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-openfeign</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
    
            <dependency>
                <groupId>com.lele.springcloud</groupId>
                <artifactId>cloud-api-commons</artifactId>
                <version>${project.version}</version>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <scope>runtime</scope>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>cn.hutool</groupId>
                <artifactId>hutool-all</artifactId>
                <version>5.1.0</version>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>
    </project>

**yml**

server:
      port: 8401
    
    spring:
      application:
        name: cloudalibaba-sentinel-service
      cloud:
        nacos:
          discovery:
            #nacos服务注册中心地址
            server-addr: localhost:8848
        sentinel:
          transport:
            #配置sentinel dashboard地址
            dashboard: localhost:8080
            #默认8719端口，假如被占用会自动从8719开始依次+1扫描，直至找到未被占用的端口
            port: 8719
    management:
      endpoints:
        web:
          exposure:
            include: '*'

**主启动类**

package com.lele.springcloud.alibaba;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    /**
     * @author: lele
     * @date: 2021/4/6 22:13
     * @description:
     */
    @SpringBootApplication
    @EnableDiscoveryClient
    public class MainApp8401 {
        
        public static void main(String[] args) {
        
            SpringApplication.run(MainApp8401.class, args);
        }
    }

**业务类**

package com.lele.springcloud.alibaba.controller;
    
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    /**
     * @author: lele
     * @date: 2021/4/6 22:16
     * @description:
     */
    @RestController
    public class FlowLimitController {
        
    
        @GetMapping("/testA")
        public String testA() {
        
            return "------testA";
        }
    
        @GetMapping("/testB")
        public String testB() {
        
            return "------testB";
        }
    }

**启动微服务8401**

**启动8401微服务后查看sentienl控制台**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70]

**Sentinel采用的懒加载说明**  
执行一次访问即可  
http://localhost:8401/testA  
http://localhost:8401/testB

**效果**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 1]

## 4. 流控规则 ##

**基本介绍**  
![在这里插入图片描述][202104062235265.png]

*  资源名：唯一名称，默认请求路径
 *  针对来源：Sentinel可以针对调用者进行限流，填写微服务名，默认default（不区分来源）
 *  阈值类型/单机阈值：
    
     *  QPS（每秒的请求数量）：当调用该API的QPS达到阈值的时候，进行限流
     *  线程数：当调用该API的线程数达到阈值的时候，进行限流
 *  流控模式：
    
     *  直接：api达到限流条件时，直接限流
     *  关联：当关联的资源达到阈值时，就限流自己
     *  链路：只记录指定链路上的流量（指定资源从入口资源进来的流量，如果达到阈值，就进行限流【api级别的针对来源】）
 *  流控效果：
    
     *  快速失败：直接失败，抛异常
     *  Warm Up：根据codeFactor（冷加载因子，默认3）的值，从阈值/codeFactor，经过预热时长，才达到设置的QPS阈值
     *  排队等待：匀速排队，让请求以匀速的速度通过，阈值类型必须设置为QPS，否则无效

### 4.1 流控模式 ###

**直接（默认）**  
配置及说明：  
![在这里插入图片描述][20210407072327287.png]  
一秒内可以查询一次，若次数超过1次，就直接快速失败，报默认错误。

测试：  
快速点击访问http://localhost:8401/testA  
![在这里插入图片描述][20210407072514965.png]

**关联**  
当关联的资源达到阈值时，就限流自己  
当与A关联的资源B达到阈值后，就限流自己

配置A  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 2]  
当关联资源/testB的qps阈值超过1时，就限流/testA的Rest访问地址，当关联资源到阈值后限制配置好的资源名

postman模拟并发密集访问testB  
访问testB成功  
![在这里插入图片描述][20210407072701582.png]  
postman里新建多线程集合组  
![在这里插入图片描述][20210407072726872.png]  
将访问地址添加进新线程组  
![在这里插入图片描述][20210407072754610.png]  
大批量线程高并发访问B，导致A失效了  
![在这里插入图片描述][20210407072822558.png]

**链路**  
多个请求调用了同一个微服务

新增方法  
![在这里插入图片描述][20210410111541334.png]  
两个方法调用一个资源  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 3]

### 4.2 流控效果 ###

**直接->快速失败（默认的流控处理）**

*  直接失败，抛出异常：Blocked by Sentinel (flow limiting)
 *  源码：com.alibaba.csp.sentinel.slots.block.flow.controller.DefaultController

**预热**

*  说明  
    公式：阈值除以coldFactor（默认值为3），经过预热时长后才会达到阈值
 *  官网  
    默认coldFactor为3，即请求QPS从threshold/3开始，经预热时长逐渐升至设定的QPS阈值。  
    限流 冷启动  
    https://github.com/alibaba/Sentinel/wiki/%E9%99%90%E6%B5%81—%E5%86%B7%E5%90%AF%E5%8A%A8
 *  源码  
    com.alibaba.csp.sentinel.slots.block.flow.controller.WarmUpController  
    ![在这里插入图片描述][20210410112437666.png]
 *  Warmup配置  
    默认coldFactor为3，即请求QPS从（threshold/3）开始，经多少预热时长才逐渐升至设定的QPS阈值。  
    阈值为10+ 预热时长设置5秒  
    系统初始化的阈值为10/3 约等于3，即阈值刚开始为3；然后过了5秒以后慢慢升高至10

![在这里插入图片描述][20210410113221771.png]

*  应用场景  
    如：秒杀系统在开启的瞬间，会有很多流量上来，很有可能把系统打死，预热方式就是把为了保护系统、可以慢慢的把流量放进来，慢慢的把阈值增长到设置的阈值

**排队等待**  
匀速排队，阈值必须设置为QPS

![在这里插入图片描述][20210410113855390.png]

*  源码com.alibaba.csp.sentinel.slots.block.flow.controller.RateLimiterController

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 4]

[2021040621265590.png]: /images/20221022/03a2de72d6684b58b9b7c13d37427860.png
[20210406212748170.png]: /images/20221022/33450d8903e44d5ea48bf5a1ac1c7b67.png
[20210406213252978.png]: /images/20221022/315c76e159814ff8ae3ff7168fd605a9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70]: /images/20221022/be1e99818560431484f2a7811f7546ee.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 1]: /images/20221022/6cbe167e302c4682ab7a73f0442eb39d.png
[202104062235265.png]: /images/20221022/6bcc075c4d1e4b8aaca17c933a2e13f7.png
[20210407072327287.png]: /images/20221022/43df1d0d78b74be58c6428560cf886bb.png
[20210407072514965.png]: /images/20221022/eaaceefa95414761b843c70a805bd650.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 2]: /images/20221022/2a989ff2035d4852976675373bf32bf4.png
[20210407072701582.png]: /images/20221022/3539e4c35e8a46ba8792a7ab3d11c5e8.png
[20210407072726872.png]: /images/20221022/d94ce60f215447dbb61e2b45c3514311.png
[20210407072754610.png]: /images/20221022/0f6e4a8ea30c4cc4803683b49e0f0845.png
[20210407072822558.png]: /images/20221022/50b5a9767c7a4d859ed989a12ce277f6.png
[20210410111541334.png]: /images/20221022/677018d1ed0145b2a41bd300b6ef5169.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 3]: /images/20221022/4cb1833dcbb6408f82192f2a2f7f96b9.png
[20210410112437666.png]: /images/20221022/50f5893842474cbf9de1139b87d7f40b.png
[20210410113221771.png]: /images/20221022/e73bd5cff6fa44bda97acc866221ed76.png
[20210410113855390.png]: /images/20221022/571a0270cf2244e48ded596812102b6f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 4]: /images/20221022/94d6d43fcf3349cdbc7365f92c846742.png