02 NameServer是如何管理Broker集群的
1. 图示
2. Broker注册与心跳机制
- 注册过程: Broker启动时向所有NameServer(集群中通常部署2-4个)发送注册请求,携带自身信息:
- Broker地址(IP:Port)、集群名称(ClusterName)、Broker名称(BrokerName)
- 角色(Master/Slave)、Topic配置(负责的Topic列表及队列数量)
// 伪代码:Broker注册请求结构public class RegisterBrokerRequest {private String clusterName; // 集群名private String brokerAddr; // Broker地址private String brokerName; // Broker名称private boolean isMaster; // 是否主节点private Map<String, TopicConfig> topicConfigTable; // Topic配置}
- 心跳维持: Broker每 30秒 向所有NameServer发送一次心跳包