轻拢慢捻，微服务熔断大总管。一文讲透SpringCloud熔断组件

原创：小姐姐味道（微信公众号ID：xjjdog），欢迎分享，转载请保留出处。

我这篇文章来的晚了些，由于hystrix已经进入维护模式。但已经有很是多的同窗入坑了，那么本篇文章就是及时雨。本文将说明熔断使用的一些注意事项，可能会细的让你厌烦。

前半段，是理论部分，各类熔断都适用。后半段，是参数部分，适合微调。

那咱们开始。

一般来讲，皇帝在微服务里想夜生活过得舒服，可以大刀阔斧单刀直入，不因私事丢江山，就不得不靠熔断大总管。

时过境迁。提到熔断大总管就不得不说他手下最突出的三位公公：sentinel，或hystrix，也多是resilience4j。

这三位都是解决一类问题的，如著名的雪崩：A→B→C互相依次调用，但C项目极可能出现问题（流量过大或者报错等），引起线程一直进行等待，致使拖垮整个链路层，线程资源耗尽。

1、背景

假如是用的spring全家桶系列，在接口调用上大多会走这个路线。咱们这里依然是在说hystrix，虽然如今再也不受宠。

Feign -----> Hystrix -----> Ribbon -----> Http Client（apache http components/Okhttp）

具体以下图所示：

2、配置

首先来点理论性的东西。好吃不贵。

Ⅰ隔离方式

线程隔离（默认）：使用一个线程池来存储当前的请求，线程池对请求做处理，设置任务返回处理超时时间，堆积的请求堆积入线程池队列。这种方式须要为每一个依赖的服务申请线程池，有必定的资源消耗，好处是能够应对突发流量（流量洪峰来临时，处理不完可将数据存储到线程池队里慢慢处理）

信号隔离：使用一个原子计数器（或信号量）来记录当前有多少个线程在运行，请求来先判断计数器的数值，若超过设置的最大线程个数则丢弃改类型的新请求，若不超过则执行计数操做请求来计数器+1，请求返回计数器-1。这种方式是严格的控制线程且当即返回模式，没法应对突发流量（流量洪峰来临时，处理的线程超过数量，其余的请求会直接返回，不继续去请求依赖的服务）

Ⅱ熔断

若是某个目标服务调用慢或者大量超时，则此时熔断该服务的调用，对于后续调用请求，再也不继续调用目标服务，直接返回，快速释放资源。若是目标服务状况好转，则恢复调用。

这个过程，能够想象成保险丝的行为。

行为虽然简单，但须要调节的参数却很是多。

使用方式

1.引入依赖

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>
复制代码

2.配置参数

feign:
  hystrix:
#不配置或为false则不生效
    enabled: true
hystrix:
  command:
    default:
      execution:
        isolation:
          thread:
#若配置了重试则超时时间= (1 + MaxAutoRetries + MaxAutoRetriesNextServer) * ReadTimeout
            timeoutInMilliseconds: 60000
  threadpool:
    default:
      coreSize: 10
      maxQueueSize: 50
      queueSizeRejectionThreshold: 30
      keepAliveTimeMinutes: 3
复制代码

3.配置fallback

因业务处理不一样，建议每一个feign client使用不一样的fallback

到此，hystrix已经能够走立刻任，至于干活儿稳不稳那是后话。

4.配置的其余姿式

hystrix到任后，发现有的服务接口1s内就完事儿 ，还有的5s到10几秒才堪堪返回。一刀切的配置已难以管理诸多服务&接口。

想必已经有人发现，以前配置中混进了奇怪的东西——default关键词。这是对全局配置，那么对应的确定有局部的配置。

如：对服务的，对某个接口的...

hystrix:
  command:
    default:
      execution:
        isolation:
          thread:
            timeoutInMilliseconds: 60000
  threadpool:
  #全局配置
    default:
      coreSize: 10
      maxQueueSize: 50
      queueSizeRejectionThreshold: 30
      keepAliveTimeMinutes: 3
    #对某个服务配置，写service-id
    base-rpc:
      coreSize: 10
      maxQueueSize: 30
      queueSizeRejectionThreshold: 20
      keepAliveTimeMinutes: 3
    #对某个接口配置
    BaseApiClient#searchItemSkuList(PosSkuSearch):
      coreSize: 10
      maxQueueSize: 40
      queueSizeRejectionThreshold: 30
      keepAliveTimeMinutes: 1
复制代码

另外，还可使用@HystrixCommand注解进行配置。

5.配置的动态修改

不少状况下，不能修改个配置，特别是临时修改配置就重启下服务，能动态刷新就最好了。 因而咱们盯上了hystrix使用archaius管理配置的问题。

archaius是Netflix公司开源项目之一，基于java的配置管理类库，主要用于多配置存储的动态获取。 主要功能是对apache common configuration类库的扩展。在云平台开发中能够将其用做分布式配置管理依赖构件。同时，它有以下一些特性： 动态获取属性 高效和线程安全的配置操做 配置改变时提供回调机制 能够经过jmx操做配置 复合配置

说了这么多那该怎么整呢？如下就是简单的示例。

//捞配置
AbstractConfiguration config = ConfigurationManager.getConfigInstance();
 
