Producer的用途大家都很清楚，主要就是生產訊息，那麼分散式模式下與單佇列模式不一樣，如何能夠充分利用分散式的優勢，將生產的訊息分佈到不同的佇列下呢？Rocket-MQ提供了3種不同模式的Producer：

1. NormalProducer

2. OrderProducer

3. TransactionProducer

一、資料結構

1. TopicPublicInfo：僅僅是Producer使用，儲存了messageQueue列表

2.MessageQueue：公用元件，儲存了Queue的標識資訊，<topic、brokerName、queueId>

3.QueueData：包含了Queue的brokerName，queue的讀寫數目等資訊

4.BrokerData：包含了broker的名字，IP，等資訊

二、主要模組

根據<clientId([email protected]), group>每一個DefaultMQProducer有2層的分發：

首先，根據不同的clientId，MQClientManager將給出不同的MQClientInstance；

其次，根據不同的group，MQClientInstance將給出不同的MQProducer和MQConsumer

DefaultMQProducer: 主要儲存了配置資訊，包括clientId，instantName和groupName，以及傳送的網路引數等；

DefaultMQProducerImpl：主要儲存了<topic,TopicPublishInfo>資訊，SendMessageHook、CheckForbiddenHook、RPCHook以及MQClientInstance資訊；

MQClientManager：儲存了<clientId,MQClientInstance>資訊，clientId([email protected]);

MQClientInstance：儲存了producerTable、consumerTable，adminExtTable，NettyClientConfig，<Topic,TopicRouteData>,<brokerName, <brokerId, address>>,RebalanceService, ClientRemotingProcessor, ConsumerStatsManager等資訊；

三、三種處理模式

這三種處理主要是select broker queue的方法不一樣

1. NormalProducer：普通模式；這裡的select呼叫TopicPublishInfo的selectOneMessageQueue，他的機制如下：正常情況下，順序選擇TopicPublishInfo中messageQueueList的queue進行傳送；如果某一個節點發生了超時，則下次選擇queue時，跳過相同的brokerName；

2. OrderProducer：順序模式；假設相同訂單號的支付，退款需要放到同一個佇列，那麼就可以在send的時候，自己實現MessageQueueSelector，根據裡面的arg欄位來選擇queue

3. TransactionProducer：

四、處理邏輯

1. 首先獲取程序pid，將它作為instanceName，系統中所有相同instanceName的Producer和Consumer共用同一個MQClientInstance

2. 將Consumer或者Producer註冊到MQClientInstance

3. 呼叫MQClientInstance.start，啟動如下定時任務

3.1 fetchNameServerAddr：不斷遍歷nameSrv的地址

3.2 updateTopicRouteInfoFromNameServer：從NameSrv遍歷TopicRouteInfo，然後更新producer和consumer的topic資訊