[發(fā)明專利]基于分布式框架的故障節(jié)點(diǎn)處理方法及裝置

在審

• 申請(qǐng)?zhí)枺?/td>: 202010475416.4
• 申請(qǐng)日: 2020-05-29
• 公開(kāi)（公告）號(hào): CN111666170A
• 公開(kāi)（公告）日: 2020-09-15
• 發(fā)明（設(shè)計(jì)）人: 顧欣;夏龍飛;讓濤;張家宇
• 申請(qǐng)（專利權(quán)）人: 中國(guó)工商銀行股份有限公司
• 主分類號(hào): G06F11/07
• 分類號(hào): G06F11/07
• 代理公司: 北京三友知識(shí)產(chǎn)權(quán)代理有限公司 11127
• 代理人: 王濤;湯在彥

本發(fā)明提供了一種基于分布式框架的故障節(jié)點(diǎn)處理方法及裝置，包括：通過(guò)預(yù)先建立的提供方節(jié)點(diǎn)與消費(fèi)方節(jié)點(diǎn)之間的故障消息通道獲取健康狀態(tài)發(fā)生變化的提供方節(jié)點(diǎn)；根據(jù)健康狀態(tài)變化情況對(duì)對(duì)應(yīng)的提供方節(jié)點(diǎn)執(zhí)行相應(yīng)的處理操作，處理操作包括隔離及恢復(fù)。本申請(qǐng)無(wú)需通過(guò)注冊(cè)中心進(jìn)行網(wǎng)絡(luò)廣播將故障節(jié)點(diǎn)推送，而是在消費(fèi)方節(jié)點(diǎn)和提供方節(jié)點(diǎn)之間建立故障消息通道，直接將發(fā)生故障的提供方節(jié)點(diǎn)告知消費(fèi)方，由消費(fèi)方節(jié)點(diǎn)主動(dòng)對(duì)該故障節(jié)點(diǎn)進(jìn)行隔離，不會(huì)造成巨大的網(wǎng)絡(luò)壓力并且不會(huì)影響在途請(qǐng)求。

技術(shù)領(lǐng)域

本申請(qǐng)屬于分布式微服務(wù)技術(shù)領(lǐng)域，具體地講，涉及一種基于分布式框架的故障節(jié)點(diǎn)處理方法及裝置。

背景技術(shù)

隨著分布式微服務(wù)的流行，分布式集群服務(wù)框架越來(lái)越龐大，如何在復(fù)雜的調(diào)用鏈路中隔離故障的節(jié)點(diǎn)就變的越來(lái)越重要。傳統(tǒng)的分布式服務(wù)節(jié)點(diǎn)隔離需要依賴與注冊(cè)中心的下線機(jī)制。即該節(jié)點(diǎn)下線，然后由注冊(cè)中心廣播事件通知所有節(jié)點(diǎn)，該節(jié)點(diǎn)的下游方節(jié)點(diǎn)從路由列表中刪除該節(jié)點(diǎn)。但是該種廣播方法會(huì)造成巨大的網(wǎng)絡(luò)壓力，特別是當(dāng)集群中的下游節(jié)點(diǎn)較多時(shí)，會(huì)造成網(wǎng)絡(luò)風(fēng)暴引發(fā)風(fēng)險(xiǎn)。

發(fā)明內(nèi)容

本申請(qǐng)?zhí)峁┝艘环N基于分布式框架的故障節(jié)點(diǎn)處理方法及裝置，以至少解決現(xiàn)有技術(shù)中分布式微服務(wù)框架中的故障節(jié)點(diǎn)隔離需要通過(guò)注冊(cè)中心進(jìn)行光從從而造成網(wǎng)絡(luò)壓力過(guò)大的問(wèn)題。

根據(jù)本申請(qǐng)的一個(gè)方面，提供了一種基于分布式框架的故障節(jié)點(diǎn)處理方法，包括：

通過(guò)預(yù)先建立的提供方節(jié)點(diǎn)與消費(fèi)方節(jié)點(diǎn)之間的故障消息通道獲取健康狀態(tài)發(fā)生變化的提供方節(jié)點(diǎn)；

根據(jù)健康狀態(tài)變化情況對(duì)對(duì)應(yīng)的提供方節(jié)點(diǎn)執(zhí)行相應(yīng)的處理操作，處理操作包括隔離及恢復(fù)。

在一實(shí)施例中，根據(jù)健康狀態(tài)變化情況對(duì)對(duì)應(yīng)的提供方節(jié)點(diǎn)執(zhí)行相應(yīng)的處理操作，包括：

將健康狀態(tài)變化情況從正常變?yōu)楫惓５奶峁┓焦?jié)點(diǎn)設(shè)置為故障節(jié)點(diǎn)；

對(duì)故障節(jié)點(diǎn)進(jìn)行本地隔離。

在一實(shí)施例中，對(duì)故障節(jié)點(diǎn)進(jìn)行本地隔離，包括：

將故障節(jié)點(diǎn)對(duì)應(yīng)的鏈接設(shè)置為可讀不可寫狀態(tài)；

從本地路由列表中刪除故障節(jié)點(diǎn)的地址信息。

在一實(shí)施例中，根據(jù)健康狀態(tài)變化情況對(duì)對(duì)應(yīng)的提供方節(jié)點(diǎn)執(zhí)行相應(yīng)的處理操作，包括：

將健康狀態(tài)變化情況從異常變?yōu)檎５奶峁┓焦?jié)點(diǎn)設(shè)置為康復(fù)節(jié)點(diǎn)；

對(duì)康復(fù)節(jié)點(diǎn)進(jìn)行本地恢復(fù)。

在一實(shí)施例中，對(duì)康復(fù)節(jié)點(diǎn)進(jìn)行本地恢復(fù)，包括：

將康復(fù)節(jié)點(diǎn)對(duì)應(yīng)的鏈接設(shè)置為可讀可寫狀態(tài)；

從本地路由列表中增加康復(fù)節(jié)點(diǎn)的地址信息。

根據(jù)本申請(qǐng)的另一個(gè)方面，還提供了一種基于分布式框架的故障節(jié)點(diǎn)處理裝置，包括：

健康狀態(tài)監(jiān)測(cè)單元，用于通過(guò)預(yù)先建立的提供方節(jié)點(diǎn)與消費(fèi)方節(jié)點(diǎn)之間的故障消息通道獲取健康狀態(tài)發(fā)生變化的提供方節(jié)點(diǎn)；

隔離及恢復(fù)單元，用于根據(jù)健康狀態(tài)變化情況對(duì)對(duì)應(yīng)的提供方節(jié)點(diǎn)執(zhí)行相應(yīng)的處理操作，處理操作包括隔離及恢復(fù)。

在一實(shí)施例中，隔離及恢復(fù)單元包括：

故障節(jié)點(diǎn)確定模塊，用于將健康狀態(tài)變化情況從正常變?yōu)楫惓５奶峁┓焦?jié)點(diǎn)設(shè)置為故障節(jié)點(diǎn)；

隔離模塊，用于對(duì)故障節(jié)點(diǎn)進(jìn)行本地隔離。

在一實(shí)施例中，隔離模塊包括：

鏈接狀態(tài)更改模塊，用于將故障節(jié)點(diǎn)對(duì)應(yīng)的鏈接設(shè)置為可讀不可寫狀態(tài)；