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

一、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

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。