云消息队列 RabbitMQ 版是阿里云消息队列(MQ)团队基于AMQP 0-9-1协议研发的分布式、高吞吐、低延迟、高可扩展的云消息队列服务。消息队列RabbitMQ版完全兼容开源RabbitMQ社区、开箱即用、无需部署、免运维,帮助您快速上云。
本文为您介绍目标数据库实例为 专线/VPN网关/智能网关 方式接入的 阿里云消息队列Kafka版 时,部分特殊参数的配置方法和获取方式。注意事项 使用此方案将 阿里云消息队列Kafka版 接入DTS,会将数据写入到您指定的节点中。若您的源库为MySQL...
音视频通信解决方案是由阿里云 云消息队列 MQTT 版 和音视频通信RTC联合推出的有助于快速搭建各种实时通信场景产品,譬如在线音视频会议、1对1语音通话应用的解决方案。本文将详细描述该解决方案的系统架构、数据流设计以及相关注意事项。...
重要 社区版的Apache RocketMQ和阿里云 云消息队列 RocketMQ 版 配置方式不同,实现效果也有所差异。社区版的Apache RocketMQ支持延时消息,但不支持定时消息,因此没有专门的定时消息接口。阿里云 云消息队列 RocketMQ 版 不仅同时支持...
和开源Apache RocketMQ相比,阿里云 云消息队列 RocketMQ 版 具有更高的稳定性、安全性及更完善的运维体系。您可以将开源RocketMQ集群迁移到 云消息队列 RocketMQ 版 上以获得更好的业务体验,本文为您介绍开源RocketMQ集群迁移上云的方案...
本文介绍如何通过 云消息队列 RocketMQ 版 的C/C++ SDK订阅消息。订阅方式 云消息队列 RocketMQ 版 支持以下两种订阅方式:集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息,一个Group ID有3个...
阿里云 云消息队列 RocketMQ 版 提供三种方式来发送普通消息:同步发送、异步发送和单向(Oneway)发送。本文介绍了每种发送方式的原理、使用场景、示例代码,以及三种发送方式的对比;此外还提供了订阅普通消息的示例代码。前提条件 您已...
重要 社区版的Apache RocketMQ和阿里云 云消息队列 RocketMQ 版 配置方式不同,实现效果也有所差异。社区版的Apache RocketMQ支持延时消息,但不支持定时消息,因此没有专门的定时消息接口。阿里云 云消息队列 RocketMQ 版 不仅同时支持...
顺序消息(FIFO消息)是阿里云 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的社区版C++ SDK收发顺序消息的示例代码供您参考。顺序消息分为两类:全局顺序:对于指定的一个Topic,所有...
阿里云 云消息队列 RocketMQ 版 提供类似X/Open XA的分布式事务功能,通过阿里云 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图所示。更多信息,请参见 事务消息。前提条件 安装CPP动态...
问题描述 使用阿里云消息队列Kafka版时,删除Group后,仍然收到消息堆积的告警信息,如何过滤某个Group的消费堆积告警。问题原因 发生消息堆积告警信息的原因如下:2.2.0以前的Kafka服务端版本,开源Kafka未提供删除Group和消费位点的Open...
LocalTransactionState.UNKNOW:无法判断状态,期待阿里云 云消息队列 RocketMQ 版 的Broker向发送方再次询问该消息对应的本地事务的状态。import org.apache.rocketmq.client.producer.LocalTransactionState;import org.apache.rocketmq....
普通消息是指阿里云 云消息队列 RocketMQ 版 中无特性的消息,区别于有特性的定时消息、顺序消息和事务消息。本文提供使用TCP协议下的社区版C++ SDK收发普通消息的示例代码供您参考。前提条件 安装CPP动态库 获取阿里云访问密钥AccessKey ...
您可获取社区版TCP协议的SDK,来访问阿里云 云消息队列 RocketMQ 版。重要 所有社区版的SDK均由Apache RocketMQ社区提供,您可获取源码自行编译,但不在阿里云RocketMQ的SLA范围。和社区版SDK相比,商业版的SDK提供了更加丰富的功能特性并...
云消息队列 RocketMQ 版 5.x版本实例可兼容4.x/3.x SDK客户端接入,您可以使用4.x/3.x版本的SDK接入5.x实例进行消息收发。本文为您介绍4.x/3.x版本下的Java SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK,5.x系列SDK...
设置为您在阿里云云消息队列 RocketMQ 版控制台上创建的Topic。consumer.subscribe("YOUR TOPIC","*");consumer.registerMessageListener(new MessageListenerConcurrently(){@Override public ConsumeConcurrentlyStatus consumeMessage...
云消息队列 RocketMQ 版 5.x版本实例可兼容4.x/3.x SDK客户端接入,您可以使用4.x/3.x版本的SDK接入5.x实例进行消息收发。本文为您介绍4.x/3.x版本下的C++ SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK,5.x系列SDK作为...
云消息队列 Kafka 版 规定了阿里云向客户提供的阿里云 云消息队列 Kafka 版 的服务可用性等级指标及赔偿方案。如需查看 云消息队列 Kafka 版 的服务可用性等级指标及赔偿方案,请参见 云消息队列 Kafka 版服务等级协议。
本文介绍使用社区版TCP协议的Java SDK访问阿里云 云消息队列 RocketMQ 版 来收发消息的流程。使用说明 社区版SDK仅在开源RocketMQ迁移上云且不希望修改代码时使用,其他场景推荐您使用阿里云 云消息队列 RocketMQ 版 提供的商业版SDK进行接...
三分钟了解阿里云 云消息队列 RabbitMQ 版。
本文主要介绍如何使用开源社区发布的rocketmq-client-cpp二进制包进行部署和连接阿里云 云消息队列 RocketMQ 版 的过程。如需源码编译,请您自行前往开源社区下载。使用说明 社区版SDK仅在开源RocketMQ迁移上云且不希望修改代码时使用,...
本文从稳定性、内核能力、治理能力以及使用习惯等方面,对比阿里云 云消息队列 Kafka 版 与开源Apache Kafka。稳定性 项目 云消息队列 Kafka 版 Apache Kafka 磁盘水位 磁盘写满删除旧数据。磁盘写满直接宕机。线程池隔离 读冷数据仍可以...
本文介绍使用RocketMQ 4.x/3.x系列的Java SDK访问阿里云 云消息队列 RocketMQ 版 实例收发消息的流程。重要 推荐您使用最新的RocketMQ 5.x系列SDK,5.x系列SDK作为主力研发版本,和 云消息队列 RocketMQ 版 5.x服务端完全兼容,提供了更...
迁移前须知 云消息队列 RabbitMQ 版 是阿里云基于专有的分布式消息存储技术开发的高级消息队列服务。它严格遵循AMQP 0-9-1协议,但并不是开源RabbitMQ的简单托管版本。云消息队列 RabbitMQ 版 的架构有效避免了因消息积压导致的内存泄漏和...
如果您有共享服务需求,可考虑阿里云 云消息队列 RocketMQ 版 或 轻量消息队列(原 MNS)提供的按量付费共享服务。公测期间在所有地域(包括公网)创建的共享实例在2019年4月1日开始下线,于2019年5月底完成,届时共享实例将停止服务。请...
云消息队列 Kafka 版 优化了集群增加大量分区后带来的性能下降问题。自建开源Apache Kafka...阿里云 云消息队列 Kafka 版 对此进行了优化,单个集群的分区数理论上没有上限。但分区数的增加会消耗一些服务端资源,因此增加分区数需要收费。
新零售电子价签解决方案由阿里云 云消息队列 MQTT 版 推出,通过MQTT以实现商场超市、公共场所电子标签、多媒体屏幕的数据更新管理。本文将以电子价签为例详细描述该解决方案的系统架构、数据流设计以及注意事项,其他类似行业可参考该方案...
不支持。与开源RabbitMQ的单机部署天然支持顺序消息不同,阿里云 云消息队列 RabbitMQ 版 为自研产品,分布式部署,暂不支持顺序消息。
在运行Java SDK代码收发消息前,您需按照本文...代码里涉及到的资源信息,例如阿里云 云消息队列 RocketMQ 版 实例、Topic和Group ID等,需要到阿里云 云消息队列 RocketMQ 版 控制台 上创建。更多信息,请参见 创建资源。后续步骤 示例代码
在运行Java SDK代码收发消息前,您需按照本文...代码里涉及到的资源信息,例如阿里云 云消息队列 RocketMQ 版 实例、Topic和Group ID等,需要到阿里云 云消息队列 RocketMQ 版 控制台 上创建。更多信息,请参见 创建资源。后续步骤 示例代码
阿里云基于Confluent Platform提供全托管的 云消息队列 Confluent 版,提供消息流式处理能力以及大数据系统的集成的一站式解决方案。本文介绍 云消息队列 Confluent 版 提供的能力及产品优势。前置概念 阅读本文前,您可能需要了解如下概念...
迁移元数据上云是指将开源RabbitMQ集群的元数据导出,并将其导入到阿里云 云消息队列 RabbitMQ 版 实例。云消息队列 RabbitMQ 版 会根据成功导入的元数据在目标 云消息队列 RabbitMQ 版 实例中创建对应的Vhost、Queue、Exchange、Binding,...
SDK调用 阿里云 云消息队列 MQTT 版 提供多语言的SDK。阿里云SDK免去您手动签名的过程,方便使用。SDK详细信息,请参见 获取OpenAPI的SDK。OpenAPI开发者门户调用 使用OpenAPI开发者门户的API调试功能,您可以通过网页或者命令行调用各云...
本文介绍如何在 云消息队列 Kafka 版 控制台创建迁移任务,将元数据迁移至 云消息队列 Kafka 版 已有实例。前提条件 下载JDK 8 购买并部署 云消息队列 Kafka 版 实例:购买并部署VPC实例 购买并部署公网/VPC实例 背景信息 Kafka集群元数据...
本文主要介绍如何使用RocketMQ 4.x/3.x系列的rocketmq-client-cpp二进制包进行部署和连接阿里云 云消息队列 RocketMQ 版 的过程。如需源码编译,请您自行前往开源社区下载。重要 推荐您使用最新的RocketMQ 5.x系列SDK,5.x系列SDK作为主力...
本文以社区版Apache RocketMQ Client为例,提供操作示例帮助您从零开始搭建阿里云 云消息队列 RocketMQ 版 收发消息的测试工程。Demo工程包含普通消息、顺序消息、事务消息的测试代码。前提条件 安装IDE。您可以使用IntelliJ IDEA或者...
针对该问题,阿里云 云消息队列 RocketMQ 版 推出了权益分发解决方案。本文将以电商场景为例说明权益分发解决方案的背景信息、方案架构、以及方案优势等内容。背景信息 在电商平台运营决定对特定用户进行营销活动时,会针对不同的用户群...
SDK兼容性说明 云消息队列 RocketMQ 版 服务端版本和客户端SDK版本的兼容情况如下:服务端版本 协议 客户端版本 兼容性 约束限制 5.x版本实例 gRPC协议v2 RocketMQ 5.x SDK 兼容 云消息队列 RocketMQ 版 5.x版本实例的所有功能完全支持。...
本文介绍您在使用社区版C++ SDK接入阿里云 云消息队列 RocketMQ 版 时,需要配置的参数。通用参数 参数名 说明 NameServer 设置TCP协议接入点,从 控制台 的 实例详情 页面获取。GroupID 您在 控制台 上创建的Group ID,更多信息,请参见 ...