• 极客专栏正式上线!欢迎访问 https://www.jikewenku.com/topic.html
  • 极客专栏正式上线!欢迎访问 https://www.jikewenku.com/topic.html

消息队列批拉超过32不生效!什么情况?

技术杂谈 勤劳的小蚂蚁 2个月前 (02-13) 68次浏览 已收录 0个评论 扫描二维码

1

说明
由于一些原因,我需要RocketMQ消费的时候,一批拉400条,一批处理400条。设置如下:
为了简单验证是否正确,消费如下:
直接通过打印msgs.size()观察情况即可。

2

现象
实验的topic里面的消息数量很多很多,但是启动消费端,消费端的日志如下:
奇怪啦,明明已经进行了修改
为什么还是每次只能消费32条呢?

3

调试RocketMQ源码
通过跟踪consumer代码:
这里的确已经设置为400了,那么我们需要跟踪到broker服务端进行查看了。
broker接受到的也是400,我们只有继续跟踪
因为返回为true导致下面的if判断成立,for循环就break了,所有只取了32条数据返回到consumer了:
如果需要让可以一次拉取400条,需要修改broker这里的数据配置才可(其实关于一条消息大小也是类似的,虽然说最大设置16M,但是也是和这里同理需要设置broker相关的数据配置才可生效)。
修改broker的配置文件,添加:maxTransferCountOnMessageInMemory=400 重启broker即可,效果如下:
效果正常,其实如果消息过大,还需要考虑下面几个参数:
备注:也可以不用重启broker,通过命令实时修改:

4

总结
需要RocketMQ消费的时候,一批拉400条,一批处理400条。设置如下:
还是达不到效果的,还需要设置broker相关的参数,本次里面设置broker的maxTransferCountOnMessageInMemory=400即可,其他情况需要考虑如下等参数。


丨极客文库, 版权所有丨如未注明 , 均为原创丨
本网站采用知识共享署名-非商业性使用-相同方式共享 3.0 中国大陆许可协议进行授权
转载请注明原文链接:消息队列批拉超过32不生效!什么情况?
喜欢 (0)
[247507792@qq.com]
分享 (0)
勤劳的小蚂蚁
关于作者:
温馨提示:本文来源于网络,转载文章皆标明了出处,如果您发现侵权文章,请及时向站长反馈删除。

您必须 登录 才能发表评论!

  • 精品技术教程
  • 编程资源分享
  • 问答交流社区
  • 极客文库知识库

客服QQ


QQ:2248886839


工作时间:09:00-23:00