消息（Message） 定义 模型关系 消息内部属性 行为约束 使用建议 消息（Message） 本文介绍 Apache RocketMQ 中消息（Message）的定义、模型关系、内部属性、行为约束及使用建议。 定义 消息是 Apache RocketMQ 中的最小数据传输单元。生产者将业务数据的负载和拓展属性包装成消息发送到 Apac...

Metrics Details of metrics Metric types Broker metrics Producer metrics Consumer metrics Background information Message accumulation scenarios PushConsumer consumption scenar...

Dledger集群搭建 前言 1. 新集群部署 1.1 编写配置 1.2 启动 Broker 2. 旧集群升级 2.1 杀掉旧的 Broker 2.2 检查旧的 Commitlog 2.3 修改配置 2.4 重新启动 Broker Dledger集群搭建 前言 该文档主要介绍如何部署自动容灾切换的 RocketMQ-on-DL...

Run RocketMQ locally Run RocketMQ in Docker Run RocketMQ with Docker Compose

2 通信机制 2.1 Remoting通信类结构 2.2 协议设计与编解码 2.3 消息的通信方式和流程 2.4 Reactor多线程设计 2 通信机制 RocketMQ消息队列集群主要包括NameServer、Broker(Master/Slave)、Producer、Consumer4个角色，基本通讯流程如下： (1) Broker启动...

Normal Message Scenarios Working mechanism Usage limits Example Usage notes Normal Message Normal messages are messages that have no special features in Apache RocketMQ. Th...

消息存储和清理机制 背景信息 消息存储机制 消息过期清理机制 使用建议 消息存储和清理机制 本文为您介绍 Apache RocketMQ 中消息的存储机制，包括消息的存储粒度、判断依据及后续处理策略等。 背景信息 参考 Apache RocketMQ 中队列 的定义，消息按照达到服务器的先后顺序被存储到队列中，理论上每个队列都支持无限存储。...

Delay Message Scenarios Working mechanism Usage limits Example Usage notes Delay Message Delay messages are messages with advanced features in Apache RocketMQ. This topic d...

主题（Topic） 定义 模型关系 内部属性 行为约束 版本兼容性 使用示例 使用建议 主题（Topic） 本文介绍 Apache RocketMQ 中主题（Topic）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。 定义 主题是 Apache RocketMQ 中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。...

Transaction Message Scenarios Working mechanism Usage limits Example Usage notes Transaction Message Transactional messages are an advanced message type in Apache RocketMQ....