深入理解 OpenFeign 的架構(gòu)原理
大家好,我是悟空呀。
上次我們深入講解了 Ribbon 的架構(gòu)原理,這次我們?cè)賮砜聪?Feign 遠(yuǎn)程調(diào)用的架構(gòu)原理。
一、理解遠(yuǎn)程調(diào)用
遠(yuǎn)程調(diào)用怎么理解呢?
遠(yuǎn)程調(diào)用和本地調(diào)用是相對(duì)的,那我們先說本地調(diào)用更好理解些,本地調(diào)用就是同一個(gè) Service 里面的方法 A 調(diào)用方法 B。
那遠(yuǎn)程調(diào)用就是不同 Service 之間的方法調(diào)用。Service 級(jí)的方法調(diào)用,就是我們自己構(gòu)造請(qǐng)求 URL和請(qǐng)求參數(shù),就可以發(fā)起遠(yuǎn)程調(diào)用了。
在服務(wù)之間調(diào)用的話,我們都是基于 HTTP 協(xié)議,一般用到的遠(yuǎn)程服務(wù)框架有 OKHttp3,Netty, HttpURLConnection 等。其調(diào)用流程如下:
但是這種虛線方框中的構(gòu)造請(qǐng)求的過程是很繁瑣的,有沒有更簡(jiǎn)便的方式呢?
Feign 就是來簡(jiǎn)化我們發(fā)起遠(yuǎn)程調(diào)用的代碼的,那簡(jiǎn)化到什么程度呢?簡(jiǎn)化成就像調(diào)用本地方法那樣簡(jiǎn)單。
比如我的開源項(xiàng)目 PassJava 中的使用 Feign 執(zhí)行遠(yuǎn)程調(diào)用的代碼:
- //遠(yuǎn)程調(diào)用拿到該用戶的學(xué)習(xí)時(shí)長
- R memberStudyTimeList = studyTimeFeignService.getMemberStudyTimeListTest(id);
而 Feign 又是 Spring Cloud 微服務(wù)技術(shù)棧中非常重要的一個(gè)組件,如果讓你來設(shè)計(jì)這個(gè)微服務(wù)組件,你會(huì)怎么來設(shè)計(jì)呢?
我們需要考慮這幾個(gè)因素:
- 如何使遠(yuǎn)程調(diào)用像本地方法調(diào)用簡(jiǎn)單?
- Feign 如何找到遠(yuǎn)程服務(wù)的地址的?
- Feign 是如何進(jìn)行負(fù)載均衡的?
接下來我們圍繞這些核心問題來一起看下 Feign 的設(shè)計(jì)原理。
二、Feign 和 OpenFeign
OpenFeign 組件的前身是 Netflix Feign 項(xiàng)目,它最早是作為 Netflix OSS 項(xiàng)目的一部分,由 Netflix 公司開發(fā)。后來 Feign 項(xiàng)目被貢獻(xiàn)給了開源組織,于是才有了我們今天使用的 Spring Cloud OpenFeign 組件。
Feign 和 OpenFeign 有很多大同小異之處,不同的是 OpenFeign 支持 MVC 注解。
可以認(rèn)為 OpenFeign 為 Feign 的增強(qiáng)版。
簡(jiǎn)單總結(jié)下 OpenFeign 能用來做什么:
- OpenFeign 是聲明式的 HTTP 客戶端,讓遠(yuǎn)程調(diào)用更簡(jiǎn)單。
- 提供了HTTP請(qǐng)求的模板,編寫簡(jiǎn)單的接口和插入注解,就可以定義好HTTP請(qǐng)求的參數(shù)、格式、地址等信息
- 整合了Ribbon(負(fù)載均衡組件)和 Hystix(服務(wù)熔斷組件),不需要顯示使用這兩個(gè)組件
- Spring Cloud Feign 在 Netflix Feign的基礎(chǔ)上擴(kuò)展了對(duì)SpringMVC注解的支持
三、OpenFeign 如何用?
OpenFeign 的使用也很簡(jiǎn)單,這里還是用我的開源 SpringCloud 項(xiàng)目 PassJava 作為示例。
開源地址: https://github.com/Jackson0714/PassJava-Platform
喜歡的小伙伴來點(diǎn)個(gè) Star 吧,沖 2K Star。
Member 服務(wù)遠(yuǎn)程調(diào)用 Study 服務(wù)的方法 memberStudyTime(),如下圖所示。
第一步:Member 服務(wù)需要定義一個(gè) OpenFeign 接口:
- @FeignClient("passjava-study")
- public interface StudyTimeFeignService {
- @RequestMapping("study/studytime/member/list/test/{id}")
- public R getMemberStudyTimeListTest(@PathVariable("id") Long id);
- }
我們可以看到這個(gè) interface 上添加了注解@FeignClient,而且括號(hào)里面指定了服務(wù)名:passjava-study。顯示聲明這個(gè)接口用來遠(yuǎn)程調(diào)用 passjava-study服務(wù)。
第二步:Member 啟動(dòng)類上添加 @EnableFeignClients注解開啟遠(yuǎn)程調(diào)用服務(wù),且需要開啟服務(wù)發(fā)現(xiàn)。如下所示:
- @EnableFeignClients(basePackages = "com.jackson0714.passjava.member.feign")
- @EnableDiscoveryClient
第三步:Study 服務(wù)定義一個(gè)方法,其方法路徑和 Member 服務(wù)中的接口 URL 地址一致即可。
URL 地址:"study/studytime/member/list/test/{id}"
- @RestController
- @RequestMapping("study/studytime")
- public class StudyTimeController {
- @RequestMapping("/member/list/test/{id}")
- public R memberStudyTimeTest(@PathVariable("id") Long id) {
- ...
- }
- }
第四步:Member 服務(wù)的 POM 文件中引入 OpenFeign 組件。
- <dependency>
- <groupId>org.springframework.cloud</groupId>
- <artifactId>spring-cloud-starter-openfeign</artifactId>
- </dependency>
第五步:引入 studyTimeFeignService,Member 服務(wù)遠(yuǎn)程調(diào)用 Study 服務(wù)即可。
- Autowired
- private StudyTimeFeignService studyTimeFeignService;
- studyTimeFeignService.getMemberStudyTimeListTest(id);
通過上面的示例,我們知道,加了 @FeignClient 注解的接口后,我們就可以調(diào)用它定義的接口,然后就可以調(diào)用到遠(yuǎn)程服務(wù)了。
這里你是否有疑問:為什么接口都沒有實(shí)現(xiàn),就可以調(diào)用了?
OpenFeign 使用起來倒是簡(jiǎn)單,但是里面的原理可沒有那么簡(jiǎn)單,OpenFeign 幫我們做了很多事情,接下來我們來看下 OpenFeign 的架構(gòu)原理。
四、梳理 OpenFeign 的核心流程
先看下 OpenFeign 的核心流程圖:
- 1、在 Spring 項(xiàng)目啟動(dòng)階段,服務(wù) A 的OpenFeign 框架會(huì)發(fā)起一個(gè)主動(dòng)的掃包流程。
- 2、從指定的目錄下掃描并加載所有被 @FeignClient 注解修飾的接口,然后將這些接口轉(zhuǎn)換成 Bean,統(tǒng)一交給 Spring 來管理。
- 3、根據(jù)這些接口會(huì)經(jīng)過 MVC Contract 協(xié)議解析,將方法上的注解都解析出來,放到 MethodMetadata 元數(shù)據(jù)中。
- 4、基于上面加載的每一個(gè) FeignClient 接口,會(huì)生成一個(gè)動(dòng)態(tài)代理對(duì)象,指向了一個(gè)包含對(duì)應(yīng)方法的 MethodHandler 的 HashMap。MethodHandler 對(duì)元數(shù)據(jù)有引用關(guān)系。生成的動(dòng)態(tài)代理對(duì)象會(huì)被添加到 Spring 容器中,并注入到對(duì)應(yīng)的服務(wù)里。
- 5、服務(wù) A 調(diào)用接口,準(zhǔn)備發(fā)起遠(yuǎn)程調(diào)用。
- 6、從動(dòng)態(tài)代理對(duì)象 Proxy 中找到一個(gè) MethodHandler 實(shí)例,生成 Request,包含有服務(wù)的請(qǐng)求 URL(不包含服務(wù)的 IP)。
- 7、經(jīng)過負(fù)載均衡算法找到一個(gè)服務(wù)的 IP 地址,拼接出請(qǐng)求的 URL
- 8、服務(wù) B 處理服務(wù) A 發(fā)起的遠(yuǎn)程調(diào)用請(qǐng)求,執(zhí)行業(yè)務(wù)邏輯后,返回響應(yīng)給服務(wù) A。
針對(duì)上面的流程,我們?cè)賮砜聪旅恳徊降脑O(shè)計(jì)原理。首先主動(dòng)掃包是如何掃的呢?
五、OpeFeign 包掃描原理
上面的 PassJava 示例代碼中,涉及到了一個(gè) OpenFeign 的注解:@EnableFeignClients。根據(jù)字面意思可以知道,可以注解是開啟 OpenFeign 功能的。
包掃描的基本流程如下:
(1)@EnableFeignClients 這個(gè)注解使用 Spring 框架的 Import 注解導(dǎo)入了 FeignClientsRegistrar 類,開始了 OpenFeign 組件的加載。PassJava 示例代碼如下所示。
- // 啟動(dòng)類加上這個(gè)注解
- @EnableFeignClients(basePackages = "com.jackson0714.passjava.member.feign")
- // EnableFeignClients 類還引入了 FeignClientsRegistrar 類
- @Import(FeignClientsRegistrar.class)
- public @interface EnableFeignClients {
- ...
- }
(2)FeignClientsRegistrar 負(fù)責(zé) Feign 接口的加載。
源碼如下所示:
- @Override
- public void registerBeanDefinitions(AnnotationMetadata metadata,
- BeanDefinitionRegistry registry) {
- // 注冊(cè)配置
- registerDefaultConfiguration(metadata, registry);
- // 注冊(cè) FeignClient
- registerFeignClients(metadata, registry);
- }
(3)registerFeignClients 會(huì)掃描指定包。
核心源碼如下,調(diào)用 find 方法來查找指定路徑 basePackage 的所有帶有 @FeignClients 注解的帶有 @FeignClient 注解的類、接口。
- Set<BeanDefinition> candidateComponents = scanner
- .findCandidateComponents(basePackage);
(4)只保留帶有 @FeignClient 的接口。
- // 判斷是否是帶有注解的 Bean。
- if (candidateComponent instanceof AnnotatedBeanDefinition) {
- // 判斷是否是接口
- AnnotatedBeanDefinition beanDefinition = (AnnotatedBeanDefinition) candidateComponent;
- AnnotationMetadata annotationMetadata = beanDefinition.getMetadata();
- // @FeignClient 只能指定在接口上。
- Assert.isTrue(annotationMetadata.isInterface(),
- "@FeignClient can only be specified on an interface");
接下來我們?cè)賮砜催@些掃描到的接口是如何注冊(cè)到 Spring 中。
六、注冊(cè) FeignClient 到 Spring 的原理
還是在 registerFeignClients 方法中,當(dāng) FeignClient 掃描完后,就要為這些 FeignClient 接口生成一個(gè)動(dòng)態(tài)代理對(duì)象。
順藤摸瓜,進(jìn)到這個(gè)方法里面,可以看到這一段代碼:
- BeanDefinitionBuilder definition = BeanDefinitionBuilder
- .genericBeanDefinition(FeignClientFactoryBean.class);
核心就是 FeignClientFactoryBean 類,根據(jù)類的名字我們可以知道這是一個(gè)工廠類,用來創(chuàng)建 FeignClient Bean 的。
我們最開始用的 @FeignClient,里面有個(gè)參數(shù) "passjava-study",這個(gè)是注解的屬性,當(dāng) OpenFeign 框架去創(chuàng)建 FeignClient Bean 的時(shí)候,就會(huì)使用這些參數(shù)去生成 Bean。流程圖如下:
- 解析 @FeignClient 定義的屬性。
- 將注解@FeignClient 的屬性 + 接口 StudyTimeFeignService的信息構(gòu)造成一個(gè) StudyTimeFeignService 的 beanDefinition。
- 然后將 beanDefinition 轉(zhuǎn)換成一個(gè) holder,這個(gè) holder 就是包含了 beanDefinition, alias, beanName 信息。
- 最后將這個(gè) holder 注冊(cè)到 Spring 容器中。
源碼如下:
- // 生成 beanDefinition
- AbstractBeanDefinition beanDefinition = definition.getBeanDefinition();
- // 轉(zhuǎn)換成 holder,包含了 beanDefinition, alias, beanName 信息
- BeanDefinitionHolder holder = new BeanDefinitionHolder(beanDefinition, className,
- new String[] { alias });
- // 注冊(cè)到 Spring 上下文中。
- BeanDefinitionReaderUtils.registerBeanDefinition(holder, registry);
上面我們已經(jīng)知道 FeignClient 的接口是如何注冊(cè)到 Spring 容器中了。后面服務(wù)要調(diào)用接口的時(shí)候,就可以直接用 FeignClient 的接口方法了,如下所示:
- @Autowired
- private StudyTimeFeignService studyTimeFeignService;
- // 省略部分代碼
- // 直接調(diào)用
- studyTimeFeignService.getMemberStudyTimeListTest(id);
但是我們并沒有細(xì)講這個(gè) FeignClient 的創(chuàng)建細(xì)節(jié),下面我們看下 FeignClient 的創(chuàng)建細(xì)節(jié),這個(gè)也是 OpenFeign 核心原理。
七、OpenFeign 動(dòng)態(tài)代理原理
上面的源碼解析中我們也提到了是由這個(gè)工廠類 FeignClientFactoryBean 來創(chuàng)建 FeignCient Bean,所以我們有必要對(duì)這個(gè)類進(jìn)行剖析。
在創(chuàng)建 FeignClient Bean 的過程中就會(huì)去生成動(dòng)態(tài)代理對(duì)象。調(diào)用接口時(shí),其實(shí)就是調(diào)用動(dòng)態(tài)代理對(duì)象的方法來發(fā)起請(qǐng)求的。
分析動(dòng)態(tài)代理的入口方法為 getObject()。源碼如下所示:
- Targeter targeter = get(context, Targeter.class);
- return (T) targeter.target(this, builder, context,
- new HardCodedTarget<>(this.type, this.name, url));
接著調(diào)用 target 方法這一塊,里面的代碼真的很多很細(xì),我把核心的代碼拿出來給大家講下,這個(gè) target 會(huì)有兩種實(shí)現(xiàn)類:
DefaultTargeter 和 HystrixTargeter。而不論是哪種 target,都需要去調(diào)用 Feign.java 的 builder 方法去構(gòu)造一個(gè) feign client。
在構(gòu)造的過程中,依賴 ReflectiveFeign 去構(gòu)造。源碼如下:
- // 省略部分代碼
- public class ReflectiveFeign extends Feign {
- // 為 feign client 接口中的每個(gè)接口方法創(chuàng)建一個(gè) methodHandler
- public <T> T newInstance(Target<T> target) {
- for(...) {
- methodToHandler.put(method, handler);
- }
- // 基于 JDK 動(dòng)態(tài)代理的機(jī)制,創(chuàng)建了一個(gè) passjava-study 接口的動(dòng)態(tài)代理,所有對(duì)接口的調(diào)用都會(huì)被攔截,然后轉(zhuǎn)交給 handler 的方法。
- InvocationHandler handler = factory.create(target, methodToHandler);
- T proxy = (T) Proxy.newProxyInstance(target.type().getClassLoader(),
- new Class<?>[] {target.type()}, handler);
- }
ReflectiveFeign 做的工作就是為帶有 @FeignClient 注解的接口,創(chuàng)建出接口方法的動(dòng)態(tài)代理對(duì)象。
比如示例代碼中的接口 StudyTimeFeignService,會(huì)給這個(gè)接口中的方法 getMemberStudyTimeList 創(chuàng)建一個(gè)動(dòng)態(tài)代理對(duì)象。
- @FeignClient("passjava-study")
- public interface StudyTimeFeignService {
- @RequestMapping("study/studytime/member/list/test/{id}")
- public R getMemberStudyTimeList(@PathVariable("id") Long id);
- }
創(chuàng)建動(dòng)態(tài)代理的原理圖如下所示:
解析 FeignClient 接口上各個(gè)方法級(jí)別的注解,比如遠(yuǎn)程接口的 URL、接口類型(Get、Post 等)、各個(gè)請(qǐng)求參數(shù)等。這里用到了 MVC Contract 協(xié)議解析,后面會(huì)講到。
- 然后將解析到的數(shù)據(jù)封裝成元數(shù)據(jù),并為每一個(gè)方法生成一個(gè)對(duì)應(yīng)的 MethodHandler 類作為方法級(jí)別的代理。相當(dāng)于把服務(wù)的請(qǐng)求地址、接口類型等都幫我們封裝好了。這些 MethodHandler 方法會(huì)放到一個(gè) HashMap 中。
- 然后會(huì)生成一個(gè) InvocationHandler 用來管理這個(gè) hashMap,其中 Dispatch 指向這個(gè) HashMap。
- 然后使用 Java 的 JDK 原生的動(dòng)態(tài)代理,實(shí)現(xiàn)了 FeignClient 接口的動(dòng)態(tài)代理 Proxy 對(duì)象。這個(gè) Proxy 會(huì)添加到 Spring 容器中。
- 當(dāng)要調(diào)用接口方法時(shí),其實(shí)會(huì)調(diào)用動(dòng)態(tài)代理 Proxy 對(duì)象的 methodHandler 來發(fā)送請(qǐng)求。
這個(gè)動(dòng)態(tài)代理對(duì)象的結(jié)構(gòu)如下所示,它包含了所有接口方法的 MethodHandler。
八、解析 MVC 注解的原理
上面我們講到了接口上是有一些注解的,比如 @RequestMapping,@PathVariable,這些注解統(tǒng)稱為 Spring MVC 注解。但是由于 OpenFeign 是不理解這些注解的,所以需要進(jìn)行一次解析。
解析的流程圖如下:
而解析的類就是 SpringMvcContract 類,調(diào)用 parseAndValidateMetadata 進(jìn)行解析。解析完之后,就會(huì)生成元數(shù)據(jù)列表。源碼如下所示:
- List<MethodMetadata> metadata = contract.parseAndValidateMetadata(target.type());
這個(gè)類在這個(gè)路徑下,大家可以自行翻閱下如何解析的,不在本篇的討論范圍內(nèi)。
- https://github.com/spring-cloud/spring-cloud-openfeign/blob/main/spring-cloud-openfeign-core/src/main/java/org/springframework/cloud/openfeign/support/SpringMvcContract.java
這個(gè)元數(shù)據(jù) MethodMetadata 里面有什么東西呢?
- 方法的定義,如 StudyTimeFeignService 的 getMemberStudyTimeList 方法。
- 方法的參數(shù)類型,如 Long。
- 發(fā)送 HTTP 請(qǐng)求的地址,如 /study/studytime/member/list/test/{id}。
然后每個(gè)接口方法就會(huì)有對(duì)應(yīng)的一個(gè) MethodHandler,它里面就包含了元數(shù)據(jù),當(dāng)我們調(diào)用接口方法時(shí),其實(shí)是調(diào)用動(dòng)態(tài)代理對(duì)象的 MethodHandler 來發(fā)送遠(yuǎn)程調(diào)用請(qǐng)求的。
上面我們針對(duì) OpenFeign 框架如何為 FeignClient 接口生成動(dòng)態(tài)代理已經(jīng)講完了,下面我們?cè)賮砜聪庐?dāng)我們調(diào)用接口方法時(shí),動(dòng)態(tài)代理對(duì)象是如何發(fā)送遠(yuǎn)程調(diào)用請(qǐng)求的。
九、OpenFeign 發(fā)送請(qǐng)求的原理
先上流程圖:
還是在 ReflectiveFeign 類中,有一個(gè) invoke 方法,會(huì)執(zhí)行以下代碼:
- dispatch.get(method).invoke(args);
這個(gè) dispatch 我們之前已經(jīng)講解過了,它指向了一個(gè) HashMap,里面包含了 FeignClient 每個(gè)接口的 MethodHandler 類。
這行代碼的意思就是根據(jù) method 找到 MethodHandler,調(diào)用它的 invoke 方法,并且傳的參數(shù)就是我們接口中的定義的參數(shù)。
那我們?cè)俑M(jìn)去看下這個(gè) MethodHandler invoke 方法里面做了什么事情。源碼如下所示:
- public Object invoke(Object[] argv) throws Throwable {
- RequestTemplate template = buildTemplateFromArgs.create(argv);
- ...
- }
我們可以看到這個(gè)方法里面生成了 RequestTemplate,它的值類似如下:
- GET /study/list/test/1 HTTP/1.1
RequestTemplate 轉(zhuǎn)換成 Request,它的值類似如下:
- GET http://passjava-study/study/list/test/1 HTTP/1.1
這路徑不就是我們要 study 服務(wù)的方法,這樣就可以直接調(diào)用到 study 服了呀!
OpenFeign 幫我們組裝好了發(fā)起遠(yuǎn)程調(diào)用的一切,我們只管調(diào)用就好了。
接著 MethodHandler 會(huì)執(zhí)行以下方法,發(fā)起 HTTP 請(qǐng)求。
- client.execute(request, options);
從上面的我們要調(diào)用的服務(wù)就是 passjava-study,但是這個(gè)服務(wù)的具體 IP 地址我們是不知道的,那 OpenFeign 是如何獲取到 passjava-study 服務(wù)的 IP 地址的呢?
回想下最開始我們提出的核心問題:OpenFeign 是如何進(jìn)行負(fù)載均衡的?
我們是否可以聯(lián)想到上一講的 Ribbon 負(fù)載均衡,它不就是用來做 IP 地址選擇的么?
那我們就來看下 OpenFeign 又是如何和 Ribbon 進(jìn)行整合的。
十、OpenFeign 如何與 Ribbon 整合的原理
為了驗(yàn)證 Ribbon 的負(fù)載均衡,我們需要啟動(dòng)兩個(gè) passjava-study 服務(wù),這里我啟動(dòng)了兩個(gè)服務(wù),端口號(hào)分別為 12100 和 12200,IP 地址都是本機(jī) IP:192.168.10.197。
接著上面的源碼繼續(xù)看,client.execute() 方法其實(shí)會(huì)調(diào)用 LoadBalancerFeignClient 的 exceute 方法。
這個(gè)方法里面的執(zhí)行流程如下圖所示:
- 將服務(wù)名稱 passjava-study 從 Request 的 URL 中刪掉,剩下的如下所示:
- GET http:///study/list/test/1 HTTP/1.1
- 根據(jù)服務(wù)名從緩存中找 FeignLoadBalancer,如果緩存中沒有,則創(chuàng)建一個(gè) FeignLoadBalancer。
- FeignLoadBalancer 會(huì)創(chuàng)建出一個(gè) command,這個(gè) command 會(huì)執(zhí)行一個(gè) sumbit 方法。
- submit 方法里面就會(huì)用 Ribbon 的負(fù)載均衡算法選擇一個(gè) server。源碼如下:
- Server svc = lb.chooseServer(loadBalancerKey);
通過 debug 調(diào)試,我們可以看到兩次請(qǐng)求的端口號(hào)不一樣,一個(gè)是 12200,一個(gè)是 12100,說明確實(shí)進(jìn)行了負(fù)載均衡。
- 然后將 IP 地址和之前剔除掉服務(wù)名稱的 URL 進(jìn)行拼接,生成最后的服務(wù)地址。
- 最后 FeignLoadBalancer 執(zhí)行 execute 方法發(fā)送請(qǐng)求。
那大家有沒有疑問,Ribbon 是如何拿到服務(wù)地址列表的?這個(gè)就是上一講 Ribbon 架構(gòu)里面的內(nèi)容。
Ribbon 的核心組件 ServerListUpdater,用來同步注冊(cè)表的,它有一個(gè)實(shí)現(xiàn)類 PollingServerListUpdater ,專門用來做定時(shí)同步的。默認(rèn)1s 后執(zhí)行一個(gè) Runnable 線程,后面就是每隔 30s 執(zhí)行 Runnable 線程。這個(gè) Runnable 線程就是去獲取注冊(cè)中心的注冊(cè)表的。
十一、OpenFeign 處理響應(yīng)的原理
當(dāng)遠(yuǎn)程服務(wù) passjava-study 處理完業(yè)務(wù)邏輯后,就會(huì)返回 reponse 給 passjava-member 服務(wù)了,這里還會(huì)對(duì) reponse 進(jìn)行一次解碼操作。
- Object result = decode(response);
這個(gè)里面做的事情就是調(diào)用 ResponseEntityDecoder 的 decode 方法,將 Json 字符串轉(zhuǎn)化為 Bean 對(duì)象。
十二、總結(jié)
本文通過我的開源項(xiàng)目 PassJava 中用到的 OpenFeign 作為示例代碼作為入口進(jìn)行講解。然后以圖解+解讀源碼的方式深入剖析了 OpenFeign 的運(yùn)行機(jī)制和架構(gòu)設(shè)計(jì)。
核心思想:
- OpenFeign 會(huì)掃描帶有 @FeignClient 注解的接口,然后為其生成一個(gè)動(dòng)態(tài)代理。
- 動(dòng)態(tài)代理里面包含有接口方法的 MethodHandler,MethodHandler 里面又包含經(jīng)過 MVC Contract 解析注解后的元數(shù)據(jù)。
- 發(fā)起請(qǐng)求時(shí),MethodHandler 會(huì)生成一個(gè) Request。
- 負(fù)載均衡器 Ribbon 會(huì)從服務(wù)列表中選取一個(gè) Server,拿到對(duì)應(yīng)的 IP 地址后,拼接成最后的 URL,就可以發(fā)起遠(yuǎn)程服務(wù)調(diào)用了。
OpenFeign 的核心流程圖: