springcloud笔记十sentinel

Posted 2021-10-09 今夜月色很美

sentinel dashboard

下载地址

https://github.com/alibaba/Sentinel/releases

启动dashboard

java -jar sentinel-dashboard-1.8.2.jar

登录dashboard

http://localhost:8080/

规则的种类

官网描述的非常详细。

https://sentinelguard.io/zh-cn/docs/basic-api-resource-rule.html

Sentinel 的所有规则都可以在内存态中动态地查询及修改，修改之后立即生效。同时 Sentinel 也提供相关 API，供您来定制自己的规则策略。

Sentinel 支持以下几种规则：流量控制规则、熔断降级规则、系统保护规则、来源访问控制规则 和 热点参数规则。

流量控制规则 (FlowRule)

流量规则的定义

重要属性：

Field	说明	默认值
resource	资源名，资源名是限流规则的作用对象
count	限流阈值
grade	限流阈值类型，QPS 或线程数模式	QPS 模式
limitApp	流控针对的调用来源	default，代表不区分调用来源
strategy	调用关系限流策略：直接、链路、关联	根据资源本身（直接）
controlBehavior	流控效果（直接拒绝 / 排队等待 / 慢启动模式），不支持按调用关系限流	直接拒绝

同一个资源可以同时有多个限流规则。

流控模式(直接)

单机阈值比较好理解，就是对QPS/线程数的控制。
QPS与线程数的区别在于：

• QPS(每秒的访问次数)，到达一定的阈值，就进行限流
• 线程数，调用该api的线程数达到阈值的时候，进行限流

流控模式(关联)

定义：当关联的资源达到阈值时，限流自己。
如当testB的QPS的阈值到达1的时候，testA就会被限流。

Warm Up

它的实现是在 Guava 的算法的基础上实现的。然而，和 Guava 的场景不同，Guava 的场景主要用于调节请求的间隔，即 Leaky Bucket，而 Sentinel 则主要用于控制每秒的 QPS，即我们满足每秒通过的 QPS 即可，我们不需要关注每个请求的间隔，换言之，我们更像一个 Token Bucket。

我们用桶里剩余的令牌来量化系统的使用率。假设系统每秒的处理能力为 b,系统每处理一个请求，就从桶中取走一个令牌；每秒这个令牌桶会自动掉落b个令牌。令牌桶越满，则说明系统的利用率越低；当令牌桶里的令牌高于某个阈值之后，我们称之为令牌桶"饱和"。

默认 coldFactor 为 3，即请求 QPS 从 threshold / 3 开始，经预热时长逐渐升至设定的 QPS 阈值。

例如如下配置流控规则是QPS从3开始，经过10s预热逐渐升至单机阈值10。

排队等待

Leaky Bucket 对应 流量整形 中的匀速器。它的中心思想是，以固定的间隔时间让请求通过。当请求到来的时候，如果当前请求距离上个通过的请求通过的时间间隔不小于预设值，则让当前请求通过；否则，计算当前请求的预期通过时间，如果该请求的预期通过时间小于规则预设的 timeout 时间，则该请求会等待直到预设时间到来通过（排队等待处理）；若预期的通过时间超出最大排队时长，则直接拒接这个请求。

这种方式适合用于请求以突刺状来到，这个时候我们不希望一下子把所有的请求都通过，这样可能会把系统压垮；同时我们也期待系统以稳定的速度，逐步处理这些请求，以起到“削峰填谷”的效果，而不是拒绝所有请求。

例如，如果系统使用 Apache RocketMQ 来收发消息，系统在某个时间突然收到大量消息。我们希望以固定的速率来处理消息，而不是一下子拒绝这些消息。这个时候可以使用匀速器，也就是给消息排队。

熔断策略

