ApsaraMQ for RocketMQ:RocketMQ 4.x インスタンスの非リージョンエンドポイント廃止について

非リージョンエンドポイントを使用しているクライアントの特定

1. Message Queue for Apache RocketMQ コンソールにログインします。

2. 左側のナビゲーションウィンドウで、[情報照会] をクリックします。

3. [非リージョンエンドポイントからのアクセス情報] セクションで、ご利用のリソースにアクセスしているインスタンス ID、トピック、クライアントの IP アドレスを確認します。

エンドポイント構成の更新

Message Queue for Apache RocketMQ 4.x インスタンスへのアクセスには、新しいリージョンエンドポイントを使用してください。リージョンエンドポイントの取得手順は以下のとおりです。

1. Message Queue for Apache RocketMQ コンソールにログインします。

2. 左側のナビゲーションウィンドウで、インスタンス数 をクリックします。

3. 上部のナビゲーションバーでリージョン（例：中国 (杭州)）を選択し、ターゲットインスタンスの名前をクリックします。

4. インスタンスの詳細 ページで、エンドポイント タブをクリックします。

5. エンドポイント タブの TCP エンドポイント セクションで、ネットワーク が イントラネットアクセス となっているエンドポイントを確認します。

6. このエンドポイントをプロデューサーおよびコンシューマーのコードに設定します。

   Java ons-client SDK

   1. 必要なクライアントバージョン：1.8.7.4.Final 以降

   2. ONSAddr パラメーターを NAMESRV_ADDR に変更し、エンドポイントの値を更新します。

      // Before:
      properties.put(PropertyKeyConst.ONSAddr, "http://xxxx.mq-internal.aliyuncs.com:8080");          
      // After:
      properties.put(PropertyKeyConst.NAMESRV_ADDR, "http://xxxx.cn-hangzhou.mq-internal.aliyuncs.com:8080");

   Java オープンソース RocketMQ SDK

   1. 必要なクライアントバージョン：4.5.2 以降

   2. パラメーターを更新します。

      // For a producer, update the nameserver address before the producer starts.
      // Before:
      producer.setNamesrvAddr("http://xxxx.mq-internal.aliyuncs.com:8080");
      // After:
      producer.setNamesrvAddr("http://xxxx.cn-hangzhou.mq-internal.aliyuncs.com:8080");
      
      // For a consumer, update the nameserver address before the consumer starts.
      // Before:
      consumer.setNamesrvAddr("http://xxxx.mq-internal.aliyuncs.com:8080");
      // After:
      consumer.setNamesrvAddr("http://xxxx.cn-hangzhou.mq-internal.aliyuncs.com:8080");

   C/C++ SDK

   1. 必要なクライアントバージョン：1.1.0 以降

   2. エンドポイントパラメーターを更新します。ONSFactory.getInstance() を使用して初期化する場合は、ONSFactoryProperty 内のエンドポイント設定を確認してください。

      • ONSAddr パラメーターを使用している場合、NAMESRV_ADDR に変更し、エンドポイントの値を更新します。

        // Before:
        factoryInfo.setFactoryProperty(ONSFactoryProperty::ONSAddr, "http://XXX.mq-internal.aliyuncs.com:8080");
        // After:
        factoryInfo.setFactoryProperty(ONSFactoryProperty::NAMESRV_ADDR, "http://MQ_INST_XXXXXXXXXXX.cn-hangzhou.mq-internal.aliyuncs.com:8080");

      • すでに NAMESRV_ADDR パラメーターを使用している場合、エンドポイントの値のみを更新します。

        // Before:
        factoryInfo.setFactoryProperty(ONSFactoryProperty::NAMESRV_ADDR, "http://MQ_INST_XXXXXXXXXXX.mq-internal.aliyuncs.com:8080");
        // After:
        factoryInfo.setFactoryProperty(ONSFactoryProperty::NAMESRV_ADDR, "http://MQ_INST_XXXXXXXXXXX.cn-hangzhou.mq-internal.aliyuncs.com:8080");

   .NET SDK

   1. 必要なクライアントバージョン：1.1.0 以降

   2. エンドポイントパラメーターを更新します。ONSFactory.getInstance() を使用して初期化する場合は、ONSFactoryProperty 内のエンドポイント設定を確認してください。

      • ONSAddr パラメーターを使用している場合、NAMESRV_ADDR に変更し、エンドポイントの値を更新します。

        // Before:
        factoryInfo.setFactoryProperty(ONSFactoryProperty::ONSAddr, "http://XXX.mq-internal.aliyuncs.com:8080");
        // After:
        factoryInfo.setFactoryProperty(ONSFactoryProperty::NAMESRV_ADDR, "http://MQ_INST_XXXXXXXXXXX.cn-hangzhou.mq-internal.aliyuncs.com:8080");

      • すでに NAMESRV_ADDR パラメーターを使用している場合、エンドポイントの値のみを更新します。

        // Before:
        factoryInfo.setFactoryProperty(ONSFactoryProperty::NAMESRV_ADDR, "http://MQ_INST_XXXXXXXXXXX.mq-internal.aliyuncs.com:8080");
        // After:
        factoryInfo.setFactoryProperty(ONSFactoryProperty::NAMESRV_ADDR, "http://MQ_INST_XXXXXXXXXXX.cn-hangzhou.mq-internal.aliyuncs.com:8080");