sentinel流控规则详解(图形化界面)

1、QPS

每秒的请求数,超过这个请求数,直接流控。

2、BlockException统一异常处理

2.1、创建异常返回类

Result.class

public class Result<T> {
    private Integer code;
    private String msg;
    private T data;

    public Result(Integer code, String msg, T data) {
        this.code = code;
        this.msg = msg;
        this.data = data;
    }

    public Result(Integer code, String msg) {
        this.code = code;
        this.msg = msg;
    }

    public Integer getCode() {
        return code;
    }

    public void setCode(Integer code) {
        this.code = code;
    }

    public String getMsg() {
        return msg;
    }

    public void setMsg(String msg) {
        this.msg = msg;
    }

    public T getData() {
        return data;
    }

    public void setData(T data) {
        this.data = data;
    }

    public static Result error(Integer code, String msg){
        return new Result(code,msg);
    }
}

2.2、异常处理类

@Component
public class MyBlockExceptionHandler implements BlockExceptionHandler {

    Logger log= LoggerFactory.getLogger(this.getClass());

    @Override
    public void handle(HttpServletRequest httpServletRequest, HttpServletResponse response, BlockException e) throws Exception {
        // getRule() 资源  规则的详细信息
        log.info("BlockExceptionHandler BlockException================"+e.getRule());

        Result r = null;

        if (e instanceof FlowException) {
            r = Result.error(100,"接口限流了");

        } else if (e instanceof DegradeException) {
            r = Result.error(101,"服务降级了");

        } else if (e instanceof ParamFlowException) {
            r = Result.error(102,"热点参数限流了");

        } else if (e instanceof SystemBlockException) {
            r = Result.error(103,"触发系统保护规则了");

        } else if (e instanceof AuthorityException) {
            r = Result.error(104,"授权规则不通过");
        }

        //返回json数据
        response.setStatus(500);
        response.setCharacterEncoding("utf-8");
        response.setContentType(MediaType.APPLICATION_JSON_VALUE);
        new ObjectMapper().writeValue(response.getWriter(), r);
    }
}

其中的FlowExceptionDegradeException等异常就是对应的限流,降级的异常。

2.3、测试结果

3、对单一的接口/方法流控(使用注解)

使用@SentinelResource注解。

如果需要设置自定义的流控返回信息,则需要再在@SentinelResource

注解中添加blockHandler配置。

注意:blockHandler所对应的自定义方法必须要和流控的接口/方法的返回值与参数一致,然后加上BlockException e并且BlockException必须引用自com.alibaba.csp.sentinel.slots.block.BlockException

4、关联流控

如图所示,当/order/add超过阈值QPS=1后,/order/flow就会被限流。此举不会流控/order/add

5、链路流控

5.1、开启链路

此版本的Sentinel默认没有开启链路流控,所以需要去配置文件中开启,需要将web-context-unify设置为false,如图:

5.2、链路规则详解

即/test3,/test4接口都用到了getUser方法,对getUser方法进行流控,当超过阈值以后,限制/test3接口调用,不限制/test4接口调用。

5.3、流控示例

接口:http://localhost:8861/order/test1,http://localhost:8861/order/test2都调用了方法getUser,现在针对test1接口,去实现对getUser方法的链路流控。

因为对业务方法进行流控,所以需要对所要流控的方法加上@SentinelResource

注解,如果需要设置自定义的流控返回信息,则需要再在@SentinelResource

注解中添加blockHandler配置。添加规则如步骤3中所提及。

然后,当访问getUser方法超过每秒一次以后,/order/test1接口就会被限流,/order/test2却依旧能正常访问。

6、预热流控

即预热/冷启动方式。当系统长期处于低水位的情况下,当流量 突然增加时,直接把系统拉升到高水位可能瞬间把系统压垮。通过"冷启动",让通过的流量缓慢增加,在一定时间内逐渐 增加到阈值上限,给冷系统一个预热的时间,避免冷系统被压垮。

冷加载因子: codeFactor 默认是3,即请求 QPS 从 threshold / 3 开始,经预热时长逐渐升至设定的 QPS 阈值。

例:如下图,假设阈值为10,那么请求进来时,那么刚开始每秒允许通过3个请求(10/3),然后在5秒内,逐渐把请求放开到十个每秒。

7、排队等待流控

这种方式主要用于处理间隔性突发的流量,例如消息队列。想象一下这样的场景,在某一秒有大量的请求到来,而接下来的几秒则处于空闲状态,我们希望系统能够在接下来的空闲期间逐渐处理这些请求,而不是在第一秒直接拒绝多余的请求。

如图所示,设置阈值为5,排队等待的时间为5秒,假设在0~1秒内进来了10个请求,那么只会放行五个请求,剩下的5个请求不会失败,而是会在2~5内按照阈值来放行。

相关推荐

最近更新

  1. docker php8.1+nginx base 镜像 dockerfile 配置

    2024-03-23 15:12:03       94 阅读
  2. Could not load dynamic library ‘cudart64_100.dll‘

    2024-03-23 15:12:03       100 阅读
  3. 在Django里面运行非项目文件

    2024-03-23 15:12:03       82 阅读
  4. Python语言-面向对象

    2024-03-23 15:12:03       91 阅读

热门阅读

  1. 使用docker搭建Fluentd的教程

    2024-03-23 15:12:03       42 阅读
  2. 【NC16610】Hankson的趣味题

    2024-03-23 15:12:03       40 阅读
  3. 富格林:拆穿黑幕套路维护资金安全

    2024-03-23 15:12:03       43 阅读
  4. zynq Lwip学习笔记-recv_callback函数

    2024-03-23 15:12:03       41 阅读
  5. 大数据的实时计算和离线计算你理解吗?

    2024-03-23 15:12:03       39 阅读
  6. 应用日志集成到ElasticSearch

    2024-03-23 15:12:03       37 阅读
  7. 防火墙(讲解)

    2024-03-23 15:12:03       42 阅读
  8. 设计模式: 外观模式

    2024-03-23 15:12:03       42 阅读
  9. 网络通信过程中为什么需要连接池?

    2024-03-23 15:12:03       38 阅读
  10. Vue-live2d在项目中展示Live2D 模型

    2024-03-23 15:12:03       42 阅读
  11. odoo字段访问控制

    2024-03-23 15:12:03       39 阅读
  12. VUE父子组件的传参问题

    2024-03-23 15:12:03       44 阅读
  13. 5 数据分析——matplotlib

    2024-03-23 15:12:03       36 阅读