Feign核心源码解析

本文涉及的产品
传统型负载均衡 CLB,每月750个小时 15LCU
全局流量管理 GTM,标准版 1个月
EMR Serverless StarRocks,5000CU*H 48000GB*H
简介: Feign核心源码解析

Feign作为一个声明式的Http服务客户端,通过接口加注解的方式,就能够完成对服务提供方接口的调用,极大的简化了我们在调用服务时的工作。

那么在只有接口的条件下,Feign是如何基于接口实现服务调用的呢?在之前的代理模式mybatis实现原理的文章中,我们知道了可以通过动态代理的方式生成代理对象。Feign是否这样实现的呢,我们从源码角度进行分析。

image.png

首先看一下Feign的开启注解@EnableFeignClients:

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.TYPE)
@Documented
@Import(FeignClientsRegistrar.class)
public @interface EnableFeignClients {
  String[] value() default {};
  String[] basePackages() default {};
  Class<?>[] basePackageClasses() default {};
  Class<?>[] defaultConfiguration() default {};
  Class<?>[] clients() default {};
}

@Import导入了FeignClientsRegistrar,该类实现了ImportBeanDefinitionRegistrar接口,在该接口的registerBeanDefinitions方法中,spring向外暴露了BeanDefinitionRegistry注册器。用户如果需要手动创建或修改BeanDefinition,可以通过把BeanDefinition注册到BeanDefinitionRegistry的方式,之后spring会帮我们实例化bean并放在容器中。

image.png

里面两个方法中,registerDefaultConfiguration方法主要用于读取配置信息,我们主要看一下registerFeignClients方法的实现:

image.png

这里首先定义了一个扫描器,并读取@EnableFeignClients注解的属性,配置FeignClient的注解类型过滤器,用以在后面进行进行包扫描操作。

image.png

通过扫描,得到所有在basepackage定义的路径下的被@FeignClient注解标记的类的BeanDefinition。

读取@FeignClient注解的内容,并存放在一个Map中,由于我在注解中只指定了name,因此只存在name和value的值(value通过@AliasFor指定为name的别名)

image.png

之后,调用registerFeignClient方法:

image.png

注意这里通过BeanDefinitionBuilder创建的是一个FeignClientFactoryBean类型的工厂bean,注意通过它的getObject返回的才是我们的FeignClient。之后通过BeanDefinitionBuilder填充FeignClient对象的属性,并获得BeanDefinition。

image.png

这里的BeanDefinitionHolder可以理解为BeanDefinition的包装类,提供了根据beanName获取BeanDefinition的方法,可以理解为额外加了一层封装。

完成属性填充后,通过Spring提供的registerBeanDefinition方法向BeanDefinitionRegistry注册了刚实例化的这个BeanDefinitionHolder。这里完成的是将FeignClient注解的类的信息交给工厂bean代理类,并将代理类的定义注册到Spring的容器中。

至此,已经把要创建的接口代理对象的信息放入registry里面,之后spring在启动调用refresh方法的时候会负责bean的实例化。在实例化过程中,调用FeignClientFactoryBean的getObject方法:

image.png

调用loadBalance方法:

image.png

这里创建的Client实例是一个LoadBalancerFeignClient的对象。Client是一个非常重要的组件,看一下配置类中注入的实例:

@Configuration
class DefaultFeignLoadBalancedConfiguration {
  @Bean
  @ConditionalOnMissingBean
  public Client feignClient(CachingSpringLoadBalancerFactory cachingFactory,
                SpringClientFactory clientFactory) {
    return new LoadBalancerFeignClient(new Client.Default(null, null),
        cachingFactory, clientFactory);
  }
}

在没有配置Client的情况下,会注入一个LoadBalancerFeignClient,其中delegate属性中注入了一个Client$Default对象,我们可以暂时理解为代理,后面就会讲到,Feign发送Request请求以及接收Response响应,都是借助Client$Default对象完成的。

可以回想一下之前Ribbon中讲过的RibbonLoadBalancerClient,Ribbon是使用拦截器后调用了它的execute方法。那么我们可以猜测一下,这里是不是使用什么方式最终了调用LoadBalancerFeignClient的execute方法呢?这个问题我们放在后面去证实。

image.png

接着看上面loadBalance方法中,首先调用了HystrixTargeter的target方法:

image.png

之后调用了Feign的target方法:

image.png

最终调用了ReflectiveFeign类中的newInstance方法。其中名为nameToHandler的Map中存储了FeignClient接口中定义的方法:

image.png

看到下面的InvocationHandler和Proxy就很清楚了,和我们在开头说的一样,这里是使用JDK动态代理的方式创建代理对象。创建InvocationHandler及代理对象过程:

image.png

这里的factory是InvocationHandlerFactory的对象,看一下它的create方法,用于创建FeignInvocationHandler实例来对方法进行拦截。在构造方法中传入了代理类的接口,以及需要代理的方法:

image.png

image.png

通过JDK动态代理我们知道,在InvocationHandler中,invoke方法对进行方法拦截和逻辑增强。那么我们使用一个测试接口,看一下关键的invoke方法是如何工作的:

image.png

首先根据方法名去判断是不是Object类内置的一些方法,都不是则往下,执行了一个分发的操作,这个dispatch是初始化阶段生成的MethodHandler列表。调用SynchronousMethodHandler类的invoke方法:

image.png

