rocketMq-producer介绍

producer介绍

producer在rocketMq扮演的角色是消息的发送过程，其实宏观上来讲其实就包括两大块，分别是消息的发送以及一堆定时任务。

producer在发送消息过程中涉及到发送队列的选择（topic、broker、queue），所以只要在整个发送过程中理清楚这几者之间的关系，就能理解整个发送过程，当然其中包括非严格顺序消息、顺序消息、事务消息。这里只讲非顺序消息、顺序消息，不包括事务消息。

rocketMq发送时序图

rocketMq发送消息活动图

rocketMq发送消息过程

说明：

核心逻辑参见DefaultMQProducerImpl类

rocketMq发送消息过程由以下组成：组装消息&获取topicPubInfo&选择队列&发送消息。

组装消息：发送消息的组装，包括设置topic&tag&延时&是否有序等等。

生成topicPublishInfo：定期或按需从namesrv同步该topic的broker信息

选择队列：从topicPubishInfo中按照轮询（roundrobin）选取队列，i++%(队列长度)，顺序消息根据自定义的selector按照固定的key进行hash选择同一个队列

发送消息：同步/异常方式发现on个消息给broker

TopicPublishInfo生成逻辑

TopicPublishInfo生成代码

说明：

参见MQClientInstance类

图片备注中已经写明了MessageQueue的生成过程

选择MessageQueue逻辑

说明：

关键是前3个定时任务，后面两个一般是consumer端会使用，这个类是公用的。

producer初始化过程I

producer初始化过程II

说明：