轻量消息队列（原 MNS）提供队列级别和消息级别的延时功能，本文为您介绍延时功能的典型应用场景、生效规则和使用方法。应用场景 典型场景一：分布式定时调度 在分布式定时调度场景下，需要实现各类精度的定时任务，例如每天05:00执行文件...
阿里云 轻量消息队列（原 MNS）SMQ（Simple Message Queue(formerly MNS)）是一种高效、可靠、安全、便捷和可弹性扩展的分布式消息服务。轻量消息队列（原 MNS）能够帮助开发者在应用的分布式组件之间自由地传递数据、通知消息，从而构建松...
阿里云CLI（Alibaba Cloud Command Line Interface）是基于OpenAPI构建的通用命令行工具，您可以通过阿里云CLI实现自动化管理和维护 云消息队列 RocketMQ 版（ApsaraMQ for RocketMQ）。本文以调用 ListInstances 接口查询 云消息队列 ...
本文介绍如何在 云消息队列 Kafka 版 控制台创建迁移任务，将自建Kafka集群的元数据迁移至 云消息队列 Kafka 版 实例。迁移流程 注意事项 Serverless实例暂不支持元数据导入任务。当自建Kafka集群不支持公网访问时，建议采用元数据导入的...
本文介绍如何通过创建AnalyticDB Sink Connector，将数据从 云消息队列 Kafka 版 实例的数据源Topic通过函数计算服务导出至 云原生数据仓库 AnalyticDB MySQL 版 或云原生数据仓库AnalyticDB PostgreSQL版。前提条件 在导出数据前，请确保...
借助 云消息队列 Kafka 版 ACL功能，您可以按需为SASL用户赋予向 云消息队列 Kafka 版 收发消息的权限，从而实现权限分割。说明 仅专业版实例支持ACL功能。启用 禁用 禁用 VPC 传输加密 是否启用消息传输加密。仅当启用 ACL 功能 时，方可...
借助 云消息队列 Kafka 版 ACL功能，您可以按需为SASL用户赋予向 云消息队列 Kafka 版 收发消息的权限，从而实现权限分割。说明 仅专业版实例支持ACL功能。启用 禁用 禁用 VPC 传输加密 是否启用消息传输加密。仅当启用 ACL 功能 时，方可...
阿里云的 云消息队列 RabbitMQ 版 支持AMQP 0-9-1协议，兼容开源的RabbitMQ客户端，您可以使用开源的客户端SDK接入 云消息队列 RabbitMQ 版 服务端进行消息收发。前提条件 创建实例 创建Vhost 背景信息 借助访问控制RAM的RAM用户，您可以...
云消息队列 MQTT 版 升级后实现了自身数据存储的能力，同时还去除了对 云消息队列 RocketMQ 版 的消息依赖，因此，云消息队列 MQTT 版 的实例和Topic使用有变更。资源 旧版本 使用说明 新版本 使用说明 云消息队列 MQTT 版 实例 旧版本 云...
本文介绍如何在 云消息队列 Kafka 版 控制台创建元数据导入任务，将元数据迁移至 云消息队列 Kafka 版 已有实例。前提条件 下载JDK 8 购买并部署云消息队列 Kafka 版实例：购买并部署VPC实例 购买并部署公网/VPC实例 说明 购买实例的规格可...
云消息队列 MQTT 版 旧版本 强依赖 云消息队列 RocketMQ 版 作为消息存储，因此 云消息队列 MQTT 版 消息和 云消息队列 RocketMQ 版 天然打通，创建了Topic后即可天然使用 云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的SDK相互通信。...
云消息队列 RocketMQ 版 支持将指定实例的Topic列表信息导出，再导入至其他的 云消息队列 RocketMQ 版 实例，实现Topic的跨实例迁移。您可以在更换实例或者克隆实例时，使用Topic导入/导出功能快速批量创建出相同的Topic。背景信息 云消息...
云消息队列 RocketMQ 版 支持将指定实例的Topic列表信息导出，再导入至其他的 云消息队列 RocketMQ 版 实例，实现Topic的跨实例迁移。您可以在更换实例或者克隆实例时，使用Topic导入/导出功能快速批量创建出相同的Topic。背景信息 云消息...
本文介绍 轻量消息队列（原 MNS）是否可以与其他阿里云产品协作使用的问题。轻量消息队列（原 MNS）可以与ECS、OSS和OTS等阿里云服务一起使用，从而让应用程序具有更好的灵活性和可扩展性。常见的使用案例如：创建需要互相通信却又不能同时...
本文介绍 云消息队列 Kafka 版 发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息 发送消息的示例代码如下：Future ...
本文针对使用 云消息队列 RocketMQ 版 SDK与 云消息队列 MQTT 版 交互的场景，提供交互中所涉及的消息结构和属性字段的映射关系，方便您更好的理解和组合使用这两个产品。云消息队列 MQTT 版 是一款面向移动端的网关产品，可通过数据互通...
本文介绍如何创建MySQL Source Connector，通过DataWorks将数据从阿里云数据库RDS MySQL版导出至 云消息队列 Kafka 版 实例的Topic。前提条件 在导出数据前，请确保您已完成以下操作：为 云消息队列 Kafka 版 实例开启Connector。更多信息...
云消息队列 RocketMQ 版 提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从 云消息队列 RocketMQ 版 获取消息。本文介绍消息发送和订阅的接口和参数说明。背景信息 云消息队列 RocketMQ 版 支持以下两种消息获取方式：Push...
本文说明如何创建MaxCompute Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至MaxCompute的表。前提条件 在创建MaxCompute Sink Connector前，请确保您已完成以下操作：云消息队列 Kafka 版 为 云消息队列 Kafka 版 ...
云消息队列 RocketMQ 版 支持标签功能，可以将实例通过标签进行归类，便于搜索和资源聚合。本文介绍标签的应用场景、使用说明、使用限制以及标签的相关操作。应用场景 随着您创建的 云消息队列 RocketMQ 版 实例的增加，管理难度也随之增加...
本文介绍如何通过创建Tablestore Sink Connector，将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至表格存储（Tablestore）。前提条件 云消息队列 Kafka 版 已为实例开启Connector。具体操作，请参见 开启Connector。已为实例创建...
前提条件 创建实例 创建Vhost 背景信息 当您需要通过RAM STS角色授权的方式访问 云消息队列 RabbitMQ 版 服务时，需要通过阿里云提供的权限认证类（AliyunCredentialsProvider）设置 AccessKeyID、AccessKeySecret 与 SecurityToken 进行...
若您使用 云消息队列 MQTT 版 的数据流入、数据流出规则和 云消息队列 RocketMQ 版 进行通信，云消息队列 RocketMQ 版 会根据调用的 云消息队列 RocketMQ 版 的消息收发API或Topic资源等进行计费。客户端上线下事件流出到消息队列RocketMQ...
在创建并部署 云消息队列 Kafka 版 实例后，您可以使用 云消息队列 Kafka 版 控制台直接发送消息，快速测试服务端是否正常。前提条件 您已创建并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。操作流程 快速测试 云消息队列 ...
您在升级 云消息队列 Kafka 版 实例的流量规格时，可能会触发集群横向扩容。集群横向扩容完成后，您需要进行Topic引流，使Topic流量重新均匀分布到扩容后的集群上。否则原有的Topic流量仍然会打在扩容前的集群节点上，原有的Topic的峰值...
云消息队列 MQTT 版 支持与 云消息队列 RocketMQ 版 的数据流转功能，本文为您介绍数据流转中的属性字段的映射关系。功能说明 云消息队列 MQTT 版 可以通过数据互通规则实现与其他阿里云产品的交互，例如 云消息队列 RocketMQ 版。规则的...
本文介绍如何使用Spring Cloud框架接入 云消息队列 Kafka 版 并收发消息。前提条件 安装1.8或以上版本JDK。安装2.5或以上版本Maven。下载 kafka-spring-stream-demo，并将其上传在准备好的Linux操作系统。确保您的 云消息队列 Kafka 版 ...
本文说明如何创建FC Sink Connector，您可以通过FC Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至函数计算的函数。前提条件 在创建FC Sink Connector前，请确保您已完成以下操作：云消息队列 Kafka 版 为 云消息...
云消息队列 Kafka 版 可以作为Output接入Logstash。本文说明如何在公网环境下通过Logstash向 云消息队列 Kafka 版 发送消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 ...
云消息队列 RocketMQ 版 支持将指定实例的Group列表信息导出，再导入至其他的 云消息队列 RocketMQ 版 实例，实现Group的跨实例迁移。你可以在更换实例或者克隆实例时，使用Group导入/导出功能快速批量创建出相同的Group。背景信息 您可以...
若您使用 云消息队列 MQTT 版 的数据流入、数据流出规则和 云消息队列 RocketMQ 版 进行通信，云消息队列 RocketMQ 版 会根据调用的 云消息队列 RocketMQ 版 的消息收发API或Topic资源等进行计费。客户端上线下事件流出到消息队列RocketMQ...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流入源为数据传输服务DTS的消息流入任务。前提条件 您已购买 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买和部署实例。在 数据传输服务DTS控制台 ...
注意事项 云消息队列 MQTT 版 通过配置的流入规则和 云消息队列 RocketMQ 版 进行跨云产品的消息交互时，若 云消息队列 RocketMQ 版 的服务端进行升级，则在升级期间，可能会造成 云消息队列 MQTT 版 客户端消费消息延迟。产品升级动态，请...
云消息队列 Kafka 版 系统架构 如 云消息队列 Kafka 版的系统架构 所示，一个 云消息队列 Kafka 版 集群包括Producer、Kafka Broker、Group、ZooKeeper。图 1.云消息队列 Kafka 版 的系统架构 Producer 通过push模式向 云消息队列 Kafka 版...
您可通过配置 云消息队列 MQTT 版 的数据流出规则来自定义数据从 云消息队列 MQTT 版 流出至其他阿里云产品。本文介绍数据流出的原理、应用场景、使用限制以及 云消息队列 MQTT 版 与其他阿里云产品的资源映射关系。基本原理 如需将 云消息...
本文为您介绍 云消息队列 RocketMQ 版 的操作视频。云消息队列 RocketMQ 版5.x系列 快速使用 云消息队列 RocketMQ 版5.x系列的Java SDK收发消息 云消息队列 RocketMQ 版4.x系列 快速使用云消息队列 RocketMQ 版4.x系列的Java SDK收发消息
升级说明 云消息队列 MQTT 版 新版本 相比 旧版本 而言，实现了自身的消息独立存储，再也无需强制绑定 云消息队列 RocketMQ 版，因此购买开通 云消息队列 MQTT 版 实例后即可直接创建资源，从而降低您的使用与理解成本。新版本 除了独立...
升级说明 云消息队列 MQTT 版 新版本 相比 旧版本 而言，实现了自身的消息独立存储，再也无需强制绑定 云消息队列 RocketMQ 版，因此购买开通 云消息队列 MQTT 版 实例后即可直接创建资源，从而降低您的使用与理解成本。新版本 除了独立...
变更内容 为了给您提供更优质、更稳定的产品服务，云消息队列 Kafka 版 V1版本计划于2025年11月30日下线，详情可查看产品公告和通知（短信、邮件、站内信、风险告警）。现就下线计划为您做如下提醒：2026年05月31日起，阿里云将不再提供...
本文介绍在 云消息队列 MQTT 版 中常见的授权策略示例。注意事项 在阅读本文前，建议您先查看在访问控制RAM中支持的 云消息队列 MQTT 版 相关的 权限策略。如需直接复制示例代码，使用时请删除注释内容，即“/”及以后的文字说明。示例中的...