全部產品
Search
文件中心

ApsaraMQ for RocketMQ:TCP協議用戶端大版本發布

更新時間:Feb 09, 2025

雲訊息佇列 RocketMQ 版於2021年10月18日發布新版本Java SDK和C++ SDK用戶端,本次發布對用戶端大版本進行了升級。本文介紹發布的SDK版本資訊、支援升級的地區以及主要的功能差異。

SDK版本資訊

本次發布的SDK用戶端版本資訊如下:

協議

語言

版本號碼

TCP協議

Java

V2.x.x.Final

C++

V3.x.x

使用限制

地區限制

  • Java SDK V2.x.x.Final支援如下地區:華東1(杭州)、華北1(青島)、華北2(北京)、華北3(張家口)、華北5(呼和浩特)、華南1(深圳)、西南1(成都)、中國香港、德國(法蘭克福)和印尼(雅加達)。

    重要

    其他不支援地區請勿將Java SDK升級到V2.x.x.Final版本,否則將無法訪問雲訊息佇列 RocketMQ 版服務。

  • C++ SDK V3.x.x版本支援地區:所有地區均支援。

網路限制

  • Java SDK V2.x.x.Final:僅支援通過VPC網路訪問雲訊息佇列 RocketMQ 版,不支援傳統網路訪問。

    重要

    若您使用存量雲訊息佇列 RocketMQ 版執行個體並通過傳統網路訪問,請勿將Java SDK升級到V2.x.x.Final版本,否則將無法訪問雲訊息佇列 RocketMQ 版執行個體。

  • C++ SDK V3.x.x:無網路限制。

執行個體命名空間限制

  • Java SDK 2.x.x.Final:僅支援有命名空間的執行個體,若您使用的執行個體無命名空間,請勿將用戶端版本升級到Java SDK 2.x.x.Final。

  • C++ SDK V3.x.x:僅支援有命名空間的執行個體,若您使用的執行個體無命名空間,請勿將用戶端版本升級到C++ SDK V3.x.x。

說明

5.x版本執行個體預設都有命名空間,4.x版本執行個體可在雲訊息佇列 RocketMQ 版控制台实例详情頁面的基础信息地區查看是否有命名空間。

功能差異

升級SDK大版本後,主要的功能差異如下:

主要功能變更

用戶端版本

Java SDK:V1.x.x.Final

C++ SDK:V2.x.x/V1.x.x

用戶端版本

Java SDK:V2.x.x.Final

C++ SDK:V3.x.x

負載平衡策略

隊列級訊息負載平衡策略。

該策略可能會出現以下問題:

  • 消費者數量比和Queue數量多時,部分消費者擷取不到訊息的現象。

  • 部分消費者異常或者處理緩慢,其他消費者空閑卻無法共同分擔堆積壓力的情況。

以訊息為粒度進行負載,負載策略更加均衡。

避免了隊列級負載策略可能引起的消費者空閑或訊息堆積問題。

儀錶盤

只有訊息收發量和堆積量等少數指標項。

  • 新增了訊息堆積情境的指標資料,協助您更高效定位問題。

  • 增加了訊息收發各環節的耗時、成功率等指標。

新增指標如下:

  • 生產者

    • 訊息生產調用耗時:統計Topic生產訊息時的耗時。

    • 訊息生產調用成功率 :統計Topic訊息生產的成功率。

  • 消費者

    • 平均消費成功率:統計指定執行個體下所有訊息的消費成功率。

    • 處理中訊息量:統計在消費者用戶端正在處理但用戶端還未返回消費成功響應的訊息的數量。

    • 已就緒訊息量:統計在雲訊息佇列 RocketMQ 版服務端已就緒,可以被消費者消費的訊息數量。指標反映還未被消費者開始處理的訊息規模。

    • 已就緒訊息排隊時間:統計最早一條就緒訊息的就緒時間和目前時間差。該指標反映了還未被處理的訊息的延遲時間大小,對於時間敏感的業務來說是非常重要的度量指標。

    • 訊息消費處理耗時:統計Group消費訊息時,訊息從開始被消費到消費完成的處理耗時。

    • 消費者本地等待耗時:統計Group消費訊息時,訊息到達消費者用戶端到開始被消費的耗時。

    • 消費用戶端訪問協議佔比:統計所有被消費的訊息各協議類型訊息量的佔比。

  • 執行個體 Top 20概覽

    • 已就緒訊息排隊時間 top20 GroupIDs:統計已就緒訊息排隊時間最長的前20個Group。

    • 堆積訊息量(已就緒訊息+處理中訊息)top20 GroupIDs:統計堆積的訊息量最多的前20個Group。

    • 處理中訊息量 top20 GroupIDs:統計處理中的訊息量最多的前20個Group。

    • 消費處理耗時 top20 GroupIDs:統計消費處理耗時最長的前20個Group。

    • 在消費者本地等待處理耗時 top20 GroupIDs:統計消費者本地等待耗時最長的前20個Group。

    • 訊息生產調用失敗率 top20 Topics:統計生產訊息時失敗率最高的前20個Topic。

    • 訊息消費失敗率 top20 GroupIDs:統計消費訊息時失敗率最高的前20個Group。

訊息軌跡

缺少非普通訊息的軌跡資料和消費堆積情境的相關資料。

  • 增加了訊息消費環節的軌跡資料,可根據異常、失敗及耗時等條件查詢訊息軌跡。

  • 增加了定時、事務等訊息情境的資料。

  • OpenTelemetry標準,可關聯到整個調用鏈路。

新增軌跡參數如下:

參數

說明

AccessKey

您的阿里雲帳號或RAM使用者的AccessKey ID,用於標識使用者。當您通過SDK或API調用雲訊息佇列 RocketMQ 版資源時,需要使用AccessKey ID進行身分識別驗證。

到達Server

訊息到達訊息佇列RocketMQ版服務端的時間。

預設DeliverAt

定時訊息的預計投遞時間。

實際AvailableAt

定時訊息定時結束的時間。即訊息可被消費者消費的開始時間。

Available Time

訊息可被消費者消費的開始時間。

提交/復原時間

事務訊息提交或復原的時間。

到达消费端

訊息到達消費者用戶端的時間。

等待处理耗时

訊息到達消費者用戶端,等待線程池分配線程和分配處理資源的耗時。