[發明專利]一種實現數據負載均衡的方法、系統及電子設備

有效

• 申請號: 202010117062.6
• 申請日: 2020-02-25
• 公開（公告）號: CN111338821B
• 公開（公告）日: 2023-04-07
• 發明（設計）人: 嚴麗君
• 申請（專利權）人: 北京思特奇信息技術股份有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F16/27;G06F9/50
• 代理公司: 北京輕創知識產權代理有限公司 11212
• 代理人: 徐琪琦

本發明涉及一種實現數據負載均衡的方法、系統及電子設備，通過提取各消息中相應的關鍵信息和內容，然后將各關鍵信息插入分布式消息隊列中，將各關鍵信息與各相應的內容插入至分布式內存數據庫(DMDB)，實現了各處理進程間的數據負載均衡，最后通過讀取分布式消息隊列中各關鍵信息，相應地從分布式內存數據庫中讀取各相應的內容進行處理，即通過結合分布式消息隊列(KAFKA)和分布式內存數據庫(DMDB)，保證各進程之間數據負載均衡，進而保證處理單元具有高性能的處理能力。

技術領域

本發明涉及通信領域，尤其涉及一種實現數據負載均衡的方法、系統及電子設備。

背景技術

隨著電信支撐系統的云化，電信支撐系統的處理能力趨于集群化，其中，每個處理單元由具備相同能力的處理進程完成，通過大并發達到高速數據處理的目的，目前，各個處理進程之間通過分布式消息隊列(KAFKA)中的生產者-消費者的隊列協同來進行數據負載，在數據安全級別較低時，分布式消息隊列(KAFKA)的數據負載的性能較好，但是在安全級別較高或進行高速數據處理時，分布式消息隊列容易出現隊列不協同以使數據負載不均衡，從而導致處理單元的處理能力發生異常。

因此如何實現各個處理進程之間數據負載均衡是亟待解決的技術問題。

發明內容

本發明所要解決的技術問題是針對現有技術的不足，提供了一種實現數據負載均衡的方法、系統及電子設備。

本發明的一種實現數據負載均衡的方法的技術方案如下：

S1、接收多個消息，并提取每個消息中的關鍵信息和內容；

S2、將各所述關鍵信息按照時間順序插入分布式消息隊列中，并將各所述關鍵信息和與每個關鍵信息相應的內容插入至分布式內存數據庫；

S3、讀取所述分布式消息隊列中多個第一關鍵信息，根據各所述第一關鍵信息從所述分布式內存數據庫中讀取到相一致的各第二關鍵信息，然后讀取所述相一致的第二關鍵信息的相應的內容。

本發明的一種實現數據負載均衡的方法的有益效果如下：

通過提取各消息中相應的關鍵信息和內容，然后將各關鍵信息插入分布式消息隊列中，將各關鍵信息與各相應的內容插入至分布式內存數據庫(DMDB)，實現了各處理進程間的數據負載均衡，最后通過讀取分布式消息隊列中各關鍵信息，相應地從分布式內存數據庫中讀取各相應的內容進行處理，即通過結合分布式消息隊列(KAFKA)和分布式內存數據庫(DMDB)，保證各進程之間數據負載均衡，進而保證處理單元具有高性能的處理能力。

在上述方案的基礎上，本發明的一種實現數據負載均衡的方法還可以做如下改進。

進一步，還包括如下步驟：

S10、每間隔預設時間段在所述分布式內存數據庫設置第一表和第二表，按照時間順序將所述提取的各所述關鍵信息與各相應的內容插入至所第一表內；

S11、根據各所述第一關鍵信息從所述第一表中讀取到相一致的各第二關鍵信息，然后讀取各相應的內容，并將所述相一致的第二關鍵信息插入所述第二表內；

S12、每間隔所述預設時間段判斷所述第一表與所述第二表中的關鍵信息是否相同；若否，則對所述第一表中存在且尚未在所述第二表中讀取到的關鍵信息重新進行處理；若是，刪除所述第一表和所述第二表。

采用上述進一步方案的有益效果是：通過校驗第一表和第二表是否一致，能準確地判斷出在高速數據處理時即對消息進行高速處理時是否發生異常，并作出相應的處理。

進一步，采用trunck方式刪除所述第一表和所述第二表。

采用上述進一步方案的有益效果是：分布式內存數據庫(DMDB)的刪除(DELETE)性能較低，通過trunck方式來刪除第一表和第二表，進一步提高了處理單元的處理能力。