Hystrix 分布式系统限流、降级、熔断框架

喜欢ヅ旅行 2022-05-19 13:57 240阅读 0赞

# 一:为什么需要Hystrix? #

在大中型分布式系统中，通常系统很多依赖(HTTP,hession,Netty,Dubbo等)，如下图:

![887e7862-578a-3616-a15c-1ef1cb62f3c4.png][]

在高并发访问下,这些依赖的稳定性与否对系统的影响非常大,但是依赖有很多不可控问题:如网络连接缓慢，资源繁忙，暂时不可用，服务脱机等.

如下图：QPS为50的依赖 I 出现不可用，但是其他依赖仍然可用.

![3bd6d0be-9ce5-35c2-bbd9-3493671b45d5.png][]

当依赖I 阻塞时,大多数服务器的线程池就出现阻塞(BLOCK),影响整个线上服务的稳定性.如下图:

![22f20da1-4096-314c-8c9f-5728251c46af.png][]

在复杂的分布式架构的应用程序有很多的依赖，都会不可避免地在某些时候失败。高并发的依赖失败时如果没有隔离措施，当前应用服务就有被拖垮的风险。

例如:

一个依赖30个SOA服务的系统,每个服务99.99%可用。

99.99%的30次方 ≈ 99.7%

0.3% 意味着一亿次请求 会有 3,000,00次失败

换算成时间大约每月有2个小时服务不稳定.

随着服务依赖数量的变多，服务不稳定的概率会成指数性提高.

解决问题方案:对依赖做隔离,Hystrix就是处理依赖隔离的框架,同时也是可以帮我们做依赖服务的治理和监控.

Netflix 公司开发并成功使用Hystrix,使用规模如下:

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 </td> 
 <td> <code>The&nbsp;Netflix&nbsp;API&nbsp;processes&nbsp;</code><code>10</code><code>+&nbsp;billion&nbsp;HystrixCommand&nbsp;executions&nbsp;per&nbsp;day&nbsp;using&nbsp;thread&nbsp;isolation.&nbsp;&nbsp;&nbsp;</code> <code>Each&nbsp;API&nbsp;instance&nbsp;has&nbsp;</code><code>40</code><code>+&nbsp;thread-pools&nbsp;with&nbsp;</code><code>5</code><code>-</code><code>20</code>&nbsp;<code>threads&nbsp;in&nbsp;each&nbsp;(most&nbsp;are&nbsp;set&nbsp;to&nbsp;</code><code>10</code><code>).</code> </td> 
 </tr> 
 </tbody> 
</table>

# 二:Hystrix如何解决依赖隔离 #

1:Hystrix使用命令模式HystrixCommand(Command)包装依赖调用逻辑，每个命令在单独线程中/信号授权下执行。

2:可配置依赖调用超时时间,超时时间一般设为比99.5%平均时间略高即可.当调用超时时，直接返回或执行fallback逻辑。

3:为每个依赖提供一个小的线程池（或信号），如果线程池已满调用将被立即拒绝，默认不采用排队.加速失败判定时间。

4:依赖调用结果分:成功，失败（抛出异常），超时，线程拒绝，短路。 请求失败(异常，拒绝，超时，短路)时执行fallback(降级)逻辑。

5:提供熔断器组件,可以自动运行或手动调用,停止当前依赖一段时间(10秒)，熔断器默认错误率阈值为50%,超过将自动运行。

6:提供近实时依赖的统计和监控

Hystrix依赖的隔离架构,如下图:

![8db93de3-db14-355f-ac70-16d06481b020.png][]

# 三:如何使用Hystrix #

## 1:使用maven引入Hystrix依赖 ##

## 2:使用命令模式封装依赖逻辑 ##

note:异步调用使用 command.queue()get(timeout, TimeUnit.MILLISECONDS);同步调用使用command.execute() 等同于 command.queue().get();

## 3:注册异步事件回调执行 ##

## 4:使用Fallback() 提供降级策略 ##

![ece3a873-1c63-35c3-bdf1-beb45c96b9c2.png][]

NOTE: 除了HystrixBadRequestException异常之外，所有从run()方法抛出的异常都算作失败，并触发降级getFallback()和断路器逻辑。

HystrixBadRequestException用在非法参数或非系统故障异常等不应触发回退逻辑的场景。

## 5:依赖命名:CommandKey ##

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 </td> 
 <td> <code>public</code>&nbsp;<code>HelloWorldCommand(String&nbsp;name)&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>super</code><code>(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey(</code><code>"ExampleGroup"</code><code>))&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>/*&nbsp;HystrixCommandKey工厂定义依赖名称&nbsp;*/</code>&nbsp;&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>.andCommandKey(HystrixCommandKey.Factory.asKey(</code><code>"HelloWorld"</code><code>)));&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>this</code><code>.name&nbsp;=&nbsp;name;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

NOTE: 每个CommandKey代表一个依赖抽象,相同的依赖要使用相同的CommandKey名称。依赖隔离的根本就是对相同CommandKey的依赖做隔离.

## 6:依赖分组:CommandGroup ##

命令分组用于对依赖操作分组,便于统计,汇总等.

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 </td> 
 <td> <code>//使用HystrixCommandGroupKey工厂定义&nbsp;&nbsp;</code> <code>public</code>&nbsp;<code>HelloWorldCommand(String&nbsp;name)&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey(</code><code>"HelloWorldGroup"</code><code>))&nbsp;&nbsp;</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

NOTE: CommandGroup是每个命令最少配置的必选参数，在不指定ThreadPoolKey的情况下，字面值用于对不同依赖的线程池/信号区分.

## 7:线程池/信号:ThreadPoolKey ##

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 </td> 
 <td> <code>public</code>&nbsp;<code>HelloWorldCommand(String&nbsp;name)&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>super</code><code>(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey(</code><code>"ExampleGroup"</code><code>))&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>.andCommandKey(HystrixCommandKey.Factory.asKey(</code><code>"HelloWorld"</code><code>))&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>/*&nbsp;使用HystrixThreadPoolKey工厂定义线程池名称*/</code>&nbsp;&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>.andThreadPoolKey(HystrixThreadPoolKey.Factory.asKey(</code><code>"HelloWorldPool"</code><code>)));&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>this</code><code>.name&nbsp;=&nbsp;name;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

NOTE: 当对同一业务依赖做隔离时使用CommandGroup做区分,但是对同一依赖的不同远程调用如(一个是redis 一个是http),可以使用HystrixThreadPoolKey做隔离区分.

最然在业务上都是相同的组，但是需要在资源上做隔离时，可以使用HystrixThreadPoolKey区分.

## 8:请求缓存 Request-Cache ##

NOTE:请求缓存可以让(CommandKey/CommandGroup)相同的情况下,直接共享结果，降低依赖调用次数，在高并发和CacheKey碰撞率高场景下可以提升性能.

