美文网首页
Sentinel 熔断降级

Sentinel 熔断降级

作者: KouKuma | 来源:发表于2020-12-14 17:31 被阅读0次

    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
    最后: 在控制台中也可手动控制资源的规则.

    相关文章

      网友评论

          本文标题:Sentinel 熔断降级

          本文链接:https://www.haomeiwen.com/subject/kpnvgktx.html