现象，服务重启之后可以消费挤压得消息，消费一段时间之后就停了，在重启就又可以消费消息了
线上出现的问题，程序启动的时候可以消费消息，一段时间之后，就突然不消费了。使用jstack把线程栈信息那些来，并没有阻塞的线程，mq拉取线程是waiting 状态，原因是 在拿到消息之后 就把消息中 body 设置成null了 ，导致消息在更新消息下标的时候用到body的地方就就报错了，但是mq做了异常处理，所以就不会抛出来异常，最终导致消息不在拉取mq专业的叫法是触发了流控的限制。具体原因，可以查看源码，解决方案就是 mq 传递的 body 的2进制的数据到一定不能修改。
下面贴出mq流控代码，针对于推模式的。
image.png
Consumer Acknowledgements机制 当consumer消费端成功消费完消息后，返回给broke...
消息从producer发送到了broker之后，消息的订阅者就可以订阅消费消息。 roketmq消息拉取方式有两种...
在RocketMq中消费消息有两种方式，push和pull方式： push方式会向Consumer注册一个Mess...
Kafka的消息消费是以消费的group为单位; 同属一个group中的多个consumer分别消费topic的不...
Producer消息生产者，负责产生消息，一般由业务系统负责产生消息。 Consumer消息消费者，负责消费消息，...
provider消息推送实例，consumer消息消费实例，Direct、Topic、Fanout的使用，消息回调...
2020-02-25 消息重试 Consumer消费消息失败后，令消息再消费一次。当消费者主动返回重试码RECON...
基本概念 producer消息生产者cunsumer消息消费者consumer group消费者组，相同group...
1、Consumer消费消息两种模式比较 RocketMQ提供两种方式进行消费消息pull vs push，这...
一. 工作流程 Kafka中消息是以topic进行分类的，Producer生产消息，Consumer消费消息，都是...
本文标题：rockermq消息积压consumer不消费
本文链接：https://www.haomeiwen.com/subject/tlldwdtx.html
网友评论