专栏首页中间件兴趣圈源码分析 Sentinel DegradeSlot 熔断实现原理

源码分析 Sentinel DegradeSlot 熔断实现原理

1、DegradeSlot 概述


Sentinel 中的熔断实现类为 DegradeSlot。DegradeSlot 的类定义如下图所示:

由此可见,熔断主要实现逻辑定义在 DegradeRuleManager 的 checkDegrade 方法中。 DegradeRuleManager#checkDegrade

代码@1:首先从 degradeRules 熔断规则缓存中获取资源的熔断规则。

代码@2:遍历熔断规则列表。

代码@3:调用熔断规则 DegradeRule 的 passCheck,如果该方法返回 false,则表示需要熔断,则抛出 DegradeException 异常。

即实现熔断的核心逻辑在 DegradeRule 中。

2、DegradeRule 详解


在介绍 DegradeRule 之前我们先来看看 sentinel-dashboard 关于熔断降级规则的配置:

我们可以直观的得知,降级规则可以根据如下三个指标进行设置:RT(响应时间)、异常比例、异常数。

2.1 DegradeRule 类图

  • double count 上面配置规则中对应的配置值,例如当降级策略为RT时,表示设置的响应时间值,其他类似。
  • int timeWindow 降级发生后多久进行恢复,即结束降级,单位为毫秒。
  • int grade 降级策略,可以选值如下: 1)DEGRADE_GRADE_RT 响应时间。 2)DEGRADE_GRADE_EXCEPTION_RATIO 异常数比例。 3)DEGRADE_GRADE_EXCEPTION_COUNT 异常数量。
  • int rtSlowRequestAmount 触发 RT 响应熔断出现的最小连续慢响应请求数量。
  • int minRequestAmount 触发熔断最小的请求数量。

2.2 passCheck方法详解

根据当前请求的情况触发熔断的判断逻辑由 passCheck 方法实现。在介绍这个方法之前,我们根据该方法调用上下文得知,该方法返回 false,则触发熔断。 DegradeRule#passCheck

if (cut.get()) {
    return false;
}

Step1:如果当前正在处于熔断降级中,将直接返回 false,请求将被限流。

DegradeRule#passCheck

ClusterNode clusterNode = ClusterBuilderSlot.getClusterNode(this.getResource());
    if (clusterNode == null) {
        return true;
}

Step2:根据资源名称获得对应的集群类节点,有关集群限流将在后续文章中详细介绍。

DegradeRule#passCheck

if (grade == RuleConstant.DEGRADE_GRADE_RT) {
    double rt = clusterNode.avgRt();
    if (rt < this.count) {
        passCount.set(0);
        return true;
    }
    if (passCount.incrementAndGet() < rtSlowRequestAmount) {
        return true;
    }
}

step3:降级策略为基于响应时间的判断规则,其核心实现关键点:

  • 首先获取节点的平均响应时间。
  • 如果当前平均响应时间小于阔值,则放行,并重置 passCount 为 0。
  • 如果当前平均响应时间大于阔值,但连续次数小于 rtSlowRequestAmount,依然放行,只有当连续 rtSlowRequestAmount 次响应慢才会触发降级。

DegradeRule#passCheck

} else if (grade == RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO) {
    double exception = clusterNode.exceptionQps();
    double success = clusterNode.successQps();
    double total = clusterNode.totalQps();
    if (total < minRequestAmount) {
        return true;
    }
   double realSuccess = success - exception;
    if (realSuccess <= 0 && exception < minRequestAmount) {
        return true;
    }
    if (exception / success < count) {
        return true;
    }
}

Step4:降级策略为根据异常比例,其判断规则核心如下:

  • 分别获取成功QPS,异常QPS,总TPS。
  • 如果当前总 QPS 小于 minRequestAmount,则直接返回成功,表示暂不进行熔断规则判断。
  • 如果成功数小于异常数并且异常数量小于 minRequestAmount,则返回true,表示暂不进熔断规则的判断。
  • 如果异常比例小于阔值,同样返回 true,表示暂不进熔断规则的判断。

DegradeRule#passCheck

else if (grade == RuleConstant.DEGRADE_GRADE_EXCEPTION_COUNT) {
    double exception = clusterNode.totalException();
    if (exception < count) {
        return true;
    }        
}

Step5:降级策略为根据异常数量,这策略只是简单的判断错误数量即可。

DegradeRule#passCheck

if (cut.compareAndSet(false, true)) {
    ResetTask resetTask = new ResetTask(this);
    pool.schedule(resetTask, timeWindow, TimeUnit.SECONDS);
}

Step6:如果符合触发熔断的规则,则原子更新 cut,并且开启一个调度任务,在指定时间过后进行降级恢复。

Sentinel 的熔断机制实现比较简单,就介绍到这了,下一篇将介绍 Sentinel 基于集群的限流策略。

本文分享自微信公众号 - 中间件兴趣圈(dingwpmz_zjj),作者:丁威

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2020-04-12

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 源码分析Dubbo服务调用日志(accesslog参数)实现原理

    谈到服务调用日志,大家恐怕第一想到就是如果开启了这个参数,会影响性能。那真实的情况是怎么样了?性能损耗到底有多大呢?在实践中我们如何使用该功能呢?本文将详细分析...

    丁威
  • 源码分析 RocketMQ DLedger(多副本) 之日志复制-下篇

    从上文得知,主节点会主动向从节点传播日志,从节点会通过网络接受到请求数据进行处理,其调用链如图所示:

    丁威
  • 【图文并茂】源码解析MyBatis Sharding-Jdbc SQL语句执行流程详解

    本文将详细介绍Mybatis SQL语句执行的全流程,本文与上篇具有一定的关联性,建议先阅读该系列中的前面3篇文章,重点掌握Mybatis Mapper类的初始...

    丁威
  • Java String 和 StringBuilder 中 equals 的区别

        String 中 只要内容相同 equals 就是 true, 而 == 需要地址及内容相同才行。 

    用户2965768
  • leetcode468. Validate IP Address

    校验该字符串是IPV4地址还是IPV6地址还是二者都不是。 IPV4地址通过小数点分割为4个部分,每个部分都是0~255之间的正整数,且不能包含开头的0,如01...

    眯眯眼的猫头鹰
  • kubelet statusManager 源码分析

    本篇文章没有接上篇继续更新 kube-controller-manager,kube-controller-manager 的源码阅读笔记也会继续更新,笔者会同...

    田飞雨
  • 手机端web学习基础--from慕课网

    web知识零零散散的知道一些,但总感觉不够系统,遇到问题不知道如何解决,因此特此来系统的学习一下web前端的知识。从慕课网的web基础看起。下面学习http:/...

    Ryan-Miao
  • 猿实战15——关联你所不明白的前后台类目

    上一个章节,猿人君教会了你如何去设置广告牌,今天我们一起来学习,如何绑定前后台类目。

    山旮旯的胖子
  • K.Upside down primes(求大素数--米勒卡宾算法--Miller_Rabin)

           题意是给一串数字,然后对这串数字进行180度翻转,其中1,2,5,8,0翻转完还是它本身,6翻转完是9,9翻转后是6,3,4,7都无法翻转(直接输...

    Ch_Zaqdt
  • 干货|云原生计算基金会之云原生全景图

    云是和本地相对的,传统的应用必须跑在本地服务器上,现在流行的应用都跑在云端,云包含了IaaS、PaaS和SaaS。

    猿哥

扫码关注云+社区

领取腾讯云代金券