[發(fā)明專利]消息處理方法、裝置、系統(tǒng)、電子設(shè)備及可讀存儲介質(zhì)

有效

• 申請?zhí)枺?/td>: 202010460497.0
• 申請日: 2020-05-27
• 公開（公告）號: CN111629054B
• 公開（公告）日: 2022-06-03
• 發(fā)明（設(shè)計）人: 潘禮;文峰
• 申請（專利權(quán)）人: 北京金山云網(wǎng)絡(luò)技術(shù)有限公司
• 主分類號: H04L67/562
• 分類號: H04L67/562;H04L67/10;H04L67/51;H04L47/24;H04L47/125
• 代理公司: 北京柏杉松知識產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11413
• 代理人: 項京;馬敬

本申請實施例提供了一種消息處理方法、裝置、系統(tǒng)、電子設(shè)備及可讀存儲介質(zhì)，涉及云計算技術(shù)領(lǐng)域。該方法包括：控制節(jié)點從多個計算節(jié)點中確定用于接收待發(fā)送消息的目標(biāo)計算節(jié)點；基于目標(biāo)計算節(jié)點，從多個消息隊列服務(wù)中確定用于轉(zhuǎn)發(fā)待發(fā)送消息的目標(biāo)消息隊列服務(wù)；向目標(biāo)消息隊列服務(wù)發(fā)送待發(fā)送消息；中間件節(jié)點通過目標(biāo)消息隊列服務(wù)接收待發(fā)送消息，并向目標(biāo)計算節(jié)點轉(zhuǎn)發(fā)待發(fā)送消息；目標(biāo)計算節(jié)點執(zhí)行待發(fā)送消息對應(yīng)的操作?；谏鲜鎏幚?，能夠降低網(wǎng)絡(luò)業(yè)務(wù)中斷的概率。

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

本申請涉及通信技術(shù)領(lǐng)域，特別是涉及一種消息處理方法、裝置、系統(tǒng)、電子設(shè)備及可讀存儲介質(zhì)。

背景技術(shù)

隨著云計算和虛擬化技術(shù)的快速發(fā)展，在一些云計算的實施場景中，可以基于集群管理系統(tǒng)對大規(guī)模的物理機(jī)和虛擬機(jī)資源進(jìn)行管理，集群管理系統(tǒng)可以為OpenStack系統(tǒng)或其他系統(tǒng)。

相關(guān)技術(shù)中，集群管理系統(tǒng)可以包括控制節(jié)點(Controller Node)和計算節(jié)點(Compute Node)?？刂乒?jié)點可以接收對計算節(jié)點進(jìn)行操作的消息，并向計算節(jié)點轉(zhuǎn)發(fā)該消息，計算節(jié)點則可以根據(jù)該消息進(jìn)行相應(yīng)的操作，例如，分配虛擬機(jī)資源、啟動虛擬機(jī)、關(guān)閉虛擬機(jī)等。

另外，為了方便控制節(jié)點對計算節(jié)點進(jìn)行管理，集群管理系統(tǒng)還可以包括中間件節(jié)點(Middleware Node)。控制節(jié)點可以向中間件節(jié)點發(fā)送消息，進(jìn)而，中間件節(jié)點可以將消息轉(zhuǎn)發(fā)至對應(yīng)的計算節(jié)點；并且相關(guān)技術(shù)中的網(wǎng)絡(luò)架構(gòu)，都是通過中間件節(jié)點中部署的一個全局的MQ(Message Queue，消息隊列)服務(wù)對消息進(jìn)行轉(zhuǎn)發(fā)，由于該全局的MQ服務(wù)自身業(yè)務(wù)能力處理的限制，當(dāng)網(wǎng)絡(luò)中的計算節(jié)點較多時，勢必會增加MQ服務(wù)的壓力，因而可能會導(dǎo)致消息轉(zhuǎn)發(fā)失敗，造成網(wǎng)絡(luò)業(yè)務(wù)中斷。

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

本申請實施例的目的在于提供一種消息處理方法、裝置、系統(tǒng)、電子設(shè)備及可讀存儲介質(zhì)，能夠降低網(wǎng)絡(luò)業(yè)務(wù)中斷的概率。具體技術(shù)方案如下：

第一方面，為了達(dá)到上述目的，本申請實施例公開了一種消息處理方法，所述方法應(yīng)用于消息處理系統(tǒng)中的控制節(jié)點，所述消息處理系統(tǒng)還包括中間件節(jié)點和多個計算節(jié)點，所述中間件節(jié)點中部署有多個消息隊列服務(wù)，所述方法包括：

從所述多個計算節(jié)點中確定用于接收待發(fā)送消息的計算節(jié)點，作為目標(biāo)計算節(jié)點；

基于所述目標(biāo)計算節(jié)點，從所述多個消息隊列服務(wù)中確定用于轉(zhuǎn)發(fā)所述待發(fā)送消息的目標(biāo)消息隊列服務(wù)；

向所述目標(biāo)消息隊列服務(wù)發(fā)送所述待發(fā)送消息，以使所述中間件節(jié)點通過所述目標(biāo)消息隊列服務(wù)，向所述目標(biāo)計算節(jié)點轉(zhuǎn)發(fā)所述待發(fā)送消息。

可選的，所述基于所述目標(biāo)計算節(jié)點，從所述多個消息隊列服務(wù)中確定用于轉(zhuǎn)發(fā)所述待發(fā)送消息的目標(biāo)消息隊列服務(wù)，包括：

從預(yù)設(shè)的計算節(jié)點與所述多個消息隊列服務(wù)的對應(yīng)關(guān)系中，確定所述目標(biāo)計算節(jié)點對應(yīng)的消息隊列服務(wù)，作為用于轉(zhuǎn)發(fā)所述待發(fā)送消息的目標(biāo)消息隊列服務(wù)。

可選的，所述方法還包括：

向所述中間件節(jié)點發(fā)送，用于確定所述消息處理系統(tǒng)中發(fā)生更新的計算節(jié)點的第一請求消息；

當(dāng)接收到所述中間件節(jié)點發(fā)送的，所述消息處理系統(tǒng)中發(fā)生更新的計算節(jié)點的標(biāo)識和對應(yīng)的消息隊列服務(wù)的標(biāo)識時，更新所述對應(yīng)關(guān)系。

可選的，所述基于所述目標(biāo)計算節(jié)點，從所述多個消息隊列服務(wù)中確定用于轉(zhuǎn)發(fā)所述待發(fā)送消息的目標(biāo)消息隊列服務(wù)，包括：

向所述中間件節(jié)點發(fā)送包含所述目標(biāo)計算節(jié)點的標(biāo)識的服務(wù)確定消息；

當(dāng)接收到所述中間件節(jié)點發(fā)送的消息隊列服務(wù)的標(biāo)識時，將所述消息隊列服務(wù)的標(biāo)識所屬的消息隊列服務(wù)，確定為用于轉(zhuǎn)發(fā)所述待發(fā)送消息的目標(biāo)消息隊列服務(wù)；其中，所述消息隊列服務(wù)的標(biāo)識為所述中間件節(jié)點根據(jù)所述目標(biāo)計算節(jié)點的標(biāo)識，從預(yù)設(shè)的計算節(jié)點與所述多個消息隊列服務(wù)的對應(yīng)關(guān)系中確定的。