RocketMQ 消息发送流程

目录

一. 生产者Producer启动

二. 生产者发送消息 

一. 生产者Producer启动

MQ发消息之前先启动生产者。设置生产者组并且启动生产者。

Broker既是生产者又是消费者,生产者启动的时候会启动两个生产者，一个是进程ID+时间另一个是内部生产者CLIENT_INNER_PRODUCER。

 紧接着是启动内部的生产者,预先启动Broker Netty的客户端；启动一系列的定时任务；消费者去拉取消息；消费者端的负载均衡。

二. 生产者发送消息 

RocketMQ底层是默认同步发送，根据项目的例子跟进代码，进入到DefaultMQProducerImpl类中。