rocketMq - 神奇的32

概述

    这篇文章主要是把push模式下consumer批量拉取消息数量单此最多32条的问题,这个问题是和组内的一个同事一起排查问题的时候得出的结论,我同事负责发现这个问题,我负责定位这个问题。


问题描述

    问题描述细节可以参考这篇文章,在push模式下consumer每次拉取的数目不超过32个:Rocketmq拉取pull消息分页数目测试,我这边把这篇文章的核心的测试结果贴出来。

rocketMq - 神奇的32
拉取数据量测试


拉取过程分析

    1、首先把数据拉取的过程分析一下,基本上把consumer端拉取和broker处理拉取的代码已经贴出来了。

    2、在代码最后部分我们把核心的数字32列出来了。


rocketMq - 神奇的32
client端拉取代码


rocketMq - 神奇的32
broker注册的消费者


rocketMq - 神奇的32
拉取过程-1


rocketMq - 神奇的32
拉取过程-2


rocketMq - 神奇的32
拉取过程-3


rocketMq - 神奇的32
拉取过程-4
rocketMq - 神奇的32
拉取过程-5


配置参数

    据说broker的配置参数有这个选项,但是事实上据说没效果,我本身没试过。

rocketMq - 神奇的32