阿里的消息队列-阿里的消息队列文档介绍内容-阿里云

收发定时消息和延时消息

重要社区版的Apache RocketMQ和阿里云云消息队列 RocketMQ 版配置方式不同，实现效果也有所差异。社区版的Apache RocketMQ支持延时消息，但不支持定时消息，因此没有专门的定时消息接口。阿里云云消息队列 RocketMQ 版不仅同时支持...

概述

本文介绍使用社区版TCP协议的Java SDK访问阿里云云消息队列 RocketMQ 版来收发消息的流程。使用说明社区版SDK仅在开源RocketMQ迁移上云且不希望修改代码时使用，其他场景推荐您使用阿里云云消息队列 RocketMQ 版提供的商业版SDK进行接...

收发普通消息（三种方式）

阿里云云消息队列 RocketMQ 版提供三种方式来发送普通消息：同步发送、异步发送和单向（Oneway）发送。本文介绍了每种发送方式的原理、使用场景、示例代码，以及三种发送方式的对比；此外还提供了订阅普通消息的示例代码。前提条件您已...

收发顺序消息

顺序消息（FIFO消息）是阿里云云消息队列 RocketMQ 版提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的社区版C++ SDK收发顺序消息的示例代码供您参考。顺序消息分为两类：全局顺序：对于指定的一个Topic，所有...

MQTT和RocketMQ进行数据互通（跨产品数据流入）

如果您的云端应用需要使用云消息队列 RocketMQ 版产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将云消息队列 MQTT 版和云消息队列 RocketMQ 版数据进行流转。本文介绍如何将云消息队列 RocketMQ...

收发事务消息

LocalTransactionState.UNKNOW：无法判断状态，期待阿里云云消息队列 RocketMQ 版的Broker向发送方再次询问该消息对应的本地事务的状态。import org.apache.rocketmq.client.producer.LocalTransactionState;import org.apache.rocketmq....

跨云产品数据流入

注意事项云消息队列 MQTT 版通过配置的流入规则和云消息队列 RocketMQ 版进行跨云产品的消息交互时，若云消息队列 RocketMQ 版的服务端进行升级，则在升级期间，可能会造成云消息队列 MQTT 版客户端消费消息延迟。产品升级动态，请...

收发事务消息

阿里云云消息队列 RocketMQ 版提供类似X/Open XA的分布式事务功能，通过阿里云云消息队列 RocketMQ 版事务消息，能达到分布式事务的最终一致。交互流程事务消息交互流程如下图所示。更多信息，请参见事务消息。前提条件安装CPP动态...

MQTT和RocketMQ进行数据互通（客户端上下线通知）

MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息，云消息队列 MQTT 版支持将该条消息数据导出至其他阿里云产品，并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的云消息队列 RocketMQ 版数据互通...

收发普通消息

普通消息是指阿里云云消息队列 RocketMQ 版中无特性的消息，区别于有特性的定时消息、顺序消息和事务消息。本文提供使用TCP协议下的社区版C++ SDK收发普通消息的示例代码供您参考。前提条件安装CPP动态库获取阿里云访问密钥AccessKey ...

4.x和5.x版本差异及兼容性说明

云消息队列 RocketMQ 版是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云云消息队列 RocketMQ 版将为您提供更加稳定可靠的服务端5...

4.x和5.x版本差异及兼容性说明

云消息队列 RocketMQ 版是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云云消息队列 RocketMQ 版将为您提供更加稳定可靠的服务端5...

概述

本文主要介绍如何使用RocketMQ 4.x/3.x系列的rocketmq-client-cpp二进制包进行部署和连接阿里云云消息队列 RocketMQ 版的过程。如需源码编译，请您自行前往开源社区下载。重要推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力...

什么是云消息队列 Kafka 版？

云消息队列 Kafka 版是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 版广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，已成为大数据生态中不可或缺的部分。产品优势云消息队列 ...

数据流入规则管理

