本文描述轻量消息队列（原 MNS）支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制...
本文介绍 云消息队列 RocketMQ 版 使用自定义权限策略的场景和策略示例。什么是自定义权限策略 在基于RAM的访问控制体系中，自定义权限策略是指在系统权限策略之外，您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您...
概述 本文主要介绍 轻量消息队列（原 MNS）中HttpEndpoint接口接收不到消息时的排查方法。排查步骤 请参考如下步骤进行排查。使用 主题HTTP Endpoint本地调试工具 进行调试，检查HttpEndpoint接口接收消息的逻辑是否存在问题。使用该工具可...
本教程介绍如何使用Kafka Connect的Source Connector将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Kafka Connect主要用于将数据流输入和输出 云消息队列 Kafka 版。Kafka Connect主要通过各种Source Connector的实现，将数据从第三...
本文介绍如何删除某个队列的所有消息。您可以使用Java客户端库中 queuePurge 方法删除某个队列的所有消息。示例代码如下：channel.queuePurge("queue-name");
本文为您介绍使用C++ SDK接入 云消息队列 RocketMQ 版 所需完成的准备工作、使用说明以及注意事项，以便后续使用C++ SDK收发消息。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x...
本文为您介绍使用v1.x.x版本的C++ SDK接入 云消息队列 RocketMQ 版 所需完成的准备工作、使用说明以及注意事项，以便后续使用C++ SDK收发消息。使用前，请注意以下几点：本文仅针对C++ SDK v1.x.x版本进行说明。代码里涉及到的Topic和Group...
Apache RocketMQ C++ 5.0系列SDK底层基于gRPC，本文为您介绍如何使用源码编译RocketMQ C++ Client。前提条件 安装GCC 为了确保与gRPC保持相同的兼容性矩阵，编译环境需满足以下要求：编译最低需要C++ 11环境，对应GCC版本最低为4.8.5，推荐...
云消息队列 RocketMQ 版 提供C/C++ SDK实现消息发送与订阅，您可通过本文了解消息发送和订阅相关接口的参数说明。参数名 参数说明 NAMESRV_ADDR 设置TCP协议接入点，从 云消息队列 RocketMQ 版 控制台的 实例详情 页面获取。AccessKey ...
推荐版本 云消息队列 RocketMQ 版 5.x版本实例完全兼容Apache RocketMQ C++ SDK，以下版本经过阿里云工程师进行测试验证，建议您使用以下SDK版本进行消息收发。具体推荐版本：rocketmq-client-cpp-5.0.3 重要 当前版本不支持通过公网访问 ...
本文介绍如何通过 云消息队列 RocketMQ 版 的C/C++ SDK订阅消息。订阅方式 云消息队列 RocketMQ 版 支持以下两种订阅方式：集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息，一个Group ID有3个...
在使用云消息队列 Kafka 版时，客户端可能报错，您可以根据报错消息匹配对应的解决方案。详细信息 报错信息对应的详细信息如下。报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权（sasl.mechanisms）...
在使用云消息队列 Kafka 版时，客户端可能报错，您可以根据报错消息匹配对应的解决方案。详细信息 报错信息对应的详细信息如下。报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权（sasl.mechanisms）...
您可以通过basicReject或basicNack方法否定应答消息，使消息重入队列，从而是其他Consumer可以消费消息。使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。...
本教程介绍如何使用Kafka Connect的Source Connector将SQL Server的数据同步至 云消息队列 Kafka 版。前提条件 在开始本教程前，请确保您已完成以下操作：已下载SQL Server Source Connector。具体信息，请参见 SQL Server Source ...
您可以通过basicReject或basicNack方法否定应答消息，使消息重入队列，从而是其他Consumer可以消费消息。使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。...
本教程介绍如何使用Canal将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Canal的主要用途是基于MySQL数据库增量日志解析，提供增量数据订阅和消费。Canal伪装自己为MySQL Slave，向MySQL Master发送dump请求。MySQL Master收到dump...
本文介绍您在使用社区版C++ SDK接入阿里云 云消息队列 RocketMQ 版 时，需要配置的参数。通用参数 参数名 说明 NameServer 设置TCP协议接入点，从 控制台 的 实例详情 页面获取。GroupID 您在 控制台 上创建的Group ID，更多信息，请参见 ...
使用C++ SDK接入阿里云 云消息队列 RocketMQ 版 收发消息前，您需按本文提供的操作步骤安装CPP动态库。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更...
云消息队列 RocketMQ 版 5.x版本实例支持C++ 1.x SDK客户端接入，您可以使用1.x版本的SDK接入5.x实例进行消息收发。本文为您介绍1.x版本下的C++ SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发...
在使用社区版C++ SDK接入阿里云 云消息队列 RocketMQ 版 来收发消息前，您需按本文提供的操作步骤安装CPP动态库。前提条件 在开始做准备工作前，请确保您的操作系统满足以下条件：Linux：CentOS 6.8、CentOS 7.2、RHEL 6.x、RHEL 7.x ...
本文提供使用TCP协议下的C/C++ SDK收发事务消息的示例代码供您参考。云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图...
本文提供使用TCP协议下的社区版C++ SDK来收发事务消息的示例代码供您参考。阿里云 云消息队列 RocketMQ 版 提供类似X/Open XA的分布式事务功能，通过阿里云 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。交互流程 事务...
顺序消息FIFO（First In First Out）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的C/C++ SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，...
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的C++ SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格...
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的C++ SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。更...
背景信息 延时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时消息。定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端...
本文主要介绍如何使用RocketMQ 4.x/3.x系列的rocketmq-client-cpp二进制包进行部署和连接阿里云 云消息队列 RocketMQ 版 的过程。如需源码编译，请您自行前往开源社区下载。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力...
顺序消息（FIFO消息）是阿里云 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的社区版C++ SDK收发顺序消息的示例代码供您参考。顺序消息分为两类：全局顺序：对于指定的一个Topic，所有...
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的C++ SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装C++ SDK。更多信息，请参见 准备环境...
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。不同消息类型所属的Topic不能混用，例如收发普通消息的Topic不能用来收发其他类型的消息。本文提供使用TCP协议下的C/C++ SDK收发...
普通消息是指阿里云 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时消息、顺序消息和事务消息。本文提供使用TCP协议下的社区版C++ SDK收发普通消息的示例代码供您参考。前提条件 安装CPP动态库 获取阿里云访问密钥AccessKey ...
本文提供使用TCP协议下的社区版C++ SDK来收发定时和延时消息的示例代码供您参考。背景信息 定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是推迟到在当前时间点之后的某一个时间投递到...
本文为您介绍RocketMQ 5.x系列C++ SDK的消息收发示例代码。消息类型 发送消息示例代码 订阅消息示例代码 PushConsumer SimpleConsumer 普通消息 同步发送：ExampleProducer.cpp 异步发送：ExampleProducerWithAsync.cpp ...
绝大多数情况下，消息是不重复的。作为一款分布式消息中间件，在网络抖动、应用处理超时等异常情况下，无法保证消息不重复，但是能保证消息不丢失。
本文提供使用TCP协议下的C/C++ SDK收发定时消息的示例代码供您参考。定时消息可以做到在指定时间戳之后才可被消费者消费，适用于对消息生产和消费有时间窗口要求，或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意...
本文为您介绍4.x/3.x版本下的C++ SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 ...
在使用C#SDK收发消息前，您需按照本文提供的内容来准备环境。环境要求 安装.NET。更多信息，请参见 安装.NET 。安装Visual Studio 2015或以上版本，更多信息，请参见 安装Visual Studio。安装完成后，您可以执行 dotnet-version 命令查看....
云消息队列 MQTT 版 旧版本 强依赖 云消息队列 RocketMQ 版 作为消息存储，因此 云消息队列 MQTT 版 消息和 云消息队列 RocketMQ 版 天然打通，创建了Topic后即可天然使用 云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的SDK相互通信。...
云消息队列 RabbitMQ 版是阿里云消息队列（MQ）团队基于AMQP 0-9-1协议研发的分布式、高吞吐、低延迟、高可扩展的云消息队列服务。消息队列RabbitMQ版完全兼容开源RabbitMQ社区、开箱即用、无需部署、免运维，帮助您快速上云。