Sentinel是什么?
Sentinel是面向分布式服务架构的轻量级流量控制,熔断降级产品,主要以流量控制为切入点,从流量控制,熔断降级,系统负载保护等多个维度来保护服务的稳定性。
Sentinel的基本概念
资源:
资源是Sentinel的关键概念。它可以是Java应用程序中的任何内容,例如,有应用程序提供的服务,或由应用程序调用的其他应用提供的服务,甚至可以是一段代码块。
只要通过Sentinel API定义的代码,就是资源,就能够被Sentinel保护起来。大部分情况下,可以使用方法签名,URL,甚至是服务名称作为资源名来标识资源。
规则:
围绕资源的实时状态设定的规则,可以包括流量控制规则,熔断降级规则以及系统保护规则。所有规则都可以动态实时调整。
熔断规则示例(参考https://blog.csdn.net/wangb_java/article/details/107893698):
平均响应时间规则 (秒级)
如下规则将适用于资源hello,这里每秒内只要有1次调用hello方法的处理时间超过阈值(1毫秒),则会触发熔断。后续5秒时间内,所有对hello方法的请求都会直接抛出异常DegradeException。以防止这个方法发生状况响应太慢,从而影响整个系统。
@PostConstruct
private void initDegradeRule() {
List<DegradeRule> rules = new ArrayList<>();
DegradeRule rule = new DegradeRule();
rule.setResource("hello");
//保护资源名,对应hello
rule.setCount(1);
//熔断阈值,响应时间超过N毫秒
rule.setGrade(RuleConstant.DEGRADE_GRADE_RT);
//熔断策略为平均响应时间
rule.setTimeWindow(5);
//触发熔断后,持续时间N秒
rule.setRtSlowRequestAmount(1);
//每秒内有N次请求超出阈值,就触发熔断
rules.add(rule);
DegradeRuleManager.loadRules(rules);
}
异常比例规则 (秒级)
以下规则与上面类似,有3个参数不一样。这里每秒至少有2次请求,而且超过10%的请求发生异常,就触发熔断。
@PostConstruct
private void initDegradeRule() {
List<DegradeRule> rules = new ArrayList<>();
DegradeRule rule = new DegradeRule();
rule.setResource("hello");
rule.setCount(0.1);
//阈值。发生请求异常的百分比,以小数表示
rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO);
//策略为异常比例
rule.setTimeWindow(5);
rule.setMinRequestAmount(2);
//每秒至少N次请求,达到阈值,会触发熔断
rules.add(rule);
DegradeRuleManager.loadRules(rules);
}
异常数规则 (分钟级)
类似,这里是在1分钟内,发生的异常次数达到阈值(1次),即触发熔断。注意,如果设置timeWindow熔断时间小于1分钟,在熔断时间过后可能仍然是熔断状态,因为之前发生的异常,仍然在当前1分钟有效范围内。
@PostConstruct
private void initDegradeRule() {
List<DegradeRule> rules = new ArrayList<>();
DegradeRule rule = new DegradeRule();
rule.setResource("hello");
rule.setCount(1);
//阈值 异常数N
rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_COUNT);
//策略为异常数
rule.setTimeWindow(120);
//触发熔断后,持续时间N秒
rules.add(rule);
DegradeRuleManager.loadRules(rules);
}
使用步骤
1. 导入Sentinel的依赖
<!--Sentinel 依赖-->
<dependency>
<groupId>com.alibaba.csp</groupId>
<artifactId>sentinel-core</artifactId>
<version>1.6.0</version>
</dependency>
<!--Sentinel 注解依赖-->
<dependency>
<groupId>com.alibaba.csp</groupId>
<artifactId>sentinel-annotation-aspectj</artifactId>
<version>1.6.0</version>
</dependency>
<!--Sentinel 控制台-->
<dependency>
<groupId>com.alibaba.csp</groupId>
<artifactId>sentinel-transport-simple-http</artifactId>
<version>1.6.0</version>
</dependency>
2. 定义Sentinel的bean对象
@Bean
public SentinelResourceAspect sentinelResourceAspect() {
return new SentinelResourceAspect();
}
3. 定义资源的降级规则
@PostConstruct
public void initDegradeRule() {
List<DegradeRule> rules = new ArrayList<DegradeRule>();
DegradeRule rule = new DegradeRule();
rule.setResource("资源的名字");
rule.setCount(5);
rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_COUNT);
rule.setTimeWindow(80);
rules.add(rule);
DegradeRuleManager.loadRules(rules);
}
4. 为业务方法贴注解,标识资源名称和降级方法
@SentinelResource(value = "getUserById",
fallback = "fallbackForGetUser")
public String getUserById(int id) {
throw new RuntimeException("getUserById command failed");
}
5. 实现降级方法
public String fallbackForGetUser(int id, BlockException be) {
return "fallback";
}
控制台的使用:
Sentinel 提供一个轻量级的开源控制台,它提供机器发现以及健康情况管理、监控(单机和集群),规则管理和推送的功能。
启动Sentinel控制台:
下载jar包:https://github.com/alibaba/Sentinel/releases
运行jar包:
-Dcsp.sentinel.dashboard.server=localhost:8080 -Dproject.name=sentinel-dashboard -jar sentinel-dashboard.jar
在项目中配置JVM启动参数:
-Dcsp.sentinel.dashboard.server=127.0.0.1:8080
控制台账号密码: sentinel
最后: 在控制台中也可手动控制资源的规则.
网友评论