专利交易市场

本发明公开了一种面向实时流处理的负载均衡方法、电子设备及存储介质，该方法为：使根消费者将原始消息按资源/子资源指标组进行切片并汇总到消息池，当消息处理间隙时间达到预设时间段时或者消息片总量达到第一预设阈值时，进行第一次消息池负载均衡计算后返回给根消费者；使根消费者将消息片传递给业务消费者按单个资源/子资源指标拆分消息片并汇总到消息池，当消息处理间隙时间达到预设时间段时或者消息块总量达到第二预设阈值时，进行第二次消息池负载均衡计算后批量传送给对应的业务消费者进行处理。该方法能按最小指标单元进行消息重分配，使并发的多个计算工作站之间的任务相当，实现多个并发工作站的数据处理负载均衡。