[發明專利]一種流量均衡方法、電子設備及計算機程序產品

有效

• 申請號: 202211438430.2
• 申請日: 2022-11-17
• 公開（公告）號: CN115495250B
• 公開（公告）日: 2023-03-10
• 發明（設計）人: 周磊
• 申請（專利權）人: 北京集度科技有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50
• 代理公司: 北京銀龍知識產權代理有限公司 11243
• 代理人: 李彥紅

本公開提供了一種流量均衡方法、電子設備及計算機程序產品，涉及分布式技術領域，以解決流量均衡效果較差的問題，具體方案為：方法包括：遍歷多個存儲單元中的主分區，多個存儲單元為N個消息代理服務器的磁盤；對于當前遍歷的目標存儲單元中的目標主分區，獲取第一流量均衡指標，第一流量均衡指標用于表示在目標存儲單元失去目標主分區的流量后的流量壓力情況；在第一流量均衡指標滿足第一預設切換條件，以及目標主分區對應至少一個備分區且至少一個備分區中存在目標備分區的情況下，將目標主分區調整為備分區以及將目標備分區調整為主分區，目標備分區滿足第二預設切換條件，以提高流量均衡的效果。

技術領域

本公開涉及分布式技術領域，尤其涉及一種流量均衡方法、電子設備及計算機程序產品。

背景技術

分布式消息隊列集群中的一臺或多臺接收消息的服務器稱為消息代理服務器，消息代理服務器中的分區可劃分到對應的主題，主題（topic）可理解是數據寫入操作的基本單元，是一個邏輯概念，一個主題可以有多個分區（partition），分區是數據真實寫入和存儲的地方，各個partition可能分布在不同的消息代理服務器上，一個消息代理服務器上可分布一個或多個partition，一個partition可以有一個或多個副本，這些副本有且只有一個主分區，其他都是備分區，可以理解，一個主分區可對應0個或至少一個備分區。主分區是接收消息的真正載體，用戶將消息寫入某個主題時，實際上是寫入到這個主題的主分區（即主分區所在存儲單元（例如，磁盤））中。

目前，分布式消息隊列為實現流量均衡，常采用的機制是主分區均衡機制，即在各消息代理服務器上平均分布主分區，然而，在實際工作中，有的主題有大量數據寫入，有的主題數據寫入較少，通過上述方式均衡，可能將數據寫入較少的主分區均衡到同一個消息代理服務器，導致這些消息代理服務器沒有流量寫入，而其他的消息代理服務器上的主分區集中了大量的流量，這樣，導致流量均衡效果較差。

發明內容

本公開提供一種流量均衡方法、電子設備及計算機程序產品。

第一方面，本公開一個實施例提供一種流量均衡方法，所述方法包括：

遍歷多個存儲單元中的主分區，所述多個存儲單元為N個消息代理服務器的存儲單元，N為正整數；

對于當前遍歷的目標存儲單元中的目標主分區，獲取第一流量均衡指標，所述第一流量均衡指標用于表示在所述目標存儲單元失去所述目標主分區的流量后的流量壓力情況；

在所述第一流量均衡指標滿足第一預設切換條件，以及所述目標主分區對應至少一個備分區且所述至少一個備分區中存在目標備分區的情況下，將所述目標主分區調整為備分區以及將所述目標備分區調整為主分區，所述目標備分區滿足第二預設切換條件。

在本實施例的流量均衡方法中，由于在流量均衡過程中，第一流量均衡指標用于表示在目標存儲單元失去目標主分區的流量后的流量壓力情況，在第一流量均衡指標滿足第一預設切換條件以及存在滿足第二預設切換條件的目標備分區的情況下，將目標主分區與目標備分區互換，可減少將流量較小的主分區集中的情況，也可減少將流量較大的主分區集中的情況，提高流量均衡的效果。

第二方面，本公開一個實施例提供一種流量均衡裝置，所述裝置包括：

遍歷模塊，用于遍歷多個存儲單元中的主分區，所述多個存儲單元為N個消息代理服務器的存儲單元，N為正整數；

第一獲取模塊，用于對于當前遍歷的目標存儲單元中的目標主分區，獲取第一流量均衡指標，所述第一流量均衡指標用于表示在所述目標存儲單元失去所述目標主分區的流量后的流量壓力情況；

調整模塊，用于在所述第一流量均衡指標滿足第一預設切換條件，以及所述目標主分區對應至少一個備分區且所述至少一個備分區中存在目標備分區的情況下，將所述目標主分區調整為備分區以及將所述目標備分區調整為主分區，所述目標備分區滿足第二預設切換條件。