一、hystrix介绍

1、首先贴一张hystrix工作流程图

说明：

1、Construct a HystrixCommand or HystrixObservableCommand Object

2、Execute the Command

3、Is the Response Cached?

4、Is the Circuit Open?

5、Is the Thread Pool/Queue/Semaphore Full?

6、HystrixObservableCommand.construct() or HystrixCommand.run()

7、Calculate Circuit Health

8、Get the Fallback

9、Return the Successful Response

2、常用功能介绍

依赖隔离

一个用户请求的成功执行，肯能依赖数十上百个外部服务，如果没有隔离，单个依赖的失败，可能会印象其他依赖的正常执行。如下图所示，为每个依赖配置了单独线程池

如下图：

代码示例：

线程池配置参数:

Q：怎么设置线程池大小？

A：Qps* Tp99 +冗余线程

信号量隔离

线程池隔离中，发起请求的线程和真实执行的线程不是同一个线程，使用信号量隔离时，它们是同一个线程，两种隔离的区别代码：TODO

Q: 什么时候使用线程池隔离，什么使用信号量隔离？

A: 线程池隔离缺点是带来一定的开销，但不会阻塞请求线程，适合于于IO密集型的任务

信号量隔离使用用户请求线程，没有格外线程切换开销，使用与执行时间和执行逻辑都比较短的本地计算。比如CPU密集型的任务

Fallback

Q1: 为什么需要fallback?

简单来说，在依赖调用失败时，我们一般会需要提供降级方案，Hystrix对此提供了支持

Q2：什么情况下会触发fallback？

简单来说，就是run方法抛异常，超时，线程/信号量reject、短路

Q3：fallback时我们应该怎么办？

一般有以下几种策略：

1、不实现getFallback方法：依赖调用失败时直接抛出异常

2、实现getFallback方法，返回默认值：这是一种常见的策略

3、实现getFallback方法，走降级方案

此外，生产环境中，fallback时，一般需要打点记录

请求合并

简单来说，就是将一段时间内的多次请求合并为一次请求，常用于网络IO中，能减少IO次数，缺点是增加平均延迟。

使用该特性

1、必须继承HystrixCollapser类，

2、实现以下方法：

getRequestArgument：返回请求参数对象

createCommand ：返回BatchCommand

mapResponseToRequests：实现Response和Request的映射

3、创建对应的BatchCommand类：批量请求的具体实现

一般配置如下：

请求cache

使用与监控

二、dubbo集成hystrix

建立HystrixFilter.java类

利用Dubbo的Activate机制自动激活HystrixFilter，HystrixFilter会对dubbo:reference进行资源隔离和熔断保护

在meta-inf下面建立filter文件，内容如下，dubbo的spi会自动扫描该文件，加载HystrixFilter

在建立fallback接口：

加上SPI注解，dubbo:reference里面进行保护的服务接口的FallBack实现类需要继承该接口，并且在meta-inf下面建立com.howbuy.hystrix.dubbo.rpc.filter.Fallback文件，并进行关系映射：

dubbo的spi会自动扫描该文件，并加载到dubbo的EXTENSION_LOADERS集合里面，用的时候可以这样去获取：

FallBack的实现类：

建立DubboCommand类继承HystrixCommand：

构造方法：setter为配置的参数；

invoker为dubbod的执行器；

fallbackName为降级接口名称

覆盖run方法，覆盖getFallback方法；

在run方法里面如果调用接口发生异常，抛出HystrixRuntimeException异常，一来是Hystrix需要统计异常次数，二来抛出此异常，会进入getFallback；

在getFallback里面在ExtensionLoader里面拿出基于SPI扩展加载fallback的实现，调用其服务降级方法；

关于HystrixFilter里面会实例化DubboCommand 并且调用DubboCommand 的execue

DubboCommand command = new DubboCommand(setter, invoker, invocation, fallback);

调用execute方法；

如图：

1：从dubbo的参数总线的URL李曼获取fallback,如果为空则直接使用原来dubbo的执行器调用服务；

2：从配置工厂读取配置参数；

3：实例化DubboCommand 并且调用DubboCommand 的execute方法

关于SetterFactory

如图：如果setterMap里面没有缓存，则走1步骤为调用创建参数方法；

然后2为创建线程池参数以及命令相关配置：

HystrixCommandPropertiesFactory：

HystrixThreadPoolPropertiesFactory:

关于线程池参数以及命令相关配置是在reference-hystrix.xml里面进行配置,如图：

参考博客：http://www.cnblogs.com/gaoyanqing/p/7470085.html

https://github.com/yskgood/dubbo-hystrix-support

dubbo集成netflix原生的hystrix框架--实战