队列（MessageQueue）
流式操作语义 云消息队列 RocketMQ 版 基于队列的存储模型可确保消息从任意位点读取任意数量的消息，以此实现类似聚合读取、回溯读取等特性，这些特性是RabbitMQ、ActiveMQ等非队列存储模型不具备的。模型关系 在整个 云消息队列 RocketMQ ...
消息查询
查询方式说明 由于消息在 云消息队列 RocketMQ 版 中存储的时间默认为3天（不建议修改），即只能查询从当前查询时间算起3天内的消息。例如，当前时间是2019年06月10日15:09:48，那么能查询到的某Topic下的消息最早的时间点为2019年06月07日...
查看消费明细
查询入口 登录 云消息队列 RocketMQ 版 控制台。在页面上方将鼠标悬浮至 费用，单击 用户中心。在 用户中心 左侧导航栏选择 账单管理>账单详情，然后在 账单详情 页面单击 明细账单 页签。在 产品 下拉框选择 云消息队列 MQ，产品明细 下拉...
排他队列
如果您想创建一个只有自己可见的队列，不允许其他用户访问，您可以使用 云消息队列 RabbitMQ 版 的排他性队列特性，将指定的队列声明为排他性。什么是排他队列 排他性队列的特点如下：排他队列只对首次声明它的连接（Connection）可见，...
SDK FAQ
云消息队列 RabbitMQ 版 不支持直接使用开源RabbitMQ JMS Client。您需要通过Maven配置依赖库才能接入 云消息队列 RabbitMQ 版 收发消息。如何通过Maven配置依赖库来收发消息，请参见 JMS概述。JMS标准有哪些接口不支持？云消息队列 ...
消费者负载均衡
队列分配运维更方便 传统基于绑定队列的负载均衡策略，必须保证队列数量大于等于消费者数量，以免产生部分消费者获取不到队列出现空转的情况，而消息粒度负载均衡策略则无需关注队列数。适用场景 消息粒度消费负载均衡策略下，同一队列内的...
收发事务消息
class MyLocalTransactionExecuter:LocalTransactionExecuter { MyLocalTransactionExecuter(){ }~MyLocalTransactionExecuter(){ } virtual TransactionStatus execute(Message&value){/消息ID（有可能消息体一样，但消息ID不一样...
示例代码
TagA",/Message Body，不能为空，消息队列RocketMQ版不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式。factoryInfo.getMessageContent());设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到...
收发普通消息
以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");发送消息，只要不抛出异常，就代表发送成功。try { SendResultONS sendResult=...
收发定时消息
以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");deliver time单位ms，指定一个时刻，在这个时刻之后消息才能被消费，这个例子表示3s后...
发送普通消息（三种方式）
TagA",/Message Body，任何二进制形式的数据，消息队列RocketMQ版不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式。Hello MQ".getBytes());设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常...
收发定时消息
以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");try {/定时消息，单位毫秒（ms），在指定时间戳（当前时间之后）进行投递，例如2016-...
收发顺序消息
以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");分区顺序消息中区分不同分区的关键字段。如果是全局顺序消息，该字段可以设置为任意非...
示例代码
TagA",/Message Body，任何二进制形式的数据，消息队列RocketMQ版不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式。Hello MQ".getBytes());设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常...
收发顺序消息
以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey(orderId);分区顺序消息中区分不同分区的关键字段，Sharding Key与普通消息的key是完全不同的概念。...
收发定时消息
以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");deliver time，单位：ms。指定一个时刻，在这个时刻之后消息才能被消费，这个例子表示...
版本说明
本文介绍HTTP协议下C++ SDK的版本信息，包括各版本的发布时间、发布内容以及下载链接，以便您按需获取适用的C++ SDK收发消息。1.0.3 发布时间 发布内容 下载 2021-01-05 新特性 支持顺序...暂不支持查询消息轨迹。mq-http-cpp-sdk-1.0.0.zip
版本说明
本文介绍HTTP协议下Python SDK的版本信息，包括各版本的发布时间、发布内容以及下载链接，以便您按需获取适用的Python SDK收发消息。1.0.3 发布时间 发布内容 下载 2021-01-05 新特性 ...暂不支持查询消息轨迹。mq-http-python-sdk-1.0.0.zip
版本说明
本文介绍HTTP协议下Node.js SDK的版本信息，包括各版本的发布时间、发布内容以及下载链接，以便您按需获取适用的Node.js SDK收发消息。1.0.3 发布时间 发布内容 下载 2021-01-05 新特性...暂不支持查询消息轨迹。mq-http-nodejs-sdk-1.0.0.zip
版本说明
本文介绍HTTP协议下Go SDK的版本信息，包括各版本的发布时间、发布内容以及下载链接，以便您按需获取适用的Go SDK收发消息。1.0.3 发布时间 发布内容 下载 2021-01-05 新特性 支持顺序消息...暂不支持查询消息轨迹。mq-http-go-sdk-1.0.0.zip
示例代码
以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");deliver time，单位：ms。指定一个时刻，在这个时刻之后消息才能被消费，这个例子表示...
版本说明
本文介绍HTTP协议下C#SDK的版本信息，包括各版本的发布时间、发布内容以及下载链接，以便您按需获取适用的C#SDK收发消息。1.0.5 发布时间 发布内容 下载 2022-07-04 功能优化 修复当...暂不支持查询消息轨迹。mq-http-csharp-sdk-1.0.0.zip
版本说明
本文介绍HTTP协议下PHP SDK的版本信息，包括各版本的发布时间、发布内容以及下载链接，以便您按需获取适用的PHP SDK收发消息。1.0.4 发布时间 发布内容 下载 2023-01-11 问题修复 修复当...暂不支持查询消息轨迹。mq-http-php-sdk-1.0.0.zip
版本说明
本文介绍HTTP协议下Java SDK的版本信息，包括各版本的发布时间、发布内容以及下载链接，以便您按需获取适用的Java SDK收发消息。重要 获取Maven依赖，请参见 准备环境。...暂不支持查询消息轨迹。mq-http-java-sdk-1.0.0.zip
收发事务消息
以方便您在无法正常收到消息情况下，可通消息队列RocketMQ版过控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");发送消息，只要不抛出异常，就代表发送成功。try { LocalTransactionExecuter ...
消息轨迹
背景信息 云消息队列 RabbitMQ 版 支持以下查询方式：按Queue查询：适用于只知道消息发送到的Queue，不知道发送消息时设置的Message ID的模糊查询场景。按Message ID查询：适用于知道发送消息时设置的Message ID的精确查询场景。具体操作，...
Topic管理
本文介绍如何在 云消息队列 RocketMQ 版 控制台上创建、删除、更新和查询Topic。注意事项 Topic不能跨实例使用，例如在实例A中创建的Topic A不能在实例B中使用。Topic类型和消息类型必须一致不能混用。例如，您需要创建一个Topic用于收发...
SDK参考概述
普通消息 顺序消息 定时和延时消息 事务消息 PushConsumer PullConsumer 批量消费 广播消费 集群消费 消息重试 查询消息轨迹 死信队列 重置消费位点 SDK使用说明 HTTP协议和TCP协议的接入点不可混用。例如，您使用TCP协议的SDK收发消息，您...
通过原始日志快速分析和定位问题
本文介绍基于 云消息队列 RabbitMQ 版 当前日志快速查询和分析问题的方法。当您遇到消息不符合预期、消费异常、消息堆积时，通过该方法可以帮助您高效识别出异常、保证业务正常运行。前提条件 推送 云消息队列 RabbitMQ 版 实例的消息操作...
查询消息
云消息队列 RabbitMQ 版 支持按Queue查询和按Message ID查询两种方式，前者适用于只知道消息发送到的Queue，不知道发送消息时设置的Message ID的模糊查询场景。后者适用于知道发送消息时设置的Message ID的精确查询场景。使用限制 云消息...
API概览
轨迹 API 标题 API概述 QueryMqttTraceDevice 查询设备轨迹 分页查询微消息队列MQTT版客户端的设备轨迹。当设备的状态出现异常时，您可以通过该接口查询指定设备的连接历史，帮助您快速定位异常原因。QueryMqttTraceMessageOfClient 查询...
是否支持优先级队列？
云消息队列 RabbitMQ 版 不支持优先级队列。云消息队列 RabbitMQ 版 内部暂未实现消息优先级的处理逻辑，您的客户端通过可选队列参数 x-max-priority 声明的优先级队列实际是无效的。
是否支持优先级队列？
云消息队列 RabbitMQ 版 不支持优先级队列。云消息队列 RabbitMQ 版 内部暂未实现消息优先级的处理逻辑，您的客户端通过可选队列参数 x-max-priority 声明的优先级队列实际是无效的。
快速使用MQTT.fx模拟SDK收发消息
查看消息轨迹 进入 云消息队列 MQTT 版 控制台，在 消息轨迹查询 页面输入 Group ID 和 Device ID 然后单击 查询。返回3条消息轨迹。从下至上依次为：第1条：MQTT 云消息队列 MQTT 版 控制台发送到MQTT.fx的消息。第2条：MQTT.fx客户端发送...
轨迹查询
当消息的收发不符合预期时，您可以使用消息轨迹查询功能，查询消息的收发轨迹。查询设备轨迹 登录 云消息队列 MQTT 版 控制台，在顶部菜单栏选择地域（Region），例如 华东1（杭州）。在左侧导航栏，单击 轨迹查询。在 轨迹查询 页面，单击...
查询消息轨迹
定时和延时消息 如果当前系统时间没有到达指定消费的时间，轨迹可以查询到，但是消息查询不到。事务消息 事务未提交之前，轨迹可以查询到，但是消息查询不到。各语言SDK支持消息轨迹的版本 协议 语言 支持消息轨迹的版本 版本说明 TCP协议 ...
消息轨迹
消息轨迹查询方式 云消息队列 RocketMQ 版 支持以下查询方式：按Message ID查询：该方式属于精确查询，速度快、精确匹配，推荐使用。按Message Key查询：该方式属于模糊查询，最多查询1000条轨迹。仅适用于您没有记录Message ID但是设置了...
常见问题
为什么在控制台上查询不到延时消息的轨迹？如何查看某个资源的增删改查记录？如何授予一个实例的所有权限？如何释放和删除实例？5.0系列实例和4.0系列实例的权限策略相同吗？仪表盘指标统计结果中的TPS均值和TPS Max值有何差异？消息发送...
查看迁移进度
迁移类型包括：通过命令行迁移 迁移Topic上云 迁移Group上云 迁移数据上云 通过元数据文件迁移上云 迁移自建Kafka集群至新实例 位点迁移 重要 目前不支持将自建Kafka集群的位点迁移到 云消息队列 Kafka 版。操作步骤 重要 云消息队列 Kafka...
消息查询
按时间查询消息 按时间查询允许查询全部分区的消息，不确定消息的位置，但确定消息发送的时间段，请指定该时间段中的某一个时间点查询该时间点附近的消息。在 消息查询 页面的 查询方式 列表中，选择 按时间点查询。在 Topic 列表中，选择...
- 产品推荐
- 这些文档可能帮助您