多机房消息负载均衡处理方法及装置.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN114124962A(43)申请公布日2022.03.01(21)申请号202111441126.9(22)申请日2021.11.30(71)申请人工银科技有限公司地址100029北京市朝阳区安定路5号天圆祥泰大厦申请人中国工商银行股份有限公司(72)发明人于锡璋(74)专利代理机构北京三友知识产权代理有限公司11127代理人周永君叶明川(51)Int.Cl.H04L67/1001(2022.01)H04L67/1095(2022.01)H04L47/215(2022.01)权利要求书2页说明书9页附图3页(54)发明名称多机房消息负载均衡处理方法及装置(57)摘要本申请实施例提供一种多机房消息负载均衡处理方法及装置，方法包括：通过预设分布式服务框架中的主节点获取各机房的当前消息队列积压数据量和应用节点数量，并根据所述当前消息队列积压数据量、所述应用节点数量以及预设计划执行时间确定所述各机房的目标消费速率；将所述目标消费速率发送至所述分布式服务框架中的各应用节点，以使所述各应用节点根据所述目标消费速率确定各自对应的消息队列消费速率；本申请能够有效调节下游系统吞吐量，保障自身系统稳定性。CN114124962ACN114124962A权利要求书1/2页1.一种多机房消息负载均衡处理方法，其特征在于，所述方法包括：通过预设分布式服务框架中的主节点获取各机房的当前消息队列积压数据量和应用节点数量，并根据所述当前消息队列积压数据量、所述应用节点数量以及预设计划执行时间确定所述各机房的目标消费速率；将所述目标消费速率发送至所述分布式服务框架中的各应用节点，以使所述各应用节点根据所述目标消费速率确定各自对应的消息队列消费速率。2.根据权利要求1所述的多机房消息负载均衡处理方法，其特征在于，在所述通过预设分布式服务框架中的主节点获取各机房的当前消息队列积压数据量和应用节点数量之前，还包括：通过预设选举策略从预设分布式服务框架的所有应用节点中确定一主节点。3.根据权利要求1所述的多机房消息负载均衡处理方法，其特征在于，所述以使所述各应用节点根据所述目标消费速率确定各自对应的消息队列消费速率，包括：所述各应用节点获取所述目标消费速率后，根据预设令牌桶算法确定各自对应的消息队列消费速率。4.根据权利要求1所述的多机房消息负载均衡处理方法，其特征在于，在所述将所述目标消费速率发送至所述分布式服务框架中的各应用节点之后，还包括：按照设定时间周期重新确定述各机房的目标消费速率并发送至所述分布式服务框架中的各应用节点。5.一种多机房消息负载均衡处理装置，其特征在于，包括：消费速率确定模块，用于通过预设分布式服务框架中的主节点获取各机房的当前消息队列积压数据量和应用节点数量，并根据所述当前消息队列积压数据量、所述应用节点数量以及预设计划执行时间确定所述各机房的目标消费速率；消费速率调节模块，用于将所述目标消费速率发送至所述分布式服务框架中的各应用节点，以使所述各应用节点根据所述目标消费速率确定各自对应的消息队列消费速率。6.根据权利要求5所述的多机房消息负载均衡处理装置，其特征在于，所述消费速率确定模块包括：主节点选举单元，用于通过预设选举策略从预设分布式服务框架的所有应用节点中确定一主节点。7.根据权利要求5所述的多机房消息负载均衡处理装置，其特征在于，所述消费速率调节模块包括：令牌桶算法调节单元，用于所述各应用节点获取所述目标消费速率后，根据预设令牌桶算法确定各自对应的消息队列消费速率。8.根据权利要求5所述的多机房消息负载均衡处理装置，其特征在于，所述消费速率调节模块还包括：循环计算单元，用于按照设定时间周期重新确定述各机房的目标消费速率并发送至所述分布式服务框架中的各应用节点。9.一种电子设备，包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序，其特征在于，所述处理器执行所述程序时实现权利要求1至4任一项所述的多机房消息负载均衡处理方法的步骤。2CN114124962A权利要求书2/2页10.一种计算机可读存储介质，其上存储有计算机程序，其特征在于，该计算机程序被处理器执行时实现权利要求1至4任一项所述的多机房消息负载均衡处理方法的步骤。3CN114124962A说明书1/9页多机房消息负载均衡处理方法及装置技术领域[0001]本申请涉及分布式数据处理领域，也可用于金融领域，具体涉及一种多机房消息负载均衡处理方法及装置。背景技术[0002]在现有银行间支付清结算系统，随着技术手段的演进，以及分布式系统逐渐成熟，银行系统建设多机房多活已经成为常态，在复杂的高并发场景如秒杀、抢购纪念币等场景，为保护系统稳定常常会采用限流措施。在多机房场景下，对下游服务流量稳定等