//提取关注的部分，好比hystrix.threadpool
Iterable<String> iterable = () -> config.getKeys("hystrix.threadpool");
List<Property> result = StreamSupport.stream(iterable.spliterator(), false).map(t -> new Property(t, config.getString(t, "")))
        .sorted(Comparator.comparing(Property::getName)).collect(Collectors.toList());
 
//修改配置
config.setProperty("hystrix.threadpool.base-rpc.coreSize", 20);
 
//移除配置
config.clearProperty(hystrix.threadpool.base-rpc.coreSize"); 复制代码

3、其余参数

要是以为hystrix这么听话，那就过小看它了。别忘了前面有feign，后面还有ribbon，再日后http client呢！一堆超时参数，当代的八门金锁阵

1.feign超时

feign:
  hystrix:
    enabled: true
  client:
    config:
      default:
        connectTimeout: 5000
        readTimeout: 5000
      rpc-pos:
        connectTimeout: 5000
        readTimeout: 8000
      xx-rpc:
        connectTimeout: 5000
        readTimeout: 12000
      order-rpc:
        connectTimeout: 5000
        readTimeout: 8000
复制代码

feign是暴露给用户使用的，Spring在处理这一块的时候，会有意识地使用feign的超时时间来设置后面的ribbon 和http client组件。

2.ribbon超时

#全局配置
ribbon:
  ReadTimeout: 60000
  ConnectTimeout: 10000
  #false to only allow get method to retry
  OkToRetryOnAllOperations: true
  # Max number of next servers to retry (excluding the first server)
  MaxAutoRetriesNextServer: 2
  # Max number of retries on the same server (excluding the first try)
  MaxAutoRetries: 0
  # Interval to refresh the server list from the source
  ServerListRefreshInterval: 5000
  retryableStatusCodes: 404,500
  #服务配置
base-rpc:
  ribbon:
    ReadTimeout: 60000
    ConnectTimeout: 10000
    #false to only allow get method to retry
    OkToRetryOnAllOperations: true
    # Max number of next servers to retry (excluding the first server)
    MaxAutoRetriesNextServer: 2
    # Max number of retries on the same server (excluding the first try)
    MaxAutoRetries: 0
    # Interval to refresh the server list from the source
    ServerListRefreshInterval: 5000
    retryableStatusCodes: 404,500
复制代码

当feign设置了超时时间，Ribbon会依据feign的设置同步。Ribbon的这个超时时间，用于指导真正调用接口时，设置真正实现者的超时时间。

httpclient超时

feign:
  hystrix:
    enabled: true
  okhttp:
    enabled: true
  httpclient:
    enabled: false
//链接池最大链接数，默认200
    max-connections: 500
//每个IP最大占用多少链接 默认 50
    max-connections-per-route: 50
//默认链接超时时间：2000毫秒
    connection-timeout: 8000
//链接池管理定时器执行频率：默认 3000毫秒
    connection-timer-repeat: 6000
//链接池中存活时间，默认为5
    time-to-live: 5
    time-to-live-unit: minutes
复制代码

超时设置遵循的基本原则是：依赖方的超时配置覆盖被依赖方的配置，而其配置覆盖的形式，则是使用的Spring Boot 的 AutoConfiguration 机制实现的

如：若开启feign.okhttp.enabled=true，则okhttp的超时时间是feign.httpclient.connectionTimeout的值，默认2000毫秒

总结：超时——仍是 feign 说了算！

4、hystrix dashboard

可以将这些状态可视化，是很是棒的，须要引入一个jar包。

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-hystrix-dashboard</artifactId>
</dependency>
复制代码

下面这张图，就是针对后台监控的一些解释。

(图片来源于网络)

附：配置参数说明

1、Command Properties

如下属性控制HystrixCommand，前缀hystrix.command.default

一、Execution

如下属性控制HystrixCommand.run()如何执行。 比较重要的参数，有： execution.isolation.strategy execution.isolation.thread.timeoutInMilliseconds

二、Fallback

如下属性控制HystrixCommand.getFallback()如何执行。这些属性适用于ExecutionIsolationStrategy.THREAD和ExecutionIsolationStrategy.SEMAPHORE。

三、Circuit Breaker

断路器属性控制HystrixCircuitBreaker。

四、Metrics

如下属性与从HystrixCommand和HystrixObservableCommand执行捕获指标有关。

五、Request Context

这些属性涉及HystrixCommand使用的HystrixRequestContext功能

2、Command Properties

下列属性控制HystrixCollapser行为。前缀:hystrix.collapser.default

3、ThreadPool Properties

如下属性控制Hystrix命令在其上执行的线程池的行为。 大多数时候，默认值为10的线程会很好（一般能够作得更小）前缀:hystrix.threadpool.default

End

这货，说不更新，还真不更新了。但咱们的遗留系统，有不少模块在用着，因此我仍是把它的细节参数给抠出来了。这应该是绝版吧，由于hystrix是绝更了。

本文只适合收藏，不适合分享。分享出去，会等于拿着大喇叭告诉别人，你正在给某个遗留系统填坑呢。

做者简介：小姐姐味道 (xjjdog)，一个不容许程序员走弯路的公众号。聚焦基础架构和Linux。十年架构，日百亿流量，与你探讨高并发世界，给你不同的味道。个人我的微信xjjdog0，欢迎添加好友，​进一步交流。​