為了進一步提升云消息隊列 RocketMQ 版服務的穩定性,并以此保障您應用的穩定性,針對部署在某地域(Region)的應用,如果您使用的是TCP協議下的SDK,則需使用該地域的云消息隊列 RocketMQ 版服務的TCP內網接入點。本文提供對應地域的TCP內網接入點的詳細說明和配置步驟。

公告首次發布時間

2019年12月16日

公告說明

地域化的TCP內網接入點比原接入模式的穩定性更高,您需在2023年06月30日前完成切換。超過期限后,原接入點將無法提供消息收發服務。

切換TCP內網接入點的影響如下:
  • 如果應用本身沒有跨地域使用云消息隊列 RocketMQ 版,發送方和訂閱方變更可以不同步。
  • 如果應用有跨地域使用云消息隊列 RocketMQ 版,則需要根據業務評估切換的時機。您可使用HTTP協議客戶端的接入點滿足您跨地域使用云消息隊列 RocketMQ 版的需求。HTTP SDK的詳細信息,請參見HTTP協議客戶端接入說明

公告的更多信息,請參見接入點地域化通知

說明 TCP內網接入點切換適用于開源社區提供的SDK以及阿里云推出的SDK。開源TCP SDK接入指南,請參見TCP協議SDK(社區版)

判斷是否需要切換

請判斷您目前使用的云消息隊列 RocketMQ 版實例的TCP內網接入點是否包含地域ID,格式為http://xxxx.<region_id>.mq-internal.aliyuncs.com:<port>
  • 如果您使用的接入點包含地域ID,例如http://xxxx.cn-hangzhou.mq-internal.aliyuncs.com:8080,那么您無需做任何接入點配置修改。
  • 如果您所使用的接入點沒有包含地域ID,例如http://xxxx.mq-internal.aliyuncs.com:8080,請按本文提供的操作步驟,重新配置您的SDK中使用的接入點信息。

背景信息

如需使用云消息隊列 RocketMQ 版來收發消息,則需在使用TCP協議下的SDK時,將相應參數配置為您實際使用的資源信息。需特別注意的是,以下參數所對應的資源應處于同一地域:

  • GROUP_ID:您在云消息隊列 RocketMQ 版控制臺上創建的Group ID。
  • Topic:您在云消息隊列 RocketMQ 版控制臺上創建的Topic。
  • NAMESRV_ADDR:您從云消息隊列 RocketMQ 版控制臺的實例詳情頁面獲取的接入點。
例如您在華東1(杭州)地域購買了一個云消息隊列 RocketMQ 版實例A,并在此地域下創建了Topic A和Group ID A,供部署在該地域的應用客戶端A使用;同時,您也在另一個地域,如華南1(深圳)購買了另一個云消息隊列 RocketMQ 版實例B,并在此地域下創建了Topic B和Group ID B,供部署在該地域的應用客戶端B使用。需特別注意的信息如下:
  • 針對Topic A,您只能通過在華東1(杭州)地域的、歸屬于Group ID A的客戶端A向Topic A發送或接收消息。
  • 針對Topic B,您只能通過在華南1(深圳)地域的、歸屬于Group ID B的客戶端B向Topic B發送或接收消息。
具體對應關系如下圖所示。接入點設置

操作步驟

  1. 登錄云消息隊列 RocketMQ 版控制臺
  2. 在左側導航欄,單擊實例列表
  3. 在頂部菜單欄,選擇地域,如華東1(杭州),然后單擊目標實例。
  4. 實例詳情頁面,單擊接入點頁簽。
  5. 接入點頁簽,找到TCP 協議客戶端接入點,即可查看網絡內網訪問的接入點。endpoint
  6. 將該接入點配置到您發送端和訂閱端代碼的相應參數。
    • 阿里云提供的ons-sdk需滿足以下條件:

      對應的參數,以Java SDK為例:

      // 請確保您的客戶端版本滿足替換接入點的要求,并將以下配置
      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");
    • 開源社區提供的rocketmq-sdk對應的參數,以Java SDK為例:
      // 請將setNamesrvAddr設置為您從阿里云控制臺獲取的接入點信息。
      producer.setNamesrvAddr("http://xxxx.cn-hangzhou.mq-internal.aliyuncs.com:8080");