rocketmq 暂停


当调用DefaultMQPushConsumer的suspend的方法时,会暂停发送从broker中获取消息的命令,此时消息还存在broker(消息队列服务器)的某个队列中,

又因为一个队列只能对应一个消费组内的一个消费者,所以这个队列中的消息只能发送给固定的消费者,导致这个消息一直不会被其他消费者消费,

除非调用resume方法进行恢复。或者将暂停的消费者kill,那样的话broker就不会再从NameServer中拿到那个被kill的消费者的信息,那么存在broker中

的消息就会发送给其他存活的消费者来进行消费。


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM