登录 注册

Hystrix 初体验 (一): 原理

本贴最后更新于 2399 天前，其中的信息可能已经时异事殊

简介

Hystrix 是一个用来隔离延迟和错误的库，即熔断器。

具体来讲，当远程系统、服务、第三方库不可用时，可以将其隔离，防止系统整体雪崩。

由于系统迟早会出现不可用情况，其可以提高系统的弹性。

如果想了解更多，请参考底部的防雪崩利器：熔断器 Hystrix 的原理与使用。

能做什么

  • 处理突发的延时和故障：防止雪崩，做到优雅的降级。
  • 实时检测：实时监控系统运行情况和配置变化情况，秒级做出响应。
  • 并发性：并发执行请求和缓存结果。

第一个例子

$ git clone https://github.com/Netflix/Hystrix.git

在 Hystrix/hystrix-examples/src/main/java/com/netflix/hystrix/examples/demo 下有两个例子 HystrixCommandDemo 和 HystrixCommandAsyncDemo

HystrixCommandDemo 的
运行效果如下:

Request => GetUserAccountCommand[SUCCESS][40ms], GetPaymentInformationCommand[SUCCESS][14ms], GetOrderCommand[SUCCESS][216ms], GetUserAccountCommand[SUCCESS, RESPONSE_FROM_CACHE][0ms]x2, CreditCardCommand[SUCCESS][889ms]
Request => GetUserAccountCommand[SUCCESS][39ms], GetPaymentInformationCommand[SUCCESS][27ms], GetOrderCommand[SUCCESS][234ms], GetUserAccountCommand[SUCCESS, RESPONSE_FROM_CACHE][0ms]x2, CreditCardCommand[SUCCESS][920ms]
Request => GetUserAccountCommand[SUCCESS][41ms], GetPaymentInformationCommand[SUCCESS][12ms], GetOrderCommand[SUCCESS][226ms], GetUserAccountCommand[SUCCESS, RESPONSE_FROM_CACHE][0ms]x2, CreditCardCommand[SUCCESS][1040ms]
Request => GetUserAccountCommand[SUCCESS][42ms], GetPaymentInformationCommand[SUCCESS][25ms], GetOrderCommand[SUCCESS][234ms], GetUserAccountCommand[SUCCESS, RESPONSE_FROM_CACHE][0ms]x2, CreditCardCommand[SUCCESS][1302ms]
Request => GetUserAccountCommand[SUCCESS][36ms], GetPaymentInformationCommand[SUCCESS][12ms], GetOrderCommand[SUCCESS][229ms], GetUserAccountCommand[SUCCESS, RESPONSE_FROM_CACHE][0ms]x2, CreditCardCommand[SUCCESS][1361ms]
Request => GetUserAccountCommand[SUCCESS][43ms], GetPaymentInformationCommand[SUCCESS][12ms], GetOrderCommand[SUCCESS][214ms], GetUserAccountCommand[SUCCESS, RESPONSE_FROM_CACHE][0ms]x2, CreditCardCommand[SUCCESS][1494ms]
Request => GetUserAccountCommand[FAILURE, FALLBACK_SUCCESS][10ms], GetPaymentInformationCommand[SUCCESS][8ms], GetOrderCommand[SUCCESS][101ms], GetUserAccountCommand[FAILURE, FALLBACK_SUCCESS, RESPONSE_FROM_CACHE][0ms]x2, CreditCardCommand[SUCCESS][1150ms]
Request => GetUserAccountCommand[SUCCESS][3ms], GetPaymentInformationCommand[SUCCESS][19ms], GetOrderCommand[SUCCESS][71ms], GetUserAccountCommand[SUCCESS, RESPONSE_FROM_CACHE][0ms]x2, CreditCardCommand[SUCCESS][831ms]
Request => GetUserAccountCommand[SUCCESS][6ms], GetPaymentInformationCommand[SUCCESS][24ms], GetOrderCommand[SUCCESS][112ms], GetUserAccountCommand[SUCCESS, RESPONSE_FROM_CACHE][0ms]x2, CreditCardCommand[SUCCESS][1015ms]
Request => GetUserAccountCommand[SUCCESS][11ms], GetPaymentInformationCommand[SUCCESS][26ms], GetOrderCommand[SUCCESS][232ms], GetUserAccountCommand[SUCCESS, RESPONSE_FROM_CACHE][0ms]x2, CreditCardCommand[SUCCESS][971ms]
Request => GetUserAccountCommand[SUCCESS][4ms], GetPaymentInformationCommand[SUCCESS][9ms], GetOrderCommand[SUCCESS][214ms], GetUserAccountCommand[SUCCESS, RESPONSE_FROM_CACHE][0ms]x2, CreditCardCommand[SUCCESS][1325ms]
Request => GetUserAccountCommand[SUCCESS][7ms], GetPaymentInformationCommand[SUCCESS][19ms], GetOrderCommand[SUCCESS][91ms], GetUserAccountCommand[SUCCESS, RESPONSE_FROM_CACHE][0ms]x2, CreditCardCommand[SUCCESS][1480ms]
Request => GetUserAccountCommand[SUCCESS][10ms], GetPaymentInformationCommand[SUCCESS][15ms], GetOrderCommand[SUCCESS][237ms], GetUserAccountCommand[SUCCESS, RESPONSE_FROM_CACHE][0ms]x2, CreditCardCommand[SUCCESS][1412ms]

