BatchSendMessage
请求消息 请求消息由请求行、HTTP头和消息体三部分组成：请求行 POST/queues/$queueName/messages HTTP/1.1 特有Request Header 无。Request Body Request Body为XML格式，其中包含多条创建Message的属性。参数名称 类型 是否必选 示例值 ...
接入点对比
需要链路加密和消息鉴权，建议使用SSL接入点。基本概念 SASL是一种用于交换身份证书的验证机制。SASL支持两种机制验证身份：PLAIN机制：一种简单的用户名密码校验机制。云消息队列 Kafka 版 的PLAIN机制，支持不重启实例的情况下动态增加...
通过可观测性能力进行故障处理最佳实践
查看消息处理耗时（rocketmq_process_time）和消息处理成功率（rocketmq_process_time_count{invocation_status="success"/invocation_status="success｜failure"}）等指标是否异常，初步定位是否是消费者客户端的问题。消息处理成功率=...
QueueHasDiffField
包括 死信Exchange、死信Routing Key和 消息存活时间。例如要调用的Queue的autoDelete参数的已设置属性值与本次声明的Queue的autoDelete参数的属性值不一致，导致报错QueueHasDiffField[OAutoDelete=false&NAutoDelete=true;要调用的Queue...
使用云消息队列 Kafka 版时出现消息堆积
在 消费状态 页签，每间隔1分钟记录一次各个Topic分区的 最近消费时间、堆积量 和 消息位点，然后进行下列判断：说明 消息位点可通过单击 详情 按钮进行查看。最近消费时间与当前时间接近，并且堆积量保持在一个稳定的数值之间波动，没有...
消息查询
按 Topic 查询 按Topic查询一般用在Message ID和Message Key都无法获得的情况下，根据Topic和消息的发送时间范围，批量获取该时间范围内的所有消息，然后再找到关心的数据。重要 若按Topic查询消息，请注意以下几点：按Topic查询属于范围...
全球消息路由
查看任务详情 在 全球消息路由 页面的任务列表中，找到需要查看的任务，在其 操作 列单击 详情，即可查看该任务的任务详情和消息详情，以及编辑过滤规则。全球消息路由详情 页面的关键字段的说明如下表所示。参数 说明 任务状态 任务状态...
收发定时消息和延时消息
本文提供使用HTTP协议下的Node.js SDK收发定时消息和延时消息的示例代码。背景信息 延时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即...
Token鉴权概述
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的Token相关的请求以及消息收发业务。使用流程 Token鉴权模式相比签名模式更加复杂，您需要按照下图所示的流程，部署您的应用服务器。而且在初始化时，...
Exchange
该属性为 x-match，只有以下两种取值：all：所有除 x-match 以外的绑定属性键值对必须和消息Headers属性键值对匹配才会路由消息。any：只要有一组除 x-match 以外的绑定属性键值对和消息Headers属性键值对匹配就会路由消息。以下两种情况下...
全球消息路由定价详情
例如发送5条普通消息和2条事务消息，将以5+2×5=15条消息计费。说明 云消息队列 RocketMQ 版 有4种消息类型：普通消息、定时和延时消息、事务消息以及顺序消息，其中，定时和延时消息、事务消息以及顺序消息为高级特性消息。更多信息，请...
Group导入/导出
Group导入或导出操作仅涉及Group资源的基础信息，例如，Group ID、消费策略、Group的描述信息等，不涉及订阅关系和消息数据的变更或迁移。导入Group时，Group列表必须符合模板要求，具体规范，请参见 5.x Group列表模板。Group导出 登录 云...
Token鉴权概述
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的Token相关的请求以及消息收发业务。使用流程 Token鉴权模式相比签名模式更加复杂，您需要按照下图所示的流程，部署您的应用服务器。而且在初始化时，...
概述
本文介绍使用社区版TCP协议的Java SDK访问阿里云 云消息队列 RocketMQ 版 来收发消息的流程。使用说明 社区版SDK仅在开源...使用社区版TCP协议的Java SDK收发消息 收发普通消息（三种方式）收发顺序消息 收发定时消息和延时消息 收发事务消息
Serverless版实例计费
计费周期为天，即每天账单中统计的是前一天0点开始的24小时内接收消息和发送消息的总数。消息收发仅涉及通过 云消息队列 MQTT 版 进行收发的消息，不涉及通过 云消息队列 RocketMQ 版 进行收发的消息。消息收发包括消息接收和消息发送。...
OnsMessageGetByMsgId-通过MsgId查询消息
查询到的信息包括发送时间、存储服务器和消息的 Key 和 Tag 等属性。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权...
消息加密传输
注意事项 加密消息和解密消息对性能会有一定影响。请不要往加密队列里发送非加密的消息。解决方案 以下是 消息服务MNS 对消息进行加密传输的解决方案。在消息发送端先对消息进行加密，然后再发送。在消息接收端先对消息进行解密，然后再...
Queue管理
高级选项 Queue的参数设置，可用于设置死信Exchange、死信Routing Key和消息存活时间。DeadLetterExchange：指定死信消息发送的目标Exchange。DeadLetterRoutingKey：指定死信消息的Routing Key，即死信Exchange会将消息发送至匹配该死信...
消息发送重试和流控机制
本文为您介绍 云消息队列 RocketMQ 版 的消息发送重试机制和消息流控机制。背景信息 消息发送重试 云消息队列 RocketMQ 版 的消息发送重试机制主要为您解答如下问题：部分节点异常是否影响消息发送？请求重试是否会阻塞业务调用？请求重试...
消息收发定价详情
如果服务端成功返回消息，则投递消息次数按照以上规则计算，即消息条数乘以对应的高级特性倍率和消息体大小倍率。如果服务端未返回消息，则计算为1次投递次数。说明 云消息队列 RocketMQ 版 有4种消息类型：普通消息、定时和延时消息、事务...
一机一密概述
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的设备访问凭证相关的请求以及消息收发业务。计算方式 按照 鉴权概述 的描述，如果选择一机一密鉴权模式，MQTT客户端实际连接MQTT消息服务器时，connect ...
迁移消费者程序
背景信息 云消息队列 Kafka 版 控制台提供迁移实例功能，您可以使用该功能将自建Kafka集群或其他云Kafka集群的元数据（Topic和Group配置信息）和消息数据同步到目标集群，迁移完成后目标集群的元数据与源集群的元数据保持一致并且持续更新...
使用限制
单实例消息收发TPS 根据购买的规格进行限流，云消息队列 MQTT 版 消息收发TPS超过规格上限后，客户端（包含开源MQTT客户端和云端SDK）可能会出现连接断开、响应超时和消息丢弃等情况，不保证消息可靠到达。在MQTT客户端场景下，单MQTT客户...
Group导入/导出
Group导入或导出操作仅涉及Group资源的基础信息，例如，Group ID、Group类型、Group的描述信息等，不涉及订阅关系和消息数据的变更或迁移。导入Group时，Group列表必须符合模板要求，具体规范，请参见 4.x Group列表模板。Group导出 登录 ...
Spring集成
背景信息 云消息队列 RocketMQ 版 支持以下消息类型的生产者和消费者与Spring集成：普通消息的生产者和消费者 事务消息的生产者和消费者 顺序消息的生产者和消费者 说明 云消息队列 RocketMQ 版 暂不支持Spring框架下定时消息和延时消息的...
消费端挂载NFS是否会影响消费速度？
解决方案 建议您将消费端拉取消息和存储消息分别放在两个独立且不同的线程里操作。拉取消息的线程只管消费消息，把消息转给缓存处理线程后就继续消费消息，这样可以保证消费速度的稳定。您也可以考虑采用高效云盘或者SSD云盘，给每台消费端...
收发定时消息和延时消息
本文提供使用社区版TCP协议下的Java SDK收发定时消息和延时消息的示例代码。背景信息 定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是推迟到在当前时间点之后的某一个时间投递到Consumer...
常见问题
顺序消息和普通消息的区别是什么？连接服务端时的用户名和密码在哪里获取？消息队列RocketMQ版订阅的Tag数量有限制吗？消息队列RocketMQ版集群消费和广播消费的区别是什么？多个Group订阅同一个Topic消息如何消费？消息队列RocketMQ版的...
步骤二：创建资源
高级选项 Queue的参数设置，可用于设置死信Exchange、死信Routing Key和消息存活时间。DeadLetterExchange：指定死信消息发送的目标Exchange。DeadLetterRoutingKey：指定死信消息的Routing Key，即死信Exchange会将消息发送至匹配该死信...
MNS主题触发器
发布者可以通过PublishMessage接口向主题发布消息，主题的订阅者接收该消息。接口信息，请参见 PublishMessage。配置一个MNS主题触发器，相当于将函数注册为这个MNS主题的订阅者，当发布者向MNS主题发布消息的时候，就会把消息内容通知给...
收发定时消息和延时消息
本文提供使用HTTP协议下的C#SDK收发定时消息和延时消息的示例代码。背景信息 延时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时消息...
队列模型基本概念
消息包含数据和属性，可以分成普通消息和延时消息，在一个队列中能唯一标识一个消息的有Message ID和ReceiptHandle两个参数。普通队列 如果发送消息时不指定消息延时，消息发送到普通队列后可立即被消费。延时队列（Delayed Queue）如果...
收发定时消息和延时消息
本文提供使用HTTP协议下的Python SDK收发定时消息和延时消息的示例代码。背景信息 延时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即...
收发定时消息和延时消息
本文提供使用HTTP协议下的Java SDK收发定时消息和延时消息的示例代码。背景信息 延时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时...
收发定时消息和延时消息
本文提供使用HTTP协议下的Go SDK收发定时消息和延时消息的示例代码。背景信息 延时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时...
收发定时消息和延时消息
本文提供使用HTTP协议下的PHP SDK收发定时消息和延时消息的示例代码。背景信息 延时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时...
收发定时消息和延时消息
本文提供使用HTTP协议下的C++ SDK收发定时消息和延时消息的示例代码。背景信息 延时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时...
常见问题
顺序消息和普通消息的区别是什么？连接服务端时的用户名和密码在哪里获取？连接服务端时的接入点（endpoint）在哪里获取？云消息队列 RocketMQ 版订阅的Tag数量有限制吗？云消息队列 RocketMQ 版集群消费和广播消费的区别是什么？多个Group...
MNS主题触发器
发布者可以通过PublishMessage接口向主题发布消息，主题的订阅者接收该消息。接口信息，请参见 PublishMessage。配置一个MNS主题触发器，相当于将函数注册为这个MNS主题的订阅者，当发布者向MNS主题发布消息的时候，就会把消息内容通知给...
OnsMessagePush-向指定的消费者推送消息
此时重新发送的这条消息和原消息的消息内容相同，但并不是同一条消息且 MsgId 不同。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是...
- 产品推荐
- 这些文档可能帮助您