微服务组件详解——sentinel

发布于:2025-02-28 ⋅ 阅读:(18) ⋅ 点赞:(0)

1.启动sentinel:

下载jar sentinel-dashboard-1.8.0.jar

使用以下命令直接运行 jar 包(JDK 版本必须≥ 1.8):

java -Dserver.port=9999 -jar D:\sentinel-dashboard-1.8.0.jar

控制台访问地址:http://localhost:9999,默认账号密码都为 sentinel/sentinel

1.导入依赖:
<dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
2.在alibaba-user-consumer-8090项目的application.yml编写代码
spring:
  cloud:
    sentinel:
      transport:
        port: 8719 #sentinel控制台端口
        dashboard: 127.0.0.1:9999 #sentinel控制台地址
      enable: true #开启sentinel 默认true
      eager: true #取消控制台懒加载 立即初始化
3.监控

这个是实时刷新的,所以点击网址之后等几秒就行

2.流量控制

普通流控:

资源名:请求路径

阈值类型: QPS: 即每秒查询率, 线程数:用

因为是用手测试,所以选QPS

效果:会显示429代表 “Too Many Requests”,即 “请求过多”

关联:(反向关联):

点击高级选项

当sout的阈值超过到1时,demo不可用。(吧demo的资源节省出来给sout)

流控效果:

快速失败:抛异常

方式是默认的流量控制方式,当QPS超过任意规则的阈值后,新的请求就会被立即拒绝,拒绝方

式为抛出 FlowException 。

WarmUp:慢慢增加到阈值

WarmUp 旨在避免因为流量突增或系统负载过高导致的拒绝服务问题。通过“热身”过程,系统逐步适应流量的增加,避免瞬间流量过载。

通过动态控制请求的通过率(例如,限制请求的通过比例),逐渐放开流量限制,避免系统立即面对过多请求的压力。

例如,可以设定初始通过率为 20%,然后逐步提升到 100%,这样系统就能平稳适应流量增长。

排队等待:匀速排队处理

排队等待 是 Sentinel 提供的另一种流量控制策略,用于限制并发请求的数量,并确保在系统负载较高时不会直接拒绝请求,而是让请求在队列中等待,直到系统能够处理它们。

注意:匀速排队模式暂时不支持 QPS > 1000 的场景

3.熔断降级:

这里还没写熔断降级的方法,

选项解析:

最大RT:默认毫秒,请求超出时长

比例阈值:: 当每秒请求量>=N(可配置),并且每秒异常总数占通过量的比值超过阈值之后,进入降级状

态。取值范围[0.0,1.0] 代表0%-100%(如:设置为0.2,如果请求异常数超过20%则进入降级)

最小请求数:请求数小于该值时即使异常比率超出阈值也不会熔断

熔断策略:
1.慢调用比例:

当单位统计时长

( statIntervalMs )内请求数目大于设置的最小请求数目,并且慢调用的比例大于阈值,则接

下来的熔断时长内请求会自动被熔断降级。

2.异常比例:

请求异常数超过0.2(20%)就降级

3.异常数:

当单位统计时长内的异常数目超过阈值之后会自动进行熔断。经过熔断

时长后熔断器会进入探测恢复状态(HALF-OPEN 状态),若接下来的一个请求成功完成(没有错

误)则结束熔断,否则会再次被熔断。

4.热点参数限流:

热点参数限流例子:比如说id为3的商品特别火爆,需要进行限流,但是其他id的商品一般不需要限流

资源名:需要在consumer中的方法上设置@SentinelResource注解

参数索引:就是第几个参数,从0开始

单机阈值:就是正常情况下允许的点击量

限流阈值:就是限流情况下允许的点击量

5.@SentinelResource

@SentinelResource 用于定义资源,并提供可选的异常处理和 fallback 配置项。 @SentinelResource

注解包含以下属性:

value:资源名称,必需项(不能为空)

