(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211438430.2 (22)申请日 2022.11.17 (71)申请人 北京集度科技有限公司 地址 100176 北京市大兴区北京经济技 术 开发区宏达北路10号1号楼8层844室 (北京自贸试验区高端产业片区亦庄 组团) (72)发明人 周磊　 (74)专利代理 机构 北京银龙知识产权代理有限 公司 11243 专利代理师 李彦红 (51)Int.Cl. G06F 9/50(2006.01) (54)发明名称 一种流量均衡方法、 电子设备及计算机程序 产品 (57)摘要 本公开提供了一种流量均衡方法、 电子设备 及计算机程序产品， 涉及分布式技术领域， 以解 决流量均衡效果较差的问题， 具体方案为： 方法 包括： 遍历多个存储单元中的主分区， 多个存储 单元为N个消息代理服务器的磁盘； 对于当前遍 历的目标存储 单元中的目标主分区， 获取第一流 量均衡指标， 第一流量均衡指标用于表示在目标 存储单元失去目标主分区的流量后的流量压力 情况； 在第一流量均衡指标满足第一预设切换条 件， 以及目标主分区对应至少一个备分区且至少 一个备分区中存在目标备分区的情况下， 将目标 主分区调整为备分区以及将目标备分区调整为 主分区， 目标备分区满足第二预设切换条件， 以 提高流量均衡的效果。 权利要求书2页 说明书11页 附图3页 CN 115495250 A 2022.12.20 CN 115495250 A 1.一种流 量均衡方法， 其特 征在于， 所述方法包括： 遍历多个存储单元中的主分区， 所述多个存储单元为N个消息代 理服务器的存储单元， N为正整数； 对于当前遍历的目标存储单元中的目标主分区， 获取第一流量均衡指标， 所述第一流 量均衡指标用于表示在所述目标存 储单元失去所述目标主分区的流 量后的流 量压力情况； 在所述第一流量均衡指标满足第 一预设切换条件， 以及所述目标主分区对应至少一个 备分区且所述至少一个备分区中存在目标备分区的情况下， 将所述目标主分区调整为备分 区以及将所述目标 备分区调整为主分区， 所述目标 备分区满足第二预设切换 条件。 2.根据权利要求1所述的流量均衡方法， 其特征在于， 所述获取第一流量均衡指标， 包 括： 根据所述目标存储单元的总流量、 所述目标主分区的流量以及所述目标存储单元的数 据量， 获取 所述第一 流量均衡指标。 3.根据权利要求2所述的流量均衡方法， 其特征在于， 所述第 一流量均衡指标为所述目 标存储单元 的总流量和所述目标主分区的流量的差与所述目标存储单元的数据量之间的 比值。 4.根据权利要求2所述的流量均衡方法， 其特征在于， 所述第 一流量均衡指标满足所述 第一预设切换 条件包括： 所述第一 流量均衡指标 大于集群流 量均衡指标； 其中， 所述集群流量均衡指标为所述N个消息代理服务器的主分区的总流量与所述多 个存储单元的数据总量之间的比值。 5.根据权利要求1所述的流量均衡方法， 其特征在于， 所述目标备分区满足第 二预设切 换条件包括： 所述目标备分区所在存储单元的总流量与 所述目标主分区的流量之和， 与 所述目标备 分区所在存储单元的数据量之 间的比值小于或等于集群流量均衡指标， 所述集群流量均衡 指标为所述N个消息代理服务器的主分区的总流量与所述多个存储单元的数据总量之 间的 比值。 6.根据权利要求1 ‑5中任一项所述的流量均衡方法， 其特征在于， 所述遍历多个存储单 元中的主分区之前， 还 包括： 获取所述多个存储单元中每个存储单元的存储单元流量均衡指标以及多个主分区中 每个主分区的主分区流 量均衡指标， 所述多个主分区为所述 N个消息代理服 务器的主分区； 对所述多个存储单元的存储单元流量均衡指标进行排序， 以及对所述多个主分区的主 分区流量均衡指标进行排序； 其中， 所述遍历多个存储单元的主分区， 包括： 基于所述多个存储单元的存储单元流量 均衡指标从大到小的顺序， 以及同一存储单元中的主分区的主分区流量均衡指标从大到小 的顺序， 遍历所述多个存 储单元的主分区。 7.根据权利要求6所述的流量均衡方法， 其特征在于， 第 一存储单元的存储单元流量均 衡指标为所述第一存储单元中的主分区的总流量与所述第一存储单元的数据量之间的比 值， 所述第一存 储单元为所述多个存 储单元中的任一存 储单元； 第一主分区的主分区流量均衡指标为第一主题的平均主分区流量与所述第一主分区权　利　要　求　书 1/2 页 2 CN 115495250 A 2的数据量的比值， 所述第一主分区属于所述第一主题， 所述第一主题的平均主分区流量为 所述第一主题的总流量与所述第一主题的主分区数量的比值， 所述第一主题的总流量为所 述第一主题的主分区在 对应消息代理服务器上的流量总和， 所述第一主分区为所述多个主 分区中的任一主分区。 8.根据权利要求1 ‑5中任一项所述的流量均衡方法， 其特征在于， 所述N个消息代理服 务器为分布式消息队列集群中的消息代理服务器， 所述分布式消息队列为Kafka， 所述消息 代理服务器为bro ker， 所述主分区为领导分区， 所述备分区为跟随分区。 9.一种电子设备， 其特 征在于， 包括： 至少一个处 理器； 以及 与所述至少一个处 理器通信连接的存 储器； 其中， 所述存储器存储有可被所述至少一个处理器执行的指令， 所述指令被所述至少一个处 理器执行， 以使所述至少一个处 理器能够执 行权利要求1 ‑8任一所述的流 量均衡方法。 10.一种计算机程序产品， 其特征在于， 包括计算机程序， 所述计算机程序在被处理器 执行时实现根据权利要求1 ‑8中任一所述的流 量均衡方法。权　利　要　求　书 2/2 页 3 CN 115495250 A 3