云消息队列 Kafka 版 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 版 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，已成为大数据生态中不可或缺的部分。前置概念 阅读本文前，...
MNS）是否支持长轮询 轻量消息队列（原 MNS）是否提供对消息的先入先出（FIFO）访问 轻量消息队列（原 MNS）是否可以与其他阿里云产品协作使用 轻量消息队列（原 MNS）相对于自主研发、商用或开源的消息队列系统有什么优势 计费相关 删除...
轻量消息队列（原 MNS）凭借其简单的队列模型、轻量化协议以及按量后付费的计费模式，成为众多阿里云产品首选的消息传输通道，此外，其无损发布能力和多可用区的高可用特性，确保了云产品之间以及云产品与用户应用之间的消息可靠传输。...
生产者（Producer）向 轻量消息队列（原 MNS）的消息队列发送消息的角色。消费者（Consumer）从 轻量消息队列（原 MNS）的消息队列获取消息的角色。Endpoint 轻量消息队列（原 MNS）的访问域名地址，格式如下：http://$AccountId.mns.$...
本文介绍 轻量消息队列（原 MNS）如何处理较长时间没有任何消息的队列。在您正常使用服务期间，阿里云 轻量消息队列（原 MNS）不会对不可见的队列或主题进行删除操作。但是，如果您的 轻量消息队列（原 MNS）使用权限因为欠费或其他原因被...
本文介绍如何在 云消息队列 Kafka 版 控制台创建流入任务，将 云消息队列 RabbitMQ 版 中的数据快速导入至 云消息队列 Kafka 版。前提条件 您已购买 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买和...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流入任务，实现将 云消息队列 RabbitMQ 版 的数据快速导入至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 ...
作为分布式系统中关键组件的消息队列，其安全性要求也日益提高。云消息队列 RocketMQ 版 的消息云盘加密功能确保消息在存储过程中的加密状态，从而增强数据的安全性和隐私性，为社交、金融、电子商务等领域提供更为可靠的安全保障。使用...
本文为您介绍如何在 轻量消息队列（原 MNS）控制台上快速上手使用队列模型。前提条件 开通轻量消息队列（原 MNS）并授权 创建队列 登录 轻量消息队列（原 MNS）控制台。在左侧导航栏，选择 队列模型 队列列表。在顶部菜单栏，选择地域。在 ...
例如，消息Key是“云消息队列 Kafka 版 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。可以设置搜索关键词为“分布式”，或者“阿里云”和“分布式”组合。如果搜索关键字中包含星号（*）或问号?则采用通配符检索。星号（*）代表...
本文介绍在 轻量消息队列（原 MNS）控制台上可以执行的队列模型相关操作。前提条件 开通轻量消息队列（原 MNS）并授权。创建队列 登录 轻量消息队列（原 MNS）控制台。在左侧导航栏，选择 队列模型 队列列表。在顶部菜单栏，选择地域。在 ...
云消息队列 Kafka 版 云消息队列 Kafka 版 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 版 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，已成为大数据生态中不可或缺的部分。更...
轻量消息队列（原 MNS）的日志管理功能将消息请求日志推送到 日志服务 SLS（Simple Log Service），然后可以使用 SLS 的能力查询和分析请求日志功能来定位线上问题。应用场景 您在收发消息的过程中，是否遇到过以下问题：消息成功发送到...
public static final String NAMESRV_ADDR="您已创建的消息队列RocketMQ版实例的TCP接入点，可在消息队列RocketMQ版控制台实例详情页面的接入点区域查看;说明 创建AccessKey（包括AccessKeyId和AccessKeySecret）的具体步骤，请参见 创建...
轻量队列模型易接入、易集成 提供更简单，轻量的消息队列，聚焦消息领域核心能力构建。提供轻量Queue/Topic资源模型，简单易用，无复杂模型概念。提供轻量HTTP RESTful接口，原生支持HTTP协议，对平台无依赖。提供多种语言SDK，包括C++、...
当您访问 轻量消息队列（原 MNS）出错时，轻量消息队列（原 MNS）会返回一个合适的3xx、4xx或5xx的HTTP状态码，以及一个text或xml格式的消息体。本文介绍 轻量消息队列（原 MNS）错误码消息体说明及列表。错误码说明 错误响应的消息体示例...
本文为您介绍如何在 轻量消息队列（原 MNS）控制台上快速上手使用主题模型。前提条件 开通轻量消息队列（原 MNS）并授权 创建队列 登录 轻量消息队列（原 MNS）控制台。在左侧导航栏，选择 队列模型 队列列表。在顶部菜单栏，选择地域。在 ...
若根据上述几个方法查到消息确实已经被 云消息队列 RabbitMQ 版 服务端存储，则可以重点排查后续的消息推送过程是否存在异常。若是没有查询到消息，则需要检查生产者代码的参数是否正确，队列是否正确绑定。消费者问题 消息的推送事件可以...
单一主题只收发一种类型消息，避免混用 云消息队列 RocketMQ 版 主题的设计原则为通过主题隔离业务，不同业务逻辑的消息建议使用不同的主题。同一业务逻辑消息的类型都相同，因此，对于指定主题，应该只收发同一种类型的消息。主题管理尽量...
当消息内容大于64 KB以至于无法直接存入 SMQ 队列时，不做消息切片，使用 轻量消息队列（原 MNS）和 对象存储OSS 来传递大于64 KB的消息。背景信息 轻量消息队列（原 MNS）的队列的消息大小最大限制为64 KB，正常情况下基本能够满足控制流...
当消息内容大于64 KB以至于无法直接存入 SMQ 队列时，不做消息切片，使用 轻量消息队列（原 MNS）和 对象存储OSS 来传递大于64 KB的消息。背景信息 轻量消息队列（原 MNS）的队列消息大小的最大限制为64 KB，正常情况下基本能够满足控制流...
迁移上云 数据路由备份 动态路由 消息可以基于内容、规则或者其他属性，实时地决定其投递路径，而无需预先配置固定的消息队列或主题。这允许系统根据消息本身的特性、现有的业务需求或其他动态因素实时调整路由决策，从而提高了消息传递的...
轻量消息队列（原 MNS）支持把发布到主题的消息推送到队列。本文介绍如何将消息推送到队列。步骤一：创建队列 登录 轻量消息队列（原 MNS）控制台。在左侧导航栏，选择 队列模型 队列列表。在顶部菜单栏，选择地域。在 队列列表 页面，单击...
本文介绍 轻量消息队列（原 MNS）中主题（Topic）的定义、模型关系、队列属性及使用限制。定义和模型关系 在 轻量消息队列（原 MNS）中，一个主题是一个存储消息的容器。主题里的消息可以被订阅到多种渠道进行消费，订阅类型包括队列、HTTP...
通过创建事件通知规则，轻量消息队列（原 MNS）可以将 对象存储 OSS（Object Storage Service）指定资源上产生的事件以消息的方式主动推送到指定的接收端。本文介绍对象存储OSS事件通知的背景信息、适用场景、事件类型、消息格式及操作步骤...
轻量消息队列（原 MNS）的主题订阅功能使用存在一定的限制，本文介绍 SMQ 主题订阅功能的使用限制。地域限制 阿联酋（迪拜）不支持主题。主题个数 主题个数上限为1000，且一个主题下的订阅个数上限为100。推送限制 发送消息时，目前只能...
} } public void close(){} } OOM 结合 云消息队列 Kafka 版 的Batch设计思路，云消息队列 Kafka 版 会缓存消息并打包发送，如果缓存太多，则有可能造成OOM（Out of Memory）。buffer.memory:发送的内存池大小。如果内存池设置过小，则有...
轻量消息队列（原 MNS）对某些具体指标进行了约束和规范，您在使用时注意不要超过相应的限制值，以免程序出现异常。队列模型限制 限制项 限制值 说明 命名长度 120字符 超过该限制，队列创建失败。队列数量 1000个 说明 如果您有额外需求，...
接口说明 警告 为优化服务性能，轻量消息队列即将下线以下字段的返回值（后续默认为 0）：ActiveMessages-InactiveMessages-DelayMessages 请通过以下方式获取替代方案：使用云监控 OpenAPI 获取队列指标，请参考 云监控 OpenAPI 文档 云...
true DelaySeconds integer 否 发送到该 Queue 的所有消息的延迟时间，发送到队列的消息经过此参数设定的延时时间后，才能被消费。取值范围：0~604800，单位为秒。默认值：0。0 Tag array object 否 资源标签列表。object 否 标签键对应的...
testqueue DelaySeconds integer 否 发送到该 Queue 的所有消息的延迟时间，发送到队列的消息经过此参数设定的延时时间后，才能被消费。取值范围：0~604800，单位为秒。默认值：0。0 MaximumMessageSize integer 否 发送到该 Queue 的消息...
云消息队列 RabbitMQ 版是阿里云消息队列（MQ）团队基于AMQP 0-9-1协议研发的分布式、高吞吐、低延迟、高可扩展的云消息队列服务。消息队列RabbitMQ版完全兼容开源RabbitMQ社区、开箱即用、无需部署、免运维，帮助您快速上云。
云消息队列 MQTT 版 升级后实现了自身数据存储的能力，同时还去除了对 云消息队列 RocketMQ 版 的消息依赖，因此，云消息队列 MQTT 版 的实例和Topic使用有变更。资源 旧版本 使用说明 新版本 使用说明 云消息队列 MQTT 版 实例 旧版本 云...
1250700999 DelaySeconds integer 发送到该 Queue 的所有消息的延迟时间，发送到队列的消息经过此参数设定的延时时间后，才能被消费，单位为秒。30 MaximumMessageSize integer 发送到该 Queue 的消息体的最大长度，单位为 Byte。65536 ...
若您使用 云消息队列 MQTT 版 的数据流入、数据流出规则和 云消息队列 RocketMQ 版 进行通信，云消息队列 RocketMQ 版 会根据调用的 云消息队列 RocketMQ 版 的消息收发API或Topic资源等进行计费。客户端上线下事件流出到消息队列RocketMQ...
变更说明 由于 新版本 的 云消息队列 MQTT 版 实现了自身的消息存储，因此所有的 云消息队列 MQTT 版 Topic资源都需要在 云消息队列 MQTT 版 控制台或调用其OpenAPI进行管理。云消息队列 MQTT 版 的Topic资源不再和 云消息队列 RocketMQ 版...
若您使用 云消息队列 MQTT 版 的数据流入、数据流出规则和 云消息队列 RocketMQ 版 进行通信，云消息队列 RocketMQ 版 会根据调用的 云消息队列 RocketMQ 版 的消息收发API或Topic资源等进行计费。客户端上线下事件流出到消息队列RocketMQ...
生产者发送消息到 云消息队列 RocketMQ 版 服务端时，云消息队列 RocketMQ 版 将根据生产者负载均衡策略将消息均匀的存储在多个队列中，避免产生热点队列和性能瓶颈。本文介绍 云消息队列 RocketMQ 版 生产者的负载均衡策略。背景信息 了解...
注意事项 云消息队列 MQTT 版 通过配置的流入规则和 云消息队列 RocketMQ 版 进行跨云产品的消息交互时，若 云消息队列 RocketMQ 版 的服务端进行升级，则在升级期间，可能会造成 云消息队列 MQTT 版 客户端消费消息延迟。产品升级动态，请...
您可通过配置 云消息队列 MQTT 版 的数据流出规则来自定义数据从 云消息队列 MQTT 版 流出至其他阿里云产品。本文介绍数据流出的原理、应用场景、使用限制以及 云消息队列 MQTT 版 与其他阿里云产品的资源映射关系。基本原理 如需将 云消息...