RocketMQ 的架构

RocketMQ的核心架构包含三个主要组件，其组成结构如下图所示：

主要组件说明：

1. Producer（生产者）：负责向Broker发送消息
2. Broker（消息中转服务器）：
   • 承担消息存储和转发的核心功能
   • 支持集群部署模式，每个Broker节点拥有独立的存储空间和消息队列
3. Consumer（消费者）：负责从Broker获取并处理消息

辅助服务：

• NameServer（名称服务）：
  • 维护Broker的元数据信息（包括地址、Topic和Queue等）
  • Producer和Consumer启动时需连接NameServer获取Broker地址

核心概念：

1. Topic（消息主题）：
   • 消息的逻辑分类单元
   • Producer向指定Topic发送消息，Consumer从特定Topic消费消息
2. Message Queue（消息队列）：
   • Topic的物理实现形式
   • 每个Topic可包含多个Queue，作为独立的存储单元
   • 消息实际存储在对应的Queue中，Consumer从指定Queue获取消息