#####################################################################################
# CreditCardCommand: Requests: 13 Errors: 0 (0%)   Mean: 0 75th: 0 90th: 0 99th: 0 
# GetOrderCommand: Requests: 16 Errors: 0 (0%)   Mean: 0 75th: 0 90th: 0 99th: 0 
# GetUserAccountCommand: Requests: 16 Errors: 1 (6%)   Mean: 0 75th: 0 90th: 0 99th: 0 
# GetPaymentInformationCommand: Requests: 16 Errors: 0 (0%)   Mean: 0 75th: 0 90th: 0 99th: 0 
#####################################################################################

HystrixCommandAsyncDemo 的运行效果如下：

Request => GetUserAccountCommand[TIMEOUT, FALLBACK_SUCCESS][80ms], GetOrderCommand[SUCCESS][209ms], GetPaymentInformationCommand[SUCCESS][13ms], GetUserAccountCommand[TIMEOUT, FALLBACK_SUCCESS, RESPONSE_FROM_CACHE][0ms]x2, CreditCardCommand[SUCCESS][1269ms]
Request => GetUserAccountCommand[SUCCESS][5ms], GetOrderCommand[SUCCESS][183ms], GetPaymentInformationCommand[SUCCESS][23ms], GetUserAccountCommand[SUCCESS, RESPONSE_FROM_CACHE][0ms]x2, CreditCardCommand[SUCCESS][1443ms]
Request => GetUserAccountCommand[SUCCESS][11ms], GetOrderCommand[SUCCESS][91ms], GetPaymentInformationCommand[SUCCESS][24ms], GetUserAccountCommand[SUCCESS, RESPONSE_FROM_CACHE][0ms]x2, CreditCardCommand[SUCCESS][980ms]

#####################################################################################
# CreditCardCommand: Requests: 3 Errors: 0 (0%)   Mean: 0 75th: 0 90th: 0 99th: 0 
# GetOrderCommand: Requests: 4 Errors: 0 (0%)   Mean: 0 75th: 0 90th: 0 99th: 0 
# GetUserAccountCommand: Requests: 4 Errors: 1 (25%)   Mean: 0 75th: 0 90th: 0 99th: 0 
# GetPaymentInformationCommand: Requests: 4 Errors: 0 (0%)   Mean: 0 75th: 0 90th: 0 99th: 0 
#####################################################################################

这两个示例中，包含打印状态和执行 Hystrix 请求两部分。请求包含了四种情形：

  • HystrixCommand.execute
  • HystrixCommand.queue
  • HystrixCommand.observe
  • HystrixCommand.toObservable

具体可以看代码。

同时，通过 ConfigurationManager 来设置了超时时间等信息，如下：

        ConfigurationManager.getConfigInstance().setProperty("hystrix.threadpool.default.coreSize", 8);
        ConfigurationManager.getConfigInstance().setProperty("hystrix.command.CreditCardCommand.execution.isolation.thread.timeoutInMilliseconds", 3000);
        ConfigurationManager.getConfigInstance().setProperty("hystrix.command.GetUserAccountCommand.execution.isolation.thread.timeoutInMilliseconds", 50);
        ConfigurationManager.getConfigInstance().setProperty("hystrix.command.default.metrics.rollingPercentile.numBuckets", 60);

原理

在有了直观的认识之后，来看下其工作原理。

官方的原理介绍非常的详细，点击可见其流程图。

流程图中分为 9 个步骤，分别介绍如下：

构建对象

HystrixCommand

返回一个单一的响应

HystrixCommand command = new HystrixCommand(arg1, arg2);

HystrixObservableCommand

返回一个观测对象

HystrixObservableCommand command = new HystrixObservableCommand(arg1, arg2);

执行命令

类 方法
HystrixCommand execute() 阻塞执行, 返回 response 抛异常 queue().get()
HystrixCommand queue() 异步执行，返回 future 对象 toObservable().toBlocking().toFuture()
HystrixObservableCommand observe() 返回订阅观测量
HystrixObservableCommand toObservable() 返回观测量，订阅后执行 
K             value   = command.execute();
Future<K>     fValue  = command.queue();
Observable<K> ohValue = command.observe();         //hot observable
Observable<K> ocValue = command.toObservable();    //cold observable

结果缓存

可以设置是否缓存请求的结果。

