内容简介：由于一些原因，我需要RocketMQ消费的时候，一批拉400条，一批处理400条。设置如下：为了简单验证是否正确，消费如下：
说明
由于一些原因，我需要RocketMQ消费的时候，一批拉400条，一批处理400条。设置如下：
为了简单验证是否正确，消费如下：
直接通过打印msgs.size()观察情况即可。
现象
实验的topic里面的消息数量很多很多，但是启动消费端，消费端的日志如下：
奇怪啦，明明已经进行了修改
为什么还是每次只能消费32条呢？
调试RocketMQ源码
通过跟踪consumer代码：
这里的确已经设置为400了，那么我们需要跟踪到broker服务端进行查看了。
broker接受到的也是400，我们只有继续跟踪
因为返回为true导致下面的if判断成立，for循环就break了，所有只取了32条数据返回到consumer了：
如果需要让可以一次拉取400条，需要修改broker这里的数据配置才可（其实关于一条消息大小也是类似的，虽然说最大设置16M，但是也是和这里同理需要设置broker相关的数据配置才可生效）。
修改broker的配置文件，添加：maxTransferCountOnMessageInMemory=400 重启broker即可，效果如下：
效果正常，其实如果消息过大，还需要考虑下面几个参数：
总结
需要RocketMQ消费的时候，一批拉400条，一批处理400条。设置如下：
还是达不到效果的，还需要设置broker相关的参数，本次里面设置broker的maxTransferCountOnMessageInMemory=400即可，其他情况需要考虑如下等参数。
文章github源代码地址： rocketmq ，或者公号回复“ rocketmq ”获取源码地址。
以上就是本文的全部内容，希望本文的内容对大家的学习或者工作能带来一定的帮助，也希望大家多多支持 码农网
猜你喜欢:
- @Transactional事务生效问题
- UI抗锯齿不生效原因
- properties文件改变不生效的问题
- View.requestLayout() 不生效的问题
- C# Redis 过期机制不生效问题
- DrawMeshInstanced在Unity2018上不生效
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
浪潮之巅（下册）
吴军 / 人民邮电出版社 / 2013-6 / 45.00元
《浪潮之巅(第2版)(下册)》不是一本科技产业发展历史集，而是在这个数字时代，一本IT人非读不可，而非IT人也应该阅读的作品。一个企业的发展与崛起，绝非只是空有领导强人即可达成。任何的决策、同期的商业环境，都在都影响着企业的兴衰。《浪潮之巅》不只是一本历史书，除了讲述科技顶尖企业的发展规律，对于华尔街如何左右科技公司，以及金融风暴对科技产业的冲击，也多有着墨。此外，《浪潮之巅》也着力讲述很多尚在普......一起来看看 《浪潮之巅（下册）》 这本书的介绍吧!
CSS 压缩/解压工具
在线压缩/解压 CSS 代码
XML 在线格式化
在线 XML 格式化压缩工具