FeignClient相关整理总结

迈不过友情╰ 2023-01-14 01:46 97阅读 0赞

**目录**

前言

FeignClient原理及使用

FeignClient对hystrix的支持

hystrix两大功能相关配置

Hystrix原理介绍

主要流程图

getFallback()降级逻辑

HystrixCommand和HystrixObservableCommand

RxJava简单介绍

总结

hystrix异步方案

调用方启用线程池异步

参考资料

--------------------

## 前言 ##

之前是想做一个feignClient调用的异步化组件，然后调研后发现feignClient原生已对hystrix支持的很好，而hystrix已提供完善的异步化方案，并且提供降级/熔断等功能及策略配置。所以进而研究了下hystrix的原理，最后，掉进了rxjava的坑。

## FeignClient原理及使用 ##

首先移步[官网][Link 1]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2l2ZXJzb24yMDEwMTEyMjI4_size_16_color_FFFFFF_t_70][]

原理：Spring Cloud应用在启动时，Feign会扫描标有@FeignClient注解的接口，生成代理，并注册到Spring容器中。生成代理时Feign会为每个接口方法创建一个RequetTemplate对象，该对象封装了HTTP请求需要的全部信息，请求参数名、请求方法等信息都是在这个过程中确定的，Feign的模板化就体现在这里。

Feign 的精华是一种设计思想，它设计了一种全新的HTTP调用方式，屏蔽了具体的调用细节，与Spring MVC 注解的结合更是极大提高了效率(没有重复造轮子，又设计一套新注解。

请求判断逻辑：SynchronousMethodHandler.executeAndDecode (![200,300) || !404)

## FeignClient对hystrix的支持 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2l2ZXJzb24yMDEwMTEyMjI4_size_16_color_FFFFFF_t_70 1][]

官网描述很清楚，两种方案

1.  配置feign.hystrix.enabled=true
2.  新建配置类，使用的时候在注解里加入configuration参数即可

### hystrix两大功能相关配置 ###

隔离

<table> 
 <tbody> 
 <tr> 
 <td> <code>hystrix:</code> <code>&nbsp;&nbsp;</code><code>command:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>#全局默认配置</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>default</code><code>:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>#线程隔离相关（执行相关）</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>execution:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>timeout:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>enabled:&nbsp;</code><code>false</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>isolation</code><code>:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>#配置请求隔离的方式，这里是默认的线程池方式。还有一种信号量的方式semaphore，使用比较少。</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>strategy: THREAD</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>thread:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>#方式执行的超时时间，默认为1000毫秒，在实际场景中需要根据情况设置</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>timeoutInMilliseconds: 1000</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>#发生超时时是否中断方法的执行，默认值为</code><code>true</code><code>。不要改。</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>interruptOnTimeout:&nbsp;</code><code>true</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>#是否在方法执行被取消时中断方法，默认值为</code><code>false</code><code>。没有实际意义，默认就好！</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>interruptOnCancel:&nbsp;</code><code>false</code> </td> 
 </tr> 
 </tbody> 
</table>

熔断

<table> 
 <tbody> 
 <tr> 
 <td> <code>hystrix:</code> <code>&nbsp;&nbsp;</code><code>command:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>#全局默认配置</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>default</code><code>:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>#熔断器相关配置</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>circuitBreaker:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>#说明：是否启动熔断器，默认为</code><code>true</code><code>。</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>enabled:&nbsp;</code><code>false</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>#说明1：启用熔断器功能窗口时间内的最小请求数，假设我们设置的窗口时间为10秒，</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>#说明2：那么如果此时默认值为20的话，那么即便10秒内有19个请求都失败也不会打开熔断器。</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>#说明3：此配置项需要根据接口的QPS进行计算，值太小会有误打开熔断器的可能，而如果值太大超出了时间窗口内的总请求数，则熔断永远也不会被触发</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>#说明4：建议设置一般为：QPS*窗口描述*60%</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>requestVolumeThreshold: 20</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>#说明1：熔断器被打开后，所有的请求都会被快速失败掉，但是何时恢复服务是一个问题。熔断器打开后，Hystrix会在经过一段时间后就放行一条请求</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>#说明2：如果请求能够执行成功，则说明此时服务可能已经恢复了正常，那么熔断器会关闭；相反执行失败，则认为服务仍然不可用，熔断器保持打开。</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>#说明3：所以此配置的作用是指定熔断器打开后多长时间内允许一次请求尝试执行，官方默认配置为5秒。</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>sleepWindowInMilliseconds: 5000</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>#说明1:该配置是指在通过滑动窗口获取到当前时间段内Hystrix方法执行失败的几率后，根据此配置来判断是否需要打开熔断器</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>#说明2:这里官方的默认配置为50，即窗口时间内超过50%的请求失败后就会打开熔断器将后续请求快速失败掉</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>errorThresholdPercentage: 50</code> </td> 
 </tr> 
 </tbody> 
</table>

## Hystrix原理介绍 ##

官网：[https://github.com/Netflix/Hystrix/wiki][https_github.com_Netflix_Hystrix_wiki]

Hystrix 的设计方案是通过命令模式加 RxJava 实现的观察者模式来开发的，想完全熟悉 Hystrix 的运作流程需要熟练掌握 RxJava

### 主要流程图 ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2l2ZXJzb24yMDEwMTEyMjI4_size_16_color_FFFFFF_t_70 2][]

分析后结果如下：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2l2ZXJzb24yMDEwMTEyMjI4_size_16_color_FFFFFF_t_70 3][]

### `getFallback()降级逻辑` ###

`1，以下四种情况将触发getFallback调用：`

` ``(``1``)：run()方法抛出非HystrixBadRequestException异常`  
` ``(``2``)：run()方法调用超时`  
` ``(``3``)：熔断器开启拦截调用`  
` ``(``4``)：线程池/队列/信号量是否跑满`

`2，没有实现getFallback的Command将直接抛出异常`

`3，fallback降级逻辑调用成功直接返回`

`4，降级逻辑调用失败抛出异常`

### HystrixCommand和HystrixObservableCommand ###

1、HystrixCommand提供了同步和异步两种执行方式，而HystrixObservableCommand只有异步方式

2、HystrixCommand的run方法是用内部线程池的线程来执行的，而HystrixObservableCommand则是由调用方(例如Tomcat容器)的线程来执行的，因为是异步，所以两种方式都能很好的起到资源隔离的效果。

3、HystrixCommand一次只能发送单条数据返回，而HystrixObservableCommand一次可以发送多条数据返回，从上面的示例可以看出。

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

如图：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2l2ZXJzb24yMDEwMTEyMjI4_size_16_color_FFFFFF_t_70 4][]

