源碼入口在defaultmqproducerimpl.sendkernelimpl
第一步是選擇要發送的messagequeue
這裡又分為兩步
1 擷取該topic當時的釋出資訊,也就是該topic都落在哪些broker
defaultmqproducerimpl # trytofindtopicpublishinfo
2 選擇messgequeue
有一個細節,就是messagequeue的資訊時放在了 sendmessagerequestheader
真正進行網絡發送是在
源碼入口在defaultmqproducerimpl.sendkernelimpl
第一步是選擇要發送的messagequeue
這裡又分為兩步
1 擷取該topic當時的釋出資訊,也就是該topic都落在哪些broker
defaultmqproducerimpl # trytofindtopicpublishinfo
2 選擇messgequeue
有一個細節,就是messagequeue的資訊時放在了 sendmessagerequestheader
真正進行網絡發送是在