FIFO：顺序消息，云消息队列 RocketMQ 版 通过消息分组MessageGroup标记一组特定消息的先后顺序，可以保证消息的投递顺序严格按照消息发送时的顺序。Delay：定时/延时消息，通过指定延时时间控制消息生产后不要立即投递，而是在延时间隔后...
磁盘使用率介于[85%,90%)区间：无论消息是否超过 消息保留时长，根据服务端存储消息的时间先后顺序直接清除消息。磁盘使用率≥90%：为了保证稳定性，服务开启禁写保护，暂时无法写入新消息。非Serverless实例，Local存储Topic 磁盘使用率 ...
最近更新时间 本分区中最近一条消息的存储时间。相关文档 当您的Topic上的分区数分配不均衡时，您可以查看 分区均衡引流 将集群中所有云存储类型的Topic的分区进行引流调整。如果您的部分分区消息数量相差过大，请参见 为什么发送给Topic的...
重要 队列粒度负载均衡策略保证同一个队列仅被一个消费者处理，该策略的实现依赖消费者和服务端的信息协商机制，云消息队列 RocketMQ 版 并不能保证协商结果完全强一致。因此，在消费者数量、队列数量发生变化时，可能会出现短暂的队列分配...
定义 队列是 云消息队列 RocketMQ 版 中消息存储和传输的实际容器，也是 云消息队列 RocketMQ 版 消息的最小存储单元。云消息队列 RocketMQ 版 的所有主题、轻量主题都是由一个或多个队列组成，以此实现队列数量的水平拆分和队列内部的流式...
该能力通过多种保障机制，在服务器版本发布、重启或维护期间，避免因客户端连接突然中断导致的生产或消费端报错、消息丢失等问题，确保业务连续性。保障机制 服务端节点禁写机制 在存储节点重启前，服务端会临时禁止该节点写入操作，等节点...
使用长轮询获取队列中的消息，popMessage请求会一直在服务端运行，直到有消息的时候才返回。既可以保证立即收到消息，又避免您发送大量无效请求，减少请求次数，降低费用。注意事项 如果popMessage请求返回无消息结果次数过多，可适当增加...
说明 消息保留时长 指在磁盘容量充足的情况下，消息的最长保留时间。默认值为72小时，取值范围为24小时~480小时。磁盘容量不足（即磁盘水位达到85%）时，无论消息是否超过 消息保留时长，都将根据服务端存储消息的时间先后顺序提前删除旧的...
步骤五：按位点查询消息 您可以根据发送的消息的分区ID和位点信息查询该消息。登录 云消息队列 Kafka 版 控制台。在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在左侧导航栏，单击 消息查询。在 消息查询...
本文介绍 云消息队列 Confluent 版 的产品功能动态及对应的文档。2024-08-20 功能名称 功能描述 功能类型 相关文档 日志管理 支持将 云消息队列 Confluent 版 实例的消息操作日志推送到日志服务。开通该服务后，您可以查询客户端的所有请求...
当消息的收发不符合预期时，您可以使用消息轨迹查询功能，查询消息的收发轨迹，确保数据正常流转、快速定位异常。操作步骤 登录 云消息队列 MQTT 版 控制台，并在左侧导航栏单击 实例列表。在顶部菜单栏选择地域。在实例列表中找到目标实例...
步骤五：按位点查询消息 您可以根据发送的消息的分区ID和位点信息查询该消息。登录 云消息队列 Kafka 版 控制台。在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在左侧导航栏，单击 消息查询。在 消息查询...
普通队列：普通消息的发送与消费，不保证消费的顺序。顺序队列：保证同一分组内的消息按照发送顺序进行消费。消息最大长度：发送到队列的消息体的最大长度。长轮询时间：当队列中没有消息时，该队列的ReceiveMessage请求的最大等待时长。设...
因此，若将顺序消息的发送机制从历史4.x/3.x版本升级到5.x版本时，您需要自行保证消息的顺序性。例如，您可以将主题内的消息消费完，再切换到新的5.x版本上。RoundRobin模式 RoundRobin模式的负载均衡策略服务端5.x版本和历史版本4.x/3.x...
2025-11-06 功能名称 功能描述 功能类型 相关文档 消息轨迹 轻量消息队列（原 MNS）提供消息轨迹查询功能，您可以通过消息轨迹查询消息的完整链路信息，包括消息的发送、订阅匹配、推送、消费等环节的时间、结果、生产者和消费者身份等信息...
如果不设置死信消息的Routing Key，则死信消息的Routing Key默认为消息本身的Routing Key。死信消息 被重新发送到死信Exchange的消息。消息变成死信消息的可能原因如下：requeue 参数被设置为 false，消费者使用 basic.reject 或 basic....
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的PHP SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格...
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的Node.js SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照...
当消息的收发不符合预期时，您可以通过该接口查看消息的收发状态等轨迹信息，帮助您快速定位异常原因。接口说明 每成功调用一次 QueryMqttTraceMessageOfClient 接口，都会计算为一次消息 TPS，从而影响您的计费。计费详情，请参见 计费...
适用场景 通知公告：当某个重要公告或通知发布时，系统可以使用广播消费模式，将通知发送给所有订阅了该消息的用户。这样可以确保每个用户都能及时收到通知，并避免遗漏。实时数据同步：在分布式系统中，有时需要将某个数据进行实时同步，...
在该模型中消息的生产者和消费者都是分布在终端设备，通过MQTT协议连接到 云消息队列 MQTT 版 产品。根据以上两种消息收发模型，可以将使用 云消息队列 MQTT 版 的开发人员分为终端和云端两大类。两类开发人员所需的二次开发内容请分别参见...
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的Java SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格...
在使用开源RabbitMQ集群时，当您希望能够解决各种稳定性痛点（例如消息堆积、脑裂等问题）、实现高并发、分布式、灵活扩缩容时，您可以将开源RabbitMQ集群迁移至 云消息队列 RabbitMQ 版，本文介绍迁移上云的前提条件、操作步骤、注意事项...
轻量消息队列（原 MNS）提供了以下API接口：队列接口 队列接口适用于点对点的消息收发，当接收消息时，需要应用端自行轮询获取消息（拉模式）。主题接口 主题接口适用于一对多的消息收发，应用端只需要在某个地址上启动监听，服务端就会...
本文介绍如何在 云消息队列 MQTT 版 的控制台查询所有Topic的收发消息的数量和TPS。背景信息 此查询支持多维度筛选，以及自定义时间范围查询。您可以通过以下任一控制台路径进入查询页面：在控制台左侧导航栏，选择 资源报表。在控制台左侧...
如何获取部署实例时需要的VPC信息？升级Broker可能产生哪些影响？实例的地域无法变更 云消息队列 Kafka 版何时删除旧消息？如何快速测试云消息队列 Kafka 版服务端是否正常？是否支持延迟消息？能否通过公网访问云消息队列 Kafka 版实例？...
轻量消息队列（原 MNS）凭借其简单的队列模型、轻量化协议以及按量后付费的计费模式，成为众多阿里云产品首选的消息传输通道，此外，其无损发布能力和多可用区的高可用特性，确保了云产品之间以及云产品与用户应用之间的消息可靠传输。...
本文为您介绍 云消息队列 RocketMQ 版 中消息的存储机制，包括消息的存储粒度、判断依据及后续处理策略等。背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义，消息按照达到服务器的先后顺序被存储到队列中，理论上每个队列都支持无限...
步骤五：按位点查询消息 您可以根据发送的消息的分区ID和位点信息查询该消息。登录 云消息队列 Kafka 版 控制台。在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在左侧导航栏，单击 消息查询。在 消息查询...
当消息的收发不符合预期时，您可以通过该接口查看订阅该消息的客户端、消息的投递时间等详细信息，帮助您快速定位异常原因。接口说明 每成功调用一次 QueryMqttTraceMessageSubscribe 接口，都会计算为一次消息 TPS，从而影响您的计费。...
背景信息 云消息队列 Kafka 版 支持以下重置消费位点方式：从最新位点开始消费：不再消费Broker上堆积的消息，将消费位点重置到最新的位置。指定时间点开始消费：将消费位点重置到过去的某个时间点（该时间点以Topic的消息存储时间为准）。...
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的C#SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的...
本文提供使用TCP协议下的C/C++ SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和消费。分区顺序：对于指定的一个Topic，...
步骤五：按位点查询消息 您可以根据发送的消息的分区ID和位点信息查询该消息。登录 云消息队列 Kafka 版 控制台。在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在左侧导航栏，单击 消息查询。在 消息查询...
映射关系 MQTT资源 其他阿里云产品 其他阿里云产品资源 数据包定义 MQTT Topic 云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 的Topic MQTT与RocketMQ的消息结构映射 更多信息 如需了解控制台上的操作，请参见 数据流出规则管理。
本文为您介绍 云消息队列 Kafka 版 实例的常见问题。实例支持哪些开源版本？VPC实例和公网/VPC实例的区别是什么？如何选择实例规格？如何获取部署实例时需要的VPC信息？升级Broker可能产生哪些影响？实例的地域无法变更 云消息队列 Kafka ...
本文介绍通过两种协议的多语言SDK收发普通消息的流程和使用须知。背景信息 云消息队列 RocketMQ 版 提供了四种消息类型，更多信息，请参见 消息类型列表。本文以收发普通消息为例进行说明，因此，您按照本文提供的步骤创建的普通消息的...
如果消息重复消费会影响您的业务处理，请对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 在数学与计算机学中，幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。在消息领域，幂等是...
本文主要介绍 云消息队列 RabbitMQ 版 的顺序消费实现原理，与开源RabbitMQ的不同之处，以及其配置方式和使用限制。顺序消费实现原理 RabbitMQ的顺序消费需要“顺序存储”和“单一消费者”两个条件同时满足才能实现。开源 RabbitMQ 实现 ...
普通队列：普通消息的发送与消费，不保证消费的顺序。顺序队列：保证同一分组内的消息按照发送顺序进行消费。消息最大长度：发送到队列的消息体的最大长度。长轮询时间：当队列中没有消息时，该队列的ReceiveMessage请求的最大等待时长。设...