MySQL, Oracle, Linux, 软件架构及大数据技术知识分享平台

网站首页 > 精选文章 / 正文

SpringCloudRPC核心原理:HystrixFeign动态代理实例创建流程

2025-02-24 16:39 huorong 精选文章 1 ℃ 0 评论

HystrixFeign动态代理实例的创建流程

Spring Cloud中使用Hystrix进行RPC保护基本是必选项,所以这里重点介绍HystrixFeign相关的动态代理实例的创建流程。

HystrixInvocationHandler具体的替换过程通过HystrixFeign.Builder建造者容器实例的build()方法来完成。

HystrixFeign.Builder建造者容器实例

首先,复习一下Feign中JDK代理实例创建的整体流程。前面讲到,Feign中默认的远程接口的JDK动态代理实例创建是通过Feign.Builder建造者容器实例的target(...)方法来完成的。而target(...)方法的第一步是通过自身的build()方法来构造一个ReflectiveFeign(反射式Feign)实例,第二步是通过反射式Feign实例的newInstance()方法创建真正的JDK Proxy代理实例。

HystrixFeign有自己的建造者类HystrixFeign.Builder类,该类继承了feign.Feign.Builder默认的建造者,重写了它获得Feign实例的build()方法。

HystrixFeign的关键源码如下:

package feign.hystrix;
//省略import
public final class HystrixFeign {
 public HystrixFeign() {
 }
 //创建一个新的HystrixFeign.Builder实例
 public static HystrixFeign.Builder builder() {
 return new HystrixFeign.Builder();
}
 //HystrixFeign的建造者类
 //继承了Feign默认的建造者,重写了build()方法
 public static final class Builder extends feign.Feign.Builder {
 public Feign build() {
 return this.build((FallbackFactory)null);
 }
 //重载的build方法替换了基类的invocationHandlerFactory
 //然后调用基类的build()方法建造一个ReflectiveFeign(反射式Feign)的实例
 Feign build(final FallbackFactory nullableFallbackFactory) {
 super.invocationHandlerFactory(new InvocationHandlerFactory() {
 //实现InvocationHandlerFactory的create方法
 public InvocationHandler create(Target target, Map dispatch)
 {
 //返回的是HystrixInvocationHandler
 return new HystrixInvocationHandler(
target, dispatch, Builder.this.setterFactory, nullableFallbackFactory);
 }
 });
 super.contract(new HystrixDelegatingContract(this.contract));
 return super.build();
 }
 }
}

HystrixFeign.Builder类继承了默认的feign.Feign.Builder建造者类,创建一个匿名的调用处理器工厂实例,该工厂在创建调用处理器时使用HystrixInvocationHandler替换基类中用到的默认调用处理器FeignInvocationHandler。另外,在HystrixFeign.Builder重载的build()方法中,最终返回的仍然是基类的build()方法,当然返回的还是一个ReflectiveFeign(反射式Feign)的实例。

注意,HystrixFeign并不是Feign的子类,这一点不像Feign的子类ReflectiveFeign,所以在创建RPC动态代理实例时仍然会用到
ReflectiveFeign.newInstance()方法。

在通过
ReflectiveFeign.newInstance()方法创建RPC动态代理实例时,会通过调用处理器工厂的create()方法创建InvocationHandler调用处理器实例,而此时被替换过的处理器工厂将创建带RPC保护功能的HystrixInvocationHandler类型的调用处理器。

配置HystrixFeign.Builder建造者容器实例

使用HystrixFeign.Builder实例替换feign.Feign.Builder实例,在FeignClientsConfiguration中自动配置类的源码完成。相关的自动配置类FeignClientsConfiguration的部分源码如下:

package org.springframework.cloud.openfeign;
//省略import
@Configuration
public class FeignClientsConfiguration {
...
 @Configuration
 @ConditionalOnClass({HystrixCommand.class, HystrixFeign.class})
 protected static class HystrixFeignConfiguration {
 protected HystrixFeignConfiguration() {
 }
 //创建一个HystrixFeign.Builder类型的Spring IOC实例
 @Bean
 @Scope("prototype")
 @ConditionalOnMissingBean
 @ConditionalOnProperty(
 name = {"feign.hystrix.enabled"}
 )
 public Builder feignHystrixBuilder() {
 return HystrixFeign.builder();
 }
 }
}

通过上面的源码可以看出,创建了一个HystrixFeign.Builder类型的Spring IOC实例,实质上必须同时满足两个条件:

(1)在类路径中同时存在HystrixCommand.class和HystrixFeign.class两个类。

(2)应用的配置文件中存在着feign.hystrix.enabled的配置项。满足以上条件,feignHystrixBuilder()会调用HystrixFeign.builder()静态方法创建一个新的HystrixFeign.Builder类型的Spring IOC实例。

HystrixFeign.Builder容器实例注册之后,在创建JDK动态代理实例时,基类Feign.Builder建造者的target()方法会调用子类HystrixFeign.Builder实例的build()方法来完成调用处理器工厂InvocationHandlerFactory实例的替换。

本文给大家讲解的内容是SpringCloudRPC远程调用核心原理:HystrixFeign动态代理实例的创建流程

  1. 下篇文章给大家讲解的是SpringCloudRPC远程调用核心原理:feign.Client客户端容器实例;
  2. 觉得文章不错的朋友可以转发此文关注小编;
  3. 感谢大家的支持!

Tags:conditionalonproperty

控制面板
您好,欢迎到访网站!
  查看权限
网站分类
最新留言