entryTypeentry 类型,可选项(默认为 EntryType.OUT)

blockHandler / blockHandlerClass: blockHandler 对应处理 BlockException 的函数名称,可

选项。blockHandler 函数访问范围需要是 public,返回类型需要与原方法相匹配,参数类型需要

和原方法相匹配并且最后加一个额外的参数,类型为 BlockException。blockHandler 函数默认需

要和原方法在同一个类中。若希望使用其他类的函数,则可以指定 blockHandlerClass 为对应的

类的 Class 对象,注意对应的函数必需为 static 函数,否则无法解析。

fallback:fallback 函数名称,可选项,用于在抛出异常的时候提供 fallback 处理逻辑。fallback

函数可以针对所有类型的异常(除了 exceptionsToIgnore 里面排除掉的异常类型)进行处理。

fallback 函数签名和位置要求:

返回值类型必须与原函数返回值类型一致;

方法参数列表需要和原函数一致,或者可以额外多一个 Throwable 类型的参数用于接收对应的异

常。

fallback 函数默认需要和原方法在同一个类中。若希望使用其他类的函数,则可以指定

fallbackClass 为对应的类的 Class 对象,注意对应的函数必需为 static 函数,否则无法解析。

defaultFallback(since 1.6.0):默认的 fallback 函数名称,可选项,通常用于通用的 fallback

逻辑(即可以用于很多服务或方法)。默认 fallback 函数可以针对所以类型的异常(除了

exceptionsToIgnore 里面排除掉的异常类型)进行处理。若同时配置了 fallback 和

defaultFallback,则只有 fallback 会生效。defaultFallback 函数签名要求:

返回值类型必须与原函数返回值类型一致;

方法参数列表需要为空,或者可以额外多一个 Throwable 类型的参数用于接收对应的异常。

defaultFallback 函数默认需要和原方法在同一个类中。若希望使用其他类的函数,则可以指定

fallbackClass 为对应的类的 Class 对象,注意对应的函数必需为 static 函数,否则无法解析。

exceptionsToIgnore(since 1.6.0):用于指定哪些异常被排除掉,不会计入异常统计中,也不会

进入 fallback 逻辑中,而是会原样抛出

fallback属性:

因为使用热点参数限流以后如果超了阈值就会报500,ParamFlowException异常,所以我们要处理这个异常

注意:
  1. fallback 方法可以在同一个类中定义,也可以在其他类中定义。如果在其他类中定义,则需要通过 fallbackClass 属性指定该类
  2. 返回类型:fallback 方法的返回类型必须与被保护的方法相同
  3. fallback 方法应该为 public,以便 Sentinel 框架能够调用它
  4. 参数列表:fallback 方法可以有以下几种参数组合:不带参数。只有一个 Throwable 类型的参数,用于接收捕获到的异常。包含原始方法的所有参数和一个 Throwable 类型的参数。
    @SentinelResource(value = "demo",fallback = "fallback")
    @GetMapping("/demo")
    public ResultAJAX demo(Integer id) {
        System.out.println("这是方法demo——————————————————————————————"+id);

        return ResultAJAX.success();
    }

    public ResultAJAX fallback(Integer id) {
        return ResultAJAX.error("这是方法fallback,用来解决ParamFlowException异常");
    }

这样就不会直接报500,而是报我们自定义设置的message

blockHandler属性:

blockHandler 对应处理 BlockException 的函数名称,可选项。blockHandler 函数访问范围需要是 public,返回类型需要与原方法相匹配,参数类型需要 和原方法相匹配并且最后加一个额外的参数,类型为 BlockException。blockHandler 函数默认需要和原方法在同一个类中。若希望使用其他类的函数,则可以指定 blockHandlerClass 为对应的 类的 Class 对象,注意对应的函数必需为 static 函数,否则无法解析。

ParamFlowException 热点参数异常

DegradeException熔断降级异常

