1、流控效果
流控效果是指请求达到流控阈值时应该采取的措施,包括三种:
快速失败:达到阈值后,新的请求会被立即拒绝并抛出FlowException异常。是默认的处理方式。
warm up:预热模式,对超出阈值的请求同样是拒绝并抛出异常。但这种模式阈值会动态变化,从一个较小值逐渐增加到最大阈值。
排队等待:让所有的请求按照先后次序排队执行,两个请求的间隔不能小于指定时长
1.1流控效果-warm up
warm up也叫预热模式,是应对服务冷启动的一种方案。请求阈值初始值是 threshold / coldFactor,持续指定时长后,逐渐提高到threshold值。而coldFactor的默认值是3.
例如,我设置QPS的threshold为10,预热时间为5秒,那么初始阈值就是 10 / 3 ,也就是3,然后在5秒后逐渐增长到10
需求:给/order/getInfo 这个资源设置限流,最大QPS为10,利用warm up效果,预热时长为5秒。
预热模式
1.2流控效果-排队等待
当请求超过QPS阈值时,快速失败和warm up 会拒绝新的请求并抛出异常。而排队等待则是让所有请求进入一个队列中,然后按照阈值允许的时间间隔依次执行。后来的请求必须等待前面执行完成,如果请求预期的等待时间超出最大时长,则会被拒绝。
在某一时刻,服务很忙,而其他时刻,服务很闲。
例如:QPS = 5,意味着每200ms处理一个队列中的请求;timeout = 2000,意味着预期等待超过2000ms的请求会被拒绝并抛出异常。
需求:给/order/{orderId}这个资源设置限流,最大QPS为10,利用排队的流控效果,超时时长设置为5s
一开始超出阈值,会在队列里,排队等待
总结
流控效果有哪些?
快速失败:QPS超过阈值时,拒绝新的请求
warm up: QPS超过阈值时,拒绝新的请求;QPS阈值是逐渐提升的,可以避免冷启动时高并发导致服务宕机。
排队等待:请求会进入队列,按照阈值允许的时间间隔依次执行请求;如果请求预期等待时长大于超时时间,直接拒绝
2、热点参数限流
之前的限流是统计访问某个资源的所有请求,判断是否超过QPS阈值。而热点参数限流是分别统计参数值相同的请求,判断是否超过QPS阈值。
代表的含义是:对hot这个资源的0号参数(第一个参数)做统计,每1秒相同参数值的请求数不能超过5个。
在热点参数限流的高级选项中,可以对部分参数设置例外配置:
结合上一个配置,这里的含义是对0号的long类型参数限流,每1秒相同参数的QPS不能超过5,有两个例外:
如果参数值是100,则每1秒允许的QPS为10
如果参数值是101,则每1秒允许的QPS为15
需求:给/order/{orderId}这个资源添加热点参数限流,规则如下:
• 默认的热点参数规则是每 1 秒请求量不超过 2• 给 102 这个参数设置例外:每 1 秒请求量不超过 4给103这个参数设置例外:每1秒请求量不超过10
controller中的接口默认无效,使用SentinelResouce注解的资源有效
@GetMapping("{id}")
@SentinelResource("hot")
public String hello(@PathVariable Integer id){
return "hello====="+id;
}
3、隔离和降级
虽然限流可以尽量避免因高并发而引起的服务故障,但服务还会因为其它原因而故障。而要将这些故障控制在一定范围,避免雪崩,就要靠线程隔离(舱壁模式)和熔断降级手段了。
不管是线程隔离还是熔断降级,都是对客户端(调用方)的保护。
3.1Feign整合Sentinel
SpringCloud中,微服务调用都是通过Feign来实现的,因此做客户端保护必须整合Feign和Sentinel。
3.2 开启Feign的Sentinel功能
开启feign整合sentinel功能
#开启feign整合sentinel的功能
feign.sentinel.enabled=true
3.3 ProductFeignFactory
创建feign接口的降级类 兜底类
package com.aaa.order.feign.factory;
import com.aaa.order.feign.ProductFeign;
import com.aaa.pojo.Product;
import feign.hystrix.FallbackFactory;
/**
* @program: parent
* @author: Jmy
* @create: 2023-05-18 21:55
* 兜底方法 熔断降级
**/
@Component
public class ProductFeignFactory implements FallbackFactory<ProductFeign> {
@Override
public ProductFeign create(Throwable throwable) {
//匿名实现类
return new ProductFeign() {
@Override
public Product getById(Integer pid) {
Product product = new Product();
product.setPid(-1);
product.setPname("商品服务出现故障");
return product;
}
};
}
}
在@FeignClient(fallbackFactory = ProductFeignFactory.class)
package com.aaa.order.feign;
import com.aaa.order.feign.factory.ProductFeignFactory;
import com.aaa.pojo.Product;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
/**
* @program: parent
* @author: Jmy
* @create: 2023-05-14 14:18
**/
//@FeignClient(value="服务提供者的名字")
@FeignClient(value = "qy163-product",fallbackFactory = ProductFeignFactory.class)
public interface ProductFeign {
//抽象方法一定要和服务提供者的接口方法一模一样
@GetMapping("/product/getById/{pid}")
public Product getById(@PathVariable Integer pid);
}