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<Method, MethodHandler> 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实例的替换。
|