使用ACL功能进行访问控制
云消息队列 Kafka 版 优化了PLAIN机制，支持不重启实例的情况下动态增加SASL用户。SCRAM：一种用户名密码校验机制，安全性比PLAIN更高。云消息队列 Kafka 版 使用SCRAM-SHA-256。密码 SASL用户的密码。确认密码 确认SASL用户的密码。创建...
Spring集成
背景信息 云消息队列 RocketMQ 版 支持以下消息类型的生产者和消费者与Spring集成：普通消息的生产者和消费者 事务消息的生产者和消费者 顺序消息的生产者和消费者 说明 云消息队列 RocketMQ 版 暂不支持Spring框架下定时消息和延时消息的...
消息负载均衡策略
云消息队列 RocketMQ 版 的消息负载均衡策略针对生产者和消费者有所差异。对消费者而言，消息负载均衡策略在一定程度上影响消息堆积。背景信息 随着SDK版本的升级，云消息队列 RocketMQ 版 的负载均衡策略也有所优化，根据SDK版本，负载...
死信队列
重要 对于顺序消息消费产生的死信消息，不支持从死信队列重新发送，您需要将消息从死信队列导出后自行处理。死信消息被重新发送后不会在死信队列中立即被删除，等到死信消息的有效期到期后才会被自动删除。单条重发 在 云消息队列 RocketMQ...
使用限制
云消息队列 RocketMQ 版 对某些具体指标进行了约束和规范，您在使用 云消息队列 RocketMQ 版 时注意不要超过相应的限制值，以免程序出现异常。限制项 限制值 说明 Topic名称长度 64个字符 Topic名称长度不得超过该限制，否则会导致无法发送...
CreateSaslUser-创建SASL用户
消息队列 Kafka 版优化了 PLAIN 机制，支持不重启实例的情况下动态增加 SASL 用户。scram：一种用户名密码校验机制，安全性比 PLAIN 更高。消息队列 Kafka 版使用 SCRAM-SHA-256。默认值为 plain。plain Mechanism string 否 加密方式。...
迁移上云概述
业务入侵小、易实施 迁移过程中仅需要相关业务应用更改接入点配置并重启应用一次，后续切流全部由 云消息队列 RocketMQ 版 服务端动态配置生效。消息的上下游链路可自由升级，无需梳理收发链路依赖。整个操作流程影响范围小，便于上下游...
Demo工程
针对初次接触 云消息队列 RocketMQ 版 的工程师，本文以TCP协议下的Java SDK为例，提供操作示例帮助您从零开始搭建 云消息队列 RocketMQ 版 测试工程。Demo工程包含普通消息、顺序消息、事务消息、定时和延时消息的测试代码，以及相关...
Group导入/导出
云消息队列 RocketMQ 版 支持将指定实例的Group列表信息导出，再导入至其他的 云消息队列 RocketMQ 版 实例，实现Group的跨实例迁移。你可以在更换实例或者克隆实例时，使用Group导入/导出功能快速批量创建出相同的Group。背景信息 您可以...
DescribeSaslUsers-查询SASL用户
消息队列 Kafka 版优化了 PLAIN 机制，支持不重启实例的情况下动态增加 SASL 用户。scram：一种用户名密码校验机制，安全性比 PLAIN 更高。消息队列 Kafka 版使用 SCRAM-SHA-256。默认值为 plain。scram Password string 密码。Username ...
YARN调度器
租户间公平性调度策略：租户间公平性是指对处于同一层级的队列（父队列相同），调度时按各个队列保障资源的使用比例从低到高的顺序进行，优先满足保障资源用量少的队列的资源使用需求。如果配置了队列优先级，同一层级的队列首先将分为两组...
概述
本文介绍使用社区版TCP协议的Java SDK访问阿里云 云消息队列 RocketMQ 版 来收发消息的流程。使用说明 社区版SDK仅在开源RocketMQ迁移上云且不希望修改代码时使用，其他场景推荐您使用阿里云 云消息队列 RocketMQ 版 提供的商业版SDK进行接...
概述
本文介绍使用RocketMQ 4.x/3.x系列的Java SDK访问阿里云 云消息队列 RocketMQ 版 实例收发消息的流程。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更...
普通消息
普通消息为 云消息队列 RocketMQ 版 中最基础的消息，区别于有特性的顺序消息、定时/延时消息和事务消息。本文为您介绍普通消息的应用场景、功能原理、使用方法和使用建议。应用场景 普通消息一般应用于微服务解耦、事件驱动、数据集成等...
Demo工程
本文以社区版Apache RocketMQ Client为例，提供操作示例帮助您从零开始搭建阿里云 云消息队列 RocketMQ 版 收发消息的测试工程。Demo工程包含普通消息、顺序消息、事务消息的测试代码。前提条件 安装IDE。您可以使用IntelliJ IDEA或者...
发布者最佳实践
本文介绍 云消息队列 Kafka 版 发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息 发送消息的示例代码如下：Future...
事务消息
消息回查：由于网络闪断、生产者应用重启等原因，导致某条事务消息的二次确认丢失，云消息队列 RocketMQ 版 服务端通过扫描发现某条消息长期处于“半事务消息”时，需要主动向消息生产者询问该消息的最终状态（Commit或是Rollback），该...
定时/延时消息
定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻...
排他队列
如果您想创建一个只有自己可见的队列，不允许其他用户访问，您可以使用 云消息队列 RabbitMQ 版 的排他性队列特性，将指定的队列声明为排他性。什么是排他队列 排他性队列的特点如下：排他队列只对首次声明它的连接（Connection）可见，...
步骤二：创建资源
在调用SDK收发消息前，您需要提前创建 云消息队列 RocketMQ 版 的相关资源，包括创建 云消息队列 RocketMQ 版 实例、获取实例的接入点、创建Topic、创建ConsumerGroup。调用SDK时，需要将这些资源信息填写到SDK代码中。前提条件 创建专有...
普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。说明 您在调用SDK收发消息时需注意，云消息队列 RocketMQ 版 提供的四种消息类型所对应的Topic不能混用，例如，您创建的普通消息...
Topic管理
Topic是 云消息队列 RocketMQ 版 里对消息的一级归类。云消息队列 RocketMQ 版 支持发布和订阅模型，通过Topic完成消息的发布和订阅。消息生产者将消息发送到Topic中，而消息消费者则通过订阅该Topic来消费消息。本文介绍如何在 云消息队列...
参数说明
参数名 参数说明 NAMESRV_ADDR 设置TCP协议接入点，从 云消息队列 RocketMQ 版 控制台的 实例详情 页面获取。AccessKey AccessKey ID，阿里云身份验证标识。获取方式，请参见 创建AccessKey。SecretKey AccessKey Secret，阿里云身份验证...
参数说明
云消息队列 RocketMQ 版 提供C/C++ SDK实现消息发送与订阅，您可通过本文了解消息发送和订阅相关接口的参数说明。参数名 参数说明 NAMESRV_ADDR 设置TCP协议接入点，从 云消息队列 RocketMQ 版 控制台的 实例详情 页面获取。AccessKey ...
仪表盘
借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力，云消息队列 RocketMQ 版 提供仪表盘功能。该功能可帮助您一站式、全方位、多维度地统计和观测指标，进而快速了解业务的运行状态。本文介绍仪表盘的应用场景、业务背景...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。不同消息类型所属的Topic不能混用，例如收发普通消息的Topic不能用来收发其他类型的消息。本文提供使用TCP协议下的C/C++ SDK收发...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用TCP协议下的.NET SDK收发普通消息的示例代码。前提条件 您已完成以下操作：下载.NET SDK。更多信息，请参见 版本...
消息收发流程变更
云消息队列 MQTT 版 V2.x.x版本强依赖 云消息队列 RocketMQ 版 作为消息存储，因此 云消息队列 MQTT 版 消息和 云消息队列 RocketMQ 版 天然打通，创建了Topic后即可天然使用 云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的SDK相互通信...
消息收发计算规格费用
包年包月或按量付费计费方式下，消息收发计算规格为 云消息队列 RocketMQ 版 的必选计费项，云消息队列 RocketMQ 版 根据消息收发TPS上限提供不同的计算规格，并按照规格大小和购买时长计算费用。计算规格说明 计算规格能力约束 消息收发...
资源使用变更
云消息队列 MQTT 版 从V2.x.x升级至V3.x.x实现了自身数据存储的能力，同时还去除了对 云消息队列 RocketMQ 版 的消息依赖，因此，云消息队列 MQTT 版 的实例和Topic使用有变更。资源 V2.x.x使用说明 V3.x.x使用说明 云消息队列 MQTT 版 ...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的C#SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装C#SDK。更多信息，请参见 准备环境。...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Node.js SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Node.js SDK。更多信息，请参见 ...
MQTT与RocketMQ的消息结构映射
本文针对使用 云消息队列 RocketMQ 版 SDK与 云消息队列 MQTT 版 交互的场景，提供交互中所涉及的消息结构和属性字段的映射关系，方便您更好的理解和组合使用这两个产品。云消息队列 MQTT 版 是一款面向移动端的网关产品，可通过数据互通...
默认配置映射关系
映射关系如下：消息服务MNS 默认入参 目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$.data.body ...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Python SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Python SDK。更多信息，请参见 ...
默认配置映射关系
映射关系如下：消息服务MNS 默认入参 目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$.data.body ...
默认配置映射关系
映射关系如下：消息服务MNS 默认入参 目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$.data.body ...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Java SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Java SDK。更多信息，请参见 准备...
计费FAQ
本文汇总了 云消息队列 RabbitMQ 版 计费的常见问题。向10个Queue发送同一条消息，为什么收10次API调用费？将1条消息发送给10个Queue，实际上是10次API调用。为什么删除的Vhost、Exchange、Queue会被自动重建并重新开始计费？虽然删除了...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的C++ SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装C++ SDK。更多信息，请参见 准备环境...
- 产品推荐
- 这些文档可能帮助您