業(yè)務(wù)提供者引入nacos客戶端sdk,通過(guò)這個(gè)sdk向nacos服務(wù)器注冊(cè)服務(wù),這個(gè)服務(wù)讓消費(fèi)者調(diào)用驻龟。
Nacos客戶端心跳續(xù)約
為了保證業(yè)務(wù)方服務(wù)的新增機(jī)器和機(jī)器下線等信息及時(shí)同步給消費(fèi)者载慈,提供者需定期向nacos服務(wù)器上報(bào)心跳包,告訴服務(wù)器自己還活著苫费,如果nacos服務(wù)器15秒沒(méi)有收到心跳包汤锨,就會(huì)把這個(gè)提供者標(biāo)示為不健康,并通報(bào)給nacos客戶端百框,如果服務(wù)器30秒沒(méi)有收到心跳包泥畅,就會(huì)在nacos服務(wù)器上刪除這個(gè)提供者,并把最新的提供者列表通過(guò)upd協(xié)議發(fā)送給nacos客戶端琅翻。
我們調(diào)用Nacos客戶端sdk時(shí)位仁,一般如下:
我們看下Nacos客戶端實(shí)現(xiàn)架構(gòu):
? ? ? ?業(yè)務(wù)服務(wù)調(diào)用nacos客戶端sdk的NacosNamingService注冊(cè)接口,這個(gè)類會(huì)判斷注冊(cè)進(jìn)來(lái)的實(shí)例是臨時(shí)的還是永久的(默認(rèn)是臨時(shí)的)方椎,如果是臨時(shí)實(shí)例聂抢,說(shuō)明這個(gè)實(shí)例很容易變化,比如上線下線棠众,這樣就需要用到心跳組件BeatReactor類琳疏,這個(gè)心跳組件會(huì)啟動(dòng)一個(gè)線程(ScheduledExecutorService)運(yùn)行BeatTask任務(wù)有决,BeatTask默認(rèn)每5秒運(yùn)行一次,它向Nacos服務(wù)器發(fā)送Http?Put請(qǐng)求空盼,來(lái)報(bào)告自己仍然存活书幕,這個(gè)上報(bào)也叫續(xù)約。
? ? ? ?如果nacos服務(wù)器15秒沒(méi)有收到心跳包揽趾,就會(huì)把這個(gè)實(shí)例標(biāo)示為不健康台汇,并通報(bào)給nacos客戶端,如果服務(wù)器30秒沒(méi)有收到心跳包篱瞎,就會(huì)在nacos服務(wù)器上刪除這個(gè)實(shí)例苟呐,并把刪除過(guò)的最新的實(shí)例列表通過(guò)upd協(xié)議發(fā)送給nacos客戶端,這塊是nacos服務(wù)端心跳檢測(cè)邏輯俐筋,在后面會(huì)介紹到牵素。
我們來(lái)看下上圖中這幾個(gè)核心組件類的具體實(shí)現(xiàn)。
先看下NacosNamingService類注冊(cè)實(shí)例方法:
NacosNamingService 就是上面例子中NamingService接口的實(shí)現(xiàn)類澄者,也就是說(shuō)這個(gè)方法直接被業(yè)務(wù)服務(wù)調(diào)用笆呆。看下主要邏輯:
首先粱挡,判斷注冊(cè)進(jìn)來(lái)的實(shí)例是否是臨時(shí)實(shí)例:instance.isEphemeral()腰奋,如果是臨時(shí)實(shí)例,就構(gòu)建心跳包BeatInfo抱怔,然后啟動(dòng)BeatReactor組件類劣坊,最后一行是啟動(dòng)NamingProxy組件類注冊(cè)服務(wù)實(shí)例。
接下來(lái)屈留,看下心跳組件BeatReactor的addBeatInfo干了啥局冰?
這個(gè)方法最主要的是使用線程池ScheduledExecutorService執(zhí)行BeatTask心跳任務(wù),默認(rèn)是每5秒執(zhí)行一次灌危。還有一個(gè)dom2Beat康二,這個(gè)Map是防止一個(gè)實(shí)例執(zhí)行2個(gè)心跳續(xù)約任務(wù),這樣會(huì)浪費(fèi)資源勇蝙,處理邏輯是:先把老的心跳任務(wù)停掉并刪除沫勿,再添加新的心跳任務(wù)。
最下面的MetricsMonitor是監(jiān)控相關(guān)的味混,和主要邏輯沒(méi)有關(guān)系产雹,我們就不看了,包括后續(xù)監(jiān)控相關(guān)的我們都先不看了翁锡。
和大家說(shuō)下蔓挖,源碼里面一般邏輯都非常多,有大量的代碼是數(shù)據(jù)組裝馆衔、數(shù)據(jù)結(jié)構(gòu)轉(zhuǎn)換瘟判、各種異常情況和程序健壯性校驗(yàn)怨绣,還有一些是輔助對(duì)象信息的填充,這些代碼都和主邏輯無(wú)法拷获,我們都可以先不看篮撑,抓住重點(diǎn)流程和骨干邏輯,這樣我們才能在紛雜的邏輯中保持清晰的思路匆瓜,才能了解復(fù)雜系統(tǒng)的架構(gòu)赢笨。
下圖是客戶端心跳續(xù)約流程概覽:
BeatTask概覽
BeatTask線程先調(diào)用sendBeat方法給服務(wù)器上報(bào)心跳,調(diào)用了封裝遠(yuǎn)程調(diào)用的方法reqApi陕壹,callServer方法會(huì)隨機(jī)選擇可用的nacos服務(wù)器發(fā)送Http請(qǐng)求质欲。BeatTask讀取服務(wù)器返回的結(jié)果树埠,判斷如果上報(bào)心跳的實(shí)例在nacos服務(wù)器不存在糠馆,則調(diào)用registerService創(chuàng)建該服務(wù)實(shí)例,這個(gè)請(qǐng)求也會(huì)調(diào)用到reqApi封裝的方法怎憋,BeatTask線程在結(jié)束時(shí)會(huì)使用ScheduledExecutorService啟動(dòng)下一次心跳續(xù)約任務(wù)又碌,所以這個(gè)BeatTask任務(wù)是持續(xù)重復(fù)運(yùn)行的。
下面我們?cè)敿?xì)看下代碼的實(shí)現(xiàn)绊袋,我們看下5秒一次的心跳任務(wù)BeatTask是怎么運(yùn)作的毕匀?
BeatTask任務(wù)是個(gè)線程類,代碼有點(diǎn)長(zhǎng)癌别,我們分2段來(lái)看:
首先皂岔,就是使用serverProxy?也就是NamingProxy類來(lái)發(fā)送心跳,從nacos服務(wù)器返回的result展姐,有2個(gè)重要字段躁垛,一個(gè)是心跳間隔interval,說(shuō)明nacos服務(wù)器可以設(shè)置客戶端發(fā)送心跳的頻率圾笨,另一個(gè)是Light_Beat_Enabled教馆,標(biāo)識(shí)心跳發(fā)送是否是輕量級(jí)的,是否帶著B(niǎo)eanInfo這個(gè)對(duì)象擂达,默認(rèn)是false土铺,每次帶著這個(gè)心跳對(duì)象,nacos服務(wù)器也可以指定每次發(fā)送是否帶著這個(gè)對(duì)象板鬓。
接著悲敷,我們看下serverProxy(NamingProxy類)sendBeat方法發(fā)送心跳:
這段代碼最重要的一句是紅框內(nèi)調(diào)用reqApi這個(gè)方法,向nacos服務(wù)器發(fā)送心跳俭令,上面的大段代碼都是為reqApi這個(gè)方法準(zhǔn)備params和bodyMap這2個(gè)參數(shù)镀迂,所以看源碼要抓住重點(diǎn),代碼很多唤蔗,但重點(diǎn)只有那么一二個(gè)探遵,其他代碼邏輯都是為這一二個(gè)重點(diǎn)做準(zhǔn)備窟赏。
可以看到reqApi這個(gè)方法是Http PUT方法,心跳包BeatInfo放到bodyMap參數(shù)中箱季,第一個(gè)參數(shù)是服務(wù)器的URI:/nacos/v1/ns/instance/beat涯穷。
我們繼續(xù)看下reqApi這個(gè)方法,是怎么請(qǐng)求nacos服務(wù)器的藏雏?
這段代碼分2塊拷况,先看nacosDomain這個(gè)變量,當(dāng)只有一臺(tái)nacos服務(wù)器時(shí)掘殴,nacosDomain就是服務(wù)器地址赚瘦,如果有多臺(tái)nacos服務(wù)器,nacosDomain就為空奏寨。至于有幾臺(tái)nacos服務(wù)器起意,看下面:是我們最開(kāi)始通過(guò)Properties屬性傳進(jìn)來(lái)的。
上面一塊代碼是只有一臺(tái)nacos服務(wù)器情況病瞳,如果調(diào)用一次出錯(cuò)揽咕,會(huì)重試maxRetry次;下面一塊代碼是當(dāng)有多臺(tái)nacos服務(wù)器時(shí)套菜,我們隨機(jī)選擇一臺(tái)調(diào)用亲善,如果出錯(cuò)就調(diào)用下一臺(tái)。
我們費(fèi)了很大勁看reqApi這個(gè)方法逗柴,就是為了看這個(gè)邏輯蛹头,客戶端發(fā)心跳到底發(fā)到哪臺(tái)nacos服務(wù)器?這下就清楚了戏溺,如果只有一臺(tái)渣蜗,就只能發(fā)給這臺(tái);如果有多臺(tái)于购,是隨機(jī)找一臺(tái)發(fā)的袍睡。
紅框內(nèi)的calServer方法我們就不看了,就是使用封裝好的NacosRestTemplate組件發(fā)送Http協(xié)議給nacos服務(wù)器了肋僧。