Spring Cloud中Hystrix、Ribbon及Feign的熔断关系是什么?

桃扇骨 2023-06-28 08:41 9阅读 0赞

## 前言 ##

今天和大家聊一聊在Spring Cloud微服务框架实践中，比较核心但是又很容易把人搞得稀里糊涂的一个问题，那就是在**Spring Cloud**中`Hystrix`、`Ribbon`以及`Feign`它们三者之间在处理微服务调用超时从而触发熔断降级的关系是什么？

我们知道在`Spring Cloud`微服务体系下，**微服务之间的互相调用可以通过`Feign`进行声明式调用，在这个服务调用过程中`Feign`会通过`Ribbon`从服务注册中心获取目标微服务的服务器地址列表，之后在网络请求的过程中`Ribbon`就会将请求以负载均衡的方式打到微服务的不同实例上**，从而实现`Spring Cloud`微服务架构中最为关键的功能即服务发现及客户端负载均衡调用。

另一方面微服务在互相调用的过程中，**为了防止某个微服务的故障消耗掉整个系统所有微服务的连接资源，所以在实施微服务调用的过程中我们会要求在调用方实施针对被调用微服务的熔断逻辑**。而要实现这个逻辑场景在`Spring Cloud`微服务框架下我们是通过`Hystrix`这个框架来实现的。

**调用方会针对被调用微服务设置调用超时时间，一旦超时就会进入熔断逻辑，而这个故障指标信息也会返回给`Hystrix`组件，`Hystrix`组件会根据熔断情况判断被调微服务的故障情况从而打开熔断器，之后所有针对该微服务的请求就会直接进入熔断逻辑，直到被调微服务故障恢复，`Hystrix`断路器关闭为止。**

## Hystrix、Feign及Ribbon的配置说明 ##

接下来我们先来看看在`Spring Cloud`微服务系统中`Hystrix`、`Feign`及`Ribbon`的常用配置都有哪些以及它们的使用场景分别是什么？

**Hystrix配置说明**

在`Spring Cloud`微服务体系中`Hystrix`**主要被用于实现实现微服务之间`网络调用故障的熔断`、`过载保护`及`资源隔离`等功能**。而要正确使用`Hystrix`提供的这些功能就需要对`Hystrix`常用的配置有一定深入的了解，否则你会发现使用过程中认为一定会生效的配置常常不会起作用，接下来我们就按照参数配置的类型对Hystrix中的常见配置做一个梳理。

1.  **线程隔离相关配置**
    
    `Hystrix`具备的重要关键特性之一**就是它能够实现对第三方服务依赖的`资源隔离`，而隔离最常见的方式是通过`线程池资源的隔离来实现的`，`Hystrix`会为每个第三方服务依赖配置单独的线程池资源，从而避免对第三方服务依赖的请求占用应用主线程资源以免造成`系统雪崩`**。Hystrix中关于线程隔离相关的配置如下：
    
        hystrix:
          command:
            #全局默认配置
            default:
              #线程隔离相关
              execution:
                timeout:
                  #是否给方法执行设置超时时间，默认为true。一般我们不要改。
                  enabled: true
                isolation:
                  #配置请求隔离的方式，这里是默认的线程池方式。还有一种信号量的方式semaphore，使用比较少。
                  strategy: threadPool
                  thread:
                    #方式执行的超时时间，默认为1000毫秒，在实际场景中需要根据情况设置
                    timeoutInMilliseconds: 1000
                    #发生超时时是否中断方法的执行，默认值为true。不要改。
                    interruptOnTimeout: true
                    #是否在方法执行被取消时中断方法，默认值为false。没有实际意义，默认就好！
                    interruptOnCancel: false
        　　
