开发者学堂课程【RocketMQ 知识精讲与项目实战(第三阶段):消息消费概述】学习笔记,与课程紧密联系,让用户快速学习知识。
课程地址:https://developer.aliyun.com/learning/course/704/detail/12492
消息消费概述
消息消费概述
消息消费以组的模式开展,一个消费组内可以包含多个消费者,每一个消费者组可订阅多个主题,消费组之间有集群模式和广播模式两种消费模式。集群模式指的是主题下的同一条消息只允许被其中一个消费者消费。广播模式指的是主题下的同一条消息,将被集群内的所有消费者消费一次。消息服务器与消费者之间的消息传递存在推模式和拉模式两种模式。所谓的拉模式,是消费端主动拉起拉消息请求,而推模式是消息达到消息服务器后,推送给消息消费者。 RocketMQ 消息推模式的实现基于拉模式,在拉模式上包装一层,一个拉取任务完成后开始下一个拉取任务。
集群模式下,多个消费者如何对消息队列进行负载呢?消息队列负载机制遵循一个通用思想:一个消息队列同一个时间只允许被一个消费者消费,一个消费者可以消费多个消息队列。这样就会起到一个消息负载的作用。
RocketMQ支持局部顺序消息消费,也就是保证同一个消息队列上的消息顺序消费。不支持消息全局顺序消费,如果要实现某一个全局顺序消费,可以将队列数设置为1,也就是全局只有一个队列,牺牲高可用性,以上是消息消费的基本描述。