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的启动流程了
网友评论