2.  **熔断器相关配置**
    
    **熔断器**是`Hystrix`最主要的功能，它开启和关闭的时机、灵敏度及准确性是`Hystrix`是否能够发挥**重要的关键**，而在Hystrix中与熔断器相关的几个配置如下：
    
        hystrix:
          command:
            #全局默认配置
            default:
              #熔断器相关配置
              circuitBreaker:
                #说明：是否启动熔断器，默认为true。我们使用Hystrix的目的就是为了熔断器，不要改，否则就不要引入Hystrix。
                enabled: true
                #说明1：启用熔断器功能窗口时间内的最小请求数，假设我们设置的窗口时间为10秒，
                #说明2：那么如果此时默认值为20的话，那么即便10秒内有19个请求都失败也不会打开熔断器。
                #说明3：此配置项需要根据接口的QPS进行计算，值太小会有误打开熔断器的可能，而如果值太大超出了时间窗口内的总请求数，则熔断永远也不会被触发
                #说明4：建议设置一般为：QPS*窗口描述*60%
                requestVolumeThreshold: 20
                #说明1：熔断器被打开后，所有的请求都会被快速失败掉，但是何时恢复服务是一个问题。熔断器打开后，Hystrix会在经过一段时间后就放行一条请求
                #说明2：如果请求能够执行成功，则说明此时服务可能已经恢复了正常，那么熔断器会关闭；相反执行失败，则认为服务仍然不可用，熔断器保持打开。
                #说明3：所以此配置的作用是指定熔断器打开后多长时间内允许一次请求尝试执行，官方默认配置为5秒。
                sleepWindowInMilliseconds: 5000
                #说明1:该配置是指在通过滑动窗口获取到当前时间段内Hystrix方法执行失败的几率后，根据此配置来判断是否需要打开熔断器
                #说明2:这里官方的默认配置为50，即窗口时间内超过50%的请求失败后就会打开熔断器将后续请求快速失败掉
                errorThresholdPercentage: 50
                #说明：是否强制启用熔断器，默认false，没有什么场景需要这么配置，忽略！
                forceOpen: false
                #说明：是否强制关闭熔断器，默认false，没有什么场景需要这么配置，忽略！
                forceClosed: false
        　　
3.  **Metrics（统计器）相关配置**
    
    `Hystrix`是否正常工作最主要的依赖就是**根据`捕获的调用指标信息`来判断是否打开或者关闭熔断器**，而影响Hystrix行为很重要的因素就是以下`Hystrix`关于`Metrics`的配置。
    
        hystrix:
          command:
            #全局默认配置
            default:
              metrics:
                rollingStats:
                  #说明：此配置用于设置Hystrix统计滑动窗口的时间，单位为毫秒，默认设置为10000毫秒，即一个滑动窗口默认统计的是10秒内的请求数据。
                  timeInMilliseconds: 10000
                  #说明2：此属性指定了滑动统计窗口划分的桶数。默认为10。
                  #说明2：需要注意的是，metrics.rollingStats.timeInMilliseconds % metrics.rollingStats.numBuckets == 0必须成立，否则就会抛出异常
                  numBuckets: 10
         
                rollingPercentile:
                  #说明1：此属性配置统计方法是否响应时间百分比，默认为true。
                  #说明2：Hystrix会统计方法执行1%，10%，50%，90%，99%等比例请求的平均耗时用来生成统计图表。
                  #说明3：如果禁用该参数设置false,那么所有汇总统计信息（平均值、百分位数）将返回-1。
                  enabled: true
                  #说明：统计响应时间百分比时的窗口大小，默认为60000毫秒，即1分钟
                  timeInMilliseconds: 60000
                  #说明1：此属性用于设置滑动百分比窗口要划分的桶数，默认为6。
                  #说明2：需要注意的是，metrics.rollingPercentile.timeInMilliseconds % metrics.rollingPercentile.numBuckets == 0必须成立，否则会抛出异常
                  numBuckets: 6
                  #说明1：该属性表示统计响应时间百分比，每个滑动窗口的桶内要保存的请求数，默认为100。
                  #说明2：即默认10秒的桶内，如果执行了500次请求，那么只有最后100次请求执行的信息会被保存到桶内。
                  #说明3：增加这个值会增加内存消耗量，一般情况下无需更改。
                  bucketSize: 100
         
                healthSnapshot:
                  #说明1：该参数配置了健康数据统计器（会影响Hystrix熔断）中每个桶的大小，默认为500毫秒。
                  #说明2：在统计时Hystrix通过metrics.rollingStats.timeInMilliseconds / metrics.healthSnapshot.intervalInMilliseconds计算出桶数。
                  #说明3：在窗口滑动时，每滑过一个桶的时间就统计一次当前窗口内请求的失败率。
                  intervalInMilliseconds: 500
    
    在上述关于`Metrics`的配置中出现了两个比较频繁的**概念**：`滑动窗口`、`桶`，`Hystrix`**的统计器就是由`滑动窗口`来实现的**。关于滑动窗口举一个非常形象的例子，假设你坐在一辆大巴车的上，车窗外是一排排笔直的大树，车辆在高速地行驶着，大树迅速地从车窗滑过，如果用每棵树来代表一个网络请求，用大巴车的行驶代表时间的流逝。那么大巴车的窗口就是一个非常典型的滑动窗口，而你通过这个车窗能够看到的大树就是Hystrix要统计的数据。
    
    **桶(bucket)是`Hystrix`统计滑动窗口数据时的最小单位**。同样以上面的例子为例，在大巴车行驶非常快的情况下，如果每掠过一棵树就统计一次窗口内大树的数据的话，会造成比较大的开销，而如果我们将车窗分成`10`份，大巴车行驶时每掠过窗口的`1/10`就统计一次数据，那么开销就会小很多了。所以，Hystrix中的桶就是滑动窗口`1/N`的概念。
