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);
}
}其中的FlowException，DegradeException等异常就是对应的限流，降级的异常。
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内按照阈值来放行。
