Spring 集成 RocketMQ ,Consumer接收消息缓慢

发布于 2021-12-01 12:08:35 字数 148 浏览 799 评论 11

spring项目,集成RocketMQ ,配置consumer bean (采用
DefaultMQPushConsumer),项目运行期间,consumer接收消息极其缓慢,几乎没有实时性可言,单开测试Consumer Java执行,消息及时到达,接受率100%(内网) 。不知何故,求高手赐教

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(11

怎言笑 2021-12-04 14:30:38

PS:RocketMQ文档中提到,集群消费模式下,在改变消费组(Group)数量时,可能会导致消费重复问题,注意在业务层面去重

爱你是孤单的心事 2021-12-04 14:30:36

没啥问题啊

不乱于心 2021-12-04 14:30:36

结贴,找到问题所在了,原因:多个项目中使用了同一个consumerGroupName,具体为什么多个项目使用了同一个消费组名称就会导致消息消费速度缓慢,这个有待研究rocketmq源码才知道,目前,先解决该问题先;解决方式:多个IP,使用不同的ConsumerGroupName。

狠疯拽 2021-12-04 14:30:34

回复

冷清清 2021-12-04 14:30:32

@yoke白板 帮忙给看看,这个配置有木有啥缺的

可是我不能没有你 2021-12-04 14:30:31

记得activeMQ 在spring集成时,有支持事务与不支持事务的区别。不知道,是不是跟连接的创建 配置有关。

冷弦 2021-12-04 14:30:31

服务接收消息没问题,已测,就是这个消费者接收拉取消息真的是醉了

浅沫记忆 2021-12-04 14:05:02

1.网络是不是有问题。

2.在mq控制台中查看一下,收到的时间。可以帮助排错

偏爱自由 2021-12-04 12:48:51

给个例子给看看,你在搞的,只要消费者配置,

千纸鹤带着心事 2021-12-04 11:32:37

springboot 集成的 表示没这个问题

自此以后,行同陌路 2021-12-04 09:11:27

人工置顶

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文