4.  **线程池相关配置**
    
    在前面提到过`Hystrix`实现对第三方服务**依赖资源隔离**最主要的方式就是**通过线程池，而`Hystrix`内线程的使用是基于`Java`内置线程池的简单封装，通过以下`Hystrix`线程池参数我们可以控制执行`Hystrix`命令的线程池的行为**。具体如下：
    
        hystrix:
          command:
            default:
              #说明：核心线程池的大小，默认值是10
              coreSize: 10
              #说明：是否允许线程池扩展到最大线程池数量，默认为false。
              allowMaximumSizeToDivergeFromCoreSize: false
              #说明：线程池中线程的最大数量，默认值是10。此配置项单独配置时并不会生效，需要启用allowMaximumSizeToDivergeFromCoreSize
              maximumSize: 10
              #说明1：作业队列的最大值，默认值为-1。表示队列会使用SynchronousQueue，此时值为0，Hystrix不会向队列内存放作业。
              #说明2：如果此值设置为一个正int型，队列会使用一个固定size的LinkedBlockingQueue，此时在核心线程池都忙碌的情况下，会将作业暂时存放在此队列内，但是超出此队列的请求依然会被拒绝
              maxQueueSize: -1
              #设置队列拒绝请求的阀值，默认为5。
              queueSizeRejectionThreshold: 5
              #控制线程在释放前未使用的时间，默认为1分钟。
              keepAliveTimeMinutes: 1

**Ribbon配置说明**

`Ribbon`在`Spring Cloud`中对于支持微服之间的通信发挥着非常关键的作用，其主要功能包括客户端负载均衡器及用于中间层通信的客户端。在基于`Feign`的微服务通信中无论是否开启`Hystrix`，`Ribbon`都是必不可少的，Ribbon的配置参数主要如下：

ribbon:
      #说明：同一台实例的最大自动重试次数，默认为1次，不包括首次
      MaxAutoRetries: 1
      #说明：要重试的下一个实例的最大数量，默认为1，不包括第一次被调用的实例
      MaxAutoRetriesNextServer: 1
      #说明：是否所有的操作都重试，默认为true
      OkToRetryOnAllOperations: true
      #说明：从注册中心刷新服务器列表信息的时间间隔，默认为2000毫秒，即2秒
      ServerListRefreshInterval: 2000
      #说明：使用Apache HttpClient连接超时时间，单位为毫秒
      ConnectTimeout: 3000
      #说明：使用Apache HttpClient读取的超时时间，单位为毫秒
      ReadTimeout: 3000
      #说明：初始服务器列表，不需要手工配置，在运行时动态根据注册中心更新
      listOfServers: www.microsoft.com:80,www.yahoo.com:80,www.google.com:80

以上配置方式将对所有的微服务调用有效，如果想针对单独的微服务进行配置，使用“微服务名.ribbon”这样的配置方式即可，例如：

