顺序消息
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步，...
签名鉴权模式
如果您需使用 云消息队列 MQTT 版 的签名鉴权模式，可根据本文提供的签名计算方式获取签名，再使用控制台来验证计算得出的签名是否正确。签名计算方式 按照 鉴权概述 的描述，如果选择签名校验模式，MQTT客户端实际连接MQTT消息服务器时，...
RBAC授权
本文介绍如何在 云消息队列 Confluent 版 控制台中进行RBAC授权。背景信息 RBAC的全称是Role Based Access Control。RBAC的授权方式是基于角色进行授权的，而ACL是基于权限进行授权。因此，RBAC比ACL更适合批量授权以及权限回收。RBAC授权...
云消息队列 Kafka 版服务等级协议
云消息队列 Kafka 版 规定了阿里云向客户提供的阿里云 云消息队列 Kafka 版 的服务可用性等级指标及赔偿方案。如需查看 云消息队列 Kafka 版 的服务可用性等级指标及赔偿方案，请参见 云消息队列 Kafka 版服务等级协议。
快速入门概述
本文为您介绍快速使用 云消息队列 RabbitMQ 版 进行消息收发的操作流程。操作流程 后续步骤 步骤一：（可选）RAM用户授权 步骤二：创建资源 步骤三：调用SDK收发消息
收发定时消息和延时消息
重要 社区版的Apache RocketMQ和阿里云 云消息队列 RocketMQ 版 配置方式不同，实现效果也有所差异。社区版的Apache RocketMQ支持延时消息，但不支持定时消息，因此没有专门的定时消息接口。阿里云 云消息队列 RocketMQ 版 不仅同时支持...
数据流出规则管理
如需将 云消息队列 MQTT 版 的数据导出至其他阿里云产品，您需创建数据流出规则。该规则用于将MQTT客户端发送的消息导出到您配置的其他阿里云产品中，从而实现直接调用云产品的API读取MQTT客户端发送的消息。流程说明 规则限制 限制项 限制...
关于TCP内网接入点设置的公告
为了进一步提升 云消息队列 RocketMQ 版 服务的稳定性，并以此保障您应用的稳定性，针对部署在某地域（Region）的应用，如果您使用的是TCP协议下的SDK，则需使用该地域的 云消息队列 RocketMQ 版 服务的TCP内网接入点。本文提供对应地域的...
查看Rebalance详情
当消费客户端出现Rebalance时，您可以查看Rebalance的详情，包括Rebalance的时间、耗时、次数、原因以及...后续步骤 当客户端频繁出现Rebalance时，您可以参考以下文档解决此问题：使用云消息队列 Kafka 版时消费客户端频繁出现Rebalance。
定时/延时消息
定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻...
HTTP SDK错误码列表
本文介绍使用 云消息队列 RocketMQ 版 提供的商业版HTTP协议的SDK收发消息时可能遇到的错误码，以及建议的处理方式。错误码 错误描述 HTTP状态码 建议处理方式 AccessDenied The OwnerId that your Access Key Id associated to is ...
使用云消息队列 Kafka 版时客户端的报错及解决方案
在使用云消息队列 Kafka 版时，客户端可能报错，您可以根据报错消息匹配对应的解决方案。详细信息 报错信息对应的详细信息如下。报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权（sasl.mechanisms）...
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
P2P消息收发模式（MQTT）
本文介绍P2P模式的概念、原理以及如何使用 云消息队列 MQTT 版 点对点收发消息。什么是P2P模式 P2P，顾名思义，是一对一的消息收发模式，即只有一个消息发送者和一个消息接收者。而Pub/Sub模式通常用于一对多或多对多的消息群发场景，即...
上下线通知规则管理
云消息队列 MQTT 版 实例版本 仅内核版本为V3.x.x的实例支持使用规则，V2.x.x的实例不支持使用规则。云消息队列 MQTT 版 实例的内核版本可在 控制台 实例列表或实例详情页面查看。云消息队列 RocketMQ 版 实例版本 仅4.0系列实例支持 云...
P2P消息收发模式（MQTT）
本文介绍P2P模式的概念、原理以及如何使用 云消息队列 MQTT 版 点对点收发消息。什么是P2P模式 P2P，顾名思义，是一对一的消息收发模式，即只有一个消息发送者和一个消息接收者。而Pub/Sub模式通常用于一对多或多对多的消息群发场景，即...
使用Canal和RocketMQ实现数据库变更订阅处理
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版，实现MySQL数据库Binlog数据的变更处理。背景信息 CDC（Change Data Capture）是一种监测并捕获数据库变更的典型技术方案，常应用于异构数据源之间的数据同步。Canal...
收发普通消息（三种方式）
阿里云 云消息队列 RocketMQ 版 提供三种方式来发送普通消息：同步发送、异步发送和单向（Oneway）发送。本文介绍了每种发送方式的原理、使用场景、示例代码，以及三种发送方式的对比；此外还提供了订阅普通消息的示例代码。前提条件 您已...
什么是消息队列RabbitMQ版？
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品。云消息队列 RabbitMQ 版 兼容开源RabbitMQ客户端，解决开源各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等云...
收发事务消息
LocalTransactionState.UNKNOW：无法判断状态，期待阿里云 云消息队列 RocketMQ 版 的Broker向发送方再次询问该消息对应的本地事务的状态。import org.apache.rocketmq.client.producer.LocalTransactionState;import org.apache.rocketmq....
MQTT和RocketMQ进行数据互通（跨产品数据流入）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
API概览
本产品（云消息队列 Kafka 版/2019-09-16）的OpenAPI采用 RPC 签名风格，签名细节参见 签名机制说明。我们已经为开发者封装了常见编程语言的SDK，开发者可通过 下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用...
使用云消息队列 Kafka 版时出现消息堆积
使用 云消息队列 Kafka 版 时，可能会发现Group中出现消息堆积。本文介绍如何判断消息堆积是否属于正常情况，以及处理方法。客户端消费流程 了解客户端消费流程，有助于理解消息是否堆积。一般情况下，客户端消费流程大致如下：判断消息...
使用Canal和RocketMQ实现数据库变更订阅处理
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版，实现MySQL数据库Binlog数据的变更处理。背景信息 CDC（Change Data Capture）是一种监测并捕获数据库变更的典型技术方案，常应用于异构数据源之间的数据同步。Canal...
Demo工程
本文介绍 云消息队列 MQTT 版 的Demo工程，包含各种应用场景的使用指导，请参见程序源码的文档注释进行理解。获取多语言Demo 示例代码全集请参见 mqtt-demo。下载完成后解压即可看到本地新增了 mqtt-demo-main 文件夹。其中一级文件夹是...
云端SDK常见问题
本文介绍使用 云消息队列 MQTT 版 云端SDK时的常见问题。使用云端SDK发送消息成功，为什么无法消费？云端SDK发送消息，只能使用终端SDK消费消息；或终端SDK发送消息，云端SDK消费消息，不支持云端SDK发送消息，云端SDK消费消息。终端SDK...
实例使用变更
云消息队列 MQTT 版 从V2.x.x升级至V3.x.x后，不再需要...说明 如果您需要将 云消息队列 MQTT 版 的数据与其他阿里云产品进行互通，则需要使用规则。详细信息，请参见 跨云产品的数据互通。更多信息 实例的控制台相关操作，请参见 实例管理。
计费常见问题
本文汇总了 云消息队列 MQTT 版 计费相关的常见问题。...云消息队列 MQTT 版 按量付费的计费周期为24小时，即阿里云将在下一个自然日对您上一个自然日的服务使用进行计量、出具账单，并从您的阿里云账户中按账单金额扣除服务费用。
消息过滤
消费者订阅了某个主题后，云消息队列 RocketMQ 版 会将该主题中的所有消息投递给消费者。若消费者只需要关注部分消息，可通过设置过滤条件在 云消息队列 RocketMQ 版 服务端进行过滤，只获取到需要关注的消息子集，避免接收到大量无效的...
Serverless版实例计费
云消息队列 MQTT 版 的Serverless实例购买成功后，默认为您预留固定规格的资源，若实际使用量超过预留规格，则按照实际使用量弹性计费，可以帮助您提高资源利用率并降低业务成本。重要 Serverless版实例购买后，无论是否使用实例都会开始按...
新功能发布记录
阿里云费用中心提供的 CreateInstance 接口仍继续支持创建 云消息队列 RabbitMQ 版 实例。建议您使用 云消息队列 RabbitMQ 版 的接口。新增 CreateInstance 2023-10-24 功能名称 功能描述 功能类型 相关文档 Serverless后付费实例 云消息...
MQTT和RocketMQ进行数据互通（客户端上下线通知）
MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息，云消息队列 MQTT 版 支持将该条消息数据导出至其他阿里云产品，并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的 云消息队列 RocketMQ 版 数据互通...
什么是云消息队列 Kafka 版？
三分钟了解阿里云 云消息队列 Kafka 版。
调用方式
Version：要使用的API版本，云消息队列 MQTT 版 的API版本是 2020-04-20。Parameters：请求参数，每个参数之间用“&”分隔。请求参数由公共请求参数和API自定义参数组成。公共参数中包含API版本号、身份验证等信息，详细信息，请参见 公共...
Topic管理
根据MQTT协议，Topic存在多级，定义第一级Topic为父级Topic，在使用 云消息队列 MQTT 版 前，需先创建该父级Topic资源。注意事项 Topic不能跨实例使用，例如不能使用实例B的接入点订阅创建在实例A中的Topic。Topic名称长度限制为3~64个字符...
什么是云消息队列 RabbitMQ 版
三分钟了解阿里云 云消息队列 RabbitMQ 版。
快速使用MQTT的Java SDK收发消息（终端和终端消息收发...
本文介绍如何快速使用 云消息队列 MQTT 版 的Java SDK实现MQTT终端与终端消息的收发。前提条件 创建资源 获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。下载安装 JDK。背景信息 云消息队列 MQTT ...
迁移元数据上云
迁移元数据上云是指将开源RabbitMQ集群的元数据导出，并将其导入到阿里云 云消息队列 RabbitMQ 版 实例。云消息队列 RabbitMQ 版 会根据成功导入的元数据在目标 云消息队列 RabbitMQ 版 实例中创建对应的Vhost、Queue、Exchange、Binding，...
RAM鉴权
云消息队列 MQTT 版 权限管理是通过阿里云的访问控制RAM（Resource Access Management）产品实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKey ID和AccessKey Secret），按需为用户分配最小权限。在使用...
资源使用变更
云消息队列 MQTT 版 从V2.x.x升级至V3.x.x实现了自身数据存储的能力，同时还去除了对 云消息队列 RocketMQ 版 的消息依赖，因此，云消息队列 MQTT 版 的实例和Topic使用有变更。资源 V2.x.x使用说明 V3.x.x使用说明 云消息队列 MQTT 版 ...
- 产品推荐
- 这些文档可能帮助您