阿里云文档 2026-08-07

RocketMQ的PushConsumer、SimpleConsumer的使用原理、场景及建议

云消息队列 RocketMQ 版支持Push型消费者和Simple型消费者这两种类型的消费者,本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。

阿里云文档 2026-06-03

RocketMQ消费重试机制的原理、版本兼容性和使用建议

消费者出现异常,云消息队列 RocketMQ 版会根据消费重试策略重新投递该消息进行故障恢复。本文介绍消费重试的应用场景、原理机制、版本兼容性和使用建议。

阿里云文档 2025-10-27

RocketMQ事务消息的应用场景、功能原理及使用说明

事务消息为云消息队列 RocketMQ 版中的高级特性消息,本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。

阿里云文档 2025-10-27

RocketMQ消费者的原理架构

本文介绍云消息队列 RocketMQ 版中消费者(Consumer)的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。

阿里云文档 2025-07-30

客户端证书认证的原理和流程

云消息队列 MQTT 版支持基于X.509证书的双向认证,分别通过服务器证书和设备证书完成服务端和客户端的认证,保证客户端和服务端通信链路的安全性和可靠性。本文介绍客户端证书认证的原理和实现方式。

文章 2024-08-16 来自:开发者社区

深入学习RocketMQ的底层存储设计原理

前言 RocketMQ的是一款追求低延迟的消息队列,虽然他是存储在磁盘上的,但是他的读写性能还是非常之高,本文将分析他的存储设计,看看他是从哪些方面对性能有改善。 RocketMQ存储组成 我们可以把RocketMQ的Broker理解成一个数据库一样,数据库存储功能主要是读和写的功能,RocketMQ也一样。在数据库中,我们将数据写入数据和索引中,在RocketMQ中,我们将数据写到c...

深入学习RocketMQ的底层存储设计原理
文章 2023-02-22 来自:开发者社区

从0到1 手把手搭建spring cloud alibaba 微服务大型应用框架(十三)rocketmq 篇(3): 消息读写队列,消息存储,消息发送,消息消费关联流程和原理

本文承接上文《从0到1 手把手搭建spring cloud alibaba 微服务大型应用框架(十三)rocketmq 篇(2):路由注册,消息发送核心流程原理》闲话少说,我们直接上图,我这特意用颜色标注了一下,注意观察颜色相同的部分流程描述消息生产-存储流程1.首选生产者从本地缓存或者从nameserver 获取到对应topic 对应的broker路由以及quene 写队列2.生产者本地使用负....

从0到1 手把手搭建spring cloud alibaba 微服务大型应用框架(十三)rocketmq 篇(3): 消息读写队列,消息存储,消息发送,消息消费关联流程和原理
文章 2022-06-13 来自:开发者社区

RocketMQ消息存储原理(下)

对于数据的写入 OS会先写入至Cache内 随后通过异步的方式由pdflush内核线程将Cache内的数据刷盘至物理磁盘上对于数据的读取 如果一次读取文件时出现未命中PageCache的情况 OS从物理磁盘上访问读取文件的同时 会顺序对其他相邻块的数据文件进行预读取消费队列的读性能几乎接近读内存的原因在消息堆积的情况下也不会影响性能存储的数据较少page cache机制预读取顺序读取消息存储的日....

RocketMQ消息存储原理(下)
文章 2022-06-13 来自:开发者社区

RocketMQ消息存储原理(上)

消息存储CommitLog1、消息内容和元数据都会存在CommitLog日志文件中 2、消息内容不是定长的 3、单个文件大小默认1G 文件名长度为20位 左边补零 剩余为起始偏移量 比如第一个文件名是 00000000000000000000 起始偏移量为0 文件大小为1G=1073741824 当第一个文件写满了 第二个文件为0000000000107374...

RocketMQ消息存储原理(上)

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。