天天看點

activeMq發送消息流程

1,發送消息入口

2,調用activemqmessageproducersupport的send方法。

該類實作了messageproducer接口

3調用activemqsession的send接口進行消息發送

4,activemqconnection發送消息

5,responsecorrelator發送request

6,調用mutextransport來發送消息

7,調用abstractinactivitymonitor完畢消息發送準備

8。調用tcptransport。openwireformat,dataoutputstream終于完畢通過tcp發送消息

附圖

activeMq發送消息流程

備注:messageid是通過producerid+sequencenumber來生成的,sequencenumber通過原子變量的加1完畢