ApsaraMQ for RocketMQ：功能與特性概述

概覽

雲訊息佇列 RocketMQ 版在阿里雲多個地區（Region）提供了高可用訊息雲端服務。單個地區內採用多機房部署，可用性極高，即使整個機房都不可用，仍然可以為應用提供訊息發布服務。

雲訊息佇列 RocketMQ 版提供TCP和HTTP協議的多語言接入方式，方便不同程式設計語言開發的應用快速接入雲訊息佇列 RocketMQ 版訊息雲端服務。您可以將應用部署在阿里雲ECS、企業自建雲，或者嵌入到移動端、物聯網裝置中與雲訊息佇列 RocketMQ 版建立串連進行訊息收發；同時，本地開發人員也可以通過公網接入雲訊息佇列 RocketMQ 版服務進行訊息收發。

多協議接入

• TCP協議：區別於HTTP簡單的接入方式，提供更為專業、可靠、穩定的TCP協議的SDK接入服務。支援的語言套件括Java、C/C++ 以及.NET。
• HTTP協議：採用RESTful風格，方便易用，快速接入，跨網路能力強。支援Java、C++、.NET、Go、Python、Node.js和PHP七種語言用戶端。

管理工具

• Web控制台：支援通過控制台完成資源管理、訊息查詢、訊息軌跡查詢、監控警示管理等操作。具體操作，請參見控制台使用指南。
• OpenAPI：提供開放的API便於將雲訊息佇列 RocketMQ 版管理工具整合到自己的控制台。雲訊息佇列 RocketMQ 版的API的更多資訊，請參見OpenAPI參考。

訊息類型列表

訊息特性

• 訊息重試：在消費者返回訊息重試的響應後，雲訊息佇列 RocketMQ 版會按照相應的重試規則進行訊息重投。
• 至少投遞一次（At-least-once）：雲訊息佇列 RocketMQ 版保證訊息成功被消費一次。雲訊息佇列 RocketMQ 版的分布式特點和瞬變的網路條件，或者使用者應用重啟發布的情況下，可能導致消費者收到重複的訊息。開發人員應將其應用程式設計為多次處理一條訊息不會產生任何錯誤或不一致性。訊息等冪最佳實務請參見訊息等冪。
• 訊息過濾：雲訊息佇列 RocketMQ 版支援設定訊息屬性給訊息進行分類，雲訊息佇列 RocketMQ 版服務端會根據您訂閱訊息時設定的過濾條件對訊息進行過濾，您將只消費到需要關注的訊息。

訊息功能

• 訊息查詢：雲訊息佇列 RocketMQ 版提供了三種訊息查詢的方式，分別是按Message ID、Message Key以及Topic查詢。
• 查詢訊息軌跡：通過訊息軌跡，能清晰定位訊息從生產者發出，經由雲訊息佇列 RocketMQ 版服務端，投遞給訊息消費者的完整鏈路，方便定位排查問題。
• 叢集消費和廣播消費：當使用叢集消費模式時，雲訊息佇列 RocketMQ 版認為任意一條訊息只需要被消費者叢集內的任意一個消費者處理即可；當使用廣播消費模式時，雲訊息佇列 RocketMQ 版會將每條訊息推送給消費者叢集內所有註冊過的消費者，保證訊息至少被每台機器消費一次。
• 重設消費位點：根據時間或位點重設消費進度，允許使用者進行訊息回溯或者跳過堆積的訊息從最新位點消費。
• 無效信件佇列：將無法正常消費的訊息儲存到特殊的無效信件佇列供後續處理。
• 儀錶盤：提供豐富、全面、多維度統計指標，您可以分別從執行個體、Topic和Group維度查看訊息生產指標、訊息消費指標以及訊息堆積等相關指標。
• 監控警示：您可使用雲訊息佇列 RocketMQ 版提供的監控警示功能，監控某Group ID訂閱的某Topic的訊息消費狀態並接收警示簡訊，協助您即時掌握訊息消費狀態，以便及時處理消費異常。