RocketMQのクラスターの状態を取得する方法は何ですか？

2年 ago
夏樹, 風
1 minute

RocketMQクラスターの状態を取得するには、次の2つの方法があります。

  1. RocketMQのコマンドラインツールを使用すると、クラスターの状態を取得することができます。具体的なコマンドは次の通りです。
  2. sh mqadmin クラスターリスト -n <namesrvアドレス>
  3. 名前サーバのアドレスである。
  4. このコマンドは、すべてのブローカーとネームサーバーの状態情報を返します。これには、ブローカーのID、IP、バージョン情報、および状態が含まれます。
  5. RocketMQのJava APIを使用すると、クラスターの状態を取得することができます。具体的なコードは以下の通りです:
  6. 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);
    // ブローカーのID、IP、バージョン情報、状態などを出力
    System.out.printf(“Broker Name: %s, Broker Address: %sq%n”, brokerName, brokerAddr);
    }
    } catch (Exception e) {
    // 例外処理
    } finally {
    admin.shutdown();
    }
  7. このコードでは、はNameServerのアドレスです。admin.examineBrokerClusterInfo()メソッドを呼び出してクラスタの状態情報を取得し、各BrokerのID、IP、バージョン情報、状態などを順に出力します。

コマンドラインツールを使用する場合でも、Java APIを使用する場合でも、NameServerのアドレスを指定する必要があります。

bannerAds