• 慢调用比例 (SLOW_REQUEST_RATIO)：选择以慢调用比例作为阈值，需要设置允许的慢调用 RT（即最大的响应时间），请求的响应时间大于该值则统计为慢调用。当单位统计时长（statIntervalMs）内请求数目大于设置的最小请求数目，并且慢调用的比例大于阈值，则接下来的熔断时长内请求会自动被熔断。经过熔断时长后熔断器会进入探测恢复状态（HALF-OPEN 状态），若接下来的一个请求响应时间小于设置的慢调用 RT 则结束熔断，若大于设置的慢调用 RT 则会再次被熔断。
• 异常比例 (ERROR_RATIO)：当单位统计时长（statIntervalMs）内请求数目大于设置的最小请求数目，并且异常的比例大于阈值，则接下来的熔断时长内请求会自动被熔断。经过熔断时长后熔断器会进入探测恢复状态（HALF-OPEN 状态），若接下来的一个请求成功完成（没有错误）则结束熔断，否则会再次被熔断。异常比率的阈值范围是 [0.0, 1.0]，代表 0% - 100%。
• 异常数 (ERROR_COUNT)：当单位统计时长内的异常数目超过阈值之后会自动进行熔断。经过熔断时长后熔断器会进入探测恢复状态（HALF-OPEN 状态），若接下来的一个请求成功完成（没有错误）则结束熔断，否则会再次被熔断。

热点参数限流

热点参数限流会统计传入参数中的热点参数，并根据配置的限流阈值与模式，对包含热点参数的资源调用进行限流。热点参数限流可以看做是一种特殊的流量控制，仅对包含热点参数的资源调用生效。

以下热点参数限流配置即意味着调用sentinel资源aa接口的时候，如果传了该方法第0个参数则进行热点参数限流计数，满足规则触发限流。

可以通过@SentinelResource设置资源点和兜底异常处理方法(仅热点规则兜底)，注意，定义兜底异常处理方法时，兜底方法参数列表和资源点参数列表一致，并在参数列表中添加BlockException。

	@GetMapping("/testParamKey")
    @SentinelResource(value = "aa", blockHandler = "deal_testParamKey")
    public String testParamKey(@RequestParam(value = "name", required = false) String name,
                               @RequestParam(value = "age", required = false) String age){
        System.out.println("name:" + name + "，age:" + age);
        return "---------------testParamKey";
    }

    public String deal_testParamKey(String name, String age, BlockException blockException){
        return "---------------deal_testParamKey";
    }

系统限流

Sentinel 系统自适应限流从整体维度对应用入口流量进行控制，结合应用的 Load、CPU 使用率、总体平均 RT、入口 QPS 和并发线程数等几个维度的监控指标，通过自适应的流控策略，让系统的入口流量和系统的负载达到一个平衡，让系统尽可能跑在最大吞吐量的同时保证系统整体的稳定性。

全局兜底处理

自定义全局兜底方法

package com.fox.springcloud.handler;

import com.alibaba.csp.sentinel.slots.block.BlockException;
import com.fox.springcloud.entity.CommonResult;

public class GlobalBlockExceptionHandler {

    public static CommonResult testA_handler(BlockException exception){
        return new CommonResult(500, exception.getLocalizedMessage() + "==testA服务不可用");
    }

    public static CommonResult testC_handler(BlockException exception){
        return new CommonResult(500, exception.getLocalizedMessage() + "==testC服务不可用");
    }
}

controller

@GetMapping("/testA")
    @SentinelResource(value = "testA", blockHandlerClass = GlobalBlockExceptionHandler.class, blockHandler = "testA_handler")
    public CommonResult testA(){
        log.info(Thread.currentThread().getName());
        return new CommonResult(200, Thread.currentThread().getName());
    }

    @GetMapping("/testC")
    @SentinelResource(value = "testC", blockHandlerClass = GlobalBlockExceptionHandler.class, blockHandler = "testC_handler")
    public CommonResult testC(){
        return new CommonResult(200, "testC");
    }

本人自测全局兜底处理配置流控规则时只能用资源名，用url配置的流控规则促发限流时自定义兜底不生效。

