Hystrix 各个配置

简介

发现不少使用Hystrix的同窗对Hystrix的理解都有一些问题，因此这里尝试用比较通俗易懂的方式来介绍一下Hystrix。

首先使用Hystrix的经常使用目的：降级(限流)，熔断

绝大多数时候咱们的资源是有限的，通常状况下使用是没有问题的，可是也会有流量高的时候。

举一个常见的例子：早上咱们去上班，若是早一点，路上的人车都比较少，你能够随便走，都没有问题。可是当上班高峰期的时候，就会走走停停。当应用流量大的时候，状况也就是想这样的状况。

解决办法

1. 依赖隔离：多少对依赖进行分组，使用不一样的线程池。这就像咱们的车道划分，咱们知道一个车道若是出了车祸，就很容易拥堵。是由于资源没有划分，你们都使用一个车道，若是一个车道出车祸，这个车道的车就会使用其余的车道，让流量更高，很容易出再问题。若是每一辆车只能在固定的车道行驶，就会好不少。

2. 降级：就是对于一个指定的服务若是执行超时，或者在一段时间内请求超过多少直接是否fallback快速返回。相似于交警设卡每分钟值容许多少车辆经过。

3. 熔断：对于一个服务若是调用失败率达到一个指定的阈值，就直接拒绝服务。至关于交通管制，不让过。

怎样实现

这里有一些点很重要，有助于咱们理解后面的一些配置。咱们知道要实现降级和熔断须要一些统计信息。好比一个服务的执行时间，一个服务的失败率等。

Hystrix怎样知道这些信息呢？确定得和服务发生联系。Hystrix采用的方式是使用命令模式来封装服务。

HystrixCommand和HystrixObservableCommand就至关于命令角色(Command)。

ConcreteCommand(具体命令角色)须要咱们实现。

具体的服务就是扮演的Receiver角色

客服端就至关于Invoker角色

这样就至关于在具体的服务外面包装了一层，Hystrix就能够在Command中为服务分配线程，统计执行时间，统计服务失败率等。

关于统计这里还有2个重要的概念：时间窗口(metricsRollingStatisticalWindow)和段(bucket)

统计确定是有时间周期才有意义，这个时间周期就叫作时间窗口。统计的服务失败率就是时间窗口类的失败率。默认的时间窗口是10000ms就是10秒。

举个例子，假设咱们配置容许熔断，熔断的条件是服务调用失败率为80%，就表示10秒内: 调用这个服务失败的次数/调用这个服务的总次数>=80% 就拒绝服务。

至于Bucket则涉及到更加底层的一些东西。时间窗口内不是指执行一次数据收集，而是把时间窗口t划分为n段，每段收集一次信息放在Bucket中。这个稍后介绍时间窗口的时候再详细介绍。

Hystrix很容易上手，要应用很容易，随便搜索一下都有不少，接下来咱们重点来看一下配置，看一下这些配置是怎样影响应用的。

配置的默认值是在HystrixCommandProperties、HystrixCollapserProperties、HystrixThreadPoolProperties类中。

熔断配置参数

circuitBreakerEnabled

是否容许熔断，默认true

circuitBreakerRequestVolumeThreshold

判断熔断的最少请求数，默认是20，只有在一个统计窗口内处理的请求数量达到这个阈值，才会进行是否熔断的判断

circuitBreakerErrorThresholdPercentage

判断熔断的阈值，默认值50，表示在一个统计窗口内有50%的请求处理失败，会触发熔断 注意：circuitBreakerEnabled为true,circuitBreakerErrorThresholdPercentage知足条件才会触发

circuitBreakerForceOpen

是否强制开启熔断器阻断全部请求,默认false，若是为true就会拒绝全部请求(服务调用)

circuitBreakerForceClosed

强制熔断器进入closed状态，默认false，若是是true，忽略错误百分比(circuitBreakerErrorThresholdPercentage)

优先级比circuitBreakerForceOpen低，也就是说circuitBreakerForceOpen设置为true，circuitBreakerForceClosed这个设置就是无效的。