详细：[https://www.jianshu.com/p/b9af028efebb][https_www.jianshu.com_p_b9af028efebb]

hystrix任务执行代码：AbstractCommand.executeCommandAndObserve

冷observe和热：[https://zhuanlan.zhihu.com/p/28628089][https_zhuanlan.zhihu.com_p_28628089]

AbstractCommand.executeCommandAndObserve

## RxJava简单介绍 ##

RxJava 在 GitHub 主页上的自我介绍是 "a library for composing asynchronous and event-based programs using observable sequences for the Java VM"（一个在 Java VM 上使用可观测的序列来组成异步的、基于事件的程序的库）。这就是 RxJava ，概括得非常精准。

其实， RxJava 的本质可以压缩为异步这一个词。说到根上，它就是一个实现异步操作的库，而别的定语都是基于这之上的。

Rx基于观察者模式，他是一种编程模型，目标是提供一致的编程接口，帮助开发者更方便的处理异步数据流。*[ReactiveX.io][]给的定义是，Rx是一个使用可观察数据流进行异步编程的编程接口，**ReactiveX结合了观察者模式、迭代器模式和函数式编程的精华。***

## 总结 ##

### hystrix异步方案 ###

1.  启用hystrix
2.  给接口方法的返回值用HystrixCommand包裹
3.  调用时，有以下几种方式：

<table> 
 <tbody> 
 <tr> 
 <td> <code>Future&lt;EpgFilterRespDTO&gt; future = epgInfoClient.epgFilterFuture(EpgFilterReqDTO.of(Lists.newArrayList(2447052500L),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"204.101.161.159"</code><code>,&nbsp;</code><code>20000030</code><code>,&nbsp;</code><code>"2.3"</code><code>,</code><code>80000013</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"zh_tw"</code><code>,&nbsp;</code><code>"tw"</code><code>, PlatformEnum.APPLE_TV)).queue();</code><code>//异步方式</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Observable&lt;EpgFilterRespDTO&gt; observable = epgInfoClient.epgFilterFuture(EpgFilterReqDTO.of(Lists.newArrayList(2447052500L),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"204.101.161.159"</code><code>,&nbsp;</code><code>20000030</code><code>,&nbsp;</code><code>"2.3"</code><code>,</code><code>80000013</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"zh_tw"</code><code>,&nbsp;</code><code>"tw"</code><code>, PlatformEnum.APPLE_TV)).observe();</code><code>//热观察</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(observable.toBlocking().single())</code><code>//直接获取</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Observable&lt;EpgFilterRespDTO&gt; toobservable = epgInfoClient.epgFilterFuture(EpgFilterReqDTO.of(Lists.newArrayList(2447052500L),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"204.101.161.159"</code><code>,&nbsp;</code><code>20000030</code><code>,&nbsp;</code><code>"2.3"</code><code>,</code><code>80000013</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"zh_tw"</code><code>,&nbsp;</code><code>"tw"</code><code>, PlatformEnum.APPLE_TV)).toObservable();</code><code>//冷观察</code> <code>observable.subscribe(</code><code>new</code>&nbsp;<code>Observer&lt;EpgFilterRespDTO&gt;() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>void</code>&nbsp;<code>onCompleted() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println();</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>void</code>&nbsp;<code>onError(Throwable throwable) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(throwable);</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>void</code>&nbsp;<code>onNext(EpgFilterRespDTO epgFilterRespDTO) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(epgFilterRespDTO);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>});</code> &nbsp; <code>toobservable.subscribe(</code><code>new</code>&nbsp;<code>Observer&lt;EpgFilterRespDTO&gt;() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>void</code>&nbsp;<code>onCompleted() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println();</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>void</code>&nbsp;<code>onError(Throwable throwable) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(throwable);</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>void</code>&nbsp;<code>onNext(EpgFilterRespDTO epgFilterRespDTO) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(epgFilterRespDTO);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>});</code> </td> 
 </tr> 
 </tbody> 
</table>

### 调用方启用线程池异步 ###

## 参考资料 ##

*  [https://my.oschina.net/7001/blog/1619842][https_my.oschina.net_7001_blog_1619842]
 *  [https://www.jianshu.com/p/b9af028efebb][https_www.jianshu.com_p_b9af028efebb]

[Link 1]: https://cloud.spring.io/spring-cloud-netflix/multi/multi_spring-cloud-feign.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2l2ZXJzb24yMDEwMTEyMjI4_size_16_color_FFFFFF_t_70]: /images/20221022/6b3daa70465b4c59975d7058794428ba.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2l2ZXJzb24yMDEwMTEyMjI4_size_16_color_FFFFFF_t_70 1]: /images/20221022/ffb014b4a5e14a5c85505e5472540c31.png
[https_github.com_Netflix_Hystrix_wiki]: https://github.com/Netflix/Hystrix/wiki
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2l2ZXJzb24yMDEwMTEyMjI4_size_16_color_FFFFFF_t_70 2]: /images/20221022/99b254268f034b4a9c328518e77d8c9e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2l2ZXJzb24yMDEwMTEyMjI4_size_16_color_FFFFFF_t_70 3]: /images/20221022/184ff3415c7e472484d8e3fede20d836.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2l2ZXJzb24yMDEwMTEyMjI4_size_16_color_FFFFFF_t_70 4]: /images/20221022/3c70fbb60f7a49a482965527fba34d3b.png
[https_www.jianshu.com_p_b9af028efebb]: https://www.jianshu.com/p/b9af028efebb
[https_zhuanlan.zhihu.com_p_28628089]: https://zhuanlan.zhihu.com/p/28628089
[ReactiveX.io]: http://reactivex.io/
[https_my.oschina.net_7001_blog_1619842]: https://my.oschina.net/7001/blog/1619842