公开(公告)号：CN105306552A

公开(公告)日：2016-02-03

申请号：CN201510641915.5

申请日：2015-09-30

Applicant: 中国科学院计算技术研究所

Inventor： 程学旗 ,  欧陈庚 ,  张敬亮 ,  宋凯凯

IPC: H04L29/08 ,  G06Q10/06

CPC classification number: Y02D50/10 ,  H04L67/2842 ,  G06Q10/0631 ,  G06Q10/06316

Abstract: 本发明公开了一种基于消息队列的消费均衡及系统，该方法包括：排序步骤，消费者端实时依照多个消息队列的未消费消息数，对该多个消息队列进行排序；消费步骤，当消费者端所执行的任一线程需要消费消息时，均以未消费消息数最大的消息队列作为目标队列，从该目标队列中获取消息，进行消费。通过本发明的上述技术方案，不管生产者端以何种策略生产消息，或者消费者端每次是否拉取相同条数的消息，或者服务器是否发生了宕机，本发明均可以保证未消费数最大的消息队列在下一次消费的时候得到了消费，维护整个消息队列的消费均衡，不会出现某个消息队列的消息积压的现象。