bike:
      ribbon:
        ReadTimeout: 30000
    operation:
      ribbon:
        ReadTimeout: 30000

**Feign配置说明**

`Feign`是一款`Java`语言编写的`HttpClient`绑定器，在`Spring Cloud`微服务中用于**实现微服务之间的声明式调用**，`Feign`自身可以支持多种`HttpClient`工具包，例如`OkHttp`及`Apache HttpClient`，针对不同的`HttpClient`其默认常见配置如下：

feign:
      hystrix:
        enabled: true
      client:
        config:
          #JDK默认HttpURLConnection 实现的 Http Client配置
          default:
            #连接超时时间
            connectTimeout: 5000
            #读取超时时间
            readTimeout: 5000
            #错误解码器
            errorDecoder: com.wudimanong.client.common.FeignClientErrorDecoder
            #解码器
            encoder: com.wudimanong.client.common.FeignClientEncoder
            #编码器
            decoder: com.wudimanong.client.common.FeignClientDecoder

## Feign、Hystrix、Ribbon的超时配置关系 ##

在前面的内容我们分别单独梳理了`Feign`、`Hystrix`及`Ribbon`三者常见的配置，针对各自的特性功能配置我们并没有异议，但是我们也看到它们都有针对微服务超时的配置，而在开启熔断器功能后，这些超时配置会影响到熔断器及服务降级逻辑的行为，那么它们之间超时的配置有什么关系呢？如下：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjc0MDUzMA_size_16_color_FFFFFF_t_70]  
如上图所示，在`Spring Cloud`中使用`Feign`进行微服务调用分为**两层**：`Ribbon的调用`及`Hystrix的调用`。所以`Feign`**的超时时间就是`Ribbon`和`Hystrix`超时时间的结合，而如果不启用`Hystrix`则`Ribbon`的超时时间就是`Feign`的超时时间配置，`Feign`自身的配置会被覆盖。**

而如果开启了`Hystrix`，那么`Ribbon`的超时时间配置与`Hystrix`的超时时间配置则存在依赖关系，因为涉及到`Ribbon`的重试机制，所以一般情况下都是`Ribbon`的超时时间小于`Hystrix`的超时时间，否则会出现以下错误：

2019-07-12 11:10:20,238 397194 [http-nio-8084-exec-2] WARN  o.s.c.n.z.f.r.s.AbstractRibbonCommand - The Hystrix timeout of 40000ms for the command operation is set lower than the combination of the Ribbon read and connect timeout, 80000ms.

那么`Ribbon`和`Hystrix`的超时时间配置的关系具体是什么呢？如下：

Hystrix的超时时间=Ribbon的重试次数(包含首次)*(ribbon.ReadTimeout+ribbon.ConnectTimeout)

而`Ribbon`的重试次数的计算方式为：

Ribbon重试次数(包含首次)=1+ribbon.MaxAutoRetries+ribbon.MaxAutoRetriesNextServer+(ribbon.MaxAutoRetries*ribbon.MaxAutoRetriesNextServer)

以上图中的`Ribbon`配置为例子，`Ribbon的重试次数=1+(1+1+1)*(30000+10000)`，所以`Hystrix的超时配置应该>=160000毫秒`。在`Ribbon`超时但`Hystrix`没有超时的情况下，`Ribbon`便会**采取重试机制**；而重试期间如果时间超过了`Hystrix`的超时配置则会立即被熔断（`fallback`）。

如果不配置`Ribbon`的重试次数，则`Ribbon`默认会重试一次，加上第一次调用`Ribbon`的重试次数为2次，以上述配置为例`Hystrix`超时时间配置为`2*40000=80000`，由于很多情况下，大家一般不会主动配置`Ribbon`的重试次数，所以这里需要注意下！强调下，以上超时配置的值只是示范，超时配置有点大不太合适实际的线上场景，大家根据实际情况设置即可！

PS：以上整理应该是全网最全的一份，如果觉得有用辛苦转发下，给在使用Spring Cloud微服务的朋友们送去一点小温暖！\_

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjc0MDUzMA_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200108105249184.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjc0MDUzMA==,size_16,color_FFFFFF,t_70