消息消费概述|学习笔记

简介: 快速学习消息消费概述

开发者学堂课程【RocketMQ 知识精讲与项目实战(第三阶段)消息消费概述】学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址:https://developer.aliyun.com/learning/course/704/detail/12492


消息消费概述

 

消息消费概述

消息消费以组的模式开展,一个消费组内可以包含多个消费者,每一个消费者组可订阅多个主题,消费组之间有集群模式和广播模式两种消费模式。集群模式指的是主题下的同一条消息只允许被其中一个消费者消费。广播模式指的是主题下的同一条消息,将被集群内的所有消费者消费一次。消息服务器与消费者之间的消息传递存在推模式和拉模式两种模式。所谓的拉模式,是消费端主动拉起拉消息请求,而推模式是消息达到消息服务器后,推送给消息消费者。 RocketMQ 消息推模式的实现基于拉模式,在拉模式上包装一层,一个拉取任务完成后开始下一个拉取任务。

集群模式下,多个消费者如何对消息队列进行负载呢?消息队列负载机制遵循一个通用思想:一个消息队列同一个时间只允许被一个消费者消费,一个消费者可以消费多个消息队列。这样就会起到一个消息负载的作用。

RocketMQ支持局部顺序消息消费,也就是保证同一个消息队列上的消息顺序消费。不支持消息全局顺序消费,如果要实现某一个全局顺序消费,可以将队列数设置为1,也就是全局只有一个队列,牺牲高可用性,以上是消息消费的基本描述。

相关文章
|
4月前
|
消息中间件 存储 RocketMQ
RocketMQ-初体验RocketMQ(09)-广播消息、延时消息、批量消息
RocketMQ-初体验RocketMQ(09)-广播消息、延时消息、批量消息
43 0
|
消息中间件 SQL 存储
解析 RocketMQ 多样消费功能-消息过滤
在消息中间件的使用过程中,一个主题对应的消费者想要通过规则只消费这个主题下具备某些特征的消息,过滤掉自己不关心的消息,这个功能就叫消息过滤。
247 0
解析 RocketMQ  多样消费功能-消息过滤
|
消息中间件 存储 算法
RocketMQ 消息集成:多类型业务消息——定时消息
本篇将继续业务消息集成的场景,从使用场景、应用案例、功能原理以及最佳实践等角度介绍 RocketMQ 的定时消息功能。
427 0
RocketMQ  消息集成:多类型业务消息——定时消息
|
消息中间件 存储 运维
RocketMQ 消息集成:多类型业务消息-普通消息
本篇将从业务集成场景的诉求开始,介绍 RocketMQ 作为业务消息集成方案的核心能力和优势,通过功能场景、应用案例以及最佳实践等角度介绍 RocketMQ 普通消息类型的使用。
226 0
RocketMQ  消息集成:多类型业务消息-普通消息
|
消息中间件 存储 Apache
解析 RocketMQ 业务消息--“顺序消息”
本篇将继续业务消息集成的场景,从功能原理、应用案例、最佳实践以及实战等角度介绍 RocketMQ 的顺序消息功能。
240 0
解析 RocketMQ  业务消息--“顺序消息”
|
消息中间件 SQL 缓存
RocketMQ 5.0 多样消费功能详解消息过滤.|学习笔记(二)
快速学习 RocketMQ 5.0 多样消费功能详解消息过滤.
244 0
RocketMQ 5.0 多样消费功能详解消息过滤.|学习笔记(二)
|
消息中间件 存储 SQL
RocketMQ 5.0 多样消费功能详解消息过滤|学习笔记(一)
快速学习 RocketMQ 5.0 多样消费功能详解消息过滤.
336 0
RocketMQ 5.0 多样消费功能详解消息过滤|学习笔记(一)
|
消息中间件 NoSQL 关系型数据库
实战:如何防止mq消费方消息重复消费、rocketmq理论概述、rocketmq组成、普通消息的发送
实战:如何防止mq消费方消息重复消费 如果因为网络延迟等原因,mq无法及时接收到消费方的应答,导致mq重试。(计算机网络)。在重试过程中造成重复消费的问题
2500 1
实战:如何防止mq消费方消息重复消费、rocketmq理论概述、rocketmq组成、普通消息的发送
|
消息中间件 Java RocketMQ
消息消费要注意的细节|学习笔记
快速学习消息消费要注意的细节
63 0
消息消费要注意的细节|学习笔记
|
消息中间件 RocketMQ 开发者
消息消费初探|学习笔记
快速学习消息消费初探
63 0
消息消费初探|学习笔记