[發明專利]消息處理方法及裝置

有效

• 申請號: 201711436020.3
• 申請日: 2017-12-26
• 公開（公告）號: CN109962963B
• 公開（公告）日: 2020-08-18
• 發明（設計）人: 王琪;屈立學;駱艷中;劉宇宏
• 申請（專利權）人: 中國移動通信集團公司;中國移動通信集團內蒙古有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L12/58
• 代理公司: 北京路浩知識產權代理有限公司 11002
• 代理人: 王瑩;李相雨

本發明實施例提供一種消息處理方法及裝置，該方法包括：獲取待處理消息的業務類型；根據所述業務類型和預生成的資源配額鏈表矩陣確定能夠處理所述待處理消息的唯一主機IP以及端口ID；將所述待處理消息發送給對應所述主機IP的主機，使所述主機上對應端口ID的應用程序對所述待處理消息進行處理；對所述資源配額鏈表矩陣進行更新，在實現負載均衡的基礎上增加了系統動態擴容能力，大大提高了高并發消息處理的及時性，降低了由于系統性能導致消息處理失敗的情況。

技術領域

本發明實施例涉及移動通信技術領域，尤其涉及一種消息處理方法及裝置。

背景技術

在IT技術不斷發展的今天，應用的分布式部署越來越多的被應用到不同的領域，而分布式系統處理高并發業務的能力是系統最重要的技術指標之一。為了提高分布式系統處理高并發消息，各個設備廠商提供了不同的負載均衡策略，目前大多數廠家采用輪詢或者最小連接數策略實現系統的負載均衡。

輪詢法是將請求按順序輪流地分配到后端服務器上，它均衡地對待后端的每一臺服務器，而不關心服務器實際的連接數和當前的系統負載；最小連接數法比較靈活和智能，由于后端服務器的配置不盡相同，對于請求的處理有快有慢，它是根據后端服務器當前的連接情況，動態地選取其中當前積壓連接數最少的一臺服務器來處理當前的請求，盡可能地提高后端服務的利用效率，將負責合理地分流到每一臺服務器。但不論是輪詢法或者最小連接數法都無法保障多業務場景下分布式系統消息合理分配，在實際應用中，仍會出現某臺服務器或某一個進程超負荷運行的情況。

發明內容

本發明提供一種消息處理方法及裝置，用于解決現有技術中無法保障多業務場景下分布式系統消息合理分配的問題。

第一方面，本發明實施例提供一種消息處理方法，包括：

獲取待處理消息的業務類型；

根據所述業務類型和預生成的資源配額鏈表矩陣確定能夠處理所述待處理消息的唯一主機IP以及端口ID；

將所述待處理消息發送給對應所述主機IP的主機，使所述主機上對應端口ID的應用程序對所述待處理消息進行處理；

對所述資源配額鏈表矩陣進行更新。

第二方面，本發明實施例提供一種消息處理裝置，包括：

消息管理模塊，用于獲取待處理消息的業務類型；

配額管理模塊，用于根據所述業務類型和預生成的資源配額鏈表矩陣確定能夠處理所述待處理消息的唯一主機IP以及端口ID；

執行模塊，用于將所述待處理消息發送給對應所述主機IP的主機，使所述主機上對應端口ID的應用程序對所述待處理消息進行處理；

更新模塊，用于對所述資源配額鏈表矩陣進行更新。

第三方面，本發明實施例提供一種電子設備，包括：處理器、存儲器、總線及存儲在存儲器上并可在處理器上運行的計算機程序；

其中，所述處理器，存儲器通過所述總線完成相互間的通信；

所述處理器執行所述計算機程序時實現如上述的方法。

第四方面，本發明實施例提供一種非暫態計算機可讀存儲介質，所述非暫態計算機可讀存儲介質上存儲有計算機程序，該計算機程序被處理器執行時實現如上述的方法。