SpringCloud-Sentinel服务保护

wuchangjian2021-11-16 18:12:20编程学习

Sentinel服务保护

    • 1. 什么是Sentinel
    • 2. 安装下载
    • 3. 限流规则
      • 3.1 流控模式
      • 3.2 流控效果
    • 4. 隔离和降级
      • 4.1 线程隔离
      • 4.2 熔断降级
    • 5. 测试sentinel
      • 5.1 自定义处理逻辑

1. 什么是Sentinel

Sentinel是阿里巴巴开源的一款微服务流量控制组件。
具有以下特征:

  • 丰富的应用场景: 双11秒杀(即突发流量控制在系统容量可以承受的范围)、消息削峰填谷、集群流量控制、实时熔断下游不可用应用等。
  • 实时监控: 在控制台中看到接入应用的单台机器秒级数据,甚至 500 台以下规模的集群的汇总运行情况。
  • 开源生态: 提供开箱即用的与其它开源框架/库的整合模块,如与 Spring Cloud、Dubbo、gRPC 的整合。

雪崩问题: 微服务调用链路中的某个服务故障,引起整个链路中的所有微服务都不可用,这就是雪崩。

解决方案:

  • 超时处理: 设定超时时间,请求超过一定时间没有响应就返回错误信息,不会无休止等待
  • 舱壁模式: 限定每个业务能使用的线程数,避免耗尽整个tomcat的资源,因此也叫线程隔离。
  • 熔断降级: 由断路器统计业务执行的异常比例,如果超出阈值则会熔断该业务,拦截访问该业务的一切请求。
  • 流量控制: 限制业务访问的QPS,避免服务因流量的突增而故障。

2. 安装下载

下载地址:https://github.com/alibaba/Sentinel/releases
启动:

java -jar sentinel-dashboard-1.7.2.jar

默认8080端口。

访问http://localhost:8080
账号密码均为 sentinel

3. 限流规则

3.1 流控模式

1. 直接: 统计当前资源的请求,触发阈值时对当前资源直接限流,也是默认的模式

2. 关联: 统计与当前资源相关的另一个资源,触发阈值时,对当前资源限流

3. 链路: 统计从指定链路访问到本资源的请求,触发阈值时,对指定链路限流
在这里插入图片描述

3.2 流控效果

快速失败: 达到阈值后,新的请求会被立即拒绝并抛出FlowException异常。是默认的处理方式。

warm up: 预热模式,是应对服务冷启动的一种方案。请求阈值初始值是 threshold / coldFactor,持续指定时长后,逐渐提高到threshold值。而coldFactor的默认值是3.

排队等待: 让所有请求进入一个队列中,然后按照阈值允许的时间间隔依次执行。后来的请求必须等待前面执行完成,如果请求预期的等待时间超出最大时长,则会被拒绝。
例如:

QPS = 5,意味着每200ms处理一个队列中的请求;
timeout = 2000,意味着预期等待超过2000ms的请求会被拒绝并抛出异常

在这里插入图片描述

4. 隔离和降级

4.1 线程隔离

在这里插入图片描述
线程数:是该资源能使用用的tomcat线程数的最大值。也就是通过限制线程数量,实现舱壁模式。

4.2 熔断降级

慢调用比例:
超过指定时长的调用为慢调用,统计指定时间内慢调用的比例,超过阈值则熔断

异常比例:
统计单位时长内异常调用的比例,超过阈值则熔断

异常数:
统计单位时长内异常调用的次数,超过阈值则熔断
例如:
在这里插入图片描述响应时长超过500ms的调用是慢调用,统计最近10000ms内的请求,如果请求量超过10次,并且慢调用比例不低于0.5,则触发熔断,熔断时长为5秒。然后进入half-open状态,放行一次请求做测试。

5. 测试sentinel

导入依赖:

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>    
        <!-- SpringBoot整合Web组件 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
        </dependency>
        <!--SpringCloud ailibaba nacos -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
    </dependencies>

Controller接口:

@RestController
public class SentinelController {

    @GetMapping("/sentinel")
    @SentinelResource(value = "sentinel",blockHandler = "handleException")
    // value 表示 资源名 , blockHandler 表示 限流后处理方法 
    public String test() {
        System.out.println("hello,sentinel");
        return "sentinel 资源通过";
    }

    public String handleException(BlockException e) {
        System.out.println("服务繁忙");
        return "sentinel 服务繁忙" + e.getClass().getCanonicalName() + "不可用";
    }
}

5.1 自定义处理逻辑

//自定义限流处理逻辑
public class CustomBlockHandler {
    public String handleException(BlockException exception){
        return "出现异常";
    }
}

使用自定义处理

    /**
     * 自定义通用的限流处理逻辑
     */
    @GetMapping("/customBlockHandler")
    @SentinelResource(value = "customBlockHandler", blockHandler = "handleException",blockHandlerClass = CustomBlockHandler.class)
    public String blockHandler() {
        return "正常访问";
    }

发表评论    

◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。