步骤四：接收消息 当触发了事件匹配规则时，轻量消息队列将自动创建主题（Topic），Topic名称格式为 mns-en-topics-[Product]-[RuleName]-[Timestamp]，例如 mns-en-topics-oss-notification1-1700098799。此时，您需要为该Topic创建订阅，...
本文介绍如何应用 事件总线EventBridge 的事件流功能实现 轻量消息队列（原 MNS）的消息路由。前提条件 您已 开通事件总线EventBridge并授权。您已创建 轻量消息队列（原 MNS）队列。具体步骤，请参见 开通轻量消息队列（原 MNS）并授权。...
您可以通过PDS管理控制台配置事件通知规则，当这些PDS接口中对资源操作发生指定事件时，您可以通过 轻量消息队列（原 MNS）指定的接收终端，及时收到指定的事件通知。场景描述 某企业在华东1（杭州）地域创建了名为xxxx的域，该企业期望...
本文介绍如何在 Serverless 应用引擎 SAE（Serverless App Engine）上基于阿里云 云消息队列 RocketMQ 版 实现环境隔离，您可以在不修改任何业务代码的情况下，实现异步场景下的流量控制。背景信息 支持RocketMQ版本：4.2.0及以上版本。...
通过消息队列这类异步场景下的流量控制，您可以在不需要修改任何业务代码的情况下，实现全链路灰度。本文介绍MSE基于消息队列RocketMQ版实现全链路灰度。前提条件 开通MSE微服务治理。创建ACK托管集群。Demo架构 本文以容器服务控制台部署...
当配置审计发现资源配置有变更且不合规时，以事件通知的形式将告警推送到您指定的轻量消息队列（原 MNS）主题。当您收到不合规告警时，通过函数计算2.0实现不合规资源的自动修复。前提条件 请确保您已使用规则模板创建规则。具体操作，请...
背景信息 在直播互动的场景下，您需创建相应的数据互通规则实现 云消息队列 MQTT 版 与 云消息队列 RocketMQ 版 的数据互通，包含 数据流入规则、数据流出规则 以及 客户端上下线通知规则。使用 云消息队列 MQTT 版 的客户端收发消息时，...
Knative已支持Kafka事件源，您可将Knative与 云消息队列 Kafka 版 对接，在Knative上实现Kafka消息推送。前提条件 部署与管理Knative组件 购买并部署云消息队列 Kafka 版实例 重要 云消息队列 Kafka 版 实例和Knative必须处于同一VPC内。云...
本文为您介绍如何快速使用 云消息队列 RocketMQ 版 实现消息收发。使用流程 快速使用 云消息队列 RocketMQ 版 收发消息的流程如下图所示。使用说明 权限说明 若您的账号为RAM用户，则必须先为该RAM用户进行授权，才能访问 云消息队列 ...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流出任务，以实现将 云消息队列 RocketMQ 版 指定实例的数据导入至另外的 云消息队列 RocketMQ 版 实例。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。...
云消息队列 RocketMQ 版 支持通过RAM和ACL实现对 云消息队列 RocketMQ 版 资源的访问控制。使用限制 若实例未开通用户身份识别功能，则需要 提交工单 申请开通，申请通过后控制台才会出现访问控制的操作入口。类型 权限说明 授权对象 是否...
本文主要介绍 云消息队列 RabbitMQ 版 的顺序消费实现原理，与开源RabbitMQ的不同之处，以及其配置方式和使用限制。顺序消费实现原理 RabbitMQ的顺序消费需要“顺序存储”和“单一消费者”两个条件同时满足才能实现。开源 RabbitMQ 实现 ...
本文介绍 轻量消息队列（原 MNS）通过事件通知实时处理OSS文件变动的功能说明和操作指南。通过事件通知实时处理OSS文件变动 功能说明 当您需要对 ...在 OSS管理控制台 配置事件通知，详情请参见 教程示例：结合轻量消息队列实现OSS事件通知。
前提条件 已创建 云消息队列 RocketMQ 版 实例。版本要求：云消息队列 RocketMQ 版 4.0系列实例。说明 4.0系列实例标准版仅支持单向同步。云消息队列 RocketMQ 版 5.0系列实例。本文以源集群和目标集群均为 云消息队列 RocketMQ 版 5.0系列...
实例是用于 云消息队列 MQTT 版 服务的虚拟机资源，会存储消息主题（Topic）和客户端ID（Group ID）信息。按照计费方式，云消息队列 MQTT 版 提供包年包月（预付费）计费模式的实例。实例规格分为企业铂金版、标准版和专业版。使用限制 ...
本文介绍如何快速使用 云消息队列 MQTT 版 的Java SDK实现MQTT终端和云端服务的消息收发。前提条件 创建资源 获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。下载安装 JDK。背景信息 MQTT终端和...
本文介绍使用RocketMQ 4.x/3.x系列的Java SDK访问阿里云 云消息队列 RocketMQ 版 实例收发消息的流程。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更...
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版，实现MySQL数据库Binlog数据的变更处理。背景信息 CDC（Change Data Capture）是一种监测并捕获数据库变更的典型技术方案，常应用于异构数据源之间的数据同步。Canal...
本文介绍如何将 云消息队列 Kafka 版 接入Filebeat。Filebeat Filebeat是用于转发和集中日志数据的轻量级传输程序。Filebeat可以监听指定的日志文件或位置，从中收集日志事件并将其转发到Elasticsearch或Logstash进行索引。Filebeat的工作...
前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且该实例必须满足以下条件：项目 说明 状态 服务中。版本 大版本为2.2.0，且小版本为最新版本。说明 您可以在 云消息队列 Kafka 版 控制台的 实例详情 页面的 基础信息 区域查看实例的...
本文为您介绍如何在 轻量消息队列（原 MNS）控制台上快速上手使用队列模型。前提条件 开通轻量消息队列（原 MNS）并授权 创建队列 登录 轻量消息队列（原 MNS）控制台。在左侧导航栏，选择 队列模型 队列列表。在顶部菜单栏，选择地域。在 ...
云消息队列 RocketMQ 版 支持以下两种订阅方式：集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息，一个Group ID有3个Consumer实例，那么在集群消费模式下每个实例平均分摊，只消费其中的3条消息。...
前提条件 如果您要使用SSL连接AMQProxy和 云消息队列 RabbitMQ 版，请确保您的客户端服务器已安装OpenSSL。更多信息，请参见 Downloads。重要 VPC环境下不支持使用SSL连接 云消息队列 RabbitMQ 版。背景信息 部分语言的客户端，例如PHP客户...
本文介绍如何进一步提高您与 轻量消息队列（原 MNS）服务之间的网络链路上的安全性。背景信息 轻量消息队列（原 MNS）提供在公网HTTPS上进行消息加密传输的服务。对于包含敏感信息的消息，进一步提高您与阿里云服务之间的网络链路上的安全...
支持。轻量消息队列（原 MNS）支持顺序消息的能力，详情请参见 顺序消息。
云消息队列 RocketMQ 版 支持将指定实例的Topic列表信息导出，再导入至其他的 云消息队列 RocketMQ 版 实例，实现Topic的跨实例迁移。您可以在更换实例或者克隆实例时，使用Topic导入/导出功能快速批量创建出相同的Topic。背景信息 云消息...
各终端设备均通过终端SDK 云消息队列 MQTT 版 与 云消息队列 MQTT 版 服务端连接实现消息收发。本文以公网环境为例，说明如何使用Java SDK完成消息收发。接入点说明 终端和云端服务与 云消息队列 MQTT 版 通信时，需要在各自的SDK代码中...
轻量消息队列（原 MNS）提供公网接入点的访问控制功能，用于控制客户端是否可以连接 轻量消息队列（原 MNS）服务，您可以配置规则拒绝所有来自公网接入点的请求或只允许部分IP访问公网接入点。功能介绍 关闭公网访问：可以关闭公网访问，只...
用户名 集群 资源 角色 ksql Kafka cluster Topic DeveloperRead 操作 登录 云消息队列 Confluent 版 控制台，在左侧导航栏，单击 实例列表。在顶部菜单栏，选择地域，然后在 实例列表 页面，单击目标实例名称。在 实例详情 页面，单击右上...
在 服务 区域，选择云服务 轻量消息队列（原 MNS）。在 操作 区域，选择 指定操作，然后选中 写操作 中的 mns:SendMessage 复选框。在 资源 区域，选择 全部资源 或 指定资源。在 创建权限策略 对话框，输入 策略名称 和 备注，然后单击 ...
在使用开源RabbitMQ集群时，当您希望能够解决各种稳定性痛点（例如消息堆积、脑裂等问题）、实现高并发、分布式、灵活扩缩容时，您可以将开源RabbitMQ集群迁移至 云消息队列 RabbitMQ 版，本文介绍迁移上云的前提条件、操作步骤、注意事项...
操作 访问级别 资源类型 条件关键字 关联操作 mq:DisasterDowngrade update*全部资源*无 无 请求参数 名称 类型 必填 描述 示例值 InstanceId string 是 云消息队列 MQTT 版实例的 ID。mqtt-cn-xxx DowngradeInstanceId string 是 降级的...
本文为您介绍 云消息队列 Confluent 版 实例消息收发时实现Schema格式校验的整体流程和操作。通过Schema格式校验，可以确保生产者发送的消息符合预定义的数据结构，从而提高数据一致性和系统可靠性。操作流程 步骤一：购买和部署实例 购买...
云消息队列 RocketMQ 版 发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求，因此在事务消息的Check方法中，需要完成两件事情：检查该半事务消息对应的本地事务的状态（committed or ...
操作 访问级别 资源类型 条件关键字 关联操作 mq:DisasterRecovery update*全部资源*无 无 请求参数 名称 类型 必填 描述 示例值 InstanceId string 是 消息队列 MQTT 版实例的 ID。mqtt-cn-xxx RecoveryInstanceId string 是 需要恢复的...
本文介绍 云消息队列 MQTT 版 客户端在Token模式下如何上传Token、更新Token、监听Token失效信息和监听Token非法信息。Token模式MQTT客户端连接参数设置 MQTT支持三种模式的Token，每个客户端每个类型至多申请一个Token，根据实际需要可能...
借助 云消息队列 Kafka 版 ACL功能，您可以按需为SASL用户赋予向 云消息队列 Kafka 版 收发消息的权限，从而实现权限分割。说明 仅专业版实例支持ACL功能。启用 禁用 禁用 VPC 传输加密 是否启用消息传输加密。仅当启用 ACL 功能 时，方可...
轻量消息队列（原 MNS）支持作为云事件和工作流之间的通道，当云事件产生时自动触发工作流的运行，实现自动化的工作流处理。通过轻量消息队列（原 MNS）触发工作流 功能说明 工作流集群支持事件驱动功能，可通过监控事件触发工作流自动运行...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务，将 云消息队列 Kafka 版 的数据导出至 轻量消息队列（原 MNS）。前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买...
轻量消息队列（原 MNS）支持一对多拉取消息消费模型，以满足一对多订阅、主动拉取的场景。本文介绍如何高效利用该模型实现多消费者并行拉取与处理消息。说明 本文以Java SDK为例介绍广播拉取消息流程，其他语言SDK请参见 新版SDK参考（推荐...