RocketMQ基础与核心概念

RocketMQ系统架构简介

RocketMQ 由 NameServer、Broker、Producer、Consumer 四大组件组成

NameServer（注册中心）

一个轻量级的注册中心集群，无状态、高可用。它管理着所有 Broker 的元数据信息（如地址、Topic 分布等），为 Producer 和 Consumer 提供服务发现功能。各组件通过心跳机制与 NameServer 保持通信。

Broker（消息服务器）

RocketMQ 的核心消息存储与转发节点，负责接收 Producer 发来的消息、存储消息、以及为 Consumer 提供消息拉取服务。通常以主从（Master-Slave）模式部署，支持高可用和故障切换。

Producer（生产者）

负责创建并发送消息到 Broker。生产者在启动时会向 NameServer 注册，并定期从 NameServer 获取 Broker 的路由信息，从而直接与对应的 Broker 建立连接进行消息投递。

Consumer（消费者）

用于从 Broker 订阅并消费消息。消费者同样会向 NameServer 注册，并拉取 Broker 的路由信息，然后主动从指定的 Broker 拉取消息进行处理。

总结

整个架构中，NameServer 作为中枢协调者，解耦了 Producer/Consumer 与 Broker 的直接依赖；Broker 集群承担实际的消息读写，并通过主从复制保障数据可靠性。这种设计使得 RocketMQ 具备高吞吐、低延迟和强扩展性。