[發(fā)明專利]一種消息處理方法、裝置、存儲介質(zhì)及電子設(shè)備

有效

• 申請?zhí)枺?/td>: 201911038305.0
• 申請日: 2019-10-29
• 公開（公告）號: CN110808922B
• 公開（公告）日: 2023-06-06
• 發(fā)明（設(shè)計）人: 石鵬
• 申請（專利權(quán)）人: 北京大米科技有限公司
• 主分類號: H04L47/50
• 分類號: H04L47/50;H04L47/62;H04L47/80;H04L47/125
• 代理公司: 北京恒博知識產(chǎn)權(quán)代理有限公司 11528
• 代理人: 李寧寧

本申請實施例公開了一種消息處理方法、裝置、存儲介質(zhì)及電子設(shè)備，其中，方法包括：監(jiān)測第一消息隊列中在預(yù)設(shè)時長內(nèi)至少一個業(yè)務(wù)方所對應(yīng)的業(yè)務(wù)消息，計算所述至少一個業(yè)務(wù)方所對應(yīng)的業(yè)務(wù)消息的數(shù)量，當(dāng)所述數(shù)量中存在大于設(shè)定閾值的第一數(shù)量時，確定所述第一數(shù)量指示的目標(biāo)業(yè)務(wù)方對應(yīng)的待轉(zhuǎn)移業(yè)務(wù)消息，將所述待轉(zhuǎn)移業(yè)務(wù)消息從所述第一消息隊列轉(zhuǎn)移至第二消息隊列。采用本申請實施例，可以避免業(yè)務(wù)消息丟失，確保業(yè)務(wù)方所請求的業(yè)務(wù)消息得到處理。

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

本申請涉及計算機技術(shù)領(lǐng)域，尤其涉及一種消息處理方法、裝置、存儲介質(zhì)及電子設(shè)備。

背景技術(shù)

目前，消息處理裝置運用越來越廣泛，例如用于消息處理的服務(wù)器等，消息處理裝置是指支持與保障分布式應(yīng)用程序之間收發(fā)業(yè)務(wù)消息(數(shù)據(jù))的中間層，業(yè)務(wù)方可在消息處理裝置發(fā)布所請求的相關(guān)消息主題(topic)的業(yè)務(wù)消息，消息處理裝置通常會將各業(yè)務(wù)方所請求的同一消息主題(topic)的業(yè)務(wù)消息寫入一個消息隊列，在該消息隊列中的業(yè)務(wù)消息進行業(yè)務(wù)處理。

在消息處理裝置將各業(yè)務(wù)方所請求的同一消息主題(topic)的業(yè)務(wù)消息寫入到消息隊列的過程中，當(dāng)某一業(yè)務(wù)方在單位時間內(nèi)所請求的業(yè)務(wù)消息量超過該業(yè)務(wù)方所能消費速度時，就會造成業(yè)務(wù)消息積壓而影響其他請求量正常的業(yè)務(wù)方。

為了避免業(yè)務(wù)消息積壓，目前，通常采用對該業(yè)務(wù)方發(fā)送的同一消息主題的新業(yè)務(wù)消息進行限流或丟棄處理的方式，然而這種方式會造成業(yè)務(wù)消息的丟失，當(dāng)所丟失的業(yè)務(wù)消息較重要時，會導(dǎo)致業(yè)務(wù)方不能及時發(fā)現(xiàn)問題而導(dǎo)致嚴(yán)重后果。

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

本申請實施例提供了一種消息處理方法、裝置、存儲介質(zhì)及電子設(shè)備，可以避免業(yè)務(wù)消息丟失，確保業(yè)務(wù)方所請求的業(yè)務(wù)消息得到處理。所述技術(shù)方案如下：

第一方面，本申請實施例提供了一種消息處理方法，所述方法包括：

監(jiān)測第一消息隊列中在預(yù)設(shè)時長內(nèi)至少一個業(yè)務(wù)方所對應(yīng)的業(yè)務(wù)消息，計算所述至少一個業(yè)務(wù)方所對應(yīng)的業(yè)務(wù)消息的數(shù)量；

當(dāng)所述數(shù)量中存在大于設(shè)定閾值的第一數(shù)量時，確定所述第一數(shù)量指示的目標(biāo)業(yè)務(wù)方對應(yīng)的待轉(zhuǎn)移業(yè)務(wù)消息；

將所述待轉(zhuǎn)移業(yè)務(wù)消息從所述第一消息隊列轉(zhuǎn)移至第二消息隊列。

第二方面，本申請實施例提供了一種消息處理裝置，所述裝置包括：

消息數(shù)量獲取模塊，用于監(jiān)測第一消息隊列中在預(yù)設(shè)時長內(nèi)至少一個業(yè)務(wù)方所對應(yīng)的業(yè)務(wù)消息，計算所述至少一個業(yè)務(wù)方所對應(yīng)的業(yè)務(wù)消息的數(shù)量；

轉(zhuǎn)移消息確定模塊，用于當(dāng)所述數(shù)量中存在大于設(shè)定閾值的第一數(shù)量時，確定所述第一數(shù)量指示的目標(biāo)業(yè)務(wù)方對應(yīng)的待轉(zhuǎn)移業(yè)務(wù)消息；

業(yè)務(wù)消息轉(zhuǎn)移模塊，用于將所述待轉(zhuǎn)移業(yè)務(wù)消息從所述第一消息隊列轉(zhuǎn)移至第二消息隊列。

第三方面，本申請實施例提供一種計算機存儲介質(zhì)，所述計算機存儲介質(zhì)存儲有多條指令，所述指令適于由處理器加載并執(zhí)行上述的方法步驟。

第四方面，本申請實施例提供一種電子設(shè)備，可包括：處理器和存儲器；其中，所述存儲器存儲有計算機程序，所述計算機程序適于由所述處理器加載并執(zhí)行上述的方法步驟。

本申請一些實施例提供的技術(shù)方案帶來的有益效果至少包括：

在本申請一個或多個實施例中，消息服務(wù)器監(jiān)測第一消息隊列中在預(yù)設(shè)時長內(nèi)至少一個業(yè)務(wù)方所對應(yīng)的業(yè)務(wù)消息，計算所述至少一個業(yè)務(wù)方所對應(yīng)的業(yè)務(wù)消息的數(shù)量，當(dāng)所述數(shù)量中存在大于設(shè)定閾值的第一數(shù)量時，確定所述第一數(shù)量指示的目標(biāo)業(yè)務(wù)方對應(yīng)的待轉(zhuǎn)移業(yè)務(wù)消息，將所述待轉(zhuǎn)移業(yè)務(wù)消息從所述第一消息隊列轉(zhuǎn)移至第二消息隊列。通過在第一消息隊列中確定大于設(shè)定閾值的目標(biāo)業(yè)務(wù)方的待轉(zhuǎn)移業(yè)務(wù)消息，將待轉(zhuǎn)移業(yè)務(wù)消息轉(zhuǎn)移至第二消息隊列，可以在不影響其他請求量正常的業(yè)務(wù)方的前提下，避免業(yè)務(wù)方所請求的業(yè)務(wù)消息被丟失，確保業(yè)務(wù)方所請求的業(yè)務(wù)消息得到處理。