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

最新推荐文章于 2023-11-15 11:40:45 发布

红枫忆梦

最新推荐文章于 2023-11-15 11:40:45 发布

阅读量320

点赞数

分类专栏： Spring Cloud 文章标签： spring cloud alibaba sentinel

本文链接：https://blog.csdn.net/houwanle/article/details/115471553

版权

Spring Cloud 专栏收录该内容

27 篇文章

订阅专栏

本文介绍了阿里巴巴Sentinel在Spring Cloud中的应用，涵盖流控规则、安装控制台、初始化微服务实例，以及如何实现服务限流、降级和雪崩防护。通过实例演示，展示了如何配置流控模式，理解预热机制，并在实际场景中使用Sentinel进行流量控制。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

1. 概述

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

在这里插入图片描述

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

能干嘛
在这里插入图片描述

使用
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
在这里插入图片描述

运行命令
前提

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控制台
在这里插入图片描述

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

效果
在这里插入图片描述

4. 流控规则

基本介绍
在这里插入图片描述

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

4.1 流控模式

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

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

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

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

postman模拟并发密集访问testB
访问testB成功
在这里插入图片描述
postman里新建多线程集合组

将访问地址添加进新线程组

大批量线程高并发访问B，导致A失效了

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

新增方法
在这里插入图片描述
两个方法调用一个资源

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
Warmup配置
默认coldFactor为3，即请求QPS从（threshold/3）开始，经多少预热时长才逐渐升至设定的QPS阈值。
阈值为10+ 预热时长设置5秒
系统初始化的阈值为10/3 约等于3，即阈值刚开始为3；然后过了5秒以后慢慢升高至10