发明名称 |
消息队列的消费方法及装置 |
摘要 |
本发明公开了一种消息队列的消费方法及装置,至少能够解决现有技术中以恒定消费速度进行消费的方式所存在的容易导致消费失败现象的问题。该消息队列的消费方法包括:分别为消息队列中的各个消息分区分配对应的消费端进行消费,定期获取各个消费端对应的消息分区的当前消费偏移以及最大有效偏移;根据各个消费端对应的消息分区的当前消费偏移以及最大有效偏移确定各个消费端对应的消息分区的剩余可消费量;根据各个消费端对应的消息分区的剩余可消费量,动态调整各个消费端的消费速度。 |
申请公布号 |
CN106598760A |
申请公布日期 |
2017.04.26 |
申请号 |
CN201611178259.0 |
申请日期 |
2016.12.19 |
申请人 |
北京奇虎科技有限公司 |
发明人 |
邓怡豪 |
分类号 |
G06F9/54(2006.01)I |
主分类号 |
G06F9/54(2006.01)I |
代理机构 |
北京市浩天知识产权代理事务所(普通合伙) 11276 |
代理人 |
宋菲;刘兰兰 |
主权项 |
一种消息队列的消费方法,包括:分别为所述消息队列中的各个消息分区分配对应的消费端进行消费,定期获取各个消费端对应的消息分区的当前消费偏移以及最大有效偏移;根据各个消费端对应的消息分区的当前消费偏移以及最大有效偏移确定各个消费端对应的消息分区的剩余可消费量;根据各个消费端对应的消息分区的剩余可消费量,动态调整各个消费端的消费速度。 |
地址 |
100088 北京市西城区新街口外大街28号D座112室(德胜园区) |