天天看點

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