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

有效

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

1.一種流量均衡方法，其特征在于，所述方法包括：

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

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

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

所述遍歷多個存儲單元中的主分區之前，還包括：

獲取所述多個存儲單元中每個存儲單元的存儲單元流量均衡指標以及多個主分區中每個主分區的主分區流量均衡指標，所述多個主分區為所述N個消息代理服務器的主分區；

對所述多個存儲單元的存儲單元流量均衡指標進行排序，以及對所述多個主分區的主分區流量均衡指標進行排序；

其中，所述遍歷多個存儲單元的主分區，包括：基于所述多個存儲單元的存儲單元流量均衡指標從大到小的順序，以及同一存儲單元中的主分區的主分區流量均衡指標從大到小的順序，遍歷所述多個存儲單元的主分區；

第一存儲單元的存儲單元流量均衡指標為所述第一存儲單元中的主分區的總流量與所述第一存儲單元的數據量之間的比值，所述第一存儲單元為所述多個存儲單元中的任一存儲單元；

第一主分區的主分區流量均衡指標為第一主題的平均主分區流量與所述第一主分區的數據量的比值，所述第一主分區屬于所述第一主題，所述第一主題的平均主分區流量為所述第一主題的總流量與所述第一主題的主分區數量的比值，所述第一主題的總流量為所述第一主題的主分區在對應消息代理服務器上的流量總和，所述第一主分區為所述多個主分區中的任一主分區。

2.根據權利要求1所述的流量均衡方法，其特征在于，所述獲取第一流量均衡指標，包括：

根據所述目標存儲單元的總流量、所述目標主分區的流量以及所述目標存儲單元的數據量，獲取所述第一流量均衡指標。

3.根據權利要求2所述的流量均衡方法，其特征在于，所述第一流量均衡指標為所述目標存儲單元的總流量和所述目標主分區的流量的差與所述目標存儲單元的數據量之間的比值。

4.根據權利要求2所述的流量均衡方法，其特征在于，所述第一流量均衡指標滿足所述第一預設切換條件包括：

所述第一流量均衡指標大于集群流量均衡指標；

其中，所述集群流量均衡指標為所述N個消息代理服務器的主分區的總流量與所述多個存儲單元的數據總量之間的比值。

5.根據權利要求1所述的流量均衡方法，其特征在于，所述目標備分區滿足第二預設切換條件包括：

所述目標備分區所在存儲單元的總流量與所述目標主分區的流量之和，與所述目標備分區所在存儲單元的數據量之間的比值小于或等于集群流量均衡指標，所述集群流量均衡指標為所述N個消息代理服務器的主分區的總流量與所述多個存儲單元的數據總量之間的比值。

6.根據權利要求1-5中任一項所述的流量均衡方法，其特征在于，所述N個消息代理服務器為分布式消息隊列集群中的消息代理服務器，所述分布式消息隊列為Kafka，所述消息代理服務器為broker，所述主分區為領導分區，所述備分區為跟隨分區。

7.一種電子設備，其特征在于，包括：

至少一個處理器；以及

與所述至少一個處理器通信連接的存儲器；其中，

所述存儲器存儲有可被所述至少一個處理器執行的指令，所述指令被所述至少一個處理器執行，以使所述至少一個處理器能夠執行權利要求1-6任一所述的流量均衡方法。

8.一種計算機可讀存儲介質，其特征在于，所述計算機可讀存儲介質上存儲有計算機程序，所述計算機程序在被處理器執行時實現根據權利要求1-6中任一所述的流量均衡方法。