[發明專利]一種消息處理方法、裝置、存儲介質及電子設備

有效

• 申請號: 201911038305.0
• 申請日: 2019-10-29
• 公開（公告）號: CN110808922B
• 公開（公告）日: 2023-06-06
• 發明（設計）人: 石鵬
• 申請（專利權）人: 北京大米科技有限公司
• 主分類號: H04L47/50
• 分類號: H04L47/50;H04L47/62;H04L47/80;H04L47/125
• 代理公司: 北京恒博知識產權代理有限公司 11528
• 代理人: 李寧寧

1.一種消息處理方法，其特征在于，所述方法包括：

監測第一消息隊列中在預設時長內至少一個業務方所對應的業務消息，計算所述至少一個業務方所對應的業務消息的數量；所述至少一個業務方中業務方的數量大于1；

當所述數量中存在大于設定閾值的第一數量時，確定所述第一數量指示的目標業務方對應的待轉移業務消息；所述待轉移業務消息的數量為所述目標業務方的業務消息總數量與轉移系數、業務方優先級系數的乘積；

將所述待轉移業務消息從所述第一消息隊列轉移至第二消息隊列。

2.根據權利要求1所述的方法，其特征在于，所述方法還包括：

當接收到所述目標業務方發送的新業務消息時，將所述新業務消息寫入第二消息隊列中。

3.根據權利要求1所述的方法，其特征在于，所述方法還包括：

對所述第一消息隊列中的業務消息以及所述第二消息隊列中的業務消息分別進行業務處理。

4.根據權利要求3所述的方法，其特征在于，所述對所述第一消息隊列中的業務消息以及所述第二消息隊列中的業務消息分別進行業務處理，包括：

獲取所述第一消息隊列對應的業務處理速率；

基于所述第一數量以及所述業務處理速率，確定所述第一消息隊列的第一權重以及所述第二消息隊列的第二權重，所述第一權重大于所述第二權重；

根據所述第一權重和所述第二權重，將第一計算資源分配至所述第一消息隊列、將第二計算資源分配至所述第二消息隊列，以及由所述第一計算資源對所述第一消息隊列中的業務消息進行處理、由所述第二計算資源對所述第二消息隊列中的業務消息進行處理。

5.根據權利要求3所述的方法，其特征在于，所述對所述第一消息隊列中的業務消息以及所述第二消息隊列中的業務消息分別進行業務處理，包括：

獲取所述第一消息隊列對應的第一優先級以及所述第二消息隊列對應的第二優先級；

計算所述第一優先級指示的第一權重以及所述第二優先級指示的第二權重；

根據所述第一權重和所述第二權重，將第一計算資源分配至所述第一消息隊列、將第二計算資源分配至所述第二消息隊列，以及由所述第一計算資源對所述第一消息隊列中的業務消息進行處理、由所述第二計算資源對所述第二消息隊列中的業務消息進行處理。

6.一種消息處理裝置，其特征在于，所述裝置包括：

消息數量獲取模塊，用于監測第一消息隊列中在預設時長內至少一個業務方所對應的業務消息，計算所述至少一個業務方所對應的業務消息的數量；所述至少一個業務方中業務方的數量大于1；

轉移消息確定模塊，用于當所述數量中存在大于設定閾值的第一數量時，確定所述第一數量指示的目標業務方對應的待轉移業務消息；所述待轉移業務消息的數量為所述目標業務方的業務消息總數量與轉移系數、業務方優先級系數的乘積；

業務消息轉移模塊，用于將所述待轉移業務消息從所述第一消息隊列轉移至第二消息隊列。

7.一種計算機存儲介質，其特征在于，所述計算機存儲介質存儲有多條指令，所述指令適于由處理器加載并執行如權利要求1~5任意一項的方法步驟。

8.一種電子設備，其特征在于，包括：處理器和存儲器；其中，所述存儲器存儲有計算機程序，所述計算機程序適于由所述處理器加載并執行如權利要求1~5任意一項的方法步驟。