RocketMQ 架构图
次要组件如下：
NameServer
NameServer 集群，Topic 的路由注册核心，为客户端依据 Topic 提供路由服务，从而为客户端获取对应的 Broker 进而向 Broker 发送音讯。NamerServer 将 Topic 信息保留在内存里。NameServer 之间的节点不通信，NameServer 集群里的路由信息采纳的是最终一致性。NameServer 对于 RokcetMQ 好比 ZK 对于 Kafka。
Broker
音讯存储服务器，分 Master 与 Slave，Master 承当读写操作，Slave 作为一个备份。每 30s Master 与 Slave 会向 NameServer 发送心跳包，心跳包里有 Broker 上所有的 Topic 路由信息。Broker 会将 Topic 信息长久化。
Client
音讯客户端，包含 Producer 与 Consumer。个别状况下同一时间一个客户端只会连贯一台 NameServer，只有在异样的时候才会尝试连贯另外一台。客户端每 30s 向 NamerServer 发动 Topic 的路由信息查问
音讯订阅模型
RocketMQ 音讯生产模式采纳的是公布与订阅模式。
- Topic：一类音讯的汇合，不同类型的音讯归属于不同的主题
- ConsumerGroup：音讯生产组，一个生产单位的汇合，生产组启动时须要订阅须要生产的 Topic。一个 Topic 能够被多个生产组订阅，同样一个生产组也能够订阅多个主题。一个生产组有多个消费者。