Spring cloud netflix ribbon設(shè)計(jì)思路在上一篇文章已經(jīng)提及,本篇文章是記錄本人閱讀源碼過程中的一些筆記,純粹是看到一點(diǎn),寫一點(diǎn)抵栈。
ribbon是通過往resttemplate(標(biāo)注了@LoadBalanced)插入攔截器LoadBalancerInterceptor啟作用,攔截過程如下:
1.spring boot方式加載spring-cloud-commons-(版本).jar時(shí)乌逐,會(huì)啟用自動(dòng)配置LoadBalancerAutoConfiguration竭讳,該類中创葡,自動(dòng)將有所有標(biāo)注了@LoadBalanced的resttemplate浙踢, 用一個(gè)列表restTemplates維護(hù)起來(lái)。另外還做了三個(gè)事情:1)創(chuàng)建攔截器LoadBalancerInterceptor的bean 2)創(chuàng)建了RestTemplateCustomizer的bean灿渴,用于將上面的攔截器插入restTemplates內(nèi)resttemplate對(duì)象的攔截器列表洛波。該bean類似函數(shù)接口胰舆,由SmartInitializingSingleton的bean調(diào)用該函數(shù)接口。3)創(chuàng)建了LoadBalancerRequestFactory蹬挤,工廠類缚窿,最終目的是重構(gòu)負(fù)載均衡器返回的服務(wù)器信息,變成具體的host:port的請(qǐng)求地址焰扳。實(shí)現(xiàn)方法是給LoadBalancerInterceptor創(chuàng)建請(qǐng)求對(duì)象LoadBalancerRequest倦零,該對(duì)象的apply方法會(huì)將傳入的HttpRequest轉(zhuǎn)換為一個(gè)包裝類ServiceRequestWrapper,接著繼續(xù)執(zhí)行http請(qǐng)求后續(xù)通用流程吨悍。至于在什么地方apply被調(diào)用扫茅,后面會(huì)提及。這里ServiceRequestWrapper作用是override HttpRequest的getURI方法(http請(qǐng)求后續(xù)通用流程會(huì)調(diào)用此方法)育瓜,該方法內(nèi)部調(diào)用 RibbonLoadBalancerClient(下面會(huì)講)的reconstructURI葫隙,其內(nèi)部調(diào)用了RibbonLoadBalancerContext(下面會(huì)講).reconstructURIWithServer達(dá)到上述說(shuō)的最終目的(這源碼好tmd啰嗦,就是一堆c++回調(diào)函數(shù)類似的東西)躏仇,4)創(chuàng)建了RetryLoadBalancerInterceptor等和重試相關(guān)的bean恋脚,這塊還沒仔細(xì)看,先不說(shuō)焰手。
2.既然是攔截器糟描,resttemplate發(fā)起請(qǐng)求時(shí),會(huì)先調(diào)用LoadBalancerInterceptor的intercept(finalHttpRequest request, final byte[] body, finalClientHttpRequestExecution execution)方法册倒,方法內(nèi)部通過gethost方法獲取請(qǐng)求的host地址(一般就是被調(diào)用服務(wù)名了蚓挤,用serviceId標(biāo)記);接著通過類型為L(zhǎng)oadBalancerClient的bean執(zhí)行進(jìn)一步的操作:execute(String serviceId,LoadBalancerRequest request)驻子,具體bean類型為RibbonLoadBalancerClient灿意。
補(bǔ)充:LoadBalancerInterceptor有兩個(gè)對(duì)象,:LoadBalancerClient和LoadBalancerRequestFactory崇呵,是通過構(gòu)造函數(shù)賦值缤剧。后者講過了,前者的創(chuàng)建域慷,是在spring-cloud-netflix-core-(版本).jar加載時(shí)荒辕,自動(dòng)配置RibbonAutoConfiguration后創(chuàng)建的,具體的bean是RibbonLoadBalancerClient
3.RibbonLoadBalancerClient的execute方法做了幾件核心事情犹褒,1)通過SpringClientFactory和serviceId獲取類型為ILoadBalancer的bean抵窒,這屬于ribbon組件的類型;2)調(diào)用該bean的chooseServer方法叠骑,傳入?yún)?shù)是一個(gè)“default”字符串李皇,返回Server對(duì)象(ribbon的類型);3)根據(jù)Server對(duì)象構(gòu)造其包裝對(duì)象RibbonServer蝎抽,額外存儲(chǔ)了服務(wù)名口糕,https標(biāo)識(shí)和元數(shù)據(jù)集合 4)執(zhí)行LoadBalancerRequest的apply方法(作用上面1.有提到)先誉,傳入的就是RibbonServer對(duì)象攻谁,根據(jù)該對(duì)象信息鱼辙,構(gòu)造并發(fā)送請(qǐng)求到實(shí)際的host:port地址纺裁。從而實(shí)現(xiàn)了從向服務(wù)名請(qǐng)求轉(zhuǎn)換到具體地址(經(jīng)負(fù)載均衡組件挑選)請(qǐng)求挥下。
到這里汰具,spring cloud客戶端負(fù)載均衡的頂層流程走完哪亿,后續(xù)重點(diǎn)理解ribbon中ILoadBalancer.chooseServer具體做了什么負(fù)載均衡相關(guān)事宜粥烁,以及ribbon本身一堆初始化的東東。
補(bǔ)充:3.這里涉及了幾個(gè)關(guān)鍵輔助對(duì)象:1)SpringClientFactory蝇棉,是在spring-cloud-netflix-core-(版本).jar加載時(shí)页徐,調(diào)用RibbonAutoConfiguration進(jìn)行自動(dòng)配置時(shí)創(chuàng)建的。這是 a factory that creates client, load balancer and client configuration instances. It creates a Spring ApplicationContext per client name, and extracts the beans that it needs from there.從代碼看银萍,是通過為每一個(gè)服務(wù)名創(chuàng)建一個(gè)AnnotationConfigApplicationContext容器(不懂請(qǐng)惡補(bǔ)spring基礎(chǔ)知識(shí))來(lái)達(dá)到每個(gè)服務(wù)名都有獨(dú)立的client变勇,load balancer等bean。從SpringClientFactory構(gòu)造函數(shù)中看到贴唇,這些bean基本是通過RibbonClientConfiguration來(lái)配置創(chuàng)建搀绣。當(dāng)然如果用了eureka,以EurekaRibbonClientConfiguration的bean為主戳气;? ? 2)RibbonLoadBalancerContext用于存儲(chǔ)部分被負(fù)載均衡器使用的上下文和api操作链患,也是通過SpringClientFactory獲取