circuitBreakerSleepWindowInMilliseconds

熔断时间,默认:5秒 当知足熔断条件，熔断器中断请求5秒后会进入半打开状态,放部分流量过去重试

执行配置参数

executionIsolationSemaphoreMaxConcurrentRequests

当隔离策略是ExecutionIsolationStrategy.SEMAPHORE，容许进入HystrixCommand.run()方法的最大并发请求数量。

executionIsolationStrategy

隔离策略，THREAD和SEMAPHORE 默认值： HystrixCommand: THREAD HystrixObservableCommand: SEMAPHORE

executionIsolationThreadInterruptOnTimeout

隔离执行，超时的时候是否中断，默认true

executionTimeoutInMilliseconds

指定超时时间，单位毫秒。执行超过指定时间就执行fallback函数

executionTimeoutEnabled

执行的时候是否容许超时

executionIsolationThreadPoolKeyOverride

使用哪个线程池来执行(经过线程池名称来标识哪个线程池来执行，没有就建立)

fallbackIsolationSemaphoreMaxConcurrentRequests

HystrixCommand.getFallback()执行的最大并发数，若是超过直接抛出异常，而不是执行fallback,默认值10

fallbackEnabled

是否容许fallback

统计配置

metricsRollingStatisticalWindowInMilliseconds

熔断统计时间窗口默认10秒，也就是说保留10秒的统计信息

metricsRollingStatisticalWindowBuckets

一个熔断统计窗口中的Bucket数量，默认10个

Bucket

Bucket不是一个配置，这里介绍Bucket帮助咱们理解上面2个配置，咱们先看一下Hystrix文档的一张图，有助于咱们理解。

从上图看，是一个事件窗口，总共有10个Bucket，每个Bucket中是一些统计的是1秒内的成功、失败、超时、拒绝的信息。

这些信息能够计算成功、失败、超时的百分比，而后执行相应的策略。

下面2组有点像，可是差异很大： metricsRollingStatisticalWindowInMilliseconds和metricsRollingStatisticalWindowBuckets是和熔断及线程池相关的

metricsRollingPercentileWindowInMilliseconds和metricsRollingPercentileWindowBuckets是和执行时间相关的

metricsRollingPercentileEnabled

是否开启执行延迟统计，默认true，服务的执行延迟会被追踪计算，若是是false所用统计均值百分比都会返回-1

metricsRollingPercentileWindowInMilliseconds

执行时间统计窗口，默认60s

metricsRollingPercentileWindowBuckets

执行时间统计窗口Bucket数量，默认6个

metricsRollingPercentileBucketSize

执行时间Bucket的最大值，最多保留的数量

metricsHealthSnapshotIntervalInMilliseconds

计算成功失败百分比的时间间隔，默认500ms

requestCacheEnabled

是否开启请求缓存，默认true

requestLogEnabled

是否开启请求日志，默认true

Collapser配置

maxRequestsInBatch

批量执行命令的最大值，默认Integer.MAX_VALUE

timerDelayInMilliseconds

批量执行命令之间的时间延迟，默认10ms

requestCacheEnabled

批量处理是否开启执行缓存，默认true

线程池配置

coreSize

默认10

maximumSize

最大值，默认10

maxQueueSize

默认-1，使用 SynchronousQueue，若是是设置为一个正数则使用LinkedBlockingQueue

queueSizeRejectionThreshold

最大排队数量，默认5，若是maxQueueSize == -1这该参数无效

allowMaximumSizeToDivergeFromCoreSize

是否容许coreSize和maximumSize不一致，默认false

keepAliveTimeMinutes

1.5.9以前无效，由于coreSize 等于 maximumSize，1.5.9及以后，当allowMaximumSizeToDivergeFromCoreSize设置为true的时候，而且coreSize < maximumSize，这个参数就是设置线程失效的时间。

Hystrix工做流程图

最后来看一张Hystrix工做流程图帮助咱们理解：

参考

Hystrix配置 Hystrix工做原理