作者:mobiledu2502910077 | 来源:互联网 | 2023-09-13 07:03
流控是Sentinel核心功能之一,流控指的是流量控制。Sentinel的流控操作起来非常简单,在控制台进行配置即可看见效,所见即所得。名词解释资源名:唯一名称,默认是请求路径针对
流控是Sentinel核心功能之一,流控指的是流量控制。
Sentinel的流控操作起来非常简单,在控制台进行配置即可看见效,所见即所得。
名词解释
资源名: 唯一名称,默认是请求路径
针对来源: Sentinel可以针对调用者进行限流,填写微服务的名称,默认是default(不区分来源)
阈值类型/单机阈值:可随时更改,无需重启系统
- QPS:每秒的请求数量,当调用该api的QPS达到阈值的时候进行限流。
- 线程数: 当调用该api的线程数达到阈值的时候进行限流。
流控模式:
- 直接:api达到限流条件时,直接限流
- 关联:当关联的资源达到限流条件时,限流自己
- 链路:只记录指定链路上的流量(指定资源从入口资源进来的流量,如果达到阈值,就进行限流)【api级别的针对来源】
流控效果:
- 快速失败:直接失败,抛出异常
- Warm Up: 根据codeFactor(冷加载因子,默认3)的值,从阈值/codeFactor,经过预热时长,才达到设置的QPS阈值
- 排队等待:匀速排队,让请求以匀速通过,阈值类型必须设置为QPS
QPS直接失败
配置:每秒钟只能有一个请求。浏览器快速刷新请求,会出现下图的效果
Blocked by Sentinel (flow limiting) 是sentinel提供的默认提示语,表示已经被限流了。提示语的修改,后面会进一步讲解。
线程数直接失败
添加新的配置
新增一个接口进行测试,因为通过线程进行限流,便于演示,所以让线程睡眠了2秒钟。
@GetMapping("/testThreadLimit")
public String testThreadLimit() {
try {
Thread.sleep(2000);
} catch (Exception e){
e.printStackTrace();
}
return "----testThreadLimit";
}
打开两个页面,分别快速请求一次,因为其中一个线程会阻塞2秒钟,所以另一个请求就会被限流。
流控模式-关联
上文提到的名称解释,关联就是:当关联的资源达到限流条件时,限流自己。
举例说明:新增两个接口testA,testB,在控制台中将两个接口进行关联,如果testB访问触发限制条件,testA就不能被访问了。
在实际开发中,比如支付接口正在经历着巨大的访问压力,这个时候对下单的接口进行限流就很有必要了。
1. 新增接口
@GetMapping("/testA")
public String testA() {
return "----testA";
}
@GetMapping("/testB")
public String testB() {
return "----testB";
}
2. sentinel添加规则
3. 为了持续对testB接口进行访问,我使用postman进行模拟。
4. 当使用postman进行访问testB时,浏览器访问testA,会发现访问testA返回的是限流的信息。等postman访问结束后,再次访问testB,就会发现恢复正常了。
流控效果-Warm Up(预热)
上图是配置的效果图。期望单机每秒限制12次的访问,但是由于预热初始化为3,也就是说5秒后,由每秒3次转化成每秒12次的限制。
实际操作的效果:不停的请求,刚开始会出现限流信息,慢慢的,达到5秒钟后,如果你无法在1秒内请求12次,就无法触发限流规则了。
流控效果-排队等待
排队等待就是在不超时的前提下,按照单机阈值进行执行。
如上图所示,如果一瞬间有10个请求过来,系统会一秒钟处理一个请求。testA稍加修改
@GetMapping("/testA")
public String testA() {
System.out.println(DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss") + " ------" + Thread.currentThread().getName());
return "----testA";
}
使用postman进行测试
得到的结果如下: