【RocketMq源码】八、消息的消费

【RocketMq源码】八、消息的消费

 

1. 检查消费者是否合法 checkGroup()

        生产组名称不能为空 、 生产者组的最大长度 255、判断命名规则("^[%|a-zA-Z0-9_-]+$";)

2. 构建主题订阅信息

3.设置消费者客户端实例名称为进程ID

4.创建MQClient实例

5. 构建rebalanceImpl 默认AllocateMessageQueueAveragely

6. 消息消费广播模式,将消费进度保存在本地

7. 消息消费集群模式,将消费进度保存在远端 Broker

8. 是顺序的创建顺序消息消费服务、是并发的创建并发消息消费服务

9. 消息消费服务启动

10. 注册消费者实例

11. 启动消费者客户端

上一篇:关注C++细节——含有本类对象指针的类的构造函数、析构函数、拷贝构造函数、赋值运算符的例子


下一篇:RocketMQ调优过程