rocketmq一个消费者有多个服务器_RocketMQ 系列 消息消费

概念

消费模式

消息消费以组的模式开展， 一个消费组内可以包含多个消费者，每一个消费组可订阅多个主题，消费组之间有集群模式与广播模式两种消费模式。集群模式，主题下的同一条消息只允许被其中一个消费者消费。

广播模式，主题下的同一条消息将被集群内的所有消费者消费一次。

消息传送方式

消息服务器与消费者之间的消息传送也有两种方式：推模式、拉模式。所谓的拉模式，是消费端主动发起拉消息请求，而推模式是消息到达消息服务器后，推送给消息消费者。RocketMQ 消息推模式的实现基于拉模式，在拉模式上包装一层，一个拉取任务完成后开始下一个拉取任务。

消息过滤模式

问题

消息消费流程：

构建topic订阅消息SubscriptionData并加入到 Rebalancelmpl 的订阅消息中：topic订阅信息

订阅重试主题消息。RocketMQ 消息重试是以消费组为单位，而不是主题，消息重试主题名为%RETRY%＋消费组名。消费者在启动的时候会自动订阅该

主题，参与该主题的消息队列负载。

Rebalanccelmpl创建PullRequest对象放入pullRequestQueue，根据 PullRequest 拉取任务执行完一次消息拉取任务后，又将 PullRequest 对象放入到pullReque