概述
? ? 這篇文章主要是把push模式下consumer批量拉取消息數(shù)量單此最多32條的問(wèn)題先舷,這個(gè)問(wèn)題是和組內(nèi)的一個(gè)同事一起排查問(wèn)題的時(shí)候得出的結(jié)論,我同事負(fù)責(zé)發(fā)現(xiàn)這個(gè)問(wèn)題咨油,我負(fù)責(zé)定位這個(gè)問(wèn)題您炉。
問(wèn)題描述
? ? 問(wèn)題描述細(xì)節(jié)可以參考這篇文章,在push模式下consumer每次拉取的數(shù)目不超過(guò)32個(gè):Rocketmq拉取pull消息分頁(yè)數(shù)目測(cè)試役电,我這邊把這篇文章的核心的測(cè)試結(jié)果貼出來(lái)邻吭。
拉取數(shù)據(jù)量測(cè)試
拉取過(guò)程分析
? ? 1、首先把數(shù)據(jù)拉取的過(guò)程分析一下,基本上把consumer端拉取和broker處理拉取的代碼已經(jīng)貼出來(lái)了囱晴。
? ? 2膏蚓、在代碼最后部分我們把核心的數(shù)字32列出來(lái)了。
client端拉取代碼
broker注冊(cè)的消費(fèi)者
拉取過(guò)程-1
拉取過(guò)程-2
拉取過(guò)程-3
拉取過(guò)程-4
拉取過(guò)程-5
配置參數(shù)
? ? 據(jù)說(shuō)broker的配置參數(shù)有這個(gè)選項(xiàng)畸写,但是事實(shí)上據(jù)說(shuō)沒(méi)效果驮瞧,我本身沒(méi)試過(guò)。