Nacos客戶端心跳續(xù)約

業(yè)務(wù)提供者引入nacos客戶端sdk,通過(guò)這個(gè)sdk向nacos服務(wù)器注冊(cè)服務(wù),這個(gè)服務(wù)讓消費(fèi)者調(diào)用驻龟。

Nacos客戶端服務(wù)注冊(cè)概要流程

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):

Nacos客戶端注冊(cè)流程

? ? ? ?業(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類注冊(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干了啥局冰?

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心跳任務(wù)流程

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)看:

BeatTask類

首先皂岔,就是使用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ā)送心跳:

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ù)器的藏雏?

reqApi方法請(qǐng)求服務(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)的。

Properties屬性設(shè)置nacos服務(wù)器地址

上面一塊代碼是只有一臺(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ù)器了肋僧。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
禁止轉(zhuǎn)載斑胜,如需轉(zhuǎn)載請(qǐng)通過(guò)簡(jiǎn)信或評(píng)論聯(lián)系作者。
  • 序言:七十年代末嫌吠,一起剝皮案震驚了整個(gè)濱河市止潘,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌辫诅,老刑警劉巖凭戴,帶你破解...
    沈念sama閱讀 218,525評(píng)論 6 507
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場(chǎng)離奇詭異炕矮,居然都是意外死亡么夫,警方通過(guò)查閱死者的電腦和手機(jī)者冤,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,203評(píng)論 3 395
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)档痪,“玉大人涉枫,你說(shuō)我怎么就攤上這事「” “怎么了愿汰?”我有些...
    開(kāi)封第一講書(shū)人閱讀 164,862評(píng)論 0 354
  • 文/不壞的土叔 我叫張陵,是天一觀的道長(zhǎng)乐纸。 經(jīng)常有香客問(wèn)我衬廷,道長(zhǎng),這世上最難降的妖魔是什么汽绢? 我笑而不...
    開(kāi)封第一講書(shū)人閱讀 58,728評(píng)論 1 294
  • 正文 為了忘掉前任吗跋,我火速辦了婚禮,結(jié)果婚禮上庶喜,老公的妹妹穿的比我還像新娘小腊。我一直安慰自己救鲤,他們只是感情好久窟,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,743評(píng)論 6 392
  • 文/花漫 我一把揭開(kāi)白布。 她就那樣靜靜地躺著本缠,像睡著了一般斥扛。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上丹锹,一...
    開(kāi)封第一講書(shū)人閱讀 51,590評(píng)論 1 305
  • 那天稀颁,我揣著相機(jī)與錄音,去河邊找鬼楣黍。 笑死匾灶,一個(gè)胖子當(dāng)著我的面吹牛,可吹牛的內(nèi)容都是我干的租漂。 我是一名探鬼主播阶女,決...
    沈念sama閱讀 40,330評(píng)論 3 418
  • 文/蒼蘭香墨 我猛地睜開(kāi)眼,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼哩治!你這毒婦竟也來(lái)了秃踩?” 一聲冷哼從身側(cè)響起,我...
    開(kāi)封第一講書(shū)人閱讀 39,244評(píng)論 0 276
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤业筏,失蹤者是張志新(化名)和其女友劉穎憔杨,沒(méi)想到半個(gè)月后,有當(dāng)?shù)厝嗽跇?shù)林里發(fā)現(xiàn)了一具尸體蒜胖,經(jīng)...
    沈念sama閱讀 45,693評(píng)論 1 314
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡消别,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,885評(píng)論 3 336
  • 正文 我和宋清朗相戀三年抛蚤,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片寻狂。...
    茶點(diǎn)故事閱讀 40,001評(píng)論 1 348
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡霉颠,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出荆虱,到底是詐尸還是另有隱情蒿偎,我是刑警寧澤,帶...
    沈念sama閱讀 35,723評(píng)論 5 346
  • 正文 年R本政府宣布怀读,位于F島的核電站诉位,受9級(jí)特大地震影響,放射性物質(zhì)發(fā)生泄漏菜枷。R本人自食惡果不足惜苍糠,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,343評(píng)論 3 330
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望啤誊。 院中可真熱鬧岳瞭,春花似錦、人聲如沸蚊锹。這莊子的主人今日做“春日...
    開(kāi)封第一講書(shū)人閱讀 31,919評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)牡昆。三九已至姚炕,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間丢烘,已是汗流浹背柱宦。 一陣腳步聲響...
    開(kāi)封第一講書(shū)人閱讀 33,042評(píng)論 1 270
  • 我被黑心中介騙來(lái)泰國(guó)打工, 沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留播瞳,地道東北人掸刊。 一個(gè)月前我還...
    沈念sama閱讀 48,191評(píng)論 3 370
  • 正文 我出身青樓,卻偏偏與公主長(zhǎng)得像赢乓,于是被迫代替她去往敵國(guó)和親忧侧。 傳聞我的和親對(duì)象是個(gè)殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,955評(píng)論 2 355

推薦閱讀更多精彩內(nèi)容