RocketMQ基本组件!

image

Nameserver

Nameserver集群,Topic的路由注册中心,为客户端根据Topic提供路由服务,从而引导客户端向Broker发送消息。

Nameserver之间的节点不通信,路由信息在Nameserver集群中采取的最终一致性。

Broker

消息存储服务器,分为两种角色:MasterSlave

RocketMQ中,主服务承担读写操作,从服务器作为一个备份,当主服务器存在压力时,从服务器可以承担读服务(消息消费)。

所有Broker,包含Slave服务器每隔30s会向Nameserver发送心跳包,心跳包中会包含存在在Broker上所有的Topic的路由信息。

Client

消息客户端,包括Producer(消息发送者)和Consumer(消费消费者),客户端在同一时间只会连接一台NameServer

只有在连接出现异常时才会尝试连接另外一台,客户端每隔30s向NameServer发起Topic的路由信息查询。