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

本文主要是介绍【RocketMq源码】八、消息的消费，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

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

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

2. 构建主题订阅信息

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

4.创建MQClient实例

5. 构建rebalanceImpl 默认AllocateMessageQueueAveragely

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

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

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

9. 消息消费服务启动

10. 注册消费者实例

11. 启动消费者客户端

这篇关于【RocketMq源码】八、消息的消费的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！