通过消息队列这类异步场景下的流量控制，您可以在不需要修改任何业务代码的情况下，实现全链路灰度。本文介绍MSE基于消息队列RocketMQ版实现全链路灰度。前提条件 开通MSE微服务治理。创建Kubernetes托管版集群。Demo架构 本文以容器服务...
本文介绍如何在 Serverless应用引擎SAE（Serverless App Engine）上基于阿里云 消息队列RocketMQ版 实现环境隔离，您可以在不修改任何业务代码的情况下，实现异步场景下的流量控制。背景信息 支持RocketMQ版本：4.2.0及以上版本。支持Pull...
云消息队列 RocketMQ 版 的所有主题都是由多个队列组成，以此实现队列数量的水平拆分和队列内部的流式存储。队列的主要作用如下：存储顺序性 队列天然具备顺序性，即消息按照进入队列的顺序写入存储，同一队列间的消息天然存在顺序关系，...
本文以阿里云消息队列 RocketMQ 为例，介绍了如何使用 ACM 对消息队列 RocketMQ 实现流量控制。迁移到MSE Nacos ACM进入下线状态，所有配置管理相关的需求由MSE中的Nacos承接（ACM独享版，更好的安全和稳定性）。您需要在ACM控制台导出配置...
主题内部由多个队列组成，消息的存储和水平扩展能力最终是由队列实现的；并且针对主题的所有约束和属性设置，最终也是通过主题内部的队列来实现。内部属性 主题名称 定义：主题的名称，用于标识主题，主题名称集群内全局唯一。取值：由用户...
消息存储 主题（Topic）：云消息队列 RocketMQ 版 消息传输和存储的分组容器，主题内部由多个队列组成，消息的存储和水平扩展实际是通过主题内的队列实现的。队列（MessageQueue）：云消息队列 RocketMQ 版 消息传输和存储的实际单元容器，...
通过镜像队列或仲裁队列实现，容易出现脑裂问题。消息堆积能力 在海量消息堆积的情况下，始终保持高性能，不影响集群的正常服务。大量消息堆积容易引起内存问题，可能导致服务宕机。弹性能力 通过增减集群节点数量实现扩缩容。Serverless...
云消息队列 RocketMQ 版 的所有主题都是由多个队列组成，以此实现队列数量的水平拆分和队列内部的流式存储。队列通过QueueId来做唯一标识和区分。更多信息，请参见 队列（MessageQueue）。消息（Message）消息是 云消息队列 RocketMQ 版 中...
i+){/普通消息发送时无需客户端额外设置，由SDK内置逻辑实现队列轮询和平均分配。Message message=messageBuilder.setTopic("normalTopic")/设置消息索引键，可根据关键字精确查找某条消息。setKeys("messageKey")/设置消息Tag，用于消费端...
本文为您介绍如何快速使用 云消息队列 RocketMQ 版 实现消息收发。使用流程 快速使用 云消息队列 RocketMQ 版 收发消息的流程如下图所示。使用说明 权限说明 若您的账号为RAM用户，则必须先为该RAM用户进行授权，才能访问 云消息队列 ...
通过 云消息队列 MQTT 版 所提供的服务，可采用统一的框架，即云控制台，来管理不同部署模式的云存储网关CSG（Cloud Storage Gateway），并实现安全合规的公网和私网穿透，以此提供一致的用户体验。名词解释 MQTT 一种物联网和移动互联网...
Knative已支持Kafka事件源，您可将Knative与 云消息队列 Kafka 版 对接，在Knative上实现Kafka消息推送。前提条件 部署Knative 购买并部署 云消息队列 Kafka 版 实例 重要 云消息队列 Kafka 版 实例和Knative必须处于同一VPC内。云消息队列...
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版，实现MySQL数据库Binlog数据的变更处理。背景信息 CDC（Change Data Capture）是一种监测并捕获数据库变更的典型技术方案，常应用于异构数据源之间的数据同步。Canal...
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版，实现MySQL数据库Binlog数据的变更处理。背景信息 CDC（Change Data Capture）是一种监测并捕获数据库变更的典型技术方案，常应用于异构数据源之间的数据同步。Canal...
本文说明JMS客户端如何在主账号与RAM账号场景接入 云消息队列 RabbitMQ 版 并实现Pub/Sub消息收发。前提条件 创建实例 创建Vhost 创建Exchange 创建Queue 创建绑定关系 背景信息 一条消息可以被多个订阅者消费。当某个发布者向某个Topic...
某个发布者向某个Queue（队列）发送消息后，某个指定的订阅者从该Queue接收消息。发布者和订阅者之间不存在时间依赖性。发布者向Queue发送消息时不需要订阅者同时处于活跃状态，订阅者从Queue接收消息时同样不需发布者处于活跃状态。开源...
本文介绍如何快速使用 云消息队列 MQTT 版 的Java SDK实现MQTT终端和云端服务的消息收发。前提条件 创建资源 获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。下载安装 JDK。背景信息 MQTT终端和...
本文介绍JMS客户端如何在RAM角色跨账号授权场景接入 云消息队列 RabbitMQ 版 并实现P2P消息收发。前提条件 创建实例 创建Vhost 创建Exchange 创建Queue 创建绑定关系 背景信息 JMS P2P JMS P2P（点对点）消息收一条消息被一个指定的订阅者...
本文说明JMS客户端如何在RAM角色跨账号授权场景接入 云消息队列 RabbitMQ 版 并实现Pub/Sub消息收发。前提条件 创建实例 创建Vhost 创建Exchange 创建Queue 创建绑定关系 背景信息 一条消息可以被多个订阅者消费。当某个发布者向某个Topic...
云消息队列 RocketMQ 版 支持将指定实例的Topic列表信息导出，再导入至其他的 云消息队列 RocketMQ 版 实例，实现Topic的跨实例迁移。您可以在更换实例或者克隆实例时，使用Topic导入/导出功能快速批量创建出相同的Topic。背景信息 云消息...
云消息队列 RocketMQ 版 支持将指定实例的Topic列表信息导出，再导入至其他的 云消息队列 RocketMQ 版 实例，实现Topic的跨实例迁移。您可以在更换实例或者克隆实例时，使用Topic导入/导出功能快速批量创建出相同的Topic。背景信息 云消息...
云消息队列 RocketMQ 版 支持将指定实例的Group列表信息导出，再导入至其他的 云消息队列 RocketMQ 版 实例，实现Group的跨实例迁移。你可以在更换实例或者克隆实例时，使用Group导入/导出功能快速批量创建出相同的Group。背景信息 您可以...
云消息队列 RocketMQ 版 支持将指定实例的Group列表信息导出，再导入至其他的 云消息队列 RocketMQ 版 实例，实现Group的跨实例迁移。你可以在更换实例或者克隆实例时，使用Group导入/导出功能快速批量创建出相同的Group。背景信息 您可以...
本文介绍如何快速使用 云消息队列 MQTT 版 的Java SDK实现MQTT终端与终端消息的收发。前提条件 创建资源 获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。下载安装 JDK。背景信息 云消息队列 MQTT ...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流入任务，实现将其他数据源中的数据快速导入 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已购买...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流入任务，实现将其他数据源中的数据快速导入 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。创建...
仅限有权限的RAM用户可以通过 云消息队列 RocketMQ 版 控制台或API管理指定资源。应用场景 企业A购买了 云消息队列 RocketMQ 版 服务，...相关文档 权限概述 通过RAM角色实现跨云账号授权 服务关联角色 云消息队列 RocketMQ 版自定义权限策略
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
微消息队列MQTT版权限管理是通过阿里云的访问控制RAM（Resource Access Management）产品实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKeyId和AccessKeySecret），按需为用户分配最小权限。在使用RAM账号...
本文介绍使用RocketMQ 4.x/3.x系列的Java SDK访问阿里云 云消息队列 RocketMQ 版 实例收发消息的流程。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更...
实例是用于 云消息队列 MQTT 版 服务的虚拟机资源，会存储消息主题（Topic）和客户端ID（Group ID）信息。按照计费方式，云消息队列 MQTT 版 提供包年包月（预付费）计费模式的实例。实例规格分为企业铂金版、标准版 和专业版。使用限制 ...
什么是全球消息路由 云消息队列 RocketMQ 版 的全球消息路由功能依托阿里云优质基础设施实现的高速通道专线（高速通道无需另行开通），高效地实现不同地域之间的消息同步复制。具体实现如下图所示。计费影响 全球消息路由为 云消息队列 ...
消息服务MNS 提供短轮询（Short Polling）和长轮询（Long Polling）两种方式来获取队列中的消息。短轮询 创建队列时，长轮询时间设置为0，且发起popMessage请求时 waitSeconds 设置为0。使用短轮询获取队列中的消息，popMessage请求会向...
云监控服务具有指标采集、可视化、实时报警等功能，云消息队列 ...相关文档 通过监控报警您可为 云消息队列 RocketMQ 版 的核心监控项和业务指标配置告警规则，具体的告警配置原则和推荐的指标项，请参见 配置消息监控告警实现风险预警。
应用场景 企业A购买了 云消息队列 RocketMQ 版 服务来开展业务，并希望将部分业务授权给企业B。具体需求如下：A希望能专注于业务系统，仅作为资源Owner；而消息发布和订阅等任务委托或授权给企业B。企业A希望当企业B的员工加入或离职时，...
云监控服务具有监控数据收集、可视化和实时监控报警等功能。...相关文档 通过监控报警您可为 云消息队列 RocketMQ 版 的核心监控项和业务指标配置告警规则，具体的告警配置原则和推荐的指标项，请参见 配置消息监控告警实现风险预警。
该规则用于从您配置的阿里云产品中读取数据并将数据通过MQTT协议推送到MQTT客户端，从而实现直接调用阿里云产品的API发送数据到MQTT客户端。流程说明 规则限制 限制项 限制值 说明 单实例规则数量 100 如果默认限制不满足，请联系 云消息...
背景信息 企业A购买了 云消息队列 RocketMQ 版 服务来开展业务，并希望将部分业务授权给企业B。需求说明：A希望能专注于业务系统，仅作为资源Owner；而消息发布和订阅等任务委托或授权给企业B。企业A希望当企业B的员工加入或离职时，无需做...
在此基础上，除了可以本地域间消息转发，也可以支持跨地域消息转发，以便您按需同步消息，实现不同实例、不同Vhost间的消息路由。注意事项 使用全球消息路由功能会带来额外的费用，计费说明如下：总费用=云消息队列 RabbitMQ 版 费用+事件...