Spring 集成 RocketMQ ,Consumer接收消息缓慢
spring项目,集成RocketMQ ,配置consumer bean (采用
DefaultMQPushConsumer),项目运行期间,consumer接收消息极其缓慢,几乎没有实时性可言,单开测试Consumer Java执行,消息及时到达,接受率100%(内网) 。不知何故,求高手赐教
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(11)
PS:RocketMQ文档中提到,集群消费模式下,在改变消费组(Group)数量时,可能会导致消费重复问题,注意在业务层面去重
没啥问题啊
结贴,找到问题所在了,原因:多个项目中使用了同一个consumerGroupName,具体为什么多个项目使用了同一个消费组名称就会导致消息消费速度缓慢,这个有待研究rocketmq源码才知道,目前,先解决该问题先;解决方式:多个IP,使用不同的ConsumerGroupName。
回复
额
@yoke白板 帮忙给看看,这个配置有木有啥缺的
记得activeMQ 在spring集成时,有支持事务与不支持事务的区别。不知道,是不是跟连接的创建 配置有关。
服务接收消息没问题,已测,就是这个消费者接收拉取消息真的是醉了
1.网络是不是有问题。
2.在mq控制台中查看一下,收到的时间。可以帮助排错
给个例子给看看,你在搞的,只要消费者配置,
springboot 集成的 表示没这个问题
人工置顶