ApsaraMQ for RocketMQ:Retirement of non-regional endpoints for RocketMQ 4.x instances

Identify clients using non-regional endpoints

1. Log on to the Message Queue for Apache RocketMQ console.

2. In the left-side navigation pane, click Query Information.

3. In the Information About Accesses from Non-regional Endpoints section, view the instance IDs, Topics, and client IP addresses that are accessing your resources.

Update endpoint configuration

Use the new regional endpoint to access your Message Queue for Apache RocketMQ 4.x instance. Follow these steps to obtain the regional endpoint:

1. Log on to the Message Queue for Apache RocketMQ console.

2. In the left-side navigation pane, click Instances.

3. In the top navigation bar, select a region, such as China (Hangzhou), and then click the name of the target instance.

4. On the Instances page, click the Endpoints tab.

5. On the Endpoints tab, go to the TCP Endpoint section and find the endpoint where the Network is Internal Access.

6. Configure this endpoint in the code of your producers and consumers.

   Java ons-client SDK

   1. Client version required: 1.8.7.4.Final or later.

   2. Change the parameter from ONSAddr to NAMESRV_ADDR and update the endpoint value.

      // 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 open source RocketMQ SDK

   1. Client version required: 4.5.2 or later.

   2. Update the parameter.

      // 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. Client version required: 1.1.0 or later.

   2. Update the endpoint parameter. If you use ONSFactory.getInstance() for initialization, check the endpoint settings in ONSFactoryProperty.

      • If you use the ONSAddr parameter, change it to NAMESRV_ADDR and update the endpoint value.

        // 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");

      • If you already use the NAMESRV_ADDR parameter, update the endpoint value.

        // 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. Client version required: 1.1.0 or later.

   2. Update the endpoint parameter. If you use ONSFactory.getInstance() for initialization, check the endpoint settings in ONSFactoryProperty.

      • If you use the ONSAddr parameter, change it to NAMESRV_ADDR and update the endpoint value.

        // 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");

      • If you already use the NAMESRV_ADDR parameter, update the endpoint value.

        // 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");