注意事项云消息队列 MQTT 版通过配置的流入规则和云消息队列 RocketMQ 版进行跨云产品的消息交互时，若云消息队列 RocketMQ 版的服务端进行升级，则在升级期间，可能会造成云消息队列 MQTT 版客户端消费消息延迟。产品升级动态，请...

迁移上云操作

重要开源Apache RocketMQ 4.x版本没有消息类型的概念，阿里云云消息队列 RocketMQ 版会对Topic的消息类型和Message的类型进行一致性校验，因此在元数据迁移时，您需要根据实际业务场景手动录入Topic的消息类型。如果消息类型选择错误，...

Demo工程

本文以社区版Apache RocketMQ Client为例，提供操作示例帮助您从零开始搭建阿里云云消息队列 RocketMQ 版收发消息的测试工程。Demo工程包含普通消息、顺序消息、事务消息的测试代码。前提条件安装IDE。您可以使用IntelliJ IDEA或者...

什么是云消息队列 MQTT 版

如果说传统的消息队列中间件一般应用于微服务之间，那么适用于物联网的云消息队列 MQTT 版则实现了端与云之间的消息传递和真正意义上的万物互联。本文介绍云消息队列 MQTT 版的消息收发模型、产品优势和应用场景。核心概念 Topic：消息...

实例使用变更

变更说明由于V3.x.x版本的云消息队列 MQTT 版实现了自身的消息存储，因此云消息队列 MQTT 版实例购买开通后即可直接创建资源使用，无需和任何其他云产品绑定使用。如您只需使用MQTT协议来收发消息，则更容易理解。变更说明的详细信息...

快速使用MQTT的Java SDK收发消息（终端和终端消息收发...

本文介绍如何快速使用云消息队列 MQTT 版的Java SDK实现MQTT终端与终端消息的收发。前提条件创建资源获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。下载安装 JDK。背景信息云消息队列 MQTT ...

概述

本文介绍使用RocketMQ 4.x/3.x系列的Java SDK访问阿里云云消息队列 RocketMQ 版实例收发消息的流程。重要推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更...

功能发布列表

功能描述变更类型相关文档 5.x系列实例自建RocketMQ集群迁移上云提供开源RocketMQ集群迁移上云工具，支持分批次将元数据迁移至阿里云云消息队列 RocketMQ 版的实例中，并支持按Topic粒度对客户端读写流量进行切换实现业务消息的迁移...

跨云产品的数据流出

映射关系 MQTT资源其他阿里云产品其他阿里云产品资源数据包定义 MQTT Topic 云消息队列 RocketMQ 版云消息队列 RocketMQ 版的Topic MQTT与RocketMQ的消息结构映射更多信息如需了解控制台上的操作，请参见数据流出规则管理。

Topic使用变更

变更说明由于V3.x.x版本的云消息队列 MQTT 版实现了自身的消息存储，因此所有的云消息队列 MQTT 版 Topic资源都需要在云消息队列 MQTT 版控制台或调用其OpenAPI进行管理。云消息队列 MQTT 版的Topic资源不再和云消息队列 RocketMQ ...

收发定时和延时消息

重要社区版的Apache RocketMQ和阿里云云消息队列 RocketMQ 版配置方式不同，实现效果也有所差异。社区版的Apache RocketMQ支持延时消息，但不支持定时消息，因此没有专门的定时消息接口。阿里云云消息队列 RocketMQ 版不仅同时支持...

通过元数据文件迁移上云

元数据迁移是指将自建Kafka集群的元数据迁移到阿里云云消息队列 Kafka 版实例。您可以将自建Kafka集群元数据导出，然后导入云消息队列 Kafka 版实例，云消息队列 Kafka 版会根据成功导入的元数据在目标云消息队列 Kafka 版实例中...

从自建MySQL同步至云消息队列 Kafka 版

背景信息云消息队列 Kafka 版是阿里云提供的分布式、高吞吐、可扩展的消息队列服务，针对开源的Apache Kafka提供全托管服务，彻底解决开源产品长期以来的痛点，您只需专注于业务开发，无需部署运维。云消息队列 Kafka 版广泛用于日志...

