要獲取RocketMQ集群的狀態,可以使用以下兩種方法:
使用RocketMQ提供的命令行工具:可以使用RocketMQ的命令行工具來獲取集群的狀態。具體命令為:
sh mqadmin clusterList -n <namesrvAddr>
其中,<namesrvAddr>
是NameServer的地址。
這個命令將返回所有Broker和NameServer的狀態信息,包括Broker的ID、IP、版本信息、狀態等。
使用RocketMQ提供的Java API:RocketMQ提供了Java API來獲取集群的狀態。具體代碼如下:
DefaultMQAdminExt admin = new DefaultMQAdminExt();
admin.setNamesrvAddr("<namesrvAddr>");
try {
admin.start();
ClusterInfo clusterInfo = admin.examineBrokerClusterInfo();
for (BrokerData brokerData : clusterInfo.getBrokerAddrTable().values()) {
String brokerName = brokerData.getBrokerName();
String brokerAddr = brokerData.getBrokerAddrs().get(MixAll.MASTER_ID);
// 打印Broker的ID、IP、版本信息、狀態等
System.out.printf("Broker Name: %s, Broker Address: %s%n", brokerName, brokerAddr);
}
} catch (Exception e) {
// 處理異常
} finally {
admin.shutdown();
}
這段代碼中,<namesrvAddr>
是NameServer的地址。通過調用admin.examineBrokerClusterInfo()
方法來獲取集群的狀態信息,然后遍歷打印出每個Broker的ID、IP、版本信息、狀態等。
無論使用命令行工具還是Java API,都需要指定NameServer的地址。