FlowException流控异常处理

    @SentinelResource(value = "demo",blockHandler = "blockHandler")//
    @GetMapping("/demo")
    public ResultAJAX demo(Integer id) {
        System.out.println("这是方法demo——————————————————————————————"+id);

        return ResultAJAX.success();
    }

    public ResultAJAX blockHandler(Integer id, BlockException e) {
            //异常类型判断
        //流控异常
        if (e instanceof FlowException) {
            return ResultAJAX.error("ParamFlowException异常流控异常处理");
        }
        //熔断降级异常处理
        if (e instanceof DegradeException) {
            return ResultAJAX.error("熔断降级处理");
        }
        //热点参数异常
        if (e instanceof ParamFlowException) {
            return ResultAJAX.error("ParamFlowException异常流控异常处理");
        }


            return ResultAJAX.error("系统异常"+id);
    }

6.基于nacos配置中心进行规则持久化:

sentinel利用nacos做持久化,然后nacos再做持久化

<!--sentinel利用nacos做持久化-->
<dependency>
<groupId>com.alibaba.csp</groupId>
<artifactId>sentinel-datasource-nacos</artifactId>
</dependency>

流量控制配置:

spring:
  cloud:
    sentinel:
      datasource:
        ds1:
          nacos:
            server-addr: 127.0.0.1:8848 #nacos地址
            data-id: ${spring.application.name}-flow
             #naocs中配置文件名称,对应服务名,可随意填写(和配置中文文件一致即可)
            group-id: DEFAULT_GROUP #文件分组
            data-type: json #使用json格式
            rule-type: flow #使用flow限流

在配置中心配置:

流量控制,热点参数,熔断降级配置:

resource:资源名称

limitApp:来源应用

grade:阈值类型,0表示线程数,1表示QPS

count:单机阈值

strategy:流控模式,0表示直接,1表示关联,2表示链路

controlBehavior:流控效果,0表示快速失败,1表示Warm Up,2表示排队等待

clusterMode:是否集群

nacos-consume-flow配置:限流配置
[
{
"resource": "demo",
"limitApp": "default",
"grade": 1,
"count": 2,
"strategy": 0,
"controlBehavior": 0,
"clusterMode": false
}
]

bill-consumer-degrade配置:熔断降级
[
{
"resource": "abc",
"grade": 0,
"count": 2,
"timeWindow": 1,
"minRequestAmount": 1,
"statIntervalMs": 5
}
]

bill-consumer-7790-param-flow 配置:热点参数限流配置
[
{
"resource": "abc",
"paramIdx": 0,
"count": 10,
"burst": 5,
"duration": 1,
"controlBehavior": 0,
"maxQueueingTimeMs": 500
}
]

yml配置:

spring:
  application:
    name: nacos-consume
  cloud:
    sentinel:
      transport:
        port: 8719 #sentinel控制台端口
        dashboard: 127.0.0.1:9999 #sentinel控制台地址
      enable: true #开启sentinel 默认true
      eager: true #取消控制台懒加载 立即初始化
      datasource:
        ds1: #限流配置
          nacos:
            server-addr: 127.0.0.1:8848 #nacos地址
            data-id: "${spring.application.name}-flow" #naocs中配置文件名称,对应服务名,可随意填写(和配置中文文件一致即可)
            group-id: DEFAULT_GROUP #文件分组
            data-type: json #使用json格式
            rule-type: flow #使用flow限流
        ds2: #熔断降级配置
          nacos:
            server-addr: 127.0.0.1:8848
            data-id: "${spring.application.name}-degrade"
            group-id: DEFAULT_GROUP
            data-type: json
            rule-type: degrade #指定为熔断降级规则
        ds3: #热点参数限流配置
          nacos:
            server-addr: 127.0.0.1:8848
            data-id: "${spring.application.name}-param-flow"
            group-id: DEFAULT_GROUP
            data-type: json
            rule-type: param-flow

能够在sentinel里面看到持久化的