Hystrix在项目中的使用(一)-注解方式

作者: 千里浪打浪 | 来源:发表于2017-09-22 10:44 被阅读0次

一. 背景

我们的业务当中会大量依赖于第三方的服务，而这些第三方的服务都是基于Http请求的。我们的调用模式基本如下:

业务时序图

因此，第三方资源的稳定性会直接影响我们的业务。除此之外，如果是第三方资源响应速度变慢，则会长时间占用我们的线程池，严重的情况下会产生雪崩效应。

外部依赖I发生堵塞

为了防止这种现象发生，我们需要对服务做隔离，熔断，降级以及限流操作。

二. 业务调用示例

2.1 Controller层

客户端请求地址

2.2 Service业务层

在service当中使用restTemplate操作第三方资源，在这里我使用restTemplate调用睡眠地址，模拟了一下第三方资源的处理过程。

模拟业务执行10秒

业务调用层

这里的restTemplate.getForEntity("http://127.0.0.1:8080/hystrix/sleep",String.class)就是在模拟第三方http资源的处理，我们这里是处理10秒。

2.3 客户端调用

直接使用浏览器访问http://127.0.0.1:8080/hystrix/hystrixTest或是模拟客户端请求

httpClient模拟客户羰

客户端返回结果

浏览器直接访问

服务端调用日志

以上就是一次正常的服务请求，耗时10S。正是我们模拟的第三方资源处理时间。

三. 模拟在第三方资源处理时间内打爆RestTemplate线程池

3.1 我们将服务端RestTemplate连接池设置为5个

设置RestTemplate线程池数量

3.2 将客户端请求封装的线程中模拟客户端请求

客户端线程模拟调用

3.3 模拟5个客户端并发访问

模拟5个客户端调用

5个客户端返回结果

服务端的日志也均为正常处理1

服务端的日志也均为正常处理2

3.4 模拟6个客户端并发访问，此时我们的并发访问数量超过了线程池设置的5.为了显示，我给线程加了个name 编号

模拟6个客户端并发访问

通过服务端的日志可以看出，服务端正常接收了来自客户端的6个请求。

服务器输出日志

但是当调用restTemplate. getForEntity()的时候，由于RestTemplate连接池资源只有5个，所以应该有一个是拿不到线程资源的。

无连接池资源报错

服务端输出日志

从服务端日志可以看出只有5个完成的调用http请求，其中有一个因为从线程池中拿不到连接而抛出异常。

5个请求正常返回，1个请求发生异常

这里我们为了演示方便所以6个客户端请求访问的都是同一个资源，在实际生产环境中，6个客户端请求完全可以是访问不同的第三方资源，然后这样就会存在一个问题，当某一个第三方资源发生延时的，后续访问该资源的请求又在不断的请求访问中，导致该资源拿到线程池资源后不能马上释放，但此时其它的第三方服务却是正常的，但是这里线程池中的所有资源已被占用，所以其它的正常访问也因拿不到线程池资源而无法正常访问。这就是我们之前说的雪崩效应。即某一个依赖服务的问题导致整个业务不可用。

四．Hystrix的引用

我们在项目中引用了Hystrix，Hystrix是用于分布式场景下服务熔断、降级的开源Java库，它的主要作用有，依赖隔离，熔断，降级和监控报警。这里不会过多的介绍Hystrix的概念及定义,具体内容可以看其github网站或是自行搜索,会有大量的仔细介绍。由于Hystrix的原生方式是命令式编程，对原有的业务修改比较大，所以我们这使用的是Hystrix提供的注解方式（hystrix-javanica）

4.1引用hystrix相关依赖

版本号

pom.xml引入Jar包

4.2.Spring中增加Aspect

因为使用的是注解方式，所以我们需要设置Aspect

增加切面

4.3.修改web.xml

添加监控

五．Hystrix的使用

5.1 业务层增加 @HystrixCommand注解

这里需要指定超时或是发生异常时执行的方法(executeFallBack),这里需要注意的是，fallbackMethod方法的签名要于业务方法签名一致，否则不会生效。

使用execution.isolation.thread.timeoutInMilliseconds设置超时时间，业务执行时间超过这个时间则执行fallbackMethod方法并返回客户端。

设置fallback方法及超时时间

5.2 客户端调用

由于业务执行时间为10S，而我们在Hystrix中设置的为5S，所以会触发服务降级，客户端应该返回fallbackMethod方法的结果

模拟客户端请求

服务端输出

可以看出客户端接收到的是fallbackMethod方法返回来的结果。但是细心点的人可以看出来，虽然客户端返回以及服务端执行了fallbackMethod方法，但是原有的业务逻辑仍然继续处理完成了。

因此对于超时的请求，业务不会被中断。当超时引发熔断器启动后，后续一段时间内的请求都将进入fallback，不会再调用业务。

六. 使用Hystrix进行线程隔离

在上面演示中，我们知道业务在超时的时候会运行fallbackMethod，并将fallbackMethod结果返回给客户端，但是业务并没有发生中断，如果这样的话，大量的客户端进行访问的时候，虽然得到了fallbackMethod返回的结果，但是仍然会点用RestTemplate线程池中的资源，还是会出现雪崩的现象。

使用Hystrix定义线程池，启到线程隔离的效果。如下图中，定义Hystrix在调用业务时新建线程池的大小为2.为了测试线程隔离的效果，所以让Hystrix的超时间修改为15秒，大于业务处理的时间10S。