一种用于消息队列的自动扩容方法及装置.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN113609071A(43)申请公布日2021.11.05(21)申请号202110859802.8(22)申请日2021.07.28(71)申请人北京金山云网络技术有限公司地址100085北京市海淀区西二旗中路33号院4号楼6层006号(72)发明人刘彬(74)专利代理机构北京华夏泰和知识产权代理有限公司11662代理人曾军韩来兵(51)Int.Cl.G06F16/11(2019.01)G06F16/13(2019.01)G06F16/17(2019.01)G06F16/182(2019.01)G06F9/54(2006.01)权利要求书2页说明书10页附图3页(54)发明名称一种用于消息队列的自动扩容方法及装置(57)摘要本申请涉及一种用于消息队列的自动扩容方法及装置。其中，方法包括：获取目标消息队列中每个候选分区的负载；根据每个所述候选分区的负载以及目标负载阀值，判断所述候选分区中是否存在高负载分区，其中，所述高负载分区的负载高于所述目标负载阀值；在确定存在至少一个所述高负载分区的情况下，生成用于对所述目标消息队列进行分区扩容的目标指令；按照所述目标指令，在所述目标消息队列中增加至少一个新增分区。通过本实施例中的方法，可以在目标消息队列中存在高负载分区的情况下，自动触发对该目标消息队列增加至少一个新增分区，进而可以提高目标消息队列的负载能力，并且便于后期通过新增分区分担高负载分区的负载目的。CN113609071ACN113609071A权利要求书1/2页1.一种用于消息队列的自动扩容方法，其特征在于，包括：获取目标消息队列中每个候选分区的负载；根据每个所述候选分区的负载以及目标负载阀值，判断所述候选分区中是否存在高负载分区，其中，所述高负载分区的负载高于所述目标负载阀值；在确定存在至少一个所述高负载分区的情况下，生成用于对所述目标消息队列进行分区扩容的目标指令；按照所述目标指令，在所述目标消息队列中增加至少一个新增分区。2.根据权利要求1所述的方法，其特征在于，所述根据每个所述候选分区的负载以及目标负载阀值，判断所述候选分区中是否存在高负载分区包括：在所述候选分区的负载指示所述候选分区的数据负载大于或等于目标数据负载阀值，或所述候选分区的计算资源负载大于或等于目标计算资源负载阀值的情况下，将所述候选分区确定为所述高负载分区。3.根据权利要求1所述的方法，其特征在于，在所述在确定存在至少一个所述高负载分区的情况下，生成用于对所述目标消息队列进行分区扩容的目标指令之前，所述方法还包括：在除所述高负载分区之外的所有所述候选分区中，确定出目标低负载分区；确定所述目标低负载分区的目标分区标识。4.根据权利要求3所述的方法，其特征在于，所述按照所述目标指令，在所述目标消息队列中增加至少一个新增分区包括：按照所述目标分区标识，将所述目标指令发送至所述目标低负载分区；在所述目标低负载分区执行所述目标指令之后，在所述目标低负载分区所在的目标节点中增加至少一个所述新增分区。5.根据权利要求3所述的方法，其特征在于，所述在除所述高负载分区之外的所有所述候选分区中，确定出目标低负载分区包括：将除所述高负载分区之外的所有所述候选分区确定为低负载分区；确定每个所述低负载分区的负载；在所有所述低负载分区中，确定出所述负载最低的所述目标低负载分区。6.根据权利要求1所述的方法，其特征在于，所述获取目标消息队列中每个候选分区的负载包括：获取目标集群中每个候选消息队列的负载信息，其中，每个所述负载信息包括对应的所述候选消息队列中每个分区的负载；根据所述负载信息在所有所述候选消息队列中确定出所述目标消息队列，并确定所述目标消息队列每个所述候选分区的负载，其中，所述目标消息队列中存在至少一个所述候选分区的负载高于目标负载阀值。7.根据权利要求1所述的方法，其特征在于，在所述按照所述目标指令，在所述目标消息队列中增加至少一个新增分区之后，所述方法还包括：获取所述新增分区的分区信息；根据所述分区信息对所述目标消息队列的历史元数据信息进行更新，得到更新后元数据信息；2CN113609071A权利要求书2/2页按照所述更新后元数据信息将待写入数据写入至所述新增分区中。8.一种用于消息队列的自动扩容装置，其特征在于，包括：获取模块，用于获取目标消息队列中每个候选分区的负载；判断模块，用于根据每个所述候选分区的负载以及目标负载阀值，判断所述候选分区中是否存在高负载分区，其中，所述高负载分区的负载高于所述目标负载阀值；生成模块，用于在确定存在至少一个所述高负载分区的情况下，生成用于对所述目标消息队列进行分区扩容的目标指令；新增模块，用于按照所述目标指令，在所述目标消息队列中增加至少一个新增分区。