producer介绍
producer在rocketMq扮演的角色是消息的发送过程,其实宏观上来讲其实就包括两大块,分别是消息的发送以及一堆定时任务。
producer在发送消息过程中涉及到发送队列的选择(topic、broker、queue),所以只要在整个发送过程中理清楚这几者之间的关系,就能理解整个发送过程,当然其中包括 非严格顺序消息、顺序消息、事务消息。这里只讲非顺序消息、顺序消息,不包括事务消息。
producer的发送过程
rocketMq发送时序图 rocketMq发送消息活动图说明:
核心逻辑参见DefaultMQProducerImpl类
rocketMq发送消息过程由以下组成:组装消息&获取topicPubInfo&选择队列&发送消息。
组装消息:发送消息的组装,包括设置topic&tag&延时&是否有序等等。
生成topicPublishInfo:定期或按需从namesrv同步该topic的broker信息
选择队列:从topicPubishInfo中按照轮询(roundrobin)选取队列,i++%(队列长度),顺序消息根据自定义的selector按照固定的key进行hash选择同一个队列
发送消息:同步/异常方式发现on个消息给broker
生成TopicPublishInfo过程
TopicPublishInfo生成逻辑 TopicPublishInfo生成代码说明:
参见MQClientInstance类
图片备注中已经写明了MessageQueue的生成过程
SelectOneMessageQueue过程
选择MessageQueue逻辑 选择MessageQueue逻辑producer的定时任务
producer的定时任务说明:
关键是前3个定时任务,后面两个一般是consumer端会使用,这个类是公用的。
producer的初始化过程
producer初始化过程I producer初始化过程II说明:
参见DefaultMQProducerImpl类,具体的功能在上图中已备注。
网友评论