本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流入任务，将 轻量消息队列（原 MNS）中的数据快速导入 云消息队列 Kafka 版。前提条件 您已购买 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买和...
如果您不想使用消息切片，轻量消息队列（原 MNS）支持通过OSS实现超大消息的传递。下面为您介绍如何通过OSS来传递大于64 KB的消息。解决方案 生产者在向 轻量消息队列（原 MNS）发送消息前，如果发现消息体大于64 KB，则先将消息体数据上传...
由于 云消息队列 MQTT 版 新版本 实现了独立存储，对 云消息队列 RocketMQ 版 没有强依赖，因此消息收发流程有相应的变更。云消息队列 MQTT 版 旧版本 强依赖 云消息队列 RocketMQ 版 作为消息存储，因此 云消息队列 MQTT 版 消息和 云消息...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建流入任务，将指定 云消息队列 RabbitMQ 版 实例中的数据快速导入至另外的 云消息队列 RabbitMQ 版 实例中。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。...
如果您不想使用消息切片，轻量消息队列（原 MNS）支持通过OSS实现超大消息的传递。下面为您介绍如何通过OSS来传递大于64 KB的消息。解决方案 生产者在向 轻量消息队列（原 MNS）发送消息前，如果发现消息体大于64 KB，则先将消息体数据上传...
常见队列增加场景 需要增加队列实现物理节点负载均衡 云消息队列 RocketMQ 版 每个主题的多个队列可以分布在不同的服务节点上，在集群水平扩容增加节点后，为了保证集群流量的负载均衡，建议在新的服务节点上新增队列，或将旧的队列迁移到...
云消息队列 MQTT 版 支持通过Kafka规则将消息流转至 云消息队列 Kafka 版 实例指定的Topic中，本文为您介绍Kafka规则的创建、修改和删除等操作。流程说明 云消息队列 MQTT 版 通过Kafka规则将发送消息和事件消息流转至 云消息队列 Kafka 版...
使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。basicReject方法的参数说明如下：deliveryTag：Channel的消息投递的唯一标识符。requeue：被否定应答的消息...
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
本文介绍如何创建MySQL Source Connector，通过DataWorks将数据从阿里云数据库RDS MySQL版导出至 云消息队列 Kafka 版 实例的Topic。前提条件 在导出数据前，请确保您已完成以下操作：为 云消息队列 Kafka 版 实例开启Connector。更多信息...
注意事项 额外的费用支出：总费用=云消息队列 RabbitMQ 版 费用+事件总线EventBridge 转发费用+CEN流量费用（只有跨地域转发才会产生CEN费用）。云消息队列 RabbitMQ 版 计费详情，请参见 计费概述；事件总线EventBridge 计费详情，请参见 ...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务，将 云消息队列 Kafka 版 的数据导出至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已...
本文介绍如何在 云消息队列 Kafka 版 控制台创建流入任务，将指定 云消息队列 Kafka 版 实例中的数据快速导入至另外的 云消息队列 Kafka 版 实例中。前提条件 您已购买 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请...
在使用 云消息队列 MQTT 版 前，需理解该产品和MQTT协议所涉及的基本概念和术语。基本概念 实例（Instance）创建购买 云消息队列 MQTT 版 服务的实体单元，每个 云消息队列 MQTT 版 实例都对应一个全局唯一的服务接入点URL。使用 云消息...
云消息队列 MQTT 版 支持基于X.509证书的双向认证，分别通过服务器证书和设备证书完成服务端和客户端的认证，保证客户端和服务端通信链路的安全性和可靠性。本文介绍客户端证书认证的原理和实现方式。使用限制 单向认证：所有类型实例均...
负载均衡时消息重复（包括但不限于网络抖动、服务端重启以及Consumer应用重启）当 云消息队列 RabbitMQ 版 的服务端或客户端重启、扩容或缩容时，会触发Rebalance，此时Consumer可能会收到重复消息。处理方法 以Message ID为幂等键对消息...
云消息队列 MQTT 版 通过Token鉴权模式向MQTT客户端提供临时访问权限。您可通过MQTT Token服务来给本地账号系统管理的用户颁发临时的访问凭证，并限制访问权限，以实现对单一客户端、单一资源的细粒度权限控制。本文介绍使用流程以及相关...
本文介绍 云消息队列 MQTT 版 ...云消息队列 Kafka 版 的权限，实现将 云消息队列 MQTT 版 消息流转到 云消息队列 Kafka 版 的功能。重要 为避免服务异常，在删除服务关联角色前，需要先手动删除当前阿里云账号下的所有规则引擎，请谨慎操作。...
应用场景 企业A购买了 云消息队列 RocketMQ 版 服务来开展业务，并希望将部分业务授权给企业B。具体需求如下：A希望能专注于业务系统，仅作为资源Owner；而控制台的查询资源和可观测等功能授权给企业B使用。企业A希望当企业B的员工加入或...
本文以调用Java SDK为例，介绍在RAM角色跨账号授权场景，通过开源SDK实现消息收发的操作过程，帮助您更好地理解消息收发的完整过程，其他语言或框架的SDK消息收发过程相似。前提条件 创建实例 创建Vhost 背景信息 当您需要通过RAM STS角色...
云消息队列 MQTT 版 升级后，实现了独立存储，Topic资源不再依赖于 云消息队列 RocketMQ 版，因此两个产品的Topic将完全彼此独立。本文介绍两个版本中Topic资源控制台操作的差异并提供相应控制台截图进行对比。变更说明 由于 新版本 的 云...
本文介绍 云消息队列 RocketMQ 版 使用自定义权限策略的场景和策略示例。什么是自定义权限策略 在基于RAM的访问控制体系中，自定义权限策略是指在系统权限策略之外，您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您...
新版本 除了独立存储之外，还对 旧版本 实现的 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 互通的功能进行抽象，使得 云消息队列 MQTT 版 的数据可以根据您配置相应规则转发到其他阿里云产品，也可以配置规则从其他阿里云产品导入数据...
新版本 除了独立存储之外，还对 旧版本 实现的 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 互通的功能进行抽象，使得 云消息队列 MQTT 版 的数据可以根据您配置相应规则转发到其他阿里云产品，也可以配置规则从其他阿里云产品导入数据...
同时 云消息队列 RocketMQ 版 支持ACL身份识别，您可以按需为指定ACL用户赋予具体的Topic或Group的发布订阅权限，实现客户端权限的精细化控制。使用限制 若实例未开通用户身份识别功能，则需要 提交工单 申请开通，申请通过后控制台才会...
变更说明 由于 新版本 的 云消息队列 MQTT 版 实现了自身的消息存储，因此 云消息队列 MQTT 版 实例购买开通后即可直接创建资源使用，无需和任何其他云产品绑定使用。如您只需使用MQTT协议来收发消息，则更容易理解。变更说明的详细信息，...
方案优势 触发云产品任务执行的可靠数据通道：轻量消息队列（原 MNS）的核心优势诸如异步解耦、可靠传输及削峰填谷能力，能确保通知内容能够被稳定且高效地传递，实现应用和云产品服务的松散耦合，保障在高并发请求下系统的平稳运行。...
推荐的做法是使用RAM身份（即RAM用户和RAM角色）来访问 云消息队列 RocketMQ 版。RAM用户 RAM用户需要由阿里云账号（即主账号）或拥有管理员权限的RAM用户、RAM角色来创建，且必须在获得授权后才能登录控制台或使用API访问阿里云账号下的...
本文介绍如何创建使用OSS Sink Connector，您可以通过OSS Sink Connector将数据从 云消息队列 Kafka 版 的数据源Topic导出至对象存储OSS的Object中。前提条件 详细步骤，请参见 创建前提。注意事项 Connector基于事件被处理的时间做时间...
Topic跨地域使用 不支持 云消息队列 MQTT 版 配置了相关规则实现与 云消息队列 RocketMQ 版 的数据互通，则相关资源应处于同一地域。客户端限制 限制项 限制值 说明 Client ID 名称长度：不超过64个字符 可用字符：仅限数字0~9、字母a~z或A...
消息收发为 云消息队列 MQTT 版 最基本的功能，云消息队列 MQTT 版 支持终端和云端服务接入 云消息队列 MQTT 版 服务器，实现终端和终端、终端和云端的消息通信。本文介绍消息收发功能的基本场景和示例代码。背景信息 云消息队列 MQTT 版 ...
数据交互 数据流 所展示的是基于 云消息队列 MQTT 版 和音视频通信RTC实现一次音视频通话会议的调用流程，其中灰色部分为您的自建开发程序或服务，蓝色部分是 云消息队列 MQTT 版、云消息队列 RocketMQ 版 以及音视频通信RTC所提供的服务。...
Topic跨地域使用 不支持 云消息队列 MQTT 版 配置了相关规则实现与 云消息队列 RocketMQ 版 的数据互通，则相关资源应处于同一地域。客户端限制 限制项 限制值 说明 Client ID 名称长度：不超过64个字符 可用字符：仅限数字0~9、字母a~z或A...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流入任务，实现将 云消息队列 RabbitMQ 版 的数据快速导入至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 ...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流出任务，以实现将 云消息队列 RocketMQ 版 的数据快速导出至 轻量消息队列（原 MNS）。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流出任务，以实现将 云消息队列 RocketMQ 版 数据快速导入至 云消息队列 Kafka 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流出任务，以实现将 云消息队列 RocketMQ 版 的数据快速导出至 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见...
场景描述 适用于在线教育的视频直播场景，通过阿里云视频直播服务实现移动端的推拉流能力，同时移动端利用 云消息队列 MQTT 版 实现发送和接收消息，在消息转发时利用内容安全服务对消息内容进行审核。发送的消息可以存储在表格存储中。...
通过 云消息队列 MQTT 版 所提供的服务，可采用统一的框架，即云控制台，来管理不同部署模式的云存储网关CSG（Cloud Storage Gateway），并实现安全合规的公网和私网穿透，以此提供一致的用户体验。名词解释 MQTT 一种物联网和移动互联网...
如下图所示，您可以使用MQTT.fx作为MQTT客户端，在MQTT.fx客户端配置相关参数后接入 云消息队列 MQTT 版 实现消息的发送和接收。云消息队列 MQTT 版 同时提供了 公网接入点 和 VPC 接入点。在物联网和移动互联网的场景中，客户端推荐使用 ...