天天看點

Rocketmq 總結 (二) -- 消息發送

源碼入口在defaultmqproducerimpl.sendkernelimpl

第一步是選擇要發送的messagequeue

這裡又分為兩步

  1 擷取該topic當時的釋出資訊,也就是該topic都落在哪些broker

  defaultmqproducerimpl # trytofindtopicpublishinfo

 2 選擇messgequeue

有一個細節,就是messagequeue的資訊時放在了 sendmessagerequestheader

真正進行網絡發送是在