rocketmq怎么获取集群状态

要获取RocketMQ集群的状态，可以使用以下两种方法：

1. 使用RocketMQ提供的命令行工具：可以使用RocketMQ的命令行工具来获取集群的状态。具体命令为：

   sh mqadmin clusterList -n 
   

   其中，是NameServer的地址。

   这个命令将返回所有Broker和NameServer的状态信息，包括Broker的ID、IP、版本信息、状态等。

2. 使用RocketMQ提供的Java API：RocketMQ提供了Java API来获取集群的状态。具体代码如下：

   DefaultMQAdminExt admin = new DefaultMQAdminExt();
   admin.setNamesrvAddr("");
   
   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();
   }
   

   这段代码中，是NameServer的地址。通过调用admin.examineBrokerClusterInfo()方法来获取集群的状态信息，然后遍历打印出每个Broker的ID、IP、版本信息、状态等。

无论使用命令行工具还是Java API，都需要指定NameServer的地址。