Servlet容器中，可以直接实用Filter机制Hystrix请求上下文

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 </td> 
 <td> <code>public</code>&nbsp;<code>class</code>&nbsp;<code>HystrixRequestContextServletFilter&nbsp;</code><code>implements</code>&nbsp;<code>Filter&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>void</code>&nbsp;<code>doFilter(ServletRequest&nbsp;request,&nbsp;ServletResponse&nbsp;response,&nbsp;FilterChain&nbsp;chain)&nbsp;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>throws</code>&nbsp;<code>IOException,&nbsp;ServletException&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>HystrixRequestContext&nbsp;context&nbsp;=&nbsp;HystrixRequestContext.initializeContext();&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>try</code>&nbsp;<code>{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>chain.doFilter(request,&nbsp;response);&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;</code><code>finally</code>&nbsp;<code>{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>context.shutdown();&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 </td> 
 <td> <code>&lt;</code><code>filter</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>display-name</code><code>&gt;HystrixRequestContextServletFilter&lt;/</code><code>display-name</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>filter-name</code><code>&gt;HystrixRequestContextServletFilter&lt;/</code><code>filter-name</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>filter-class</code><code>&gt;com.netflix.hystrix.contrib.requestservlet.HystrixRequestContextServletFilter&lt;/</code><code>filter-class</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;/</code><code>filter</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>filter-mapping</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>filter-name</code><code>&gt;HystrixRequestContextServletFilter&lt;/</code><code>filter-name</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>url-pattern</code><code>&gt;/*&lt;/</code><code>url-pattern</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;</code><code>&lt;/</code><code>filter-mapping</code><code>&gt;</code> </td> 
 </tr> 
 </tbody> 
</table>

## 9:信号量隔离:SEMAPHORE ##

隔离本地代码或可快速返回远程调用(如memcached,redis)可以直接使用信号量隔离,降低线程隔离开销.

## 10:fallback降级逻辑命令嵌套 ##

![98dd13fb-4ff2-39fc-a8df-7758d09fe16f.png][]

适用场景:用于fallback逻辑涉及网络访问的情况,如缓存访问。

NOTE:依赖调用和降级调用使用不同的线程池做隔离，防止上层线程池跑满，影响二级降级逻辑调用.

## 11:显示调用fallback逻辑,用于特殊业务处理 ##

![5c307f4e-2fdd-3bb8-a472-06abeb60ce47.png][]

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 </td> 
 <td> <code>public</code>&nbsp;<code>class</code>&nbsp;<code>CommandFacadeWithPrimarySecondary&nbsp;</code><code>extends</code>&nbsp;<code>HystrixCommand&lt;String&gt;&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code>&nbsp;<code>final</code>&nbsp;<code>static</code>&nbsp;<code>DynamicBooleanProperty&nbsp;usePrimary&nbsp;=&nbsp;DynamicPropertyFactory.getInstance().getBooleanProperty(</code><code>"primarySecondary.usePrimary"</code><code>,&nbsp;</code><code>true</code><code>);&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code>&nbsp;<code>final</code>&nbsp;<code>int</code>&nbsp;<code>id;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>CommandFacadeWithPrimarySecondary(</code><code>int</code>&nbsp;<code>id)&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>super</code><code>(Setter&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>.withGroupKey(HystrixCommandGroupKey.Factory.asKey(</code><code>"SystemX"</code><code>))&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>.andCommandKey(HystrixCommandKey.Factory.asKey(</code><code>"PrimarySecondaryCommand"</code><code>))&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>.andCommandPropertiesDefaults(&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>HystrixCommandProperties.Setter()&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>.withExecutionIsolationStrategy(ExecutionIsolationStrategy.SEMAPHORE)));&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>this</code><code>.id&nbsp;=&nbsp;id;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Override</code>&nbsp;&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>protected</code>&nbsp;<code>String&nbsp;run()&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>(usePrimary.get())&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>new</code>&nbsp;<code>PrimaryCommand(id).execute();&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;</code><code>else</code>&nbsp;<code>{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>new</code>&nbsp;<code>SecondaryCommand(id).execute();&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Override</code>&nbsp;&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>protected</code>&nbsp;<code>String&nbsp;getFallback()&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>"static-fallback-"</code>&nbsp;<code>+&nbsp;id;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Override</code>&nbsp;&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>protected</code>&nbsp;<code>String&nbsp;getCacheKey()&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>String.valueOf(id);&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code>&nbsp;<code>static</code>&nbsp;<code>class</code>&nbsp;<code>PrimaryCommand&nbsp;</code><code>extends</code>&nbsp;<code>HystrixCommand&lt;String&gt;&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code>&nbsp;<code>final</code>&nbsp;<code>int</code>&nbsp;<code>id;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code>&nbsp;<code>PrimaryCommand(</code><code>int</code>&nbsp;<code>id)&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>super</code><code>(Setter&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>.withGroupKey(HystrixCommandGroupKey.Factory.asKey(</code><code>"SystemX"</code><code>))&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>.andCommandKey(HystrixCommandKey.Factory.asKey(</code><code>"PrimaryCommand"</code><code>))&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>.andThreadPoolKey(HystrixThreadPoolKey.Factory.asKey(</code><code>"PrimaryCommand"</code><code>))&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>.andCommandPropertiesDefaults(&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//&nbsp;we&nbsp;default&nbsp;to&nbsp;a&nbsp;600ms&nbsp;timeout&nbsp;for&nbsp;primary&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>HystrixCommandProperties.Setter().withExecutionTimeoutInMilliseconds(</code><code>600</code><code>)));&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>this</code><code>.id&nbsp;=&nbsp;id;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Override</code>&nbsp;&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>protected</code>&nbsp;<code>String&nbsp;run()&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//&nbsp;perform&nbsp;expensive&nbsp;'primary'&nbsp;service&nbsp;call&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>"responseFromPrimary-"</code>&nbsp;<code>+&nbsp;id;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code>&nbsp;<code>static</code>&nbsp;<code>class</code>&nbsp;<code>SecondaryCommand&nbsp;</code><code>extends</code>&nbsp;<code>HystrixCommand&lt;String&gt;&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code>&nbsp;<code>final</code>&nbsp;<code>int</code>&nbsp;<code>id;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code>&nbsp;<code>SecondaryCommand(</code><code>int</code>&nbsp;<code>id)&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>super</code><code>(Setter&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>.withGroupKey(HystrixCommandGroupKey.Factory.asKey(</code><code>"SystemX"</code><code>))&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>.andCommandKey(HystrixCommandKey.Factory.asKey(</code><code>"SecondaryCommand"</code><code>))&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>.andThreadPoolKey(HystrixThreadPoolKey.Factory.asKey(</code><code>"SecondaryCommand"</code><code>))&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>.andCommandPropertiesDefaults(&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//&nbsp;we&nbsp;default&nbsp;to&nbsp;a&nbsp;100ms&nbsp;timeout&nbsp;for&nbsp;secondary&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>HystrixCommandProperties.Setter().withExecutionTimeoutInMilliseconds(</code><code>100</code><code>)));&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>this</code><code>.id&nbsp;=&nbsp;id;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Override</code>&nbsp;&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>protected</code>&nbsp;<code>String&nbsp;run()&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//&nbsp;perform&nbsp;fast&nbsp;'secondary'&nbsp;service&nbsp;call&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>"responseFromSecondary-"</code>&nbsp;<code>+&nbsp;id;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>static</code>&nbsp;<code>class</code>&nbsp;<code>UnitTest&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Test</code>&nbsp;&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>void</code>&nbsp;<code>testPrimary()&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>HystrixRequestContext&nbsp;context&nbsp;=&nbsp;HystrixRequestContext.initializeContext();&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>try</code>&nbsp;<code>{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>ConfigurationManager.getConfigInstance().setProperty(</code><code>"primarySecondary.usePrimary"</code><code>,&nbsp;</code><code>true</code><code>);&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>assertEquals(</code><code>"responseFromPrimary-20"</code><code>,&nbsp;</code><code>new</code>&nbsp;<code>CommandFacadeWithPrimarySecondary(</code><code>20</code><code>).execute());&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;</code><code>finally</code>&nbsp;<code>{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>context.shutdown();&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>ConfigurationManager.getConfigInstance().clear();&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Test</code>&nbsp;&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>void</code>&nbsp;<code>testSecondary()&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>HystrixRequestContext&nbsp;context&nbsp;=&nbsp;HystrixRequestContext.initializeContext();&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>try</code>&nbsp;<code>{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>ConfigurationManager.getConfigInstance().setProperty(</code><code>"primarySecondary.usePrimary"</code><code>,&nbsp;</code><code>false</code><code>);&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>assertEquals(</code><code>"responseFromSecondary-20"</code><code>,&nbsp;</code><code>new</code>&nbsp;<code>CommandFacadeWithPrimarySecondary(</code><code>20</code><code>).execute());&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;</code><code>finally</code>&nbsp;<code>{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>context.shutdown();&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>ConfigurationManager.getConfigInstance().clear();&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

NOTE:显示调用降级适用于特殊需求的场景,fallback用于业务处理，fallback不再承担降级职责，建议慎重使用，会造成监控统计换乱等问题.

## 12:命令调用合并:HystrixCollapser ##

命令调用合并允许多个请求合并到一个线程/信号下批量执行。

执行流程图如下:

![8d62f5cf-b340-34c6-8c43-bd51e9bc26ee.png][]

NOTE:使用场景:HystrixCollapser用于对多个相同业务的请求合并到一个线程甚至可以合并到一个连接中执行，降低线程交互次和IO数,但必须保证他们属于同一依赖.

# 四:监控平台搭建Hystrix-dashboard #

## 1:监控dashboard介绍 ##

dashboard面板可以对依赖关键指标提供实时监控,如下图:

![65dccd3d-5adf-34c2-bd00-42629ed46319.png][]

## 2:实例暴露command统计数据 ##

Hystrix使用Servlet对当前JVM下所有command调用情况作数据流输出

配置如下:

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 </td> 
 <td> <code>&lt;</code><code>servlet</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>display-name</code><code>&gt;HystrixMetricsStreamServlet&lt;/</code><code>display-name</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>servlet-name</code><code>&gt;HystrixMetricsStreamServlet&lt;/</code><code>servlet-name</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>servlet-class</code><code>&gt;com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsStreamServlet&lt;/</code><code>servlet-class</code><code>&gt;&nbsp;&nbsp;</code> <code>&lt;/</code><code>servlet</code><code>&gt;&nbsp;&nbsp;</code> <code>&lt;</code><code>servlet-mapping</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>servlet-name</code><code>&gt;HystrixMetricsStreamServlet&lt;/</code><code>servlet-name</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>url-pattern</code><code>&gt;/hystrix.stream&lt;/</code><code>url-pattern</code><code>&gt;&nbsp;&nbsp;</code> <code>&lt;/</code><code>servlet-mapping</code><code>&gt;&nbsp;&nbsp;</code> <code>&lt;!--&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>对应URL格式&nbsp;:&nbsp;http://hostname:port/application/hystrix.stream&nbsp;</code> <code>--&gt;</code> </td> 
 </tr> 
 </tbody> 
</table>

## 3:集群模式监控统计搭建 ##

1)使用Turbine组件做集群数据汇总

结构图如下：

![bd172cab-839d-357f-a8a3-5e0132858723.png][]

2)内嵌jetty提供Servlet容器,暴露HystrixMetrics

3)Turbine搭建和配置

a:配置Turbine Servlet收集器

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 </td> 
 <td> <code>&lt;</code><code>servlet</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>description</code><code>&gt;&lt;/</code><code>description</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>display-name</code><code>&gt;TurbineStreamServlet&lt;/</code><code>display-name</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>servlet-name</code><code>&gt;TurbineStreamServlet&lt;/</code><code>servlet-name</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>servlet-class</code><code>&gt;com.netflix.turbine.streaming.servlet.TurbineStreamServlet&lt;/</code><code>servlet-class</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;</code><code>&lt;/</code><code>servlet</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;</code><code>&lt;</code><code>servlet-mapping</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>servlet-name</code><code>&gt;TurbineStreamServlet&lt;/</code><code>servlet-name</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>url-pattern</code><code>&gt;/turbine.stream&lt;/</code><code>url-pattern</code><code>&gt;&nbsp;&nbsp;</code> <code>&nbsp;</code><code>&lt;/</code><code>servlet-mapping</code><code>&gt;</code> </td> 
 </tr> 
 </tbody> 
</table>

b:编写config.properties配置集群实例

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 </td> 
 <td> <code>#配置两个集群:mobil-online,ugc-online&nbsp;&nbsp;</code> <code>turbine.aggregator.clusterConfig=mobil-online,ugc-online&nbsp;&nbsp;</code> <code>#配置mobil-online集群实例&nbsp;&nbsp;</code> <code>turbine.ConfigPropertyBasedDiscovery.mobil-online.instances=</code><code>10.10</code><code>.*.*,</code><code>10.10</code><code>.*.*,</code><code>10.10</code><code>.*.*,</code><code>10.10</code><code>.*.*,</code><code>10.10</code><code>.*.*,</code><code>10.10</code><code>.*.*,</code><code>10.16</code><code>.*.*,</code><code>10.16</code><code>.*.*,</code><code>10.16</code><code>.*.*,</code><code>10.16</code><code>.*.*&nbsp;&nbsp;</code> <code>#配置mobil-online数据流servlet&nbsp;&nbsp;</code> <code>turbine.instanceUrlSuffix.mobil-online=:</code><code>8080</code><code>/hystrix.stream&nbsp;&nbsp;</code> <code>#配置ugc-online集群实例&nbsp;&nbsp;</code> <code>turbine.ConfigPropertyBasedDiscovery.ugc-online.instances=</code><code>10.10</code><code>.*.*,</code><code>10.10</code><code>.*.*,</code><code>10.10</code><code>.*.*,</code><code>10.10</code><code>.*.*#配置ugc-online数据流servlet&nbsp;&nbsp;</code> <code>turbine.instanceUrlSuffix.ugc-online=:</code><code>8080</code><code>/hystrix.stream</code> </td> 
 </tr> 
 </tbody> 
</table>

c:使用Dashboard配置连接Turbine

如下图 :

![84721ac3-b728-3810-bc6c-9df2ddfade05.jpg][]

# 五:Hystrix配置与分析 #

## 1:Hystrix 配置 ##

1):Command 配置

Command配置源码在HystrixCommandProperties,构造Command时通过Setter进行配置

具体配置解释和默认值如下

2):熔断器（Circuit Breaker）配置

Circuit Breaker配置源码在HystrixCommandProperties,构造Command时通过Setter进行配置,每种依赖使用一个Circuit Breaker

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 </td> 
 <td> <code>//&nbsp;熔断器在整个统计时间内是否开启的阀值，默认20秒。也就是10秒钟内至少请求20次，熔断器才发挥起作用&nbsp;&nbsp;</code> <code>private</code>&nbsp;<code>final</code>&nbsp;<code>HystrixProperty&lt;Integer&gt;&nbsp;circuitBreakerRequestVolumeThreshold;&nbsp;&nbsp;&nbsp;</code> <code>//熔断器默认工作时间,默认:5秒.熔断器中断请求5秒后会进入半打开状态,放部分流量过去重试&nbsp;&nbsp;</code> <code>private</code>&nbsp;<code>final</code>&nbsp;<code>HystrixProperty&lt;Integer&gt;&nbsp;circuitBreakerSleepWindowInMilliseconds;&nbsp;&nbsp;&nbsp;</code> <code>//是否启用熔断器,默认true.&nbsp;启动&nbsp;&nbsp;</code> <code>private</code>&nbsp;<code>final</code>&nbsp;<code>HystrixProperty&lt;Boolean&gt;&nbsp;circuitBreakerEnabled;&nbsp;&nbsp;&nbsp;</code> <code>//默认:50%。当出错率超过50%后熔断器启动.&nbsp;&nbsp;</code> <code>private</code>&nbsp;<code>final</code>&nbsp;<code>HystrixProperty&lt;Integer&gt;&nbsp;circuitBreakerErrorThresholdPercentage;&nbsp;&nbsp;</code> <code>//是否强制开启熔断器阻断所有请求,默认:false,不开启&nbsp;&nbsp;</code> <code>private</code>&nbsp;<code>final</code>&nbsp;<code>HystrixProperty&lt;Boolean&gt;&nbsp;circuitBreakerForceOpen;&nbsp;&nbsp;&nbsp;</code> <code>//是否允许熔断器忽略错误,默认false,&nbsp;不开启&nbsp;&nbsp;</code> <code>private</code>&nbsp;<code>final</code>&nbsp;<code>HystrixProperty&lt;Boolean&gt;&nbsp;circuitBreakerForceClosed;</code> </td> 
 </tr> 
 </tbody> 
</table>

3):命令合并(Collapser)配置

Command配置源码在HystrixCollapserProperties,构造Collapser时通过Setter进行配置

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 </td> 
 <td> <code>//请求合并是允许的最大请求数,默认:&nbsp;Integer.MAX_VALUE&nbsp;&nbsp;</code> <code>private</code>&nbsp;<code>final</code>&nbsp;<code>HystrixProperty&lt;Integer&gt;&nbsp;maxRequestsInBatch;&nbsp;&nbsp;</code> <code>//批处理过程中每个命令延迟的时间,默认:10毫秒&nbsp;&nbsp;</code> <code>private</code>&nbsp;<code>final</code>&nbsp;<code>HystrixProperty&lt;Integer&gt;&nbsp;timerDelayInMilliseconds;&nbsp;&nbsp;</code> <code>//批处理过程中是否开启请求缓存,默认:开启&nbsp;&nbsp;</code> <code>private</code>&nbsp;<code>final</code>&nbsp;<code>HystrixProperty&lt;Boolean&gt;&nbsp;requestCacheEnabled;</code> </td> 
 </tr> 
 </tbody> 
</table>

4):线程池(ThreadPool)配置

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 </td> 
 <td> <code>/**&nbsp;</code> <code>配置线程池大小,默认值10个.&nbsp;</code> <code>建议值:请求高峰时99.5%的平均响应时间&nbsp;+&nbsp;向上预留一些即可&nbsp;</code> <code>*/</code>&nbsp;&nbsp; <code>HystrixThreadPoolProperties.Setter().withCoreSize(</code><code>int</code>&nbsp;<code>value)&nbsp;&nbsp;</code> <code>/**&nbsp;</code> <code>配置线程值等待队列长度,默认值:-1&nbsp;</code> <code>建议值:-1表示不等待直接拒绝,测试表明线程池使用直接决绝策略+&nbsp;合适大小的非回缩线程池效率最高.所以不建议修改此值。&nbsp;</code> <code>当使用非回缩线程池时，queueSizeRejectionThreshold,keepAliveTimeMinutes&nbsp;参数无效&nbsp;</code> <code>*/</code>&nbsp;&nbsp; <code>HystrixThreadPoolProperties.Setter().withMaxQueueSize(</code><code>int</code>&nbsp;<code>value)</code> </td> 
 </tr> 
 </tbody> 
</table>

## 2:Hystrix关键组件分析 ##

1):Hystrix流程结构解析

![f8832cf9-8f37-361b-ab1b-369a6f2c078e.png][]

流程说明:

1:每次调用创建一个新的HystrixCommand,把依赖调用封装在run()方法中.

2:执行execute()/queue做同步或异步调用.

3:判断熔断器(circuit-breaker)是否打开,如果打开跳到步骤8,进行降级策略,如果关闭进入步骤.

4:判断线程池/队列/信号量是否跑满，如果跑满进入降级步骤8,否则继续后续步骤.

5:调用HystrixCommand的run方法.运行依赖逻辑

5a:依赖逻辑调用超时,进入步骤8.

6:判断逻辑是否调用成功

6a:返回成功调用结果

6b:调用出错，进入步骤8.

7:计算熔断器状态,所有的运行状态(成功, 失败, 拒绝,超时)上报给熔断器，用于统计从而判断熔断器状态.

8:getFallback()降级逻辑.

以下四种情况将触发getFallback调用：

(1):run()方法抛出非HystrixBadRequestException异常。

(2):run()方法调用超时

(3):熔断器开启拦截调用

(4):线程池/队列/信号量是否跑满

8a:没有实现getFallback的Command将直接抛出异常

8b:fallback降级逻辑调用成功直接返回

8c:降级逻辑调用失败抛出异常

9:返回执行成功结果

2):熔断器:Circuit Breaker