如果设置了缓存并且缓存存在，则会立即返回缓存中的结果。

断路器状态

执行请求前，会先检查断路器状态。如果断路器是打开状态(open/tripped)，则不会执行请求，而是直接到第 8 步，得到反馈。

是否已满

在执行请求前，再检查此请求相关的线程池是否已满，或者信号量是否已满。

如果满了，同样直接执行第 8 步，得到反馈。

构造方法

到了这里，才真正开始执行自己的方法。

先执行 HystrixCommand.run() 或者 HystrixObservableCommand.construct()

如果 run() 或者 construct() 方法超时了，则抛出 TimeoutException 异常，执行第 8 步，得到反馈；同时丢弃掉 run 或者 construct() 方法的返回值。

注，Hystrix 是无法强制线程停止工作的，最多是触发一个 InterruptedException 异常。如果其内部线程不响应 InterruptedException，则还是会继续工作，虽然 client 已经返回了超时异常。

这种机制可能把线程池打满，同时系统 load 还有可能不高。

大多数的 http 库是不响应 InterruptedException 异常的，需要自己设置合理的 read/write 超时时间。

如果命令执行正常结束，没有抛异常。Hystrix 在记录日志和更新状态后，会返回正常执行结果。

对于 run()，返回带有响应的 Observable，同时发送 onCompleted 事件。

对于 construct()，返回和 construct() 的返回相同的 Observable。

计算断路器状态

Hystrix 会记录成功次数，失败次数，拒绝次数和超时次数。

通过这些统计信息，来切换断路器的状态。

得到反馈

当有请求失败时，Hystrix 就会执行 fallback 方法。

对于 HystrixCommand，执行 HystrixCommand.getFallback()

对于 HystrixObservableCommand，执行 HystrixObservableCommand.resumeWithFallback()

如果没有实现 fallback 方法，或者 fallback 方法抛异常了，Hystrix 同样返回一个没有内容的 Observable 对象，同时发送 onError 事件。

最佳实践是实现一个不会失败的 fallback 方法。

方法 结果
execute() 抛异常
queue() 返回 Future 对象，调用其 get()时抛异常
observe() 返回 Observable 对象，订阅其时会触发 onError()方法来快速失败
toObservable() 同 observe()

返回成功结果

具体见图片

  • HystrixCommand 的 execute 和 queue 方法，以及 HystrixObservableCommand 的 observe()和 toObserve()方法，最后都会转化成 HystrixObservableCommand 的 toObserve()方法。

@adrianb11 制作了一个动画版本的调用说明

使用

断路器配置

含义 参数
容量 HystrixCommandProperties.circuitBreakerRequestVolumeThreshold()
错误率 HystrixCommandProperties.circuitBreakerErrorThresholdPercentage()
冷却时间 HystrixCommandProperties.circuitBreakerSleepWindowInMilliseconds()

在冷却时间后，仅将一个新请求放到后端。成功后转为 CLOSE，否则维持 OPEN。

线程池方式

优点

线程池方式可以提供完备的隔离保护，适合于经常变化的场景。

缺点

线程池方式增加了复杂度，每一个命令的执行都要经历排队、调度、上下文切换的过程。

性能影响

Netflix 选择接受这些复杂度带来的额外性能损失，来得到系统的稳定性。

在单机 350QPS 的测试场景下，

平均是没有额外时间消耗；

90th 是 3ms

99th 是 9ms

信号量方式

启用

将 execution.isolation.strategy 设置为 SEMAPHORE

fallback

直接由 tomcat 线程来执行 fallback 操作

请求合并(Request Collapsing)

如果多个请求，会同时访问后端的同一个服务时，那么可以做一个 batch 操作，将对后端的多并发访问，变成单一请求访问。

  • 优点：减少网络消耗

  • 缺点：增加延时

  • 不适用场景：并发量很小

  • 适用场景：网络 IO 是瓶颈时

请求缓存(Request Caching)

如果开启了请求缓存，不同线程请求同一数据时，仅会请求后端数据一次，然后不同线程会返回同样的请求结果。

其中的缓存主键(cache key)需要用户自己定义。

参考

  • Java

    Java 是一种可以撰写跨平台应用软件的面向对象的程序设计语言，是由 Sun Microsystems 公司于 1995 年 5 月推出的。Java 技术具有卓越的通用性、高效性、平台移植性和安全性。

    3190 引用 • 8214 回帖 • 1 关注
北京 位置
668 3 163 184 19 56 57 175

相关帖子

回帖
Hystrix 初体验 (一): 原理

欢迎来到这里！

我们正在构建一个小众社区，大家在这里相互信任，以平等 • 自由 • 奔放的价值观进行分享交流。最终，希望大家能够找到与自己志同道合的伙伴，共同成长。

注册 关于
请输入回帖内容 ...
flowaters
爱生活，爱折腾！ 北京
回帖
15
 帖子
109
 积分
3249