【赶快收藏】Hystrix实战,优雅提高系统的鲁棒性

背景

最近接手了一个系统,其功能都是查询。查询分了两种方式,一种是公司集团提供的查询能力,支持全国各个省份的查询,可是业务高峰期时服务响应比较慢;另一种是各省的分公司都分别提供了对应的查询能力,可是服务质量相对较差,业务高峰期服务超时较多,并且分公司系统升级时也会影响服务质量。为了提高服务查询的成功率,能够将两种查询方式结合起来。比较完备方案就是优先使用各省分公司提供的服务,当分公司的服务质量降低后降级到公司集团对应的服务。很早就听过Hystrix,用在现用系统服务质量提高的改造上,再适合不过了。html

Hystrix简介

Hystrix是Netflix开源的一款容错系统, 能帮助开发者码出具有强大的容错能力和鲁棒性的程序!git

Hystrix功能

一、对依赖的服务(HTTP调用、SOA服务)进行保护, 而且把控住因为依赖服务所带来的的延迟和失败。github

二、防止在一个复杂的分布式系统里出现级联失效(cascading failures)。web

三、快速失败(Fail fast),而且快速恢复依赖服务。segmentfault

四、优雅的降级。缓存

五、实时的监控和报警。服务器

健康状态系统

请求被阻塞系统

 任何的RPC均可能会面临三种状况:成功、失败、超时。若是一次用户请求所依赖外部服务(A,H,I,P)有任何一个不可用,就有可能致使整个用户请求被阻塞。考虑到应用容器的线程数目基本都是固定的,当在高并发的状况下,某一外部依赖的服务超时阻塞,就有可能使得整个主线程池被占满 线程池被占满就会致使整个服务不可用,而依赖该服务的其余服务,就又可能会重复产生上述问题。所以整个系统就像雪崩同样逐渐的扩散、坍塌、崩溃了!架构

舱壁隔离模式(Bulkheads)

货船为了进行防止漏水和火灾的扩散, 将船的底部划分红一个个的舱室, 这样一个舱室进水不会致使整艘船沉没。并发

服务雪崩

 

隔离架构

降级-触发fallback

一、run()/construct方法抛出非HystrixBadRequestException异常app

二、run()/construct()运行超时

三、熔断器启动

四、线程池/信号量拒绝

隔离策略

线程池隔离:会带来线程开销

Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("ThreadPoolTestGroup")) .andCommandKey(HystrixCommandKey.Factory.asKey(“testCommandKey"))
        //与其余命名的线程池自然隔离
      .andThreadPoolKey(HystrixThreadPoolKey.Factory.asKey("ThreadPoolTest"))

信号量隔离:服务的并发数大于信号量阈值时将进入fallback 采用资源计数法,TryableSemaphore

.andCommandPropertiesDefaults(  // 配置信号量隔离
 HystrixCommandProperties.Setter() .withExecutionIsolationStrategy(ExecutionIsolationStrategy.SEMAPHORE) .withExecutionIsolationSemaphoreMaxConcurrentRequests(3) // fallback(降级)调用最大的并发数
    .withFallbackIsolationSemaphoreMaxConcurrentRequests(10))

熔断器

熔断至关于家里电压过大电路的跳闸功能, 跳闸能够保护咱们的电器, 在代码中类比就是将调用的服务直接给屏蔽了, 再也不调用调用远程服务器的服务 举个栗子,配置熔断策略为 当请求错误比例在5s内>50%时, 该服务将进入熔断状态。

熔断器默认工做时间,默认:5秒, 熔断器中断请求5秒后会进入半打开状态, 放部分流量过去重试。

熔断器的开关能保证服务调用者在 调用异常服务时, 快速返回结果, fail fast or fallback static,避免大量的同步等待 而且熔断器能在一段时间后 继续侦测请求执行结果, 提供恢复服务调用的可能。

 

请求结果cache

将一个请求结果缓存起来, 下一个具备相同key的请求 将直接从缓存中取出结果,减小请求开销。

 Hystrix设计点

  • 资源隔离
  • 熔断器模式
  • 命令模式
  • 观察者模式
  • RxJava

 

自助服务系统查询改造方案

命令调用模式,省端直链接口;降级调用模式,集团电商接口。

自助服务整合Hystrix后系统请求流程图。

参考连接

http://www.jianshu.com/p/b9af028efebb

https://github.com/Netflix/Hystrix/wiki

https://github.com/Netflix/Hystrix/wiki/How-To-Use

https://segmentfault.com/a/1190000005988895

http://kriszhang.com/hystrix_defend_your_webapp

https://blog.51cto.com/snowtiger/2057092

原文出处:https://www.cnblogs.com/hujunzheng/p/11570189.html

相关文章
相关标签/搜索