Sentinel服务限流降级
雪崩效应:因为一个小问题导致系统奔溃
由于多个服务相互调用,假设服务B调用A,服务A出现问题,服务B全部线程进入阻塞状态,一直等待不释放资源,导致服务B堆积内存沾满,B奔溃;C调用B。。。。。导致全部崩坏
解决:
- 设置线程超时(设置时间,超时释放线程)
- 设置限流
- 熔断器-Sentinel、Hystrix
- 降级:减少提供的功能(对系统自身)
- 限流:限制流量
- 熔断:应对外部系统故障,调用对方,它出现问题,直接断开返回错误
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
<version>2.2.1.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
下载Sentinel---解压---终端该路径下运行jar包:java -jar xxxx
Sentinel是用来监控请求的,和Nacos不太一样,必须请求后才会显示数据

多请求几次后显示数据
浏览器去访问服务器,利用Sentinel去监控,控制流量

- 流控:流量控制(单机阈值-2:一秒钟只允许被请求两次)

?
?
流控高级选项——关联限流
如果请求/list一秒超过一个,/index会报错
测试开始:
新开一个程序用来大量测试/list,同时用浏览器请求/index
@SpringBootTest
class ProviderApplicationTests {
@Test
void contextLoads() throws InterruptedException {
RestTemplate restTemplate = new RestTemplate();
for(int i=0 ; i<100 ; i++){
restTemplate.getForObject("http://localhost:8082/list",String.class);
Thread.sleep(200);//1秒五次请求
}
}
}
浏览器访问/index返回错误
流控高级选项——链路限流
由于Sentinel版本太高需要自己配置,直接使用无效果
1.导入依赖:
<dependency>
<groupId>com.alibaba.csp</groupId>
<artifactId>sentinel-core</artifactId>
<version>1.7.1</version>
</dependency>
<dependency>
<groupId>com.alibaba.csp</groupId>
<artifactId>sentinel-web-servlet</artifactId>
<version>1.7.1</version>
</dependency>
2.在application.properties中配置相关信息:
spring.cloud.sentinel.filter.enabled=false
3.写配置类(写好的,复制即可):
@Configuration
public class FilterConfiguration {//链路设置,Sentinel版本低则无需设置
@Bean
public FilterRegistrationBean registrationBean(){
FilterRegistrationBean registrationBean = new FilterRegistrationBean();
registrationBean.setFilter(new CommonFilter());
registrationBean.addUrlPatterns("/*");
registrationBean.addInitParameter(CommonFilter.WEB_CONTEXT_UNIFY,"false");
registrationBean.setName("sentinelFilter");
return registrationBean;
}
}
?
@Service
public class TestService {
@SentinelResource("test")
public void Test(){
System.out.println("test");
}
}
@RequestMapping("/test1")
public String test1(){
testService.Test();
return "test1";
}
@RequestMapping("/test2")
public String test2(){
testService.Test();
return "test2";
}
?

?
Sentinel配置流控模式:链路(即,test1调用了service层test,限制test1,一秒超过一次访问直接报错)
流量效果
快速失败;Warm Up ;排队等待
- 快速失败:直接报错失败
- Warm Up:预热x秒,假设单机阈值为3(一秒三个请求),x秒之前三分之一即一秒一个请求,超过报错。x秒后变为3
- 排队等待:设置等待时间,等待时间内超过阈值不会直接报错,会再次访问,如果成功则成功,不成功则报错
降级规则
1.RT
单个请求的响应时间超过阈值,则进入准降级状态,接下来 1 S 内连续 5 个请求响应时间均超过阈值,就进行降级,持续时 间为时间窗口的值。
2.异常比例
每秒异常数量占通过量的比例大于阈值,就进行降级处理, 持续时间为时间窗口的值。
3.异常数
1 分钟内的异常数超过阈值就进行降级处理,时间窗口的值要 大于 60S,否则刚结束熔断又进入下一次熔断了。
热点规则
是流控规则的更细粒度操作,可以具体到对某个热点参数的限流,设置限流之后,如果带着限流参数的请求量 超过阈值,则进行限流,时间为统计窗口时长。 必须要添加?@SentinelResource,即对资源进行流控。
授权规则
给指定的资源设置流控应用(追加参数),可以对流控应用进行访问权限的设置,具体就是添加白名单和黑名单。同样自定义配置类(过滤器),设置必须有参数(任何值)才可以正常访问,授权:对参数设置规定值,如果设置为白名单,即只有输入固定值才能正常访问,如果设置黑名单,即输入固定值不可访问
//授权接口——设置参数为name,如果访问没带参数,即不可访问
//要让接口生效,还需配置类
public class RequestOriginParserDefinition implements RequestOriginParser {
@Override
public String parseOrigin(HttpServletRequest httpServletRequest) {
String name = httpServletRequest.getParameter("name");
if(StringUtils.isEmpty(name)){
throw new RuntimeException("name is null");
}
return name;
}
}
@Configuration
//让授权功能生效
public class SentinelConfiguration {
@PostConstruct
public void init(){
WebCallbackManager.setRequestOriginParser(new RequestOriginParserDefinition());
}
}
?
此时访问任意网址都无法访问,必须带参数(此时未设置授权,参数可为任意值)
?
?
?name的值必须为a才能进入白名单(才能正常访问,其他值不可访问)
若设置黑名单,即name值为a不可访问,其他值可以访问
|