关于4.x系列实例的非Region化接入点下线及升级公告

为了进一步提升云消息队列 RocketMQ 版服务的稳定性,针对部分使用非Region化接入点访问4.x系列实例的访问进行统一升级,通过改为使用Region化接入点访问服务,提升消息生产消费链路的稳定性。

下线时间

北京时间 2026515日,请务必在下线时间之前升级生产者和消费者接入点配置。

变更影响

  1. 影响范围:访问RocketMQ 4.x系列实例服务的接入点域名没有包含地域ID,例如http://xxxx.mq-internal.aliyuncs.com:8080

  2. 影响结果:接入点下线后,所有使用非Region化域名访问服务的消息生产消费请求都会失败。

升级方案

查看非Region化接入点访问信息

  1. 登录云消息队列 RocketMQ 版控制台

  2. 在左侧导航栏,单击信息查询

  3. Region化接入点访问信息区域,可以查看实例ID、Topic的资源信息,查看访问这些资源的客户端访问IP地址。

级接入点配置

请改用新的Region化接入点域名访问RocketMQ 4.x系列实例服务,操作步骤如下。

  1. 登录云消息队列 RocketMQ 版控制台

  2. 在左侧导航栏,单击实例列表

  3. 在顶部菜单栏,选择地域,如华东1(杭州),然后单击目标实例。

  4. 实例详情页面,单击接入点页签。

  5. 接入点页签,找到TCP 协议客户端接入点,即可查看网络内网访问的接入点。endpoint

  6. 将该接入点配置到您发送端和订阅端代码的相应参数。

    Java ons-client SDK

    1. 客户端版本要求:1.8.7.4.Final 及以上版本。

    2. 修改对应的参数:ONSAddr需要修改为NAMESRV_ADDR,并修改接入点信息:

      // 请确保您的客户端版本满足替换接入点的要求,并将以下配置
      properties.put(PropertyKeyConst.ONSAddr, "http://xxxx.mq-internal.aliyuncs.com:8080");          
      // 替换为
      properties.put(PropertyKeyConst.NAMESRV_ADDR, "http://xxxx.cn-hangzhou.mq-internal.aliyuncs.com:8080");

    Java 开源 RocketMQ SDK

    1. 客户端版本要求:4.5.2及以上版本

    2. 修改对应的参数:

      // 如果是发送端 producer,在 producer 启动前设置namesrv地址处进行更改
      producer.setNamesrvAddr("http://xxxx.mq-internal.aliyuncs.com:8080");
      // 替换为
      producer.setNamesrvAddr("http://xxxx.cn-hangzhou.mq-internal.aliyuncs.com:8080");
      
      // 如果是消费端 consumer,在 consumer 启动前设置namesrv地址处进行更改
      consumer.setNamesrvAddr("http://xxxx.mq-internal.aliyuncs.com:8080");
      // 替换为
      consumer.setNamesrvAddr("http://xxxx.cn-hangzhou.mq-internal.aliyuncs.com:8080");

    C/C++ SDK

    1. 客户端版本要求:1.1.0及以上版本

    2. 修改对应的参数:修改接入点(如有),如果使用ONSFactory.getInstance()进行初始化,检查ONSFactoryProperty中接入点的设置。

      • 如果之前使用SDKONSAddr配置方式,需要修改为NAMESRV_ADDR,并修改接入点信息:

        // 如果是发送端 producer或者consumer,设置的接入点
        factoryInfo.setFactoryProperty(ONSFactoryProperty::ONSAddr, "http://XXX.mq-internal.aliyuncs.com:8080");
        // 替换为
        factoryInfo.setFactoryProperty(ONSFactoryProperty::NAMESRV_ADDR, "http://MQ_INST_XXXXXXXXXXX.cn-hangzhou.mq-internal.aliyuncs.com:8080");
      • 如果之前使用NAMESRV_ADDR配置方式,需要修改接入点信息:

        // 如果是发送端 producer或者consumer,设置的接入点
        factoryInfo.setFactoryProperty(ONSFactoryProperty::NAMESRV_ADDR, "http://MQ_INST_XXXXXXXXXXX.mq-internal.aliyuncs.com:8080");
        // 替换为
        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中接入点的设置。

      • 如果之前使用SDKONSAddr配置方式,需要修改为NAMESRV_ADDR,并修改接入点信息:

        // 如果是发送端 producer或者consumer,设置的接入点
        factoryInfo.setFactoryProperty(ONSFactoryProperty::ONSAddr, "http://XXX.mq-internal.aliyuncs.com:8080");
        // 替换为
        factoryInfo.setFactoryProperty(ONSFactoryProperty::NAMESRV_ADDR, "http://MQ_INST_XXXXXXXXXXX.cn-hangzhou.mq-internal.aliyuncs.com:8080");
      • 如果之前使用NAMESRV_ADDR配置方式,需要修改接入点信息:

        // 如果是发送端 producer或者consumer使用factory初始化,设置的接入点信息检查是否是否需要变更
        factoryInfo.setFactoryProperty(ONSFactoryProperty::NAMESRV_ADDR, "http://MQ_INST_XXXXXXXXXXX.mq-internal.aliyuncs.com:8080");
        // 替换为
        factoryInfo.setFactoryProperty(ONSFactoryProperty::NAMESRV_ADDR, "http://MQ_INST_XXXXXXXXXXX.cn-hangzhou.mq-internal.aliyuncs.com:8080");

背景信息

如需使用云消息队列 RocketMQ 版来收发消息,则需在使用TCP协议下的SDK时,将相应参数配置为您实际使用的资源信息。需特别注意的是,以下参数所对应的资源应处于同一地域:

  • GROUP_ID:您在云消息队列 RocketMQ 版控制台上创建的Group ID。

  • Topic:您在云消息队列 RocketMQ 版控制台上创建的Topic。

  • NAMESRV_ADDR:您从云消息队列 RocketMQ 版控制台的实例详情页面获取的接入点。

例如您在华东1(杭州)地域购买了一个云消息队列 RocketMQ 版实例A,并在此地域下创建了Topic AGroup ID A,供部署在该地域的应用客户端A使用;同时,您也在另一个地域,如华南1(深圳)购买了另一个云消息队列 RocketMQ 版实例B,并在此地域下创建了Topic BGroup ID B,供部署在该地域的应用客户端B使用。需特别注意的信息如下:

  • 针对Topic A,您只能通过在华东1(杭州)地域的、归属于Group ID A的客户端ATopic A发送或接收消息。

  • 针对Topic B,您只能通过在华南1(深圳)地域的、归属于Group ID B的客户端BTopic B发送或接收消息。

具体对应关系如下图所示。接入点设置