大致流程图
openfeign
本篇开始看openfeign的初始化原理,搞明白为什么我们可以在接口上加FeignClient
注解,写上服务名称,变成RPC
一样的用法,其实我们应该可以想到,肯定是用了动态代理,扫描有FeignClient
注解的类,然后解析属性,用动态代理生成一个代理类,里面封装个Ribbon
,最后让他来做负载均衡,这样不就又简化了客户端啦,不用写RestTemplate
和LoadBalanced
注解了,直接作用到接口上,面向抽象编程,大大的解耦,其实Dubbo
也是这个思想。废话不多说,怎么用的,网上查就好了,很多,我们还是来看下原理,还是那句话,知道原理让你用的得心应手。
@EnableFeignClients作用
本身没做什么,只是有一些配置的属性,比如扫描包啊,设置配置文件啊,客户端啊,这个就不多说了,还是看这个上面的注解FeignClientsRegistrar
:
FeignClientsRegistrar
这个在spring
里讲过,用来扩展,注册bean
定义的。
主要是这两个方法:
registerDefaultConfiguration
获取EnableFeignClients注解的defaultConfiguration属性,注册默认客户端配置类,名字为default.com.ww.XXApplication.FeignClientSpecification
,类型为FeignClientSpecification
.
registerFeignClients
扫描相应的包,注册有FeignClient
注解的接口和相关的配置类。
registerFeignClient
核心在这里,给FeignClient
注解的接口添加工厂bean
,就是FeignClientFactoryBean
,然后设置一些bean
定义的属性。
private void registerFeignClient(BeanDefinitionRegistry registry,
AnnotationMetadata annotationMetadata, Map<String, Object> attributes) {
String className = annotationMetadata.getClassName();
BeanDefinitionBuilder definition = BeanDefinitionBuilder
.genericBeanDefinition(FeignClientFactoryBean.class);
validate(attributes);
definition.addPropertyValue("url", getUrl(attributes));
definition.addPropertyValue("path", getPath(attributes));
String name = getName(attributes);
definition.addPropertyValue("name", name);
String contextId = getContextId(attributes);
definition.addPropertyValue("contextId", contextId);
definition.addPropertyValue("type", className);
definition.addPropertyValue("decode404", attributes.get("decode404"));
definition.addPropertyValue("fallback", attributes.get("fallback"));
definition.addPropertyValue("fallbackFactory", attributes.get("fallbackFactory"));
definition.setAutowireMode(AbstractBeanDefinition.AUTOWIRE_BY_TYPE);
String alias = contextId + "FeignClient";
AbstractBeanDefinition beanDefinition = definition.getBeanDefinition();
boolean primary = (Boolean) attributes.get("primary"); // has a default, won't be
// null
beanDefinition.setPrimary(primary);
String qualifier = getQualifier(attributes);
if (StringUtils.hasText(qualifier)) {
alias = qualifier;
}
BeanDefinitionHolder holder = new BeanDefinitionHolder(beanDefinition, className,
new String[] { alias });
BeanDefinitionReaderUtils.registerBeanDefinition(holder, registry);
}
然后就等着容器启动,刷新,直到自动注入属性的时候,调用FeignClientFactoryBean
的getObject
获取对应的客户端,内部其实用了JDK
的动态代理,我们后面说。
好了,今天就到这里了,希望对学习理解有帮助,大神看见勿喷,仅为自己的学习理解,能力有限,请多包涵。