【RocketMQ源码】三、Producer 源码学习

谁借莪１个温暖的怀抱￠ 2023-02-26 10:24 72阅读 0赞

# 一、启动流程 #

## 1.1 默认启动类解析 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70][]![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 1][]

查看这个start 的引用可以发现它是基于 DefaultMQProducer 这个类创建的，即需要通过这个类创建 Producer 并发送消息

![20200715111353959.png][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 2][]

同时可以看到这个类中定义了各种消息的发送方法和默认参数

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 3][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 4][]

## 1.2 默认参数解析 ##

<table> 
 <tbody> 
  <tr> 
   <td><strong>参数名称</strong></td> 
   <td style="width:516px;"><strong>参数作用</strong></td> 
  </tr> 
  <tr> 
   <td>producerGroup</td> 
   <td style="width:516px;">生产者所属组</td> 
  </tr> 
  <tr> 
   <td>createTopicKey</td> 
   <td style="width:516px;">默认Topic</td> 
  </tr> 
  <tr> 
   <td>defaultTopicQueueNums</td> 
   <td style="width:516px;">默认主题在每一个Broker队列数量</td> 
  </tr> 
  <tr> 
   <td>sendMsgTimeout</td> 
   <td style="width:516px;">发送消息默认超时时间，默认3s</td> 
  </tr> 
  <tr> 
   <td>compressMsgBodyOverHowmuch</td> 
   <td style="width:516px;">消息体超过该值则启用压缩，默认4k</td> 
  </tr> 
  <tr> 
   <td>retryTimesWhenSendFailed</td> 
   <td style="width:516px;">同步方式发送消息重试次数，默认为2，总共执行3次</td> 
  </tr> 
  <tr> 
   <td>retryTimesWhenSendAsyncFailed</td> 
   <td style="width:516px;">异步方法发送消息重试次数，默认为2</td> 
  </tr> 
  <tr> 
   <td>retryAnotherBrokerWhenNotStoreOK</td> 
   <td style="width:516px;">消息重试时选择另外一个Broker时，是否不等待存储结果就返回，默认为false</td> 
  </tr> 
  <tr> 
   <td>maxMessageSize</td> 
   <td style="width:516px;">允许发送的最大消息长度，默认为4M</td> 
  </tr> 
 </tbody> 
</table>

## 1.3 代码跟踪 ##

*代码：DefaultMQProducerImpl\#start*

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 5][]

点开 MQClientManager，可以看到整个JVM中只有一个 MQClientManager 实例，维护一个MQClientInstance缓存表

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 6][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 7][]

查看MQClientInstance，发现其封装了RocketMQ网络处理API，是消息生产者和消息消费者与NameServer、Broker打交道的网络通道

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 8][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 9][]

# 二、消息发送 #

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200715111257394.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 1]: /images/20230209/1c0177cecf1d4a8b9edb87396234eb33.png
[20200715111353959.png]: /images/20230209/fb95aba35b2d46f99a5c03892fa7927f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 2]: /images/20230209/a25dbeccb75042728b141da9668a2a7b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 3]: /images/20230209/1c7a64a9810a497ca8b46a5e9732f1d0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 4]: /images/20230209/b2860a8cdbe7478e8fa4eba77481e86b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 5]: /images/20230209/3dfccb4c55ad4079854d13c87846f466.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 6]: /images/20230209/1ef7156b94ae409b9a451c84a2aad080.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 7]: /images/20230209/3ae673d55c584079b37578e678956938.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 8]: /images/20230209/0d57c83044ce4a41acb8446c42b93f99.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 9]: /images/20230209/53c72b300ca04eecaf8c9fc2e3ac3bda.png