数据流出规则管理

如需将云消息队列 MQTT 版的数据导出至其他阿里云产品，您需创建数据流出规则。该规则用于将MQTT客户端发送的消息导出到您配置的其他阿里云产品中，从而实现直接调用云产品的API读取MQTT客户端发送的消息。流程说明规则限制限制项限制...

消息检索

例如，消息Key是“云消息队列 Kafka 版是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。可以设置搜索关键词为“分布式”，或者“阿里云”和“分布式”组合。如果搜索关键字中包含星号（*）或问号?则采用通配符检索。星号（*）代表...

开通服务并授权

在阿里云官方网站开通消息队列服务后方可开始使用云消息队列 MQTT 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的云消息队列 MQTT 版资源，并使用SDK收发消息。前提条件您已注册阿里云账号并完成...

MQTT与RocketMQ的消息结构映射

本文针对使用云消息队列 RocketMQ 版 SDK与云消息队列 MQTT 版交互的场景，提供交互中所涉及的消息结构和属性字段的映射关系，方便您更好的理解和组合使用这两个产品。云消息队列 MQTT 版是一款面向移动端的网关产品，可通过数据互通...

SDK参考概述

SDK兼容性说明云消息队列 RocketMQ 版服务端版本和客户端SDK版本的兼容情况如下：服务端版本客户端版本兼容性约束限制 5.x版本实例 RocketMQ 5.x SDK 兼容云消息队列 RocketMQ 版 5.x版本实例的所有功能完全支持。RocketMQ 4.x/3.x ...

队列（MessageQueue）

队列的主要作用如下：存储顺序性队列天然具备顺序性，即消息按照进入队列的顺序写入存储，同一队列间的消息天然存在顺序关系，队列头部为最早写入的消息，队列尾部为最新写入的消息。消息在队列中的位置和消息之间的顺序通过位点（Offset...

退款说明

本文介绍了云消息队列 Kafka 版支持的退款情况。根据计费方式的特点，云消息队列 Kafka 版资源支持的退款情况如下：包年包月的云消息队列 Kafka 版资源如需退款，可在控制台上退订实例。详细信息，请参见实例生命周期管理。按量计费...

开源RabbitMQ迁移上云

迁移前须知云消息队列 RabbitMQ 版是阿里云基于专有的分布式消息存储技术开发的高级消息队列服务。它严格遵循AMQP 0-9-1协议，但并不是开源RabbitMQ的简单托管版本。云消息队列 RabbitMQ 版的架构有效避免了因消息积压导致的内存泄漏和...

迁移概述

迁移原理对于消息队列来说，如果要实现集群迁移，只需消费完旧集群的消息即可。由于Producer和Consumer都是集群化的，您可以通过一台一台机器操作的方式实现上层业务无感知。迁移方式迁移路由借助工具迁移迁移说明迁移不会删除自建的...

上下线通知规则管理

说明云消息队列 MQTT 版和云消息队列 RocketMQ 版 的消息结构映射信息，请参见 MQTT和RocketMQ的消息结构映射。编辑上下线通知规则在规则列表，找到您想编辑的规则，并在其操作列选择更多>编辑。在编辑规则页面，您可以更新除规则...

权限策略

云消息队列 MQTT 版权限管理是通过阿里云的访问控制RAM（Resource Access Management）实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKey ID和AccessKey Secret），按需为用户分配最小权限。本文介绍云...

基本概念

每个分区都是一个有序的消息队列，可以独立地进行读写操作。分区数的选择通常根据吞吐量和并发性能的需求来决定。副本数云消息队列 Kafka 版允许为每个分区创建多个副本，以提供数据冗余和高可用性。副本数是指每个分区存在的副本数量。...

死信队列

对于消费失败且重试后依然失败的消息，云消息队列 RocketMQ 版不会立丢弃，而是将消息转发至指定的队列中，即死信队列，这些消息即为死信消息。当消费失败的原因排查并解决后，您可以重发这些死信消息，让消费者重新消费；若您暂时无法...

阿里的消息队列

新品推荐