sentinel熔断

nacos使用ribbon负载均衡

nacos使用ribbon做负载均衡，服务提供者不用改，使用nacos做服务注册即可。

服务消费者添加负载均衡配置类

@Configuration
public class ApplicationContextConfig {
    @Bean
    @LoadBalanced
    public RestTemplate getRestTemplate(){
        return new RestTemplate();
    }
}

controller层注入restTemplate使用服务名调用

import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.fox.springcloud.entity.CommonResult;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import javax.annotation.Resource;

@RestController
@Slf4j
public class CircleBreakerController {

    private static final String service_url = "http://nacos-ribbon-provider";

    @Resource
    private RestTemplate restTemplate;

    @GetMapping("/consume/echo/{id}")
    public CommonResult<String> callback(@PathVariable Long id){
        if (id == 4){
            throw new IllegalArgumentException("IllegalArgumentException 非法参数异常。。。");
        }
        return new CommonResult<>(200, restTemplate.getForObject(service_url + "/echo/" + id, String.class));
    }
}

添加sentinel熔断配置

创建兜底方法添加到要兜底的方法fallback配置属性上

	@GetMapping("/consume/echo/{id}")
    @SentinelResource(value = "fallback", fallback = "handler_fallback")
    public CommonResult<String> callback(@PathVariable Long id){
        if (id == 4){
            throw new IllegalArgumentException("IllegalArgumentException 非法参数异常。。。");
        }
        return new CommonResult<>(200, restTemplate.getForObject(service_url + "/echo/" + id, String.class));
    }

    public CommonResult<String> handler_fallback(@PathVariable Long id, Throwable e){
        return new CommonResult<>(500, "全局兜底异常处理：" + e.getMessage());
    }

配置fallback和blockhandler

	@GetMapping("/consume/echo/{id}")
    @SentinelResource(value = "fallback", fallback = "handler_fallback", blockHandler = "handler_block")
    public CommonResult<String> callback(@PathVariable Long id){
        if (id == 4){
            throw new IllegalArgumentException("IllegalArgumentException 非法参数异常。。。");
        }
        return new CommonResult<>(200, restTemplate.getForObject(service_url + "/echo/" + id, String.class));
    }

    public CommonResult<String> handler_fallback(@PathVariable Long id, Throwable e){
        return new CommonResult<>(500, "全局兜底业务异常处理：" + e.getMessage());
    }

    public CommonResult<String> handler_block(@PathVariable Long id, BlockException e){
        return new CommonResult<>(543, "全局兜底流控规则异常处理：" + e.getClass().getName());
    }

当@SentinelResource同时配置fallback熔断配置和blockhandler流控规则，流控规则优先。

exceptionsToIgnore

配置某些异常不走熔断兜底处理，支持配置多个

@SentinelResource(value = "fallback", fallback = "handler_fallback", blockHandler = "handler_block", exceptionsToIgnore = {IllegalArgumentException.class})

熔断openfeign

pom.xml添加openfeign maven坐标

		<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>

yaml配置文件开启Feign对sentinel的支持

# Feign开启sentinel支持
feign:
  sentinel:
    enabled: true

启动类添加@EnableFeignClients

创建带@FeignClient的接口

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;

@FeignClient(value = "nacos-ribbon-provider", fallback = EchoFallbackService.class)
public interface EchoService {

    @GetMapping(value = "/echo/{id}")
    public String echo(@PathVariable("id") Long id);
}

创建fallback兜底处理

import org.springframework.stereotype.Component;

@Component
public class EchoFallbackService implements EchoService {
    @Override
    public String echo(Long id) {
        return "全局兜底业务异常处理";
    }
}
    public String echo(@PathVariable("id") Long id);
}

创建fallback兜底处理

import org.springframework.stereotype.Component;

@Component
public class EchoFallbackService implements EchoService {
    @Override
    public String echo(Long id) {
        return "全局兜底业务异常处理";
    }
}