Spring Cloud Alibaba：Sentinel之降级、热点限流与授权控制

Spring Cloud Alibaba：Sentinel之降级、热点限流与授权控制 Spring Cloud Alibaba：Sentinel之降级、热点限流与授权控制

在上一篇博客中，博主介绍了如何整合Sentinel以及它的流控规则：

• Spring Cloud Alibaba：整合Sentinel & 流控规则详细介绍

本篇博客将会介绍Sentinel的降级、热点限流与授权控制，需要创建Spring Cloud Alibaba项目以及整合Sentinel，这些在上面那篇博客中已经介绍过了，这里不再赘述。

降级 熔断策略

慢调用比例：选择慢调用比例作为熔断策略，需要设置允许的慢调用RT（即最大的响应时间），若请求的响应时间大于它则统计该请求为慢调用。当单位统计时长内请求数目大于设置的最小请求数目，并且慢调用的比例大于阈值，熔断器会打开（OPEN状态），则接下来的熔断时长内请求会自动被熔断。经过熔断时长后熔断器会进入探测恢复状态（HALF-OPEN状态），若接下来的一个请求响应时间小于设置的慢调用RT，则结束熔断，若大于设置的慢调用RT则会再次被熔断。这和Hystrix的熔断策略差不多：

• Spring Cloud 之Hystrix初使用
• Spring Cloud 之Hystrix熔断器、Hystrix-Dashboard可视化监控中心

给资源添加降级。

为了测试，需要修改/kaven接口：

    @GetMapping("kaven")
    public String getKaven(boolean sleep) throws InterruptedException {
        if(sleep) {
            Thread.sleep(400);
        }
        return "hello kaven " + messageService.getMessage();
    }

启动应用后，先请求几次接口，让Sentinel有展示数据，方便给资源添加降级。

当单位统计时长（100000ms=100s，为了方便测试 ）内请求数目大于设置的最小请求数目5，并且慢调用的比例大于阈值20%，熔断器会打开（OPEN状态），则接下来的熔断时长（120s）内请求会自动被熔断。经过熔断时长（120s）后熔断器会进入探测恢复状态（HALF-OPEN状态），若接下来的一个请求响应时间小于设置的慢调用RT（300ms），则结束熔断，若大于设置的慢调用RT则会再次被熔断。

第6次请求/kaven接口被降级了（100s内，慢调用的比例很显然是100%）。

熔断时长（120s）内请求会自动被熔断。

经过熔断时长（120s）后熔断器会进入探测恢复状态（HALF-OPEN状态），若接下来的一个请求响应时间小于设置的慢调用RT（300ms），则结束熔断。

异常比例：当单位统计时长内请求数目大于设置的最小请求数目，并且请求异常的比例大于阈值，熔断器打开（OPEN 状态），则接下来的熔断时长内请求会自动被熔断。经过熔断时长后熔断器会进入探测恢复状态（HALF-OPEN 状态），若接下来的一个请求访问接口成功，则结束熔断，否则会再次被熔断。异常比例的阈值范围是 [0.0, 1.0] ，代表0% - 100%。

修改/kaven接口：

    @GetMapping("kaven")
    public String getKaven(boolean throwExc) throws InterruptedException {
        if(throwExc) {
            throw new RuntimeException();
        }
        return "hello kaven " + messageService.getMessage();
    }

重新启动应用，给资源添加降级。

第6次请求/kaven接口被降级了（100s内，异常的比例很显然是100%）。

熔断时长（120s）内请求会自动被熔断。

经过熔断时长（120s）后熔断器会进入探测恢复状态（HALF-OPEN状态），若接下来的一个请求访问接口成功，则结束熔断。

异常数：当单位统计时长内的请求异常数目超过阈值之后会自动进行熔断。经过熔断时长后熔断器会进入探测恢复状态（HALF-OPEN状态），若接下来的一个请求访问接口成功则结束熔断，否则会再次被熔断。

将/kaven资源的降级规则修改为如下图所示：

第6次请求/kaven接口会被降级，其他情况与上面两种熔断策略一样，这里不再赘述。

热点限流

修改/kaven接口：

    @GetMapping("kaven")
    @SentinelResource("kaven")
    public String getKaven(@RequestParam(value = "arg1", required = false) Integer arg1,
                           @RequestParam(value = "arg2", required = false) Integer arg2) {
        return "hello kaven " + messageService.getMessage();
    }

重新启动应用，给kaven资源（不是/kaven资源）添加热点限流。

给kaven资源添加热点限流如下图所示，表示当请求的arg2参数存在，且QPS大于5则触发限流（10s内）。

第6次请求/kaven接口（每次都传入arg2参数）会被限流（10s内）。

如果不传入arg2参数，请求超过5次也不会被限流（10s内），传入arg2参数，只要携带arg2参数的请求不超过5次也不会被限流（10s内）。

授权控制

添加两个配置类：

package com.kaven.alibaba;

import com.alibaba.csp.sentinel.adapter.servlet.callback.RequestOriginParser;
import org.springframework.util.StringUtils;

import javax.servlet.http.HttpServletRequest;

public class RequestParametersLimiter implements RequestOriginParser {
    @Override
    public String parseOrigin(HttpServletRequest httpServletRequest) {
        // 每个请求都会被校验参数中是否包含arg1
        // 如果不包含则抛异常
        if(httpServletRequest.getRequestURI().startsWith("/kaven")){
            String name = httpServletRequest.getParameter("arg1");
            if(StringUtils.isEmpty(name)){
                throw new RuntimeException("arg1 is null");
            }
            return name;
        }
        return "";
    }
}

RequestParametersLimiter类可以看作一个请求参数限制器，如果请求的URI以/kaven开头，当arg1参数不存在时，会抛出异常，当arg1参数存在时，直接返回该值，其他URI的请求直接返回""。

package com.kaven.alibaba;

import com.alibaba.csp.sentinel.adapter.servlet.callback.WebCallbackManager;
import org.springframework.context.annotation.Configuration;

import javax.annotation.PostConstruct;

@Configuration
public class SentinelConfiguration {

    @PostConstruct
    public void init(){
        WebCallbackManager.setRequestOriginParser(new RequestOriginParserDefinition());
    }
}

@PostConstruct注解用于需要在依赖注入完成后执行任何初始化的方法。必须在类投入使用之前调用此方法。所有支持依赖注入的类都必须支持这个注解。@PostConstruct注解的方法将会在依赖注入完成后被自动调用。WebCallbackManager类是Sentinel提供的URL cleaner和URL block handler的注册表。通过WebCallbackManager类将RequestOriginParserDefinition实例进行注册（请求源解析器，而其实现是一个请求参数限制器）。

重新启动应用，给资源添加授权。

因此，请求/kaven接口时，arg1参数的值只有属于[0,9]区间才可以请求成功（黑名单相反）。


效果符合预期，Sentinel的降级、热点限流与授权控制就介绍到这里，如果博主有说错的地方或者大家有不同的见解，欢迎大家评论补充。