面向实时流处理的负载均衡方法、电子设备及存储介质
基本信息
申请号 | CN201911213322.3 | 申请日 | - |
公开(公告)号 | CN111258727A | 公开(公告)日 | 2020-06-09 |
申请公布号 | CN111258727A | 申请公布日 | 2020-06-09 |
分类号 | G06F9/48(2006.01)I;G06F9/50(2006.01)I | 分类 | 计算;推算;计数; |
发明人 | 詹岭;刘晓华;蔡幼忠 | 申请(专利权)人 | 广州赢领信息科技有限公司 |
代理机构 | 广州哲力智享知识产权代理有限公司 | 代理人 | 广州赢领信息科技有限公司 |
地址 | 510000广东省广州市天河区中山大道建工路13、15号天信楼706 | ||
法律状态 | - |
摘要
摘要 | 本发明公开了一种面向实时流处理的负载均衡方法、电子设备及存储介质,该方法为:使根消费者将原始消息按资源/子资源指标组进行切片并汇总到消息池,当消息处理间隙时间达到预设时间段时或者消息片总量达到第一预设阈值时,进行第一次消息池负载均衡计算后返回给根消费者;使根消费者将消息片传递给业务消费者按单个资源/子资源指标拆分消息片并汇总到消息池,当消息处理间隙时间达到预设时间段时或者消息块总量达到第二预设阈值时,进行第二次消息池负载均衡计算后批量传送给对应的业务消费者进行处理。该方法能按最小指标单元进行消息重分配,使并发的多个计算工作站之间的任务相当,实现多个并发工作站的数据处理负载均衡。 |
