排他队列
什么是排他队列 排他性队列的特点如下：排他队列只对首次声明它的连接（Connection）可见，包括该连接下所有建立的Channel。其他连接无法声明相同名称的排他队列，且其他连接以及连接下的Channel都无法访问该排他队列。连接断开时排他性...
迁移概述
重要 消息队列的特点是，数据一旦被消费，则已经完成使命。因此，除了需要将自建Kafka集群的数据备份 云消息队列 Kafka 版 实例的情况外，一般情况下不推荐您迁移数据。查看迁移进度：查看自建Kafka集群迁移到 云消息队列 Kafka 版 的进度...
事务消息
云消息队列 RocketMQ 版 提供的分布式事务消息适用于所有对数据最终一致性有强需求的场景。本文介绍 云消息队列 RocketMQ 版 事务消息的概念、优势、典型场景、交互流程、使用规则以及示例代码。概念介绍 事务消息：云消息队列 RocketMQ 版...
定时和延时消息
本文主要介绍 云消息队列 RocketMQ 版 的定时消息和延时消息的概念、适用场景以及使用过程中的注意事项。概念介绍 定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是推迟到在当前时间点...
退款说明
根据计费方式的特点，云消息队列 Kafka 版 资源支持的退款情况如下：包年包月的 云消息队列 Kafka 版 资源如需退款，可在控制台上退订实例。详细信息，请参见 实例生命周期管理。按量计费的 云消息队列 Kafka 版 资源在使用后才支付费用，...
删除队列消息
本文介绍如何删除某个队列的所有消息。您可以使用Java客户端库中 queuePurge 方法删除某个队列的所有消息。示例代码如下：channel.queuePurge("queue-name");
应用场景
异步解耦是 云消息队列 RocketMQ 版 的主要特点，主要目的是减少请求响应时间和解耦。主要的适用场景就是将比较耗时而且不需要即时（同步）返回结果的操作作为消息放入消息队列。同时，由于使用了 云消息队列 RocketMQ 版，只要保证消息...
产品优势
简单易用，在代码上只需要设置一个参数即可完成，解决开源RabbitMQ无延时队列的痛点。高精度支持，最短可精确到秒级，最长可持续1天。高性能，性能与普通消息一致。多副本数据冗余，确保消息可恢复。消息重试 重试一次一分钟，最多16次重试...
消息存储和清理机制
背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义，消息按照达到服务器的先后顺序被存储到队列中，理论上每个队列都支持无限存储。但是在实际部署场景中，服务端节点的物理存储空间有限，消息无法做到永久存储。因此，在实际使用中...
消费进度管理
消费进度原理 消息位点（Offset）参考 云消息队列 RocketMQ 版 主题 和 队列 的定义，消息是按到达服务端的先后顺序存储在指定主题的多个队列中，每条消息在队列中都有一个唯一的Long类型坐标，这个坐标被定义为消息位点。任意一个消息队列...
死信队列
对于消费失败且重试后依然失败的消息，云消息队列 RocketMQ 版 不会立丢弃，而是将消息转发至指定的队列中，即死信队列，这些消息即为死信消息。当消费失败的原因排查并解决后，您可以重发这些死信消息，让消费者重新消费；若您暂时无法...
SDK FAQ
本文记录通过SDK收发消息时常见的问题。开源客户端是否可以直接访问云上服务？云消息队列 RabbitMQ 版 完全兼容开源...您可以使用Java客户端库中 queuePurge 方法删除某个队列的所有消息。示例代码如下：channel.queuePurge("queue-name");
消息发送重试和流控机制
触发条件 云消息队列 RocketMQ 版 的消息流控触发条件如下：存储压力大：参考 消费进度管理 的原理机制，消费者分组的初始消费位点为当前队列的最大消费位点。若某些场景例如业务上新等需要回溯到指定时刻前开始消费，此时队列的存储压力会...
开源对比
云消息队列 RabbitMQ 版 支持单队列的横向扩展，性能上无并发限制，容量无上限。有上限，单队列性能上限为单节点上限。连接数 无上限。云消息队列 RabbitMQ 版 实例能承载的连接数可随集群规模扩大而增加，不受连接数增加的影响。有上限。...
顺序消息
如果是普通消息，订单A的消息可能会被轮询发送到不同的队列中，不同队列的消息将无法保持顺序，而顺序消息发送时 云消息队列 RocketMQ 版 支持将Sharding Key相同（例如同一订单号）的消息序路由到一个队列中。云消息队列 RocketMQ 版 服务...
消息轨迹
进死信时间 消息消费失败被投递至死信队列的时间。使用限制 RocketMQ 4.x/3.x 版本的SDK客户端默认不开启消息轨迹功能，您需要在消息收发代码中开启消息轨迹功能，才能在控制台查询到消息的轨迹信息。具体配置如下：生产者 producer....
顺序消息
基于 云消息队列 RocketMQ 版 本身队列的属性，消费顺序和队列存储的顺序一致，但不保证和发送顺序一致。未设置消息组，消息乱序发送。并发消费 并发消费，尽可能按照时间顺序处理。顺序消息生命周期 初始化 消息被生产者构建并完成初始化...
消息队列RabbitMQ版
amq.direct Queue 选择目标 云消息队列 RabbitMQ 版 实例中的队列。仅当 目标类型 参数配置为 Queue 模式 时需要配置该参数。queue Routing Key 路由消息规则。Body 需要投递的事件的消息内容。配置规则，请参见 消息转换。部分事件$.data....
集成概述
数据清洗/数据流出 Connector生态集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等操作。并支持将完成ETL处理的数据转储到下游。...
OnsDLQMessageResendById-重发指定的死信消息
死信消息已达最大重试次数，若重发后再次消费失败，则死信队列中将增加一条 Message ID 相同的消息，可通过控制台死信队列的查询页面或者管控 API 查看该结果。您可通过同一 Message ID 的消息出现次数判断重发后依然消费失败的次数。由于...
云消息队列 RabbitMQ 版
vhost Queue 选择源实例中的队列。queue 表 2.目标端消息队列RabbitMQ版参数配置 参数 说明 示例 地域 选择接收源端数据的目标实例所在的地域。华东1（杭州）实例ID 选择接收源端数据的目标 云消息队列 RabbitMQ 版 实例ID。amqp-cn-*03o...
云消息队列 RabbitMQ 版
vhost Queue 选择源实例中的队列。queue 表 2.目标端云消息队列 RocketMQ 版参数配置 参数 说明 示例 地域 接收 云消息队列 RocketMQ 版 消息的目标实例所在的地域。华东1（杭州）版本 选择目标端 云消息队列 RocketMQ 版 实例的版本。...
创建RabbitMQ Sink Connector
exchange Queue 当 目标类型 为 Queue 时，选择 云消息队列 RabbitMQ 版 中的选择接收消息的队列。queue 消息路由规则（Routing Key）事件总线EventBridge 通过JSONPath提取事件中的数据，将指定的事件内容路由到事件目标。当 目标类型 为 ...
消息队列RabbitMQ版
vhost Queue 选择源实例中的队列。queue 表 2.目标端消息队列RocketMQ版参数配置 参数 说明 示例 地域 接收 云消息队列 RocketMQ 版 消息的目标实例所在的地域。华东1（杭州）版本 选择目标端 云消息队列 RocketMQ 版 实例的版本。RocketMQ...
创建RabbitMQ Source Connector
test Queue 选择存储消息的队列。test 批量推送 批量推送可帮您批量聚合多个事件，当 批量推送条数 和 批量推送间隔（单位：秒）两者条件达到其一时即会触发批量推送。例如：您设置的推送条数为100 条，间隔时间为15 s，在10 s内消息条数已...
消息服务MNS
test 开启 Base64编码 是：开启Base64编码，会帮助您将数据编码后投递至 消息服务MNS 中的队列。否：不开启Base64编码。是 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用...
消息服务MNS
华东1（杭州）队列名称 选择源端 消息服务MNS 的队列。test 开启 Base64 编码 默认勾选此项。开启Base64编码，会帮助您将 消息服务MNS 的数据编码后投递至目标端。无 表 2.目标端消息队列RabbitMQ版参数配置 参数 说明 示例 地域 选择接收...
消息服务MNS
华东1（杭州）队列名称 选择源端 消息服务MNS 的队列。test 开启 Base64 编码 默认勾选此项。开启Base64编码，会帮助您将 消息服务MNS 的数据编码后投递至目标端。无 表 2.目标端云消息队列 RocketMQ 版参数配置 参数 说明 示例 地域 接收 ...
创建MNS Source Connector
参数 说明 示例 队列名称 选择MNS的队列。test-queue Base64 解码 勾选此项会帮助您将MNS的数据解码后进行投递。test 批量推送 批量推送可帮您批量聚合多个事件，当 批量推送条数 和 批量推送间隔（单位：秒）两者条件达到其一时即会触发...
消息服务MNS
test 开启 Base64编码 是：开启Base64编码，会帮助您将数据编码后投递至 消息服务MNS 中的队列。否：不开启Base64编码。是 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用...
消息服务MNS
test 开启 Base64编码 是：开启Base64编码，会帮助您将数据编码后投递至 消息服务MNS 中的队列。否：不开启Base64编码。是 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用...
消息服务MNS
华东1（杭州）队列名称 选择源端 消息服务MNS 的队列。test 开启 Base64 编码 默认勾选此项。开启Base64编码，会帮助您将 消息服务MNS 的数据编码后投递至目标端。无 表 2.目标端云消息队列 RocketMQ 版参数配置 参数 说明 示例 地域 接收 ...
获取MQTT客户端在线状态
下文以 云消息队列 RocketMQ 版 作为后端存储消息队列的情况为例说明。操作步骤 创建上下线事件对应的Topic。您需关注哪些Group ID分组的设备，就在 云消息队列 MQTT 版 控制台创建对应的Topic。创建Topic的步骤请参见 MQTT快速入门。例如...
概述
数据清洗/数据流出 消息集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等操作。并支持将完成ETL处理的数据转储到下游。Serverless...
Spring集成
spring.rabbitmq.listener.simple.missing-queues-fatal 如果容器声明的队列在代理上不可用，是否失败；或者如果在运行时删除一个或多个队列，是否停止容器。默认值为true。spring.rabbitmq.listener.simple.idle-event-interval 发布空闲...
功能与特性概述
云消息队列 RocketMQ 版 的分布式特点和瞬变的网络条件，或者用户应用重启发布的情况下，可能导致消费者收到重复的消息。开发人员应将其应用程序设计为多次处理一条消息不会产生任何错误或不一致性。消息幂等最佳实践请参见 消费幂等。消息...
消费者负载均衡
重要 消息粒度负载均衡策略保证同一个队列的消息可以被多个消费者共同处理，但是该策略使用的消息分配算法结果是随机的，并不能指定消息被哪一个特定的消费者处理。消息粒度的负载均衡机制，是基于内部的单条消息确认语义实现的。消费者...
领域模型概述
本文为您介绍 云消息队列 RocketMQ 版 的领域模型。产品定位 云消息队列 RocketMQ 版 是一款典型的分布式架构下的中间件产品，使用异步通信方式和...云消息队列 RocketMQ 版 使用的传输模型为发布订阅模型，因此也具有发布订阅模型的特点。
消息（Message）
消息队列 定义：实际存储当前消息的队列。更多信息，请参见 队列（MessageQueue）。取值：由服务端指定并填充。消息位点 定义：当前消息存储在队列中的位置。更多信息，请参见 消费进度原理。取值：由服务端指定并填充。取值范围：0~long....
队列（MessageQueue）
队列的主要作用如下：存储顺序性 队列天然具备顺序性，即消息按照进入队列的顺序写入存储，同一队列间的消息天然存在顺序关系，队列头部为最早写入的消息，队列尾部为最新写入的消息。消息在队列中的位置和消息之间的顺序通过位点（Offset...
- 产品推荐
- 这些文档可能帮助您