Circuit Breaker 流程架构和统计

![602a8749-c42e-3c99-bf94-f05cbd5f1afd.png][]

每个熔断器默认维护10个bucket,每秒一个bucket,每个blucket记录成功,失败,超时,拒绝的状态，

默认错误超过50%且10秒内超过20个请求进行中断拦截.

3)隔离(Isolation)分析

Hystrix隔离方式采用线程/信号的方式,通过隔离限制依赖的并发量和阻塞扩散.

(1):线程隔离

把执行依赖代码的线程与请求线程(如:jetty线程)分离，请求线程可以自由控制离开的时间(异步过程)。

通过线程池大小可以控制并发量，当线程池饱和时可以提前拒绝服务,防止依赖问题扩散。

线上建议线程池不要设置过大，否则大量堵塞线程有可能会拖慢服务器。

![6f54f2d8-b993-3fb5-9801-3afffe48fcf4.png][]

(2):线程隔离的优缺点

线程隔离的优点:

\[1\]:使用线程可以完全隔离第三方代码,请求线程可以快速放回。

\[2\]:当一个失败的依赖再次变成可用时，线程池将清理，并立即恢复可用，而不是一个长时间的恢复。

\[3\]:可以完全模拟异步调用，方便异步编程。

线程隔离的缺点:

\[1\]:线程池的主要缺点是它增加了cpu，因为每个命令的执行涉及到排队(默认使用SynchronousQueue避免排队)，调度和上下文切换。

\[2\]:对使用ThreadLocal等依赖线程状态的代码增加复杂性，需要手动传递和清理线程状态。

NOTE: Netflix公司内部认为线程隔离开销足够小，不会造成重大的成本或性能的影响。

Netflix 内部API 每天100亿的HystrixCommand依赖请求使用线程隔，每个应用大约40多个线程池，每个线程池大约5-20个线程。

(3):信号隔离

信号隔离也可以用于限制并发访问，防止阻塞扩散, 与线程隔离最大不同在于执行依赖代码的线程依然是请求线程（该线程需要通过信号申请）,

如果客户端是可信的且可以快速返回，可以使用信号隔离替换线程隔离,降低开销.

线程隔离与信号隔离区别如下图:

![b90615c1-f7cb-3cf1-9bf3-de11d5f57697.png][]

解析图片出自官网wiki , 更多内容请见官网: [https://github.com/Netflix/Hystrix][https_github.com_Netflix_Hystrix]

原文链接：http://hot66hot.iteye.com/blog/2155036

[887e7862-578a-3616-a15c-1ef1cb62f3c4.png]: /images/20220519/c1dce337cd7642e1904d2f20e08d1999.png
[3bd6d0be-9ce5-35c2-bbd9-3493671b45d5.png]: /images/20220519/2c2f5d302eb14df7bcece4e04f046720.png
[22f20da1-4096-314c-8c9f-5728251c46af.png]: /images/20220519/a16a9069426b46cda6dd14896d7bab85.png
[8db93de3-db14-355f-ac70-16d06481b020.png]: /images/20220519/bc6e73a41f9a457299173bd1558752ce.png
[ece3a873-1c63-35c3-bdf1-beb45c96b9c2.png]: /images/20220519/fdfef48f64d34e93a80261b6d2c40b1e.png
[98dd13fb-4ff2-39fc-a8df-7758d09fe16f.png]: /images/20220519/30546e0a7e574f08801533306a5e3a68.png
[5c307f4e-2fdd-3bb8-a472-06abeb60ce47.png]: /images/20220519/6717421fdf0c4b09ac62a784abd6e85d.png
[8d62f5cf-b340-34c6-8c43-bd51e9bc26ee.png]: /images/20220519/41b9ac962f484b4eac1e49bb60e15a24.png
[65dccd3d-5adf-34c2-bd00-42629ed46319.png]: /images/20220519/1bcf23bae1a841b689807d4410340764.png
[bd172cab-839d-357f-a8a3-5e0132858723.png]: /images/20220519/a068de704d6943feac97840bb5efccd0.png
[84721ac3-b728-3810-bc6c-9df2ddfade05.jpg]: /images/20220519/d77150aba346464882d12a5c48dc2919.png
[f8832cf9-8f37-361b-ab1b-369a6f2c078e.png]: /images/20220519/aaa789bc5d5340ae8117d6a16caf99d1.png
[602a8749-c42e-3c99-bf94-f05cbd5f1afd.png]: /images/20220519/42c21a91401f4bb899ff389884e069a1.png
[6f54f2d8-b993-3fb5-9801-3afffe48fcf4.png]: /images/20220519/dcba22c8189c450cb02cbfe4f0e47b42.png
[b90615c1-f7cb-3cf1-9bf3-de11d5f57697.png]: /images/20220519/b7ed07b1bdff439ab0bcc53c01925c8b.png
[https_github.com_Netflix_Hystrix]: https://github.com/Netflix/Hystrix