使用RequestTemplate创建了一个http请求的模板,可以看见这里创建了一个请求:

GET /user/1 HTTP/1.1

进入executeAndDecode方法,在该方法中,首先使用刚才创建的模板生成了一个Request请求,并且把我们本次调用的服务名和接口名拼接在了一起:

image.png

这里把请求交给了之前创建的LoadBalancerFeignClient,执行了它的execute方法。和开头说的一样,和Ribbon类似的调用流程。只不过需要区别一下的是,Ribbon是使用拦截器拦截请求,而Feign是使用动态代理的invoke方法对方法进行拦截并转发。

image.png

进入LoadBalancerFeignClient的execute方法,在其中构建了一个RibbonRequest的请求:

image.png

在上面的uriWithoutHost中,去除了url中的服务名。这么做是因为Feign其实只需要这个服务后面的接口字符串,至于如何选择服务与负载均衡,都交给了Ribbon去做。

进入RibbonRequest的构造方法中,可以看见,用的Client的实现类是Client$Default对象,即前面讲到的在配置文件中,LoadBalancerFeignClient中delegate存储的对象。

image.png

调用AbstractLoadBalancerAwareClient的executeWithLoadBalancer方法:

image.png

进入其submit方法:

image.png

进入selectServer方法:

image.png

进入LoadBalancerContext的getServerFromLoadBalancer方法:

image.png

在这里结合了Ribbon,完成负载均衡,根据负载均衡算法选择Server。

之后通过调用FeignLoadBalancer的execute方法,再调用Client$Default的execute方法:

image.png

调用convertAndSend创建了一个HttpURLConnection的连接,最后发起远程调用还是用的HttpURLConnection,并在convertResponse方法中封装结果,至此一次调用过程完成。

到这里,我们就能明白为什么说Feign是一个Web客户端并不准确,其实它并没有完成任何请求处理操作,只是一个伪客户端,最终还是调用其他组件完成的请求发送与接收。

最后,对Feign的实现流程进行一下总结:

1、使用JDK动态代理为接口创建代理对象

2、执行接口的方法时,调用代理对象的invoker方法

3、读取FeignClient的注解得到要调用的远程服务的接口

4、通过Ribbon负载均衡得到一个要调用的服务提供者

5、使用HttpURLConnection发起请求,得到响应

相关文章
|
3天前
|
监控 Java 应用服务中间件
高级java面试---spring.factories文件的解析源码API机制
【11月更文挑战第20天】Spring Boot是一个用于快速构建基于Spring框架的应用程序的开源框架。它通过自动配置、起步依赖和内嵌服务器等特性,极大地简化了Spring应用的开发和部署过程。本文将深入探讨Spring Boot的背景历史、业务场景、功能点以及底层原理,并通过Java代码手写模拟Spring Boot的启动过程,特别是spring.factories文件的解析源码API机制。
16 2
|
4天前
|
存储 安全 Linux
Golang的GMP调度模型与源码解析
【11月更文挑战第11天】GMP 调度模型是 Go 语言运行时系统的核心部分,用于高效管理和调度大量协程(goroutine)。它通过少量的操作系统线程(M)和逻辑处理器(P)来调度大量的轻量级协程(G),从而实现高性能的并发处理。GMP 模型通过本地队列和全局队列来减少锁竞争,提高调度效率。在 Go 源码中,`runtime.h` 文件定义了关键数据结构,`schedule()` 和 `findrunnable()` 函数实现了核心调度逻辑。通过深入研究 GMP 模型,可以更好地理解 Go 语言的并发机制。
|
16天前
|
消息中间件 缓存 安全
Future与FutureTask源码解析,接口阻塞问题及解决方案
【11月更文挑战第5天】在Java开发中,多线程编程是提高系统并发性能和资源利用率的重要手段。然而,多线程编程也带来了诸如线程安全、死锁、接口阻塞等一系列复杂问题。本文将深度剖析多线程优化技巧、Future与FutureTask的源码、接口阻塞问题及解决方案,并通过具体业务场景和Java代码示例进行实战演示。
37 3
|
1月前
|
存储
让星星⭐月亮告诉你,HashMap的put方法源码解析及其中两种会触发扩容的场景(足够详尽,有问题欢迎指正~)
`HashMap`的`put`方法通过调用`putVal`实现,主要涉及两个场景下的扩容操作:1. 初始化时,链表数组的初始容量设为16,阈值设为12;2. 当存储的元素个数超过阈值时,链表数组的容量和阈值均翻倍。`putVal`方法处理键值对的插入,包括链表和红黑树的转换,确保高效的数据存取。
53 5
|
1月前
|
Java Spring
Spring底层架构源码解析(三)
Spring底层架构源码解析(三)
108 5
|
1月前
|
XML Java 数据格式
Spring底层架构源码解析(二)
Spring底层架构源码解析(二)
|
1月前
|
算法 Java 程序员
Map - TreeSet & TreeMap 源码解析
Map - TreeSet & TreeMap 源码解析
33 0
|
1月前
|
缓存 Java 程序员
Map - LinkedHashSet&Map源码解析
Map - LinkedHashSet&Map源码解析
67 0
|
1月前
|
算法 Java 容器
Map - HashSet & HashMap 源码解析
Map - HashSet & HashMap 源码解析
52 0
|
1月前
|
存储 Java C++
Collection-PriorityQueue源码解析
Collection-PriorityQueue源码解析
60 0

推荐镜像

更多