2023-09-15
原文作者:王伟王胖胖 原文地址:https://blog.csdn.net/wangwei19871103/article/details/105658275

大致流程图

202309152313439761.png

openfeign

本篇开始看openfeign的初始化原理,搞明白为什么我们可以在接口上加FeignClient注解,写上服务名称,变成RPC一样的用法,其实我们应该可以想到,肯定是用了动态代理,扫描有FeignClient注解的类,然后解析属性,用动态代理生成一个代理类,里面封装个Ribbon,最后让他来做负载均衡,这样不就又简化了客户端啦,不用写RestTemplateLoadBalanced注解了,直接作用到接口上,面向抽象编程,大大的解耦,其实Dubbo也是这个思想。废话不多说,怎么用的,网上查就好了,很多,我们还是来看下原理,还是那句话,知道原理让你用的得心应手。

@EnableFeignClients作用

本身没做什么,只是有一些配置的属性,比如扫描包啊,设置配置文件啊,客户端啊,这个就不多说了,还是看这个上面的注解FeignClientsRegistrar

202309152313451542.png

FeignClientsRegistrar

这个在spring里讲过,用来扩展,注册bean定义的。

202309152313460233.png
主要是这两个方法:

202309152313467114.png

registerDefaultConfiguration

获取EnableFeignClients注解的defaultConfiguration属性,注册默认客户端配置类,名字为default.com.ww.XXApplication.FeignClientSpecification,类型为FeignClientSpecification.

202309152313477145.png

202309152313493406.png

registerFeignClients

扫描相应的包,注册有FeignClient注解的接口和相关的配置类。

202309152313504197.png

202309152313523258.png

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);
    	}

然后就等着容器启动,刷新,直到自动注入属性的时候,调用FeignClientFactoryBeangetObject获取对应的客户端,内部其实用了JDK的动态代理,我们后面说。

202309152313535179.png

好了,今天就到这里了,希望对学习理解有帮助,大神看见勿喷,仅为自己的学习理解,能力有限,请多包涵。

阅读全文