rocketMq启动流程

rocketMq 整体架构

image.png

刚开始阅读源代码时候从例子代码开始跟踪代码

image.png

1、看快速启动的代码逻辑

image.png

代码逻辑比较简单启动一个producer 在发送消息
2、分析一下producer 启动的过程
producer启动过程如下图

image.png

this.mQClientAPIImpl.start();
// Start various schedule tasks
this.startScheduledTask();
// Start pull service
this.pullMessageService.start();
// Start rebalance service
this.rebalanceService.start();

image.png
mq 内部通讯是依赖netty 实现的 这个介绍Remoting 模块的时候详细介绍

this.pullMessageService.start();

image.png

启动 pull 消息的服务

image.png

this.rebalanceService.start();
负载均衡启动，消息消费模块中详细介绍一下rebalanceService

this.defaultMQProducer.getDefaultMQProducerImpl().start(false);

看到这里就基本上了解了mq的启动流程了