云消息队列 RocketMQ 版：功能与特性概述

概览

云消息队列 RocketMQ 版在阿里云多个地域（Region）提供了高可用消息云服务。单个地域内采用多机房部署，可用性极高，即使整个机房都不可用，仍然可以为应用提供消息发布服务。

多协议接入

• 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的消息消费状态并接收报警短信，帮助您实时掌握消息消费状态，以便及时处理消费异常。