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

基本概念

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

什么是云消息队列 Kafka 版？

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

什么是云消息队列 MQTT 版

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

标签管理

标签可以识别资源，您可以将作用相同的云消息队列 RocketMQ 版的资源通过标签进行归类，便于搜索和资源聚合。云消息队列 RocketMQ 版支持为实例、Topic和Group添加标签，并支持修改和删除标签。本文介绍标签的应用场景、使用说明、使用...

消息（Message）

消息持久化云消息队列 RocketMQ 版会默认对消息进行持久化，即将接收到的消息存储到云消息队列 RocketMQ 版服务端的存储文件中，保证消息的可回溯性和系统故障场景下的可恢复性。模型关系在整个云消息队列 RocketMQ 版的领域模型中...

创建RabbitMQ Source Connector

本文介绍如何在云消息队列 Kafka 版控制台创建流入任务，将云消息队列 RabbitMQ 版中的数据快速导入至云消息队列 Kafka 版。前提条件您已购买云消息队列 Kafka 版实例，且实例处于服务中状态。具体步骤，请参见步骤二：购买和...

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

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

消息检索

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

顺序消息

如果是普通消息，订单A的消息可能会被轮询发送到不同的队列中，不同队列的消息将无法保持顺序，而顺序消息发送时云消息队列 RocketMQ 版支持将Sharding Key相同（例如同一订单号）的消息序路由到一个队列中。云消息队列 RocketMQ 版服务...

将云消息队列 Kafka 版接入阿里云Elasticsearch

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

获取MQTT客户端在线状态

下文以云消息队列 RocketMQ 版作为后端存储消息队列的情况为例说明。操作步骤创建上下线事件对应的Topic。您需关注哪些Group ID分组的设备，就在云消息队列 MQTT 版控制台创建对应的Topic。创建Topic的步骤请参见 MQTT快速入门。例如...

集成概述

数据清洗/数据流出 Connector生态集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等操作。并支持将完成ETL处理的数据转储到下游。...

功能特性

迁移上云数据路由备份动态路由消息可以基于内容、规则或者其他属性，实时地决定其投递路径，而无需预先配置固定的消息队列或主题。这允许系统根据消息本身的特性、现有的业务需求或其他动态因素实时调整路由决策，从而提高了消息传递的...

队列模型基本概念

生产者（Producer）向消息服务MNS 的消息队列发送消息的角色。消费者（Consumer）从消息服务MNS 的消息队列获取消息的角色。Endpoint 消息服务MNS 的访问域名地址，格式如下：http://$AccountId.mns.$Region.aliyuncs....

QueueMessage

MNS会尽量让高优先级的消息先出队列，正是因为分布式消息队列的一些特性不能百分之百保证高优先级的消息先被消费。消息类型延时消息这类消息发送到队列后，需要经过DelaySeconds指定的时间后才可被消费。发送（batch）send message请求时...

队列模型快速入门

消息最大长度：发送到队列的消息体的最大长度。长轮询时间：当队列中没有消息时，该队列的ReceiveMessage请求的最大等待时长。消息可见性超时时间：消息从队列中取出后从Active状态变成Inactive状态后的持续时间。消息保存时长：消息在队列...

队列控制台操作帮助

消息最大长度：发送到队列的消息体的最大长度。长轮询时间：当队列中没有消息时，该队列的ReceiveMessage请求的最大等待时长。消息可见性超时时间：消息从队列中取出后从Active状态变成Inactive状态后的持续时间。消息保存时长：消息在队列...

概述

数据清洗/数据流出消息集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等操作。并支持将完成ETL处理的数据转储到下游。Serverless...

什么是云消息队列 RocketMQ 版？

业务消息异步解耦、削峰填谷云消息队列 RocketMQ 版初始于阿里巴巴双十一核心链路，广泛应用于物流、购物车、积分等微服务业务系统，有效承载系统间异步解耦和流量削峰填谷的作用。通过使用云消息队列 RocketMQ 版，可有效实现如下作用...

资源使用变更

云消息队列 MQTT 版从V2.x.x升级至V3.x.x实现了自身数据存储的能力，同时还去除了对云消息队列 RocketMQ 版 的消息依赖，因此，云消息队列 MQTT 版的实例和Topic使用有变更。资源 V2.x.x使用说明 V3.x.x使用说明云消息队列 MQTT 版 ...

计费常见问题

若您使用云消息队列 MQTT 版的数据流入、数据流出规则和云消息队列 RocketMQ 版进行通信，云消息队列 RocketMQ 版会根据调用的云消息队列 RocketMQ 版 的消息收发API或Topic资源等进行计费。客户端上线下事件流出到消息队列RocketMQ...

Topic使用变更

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

计费FAQ

本文汇总了云消息队列 RabbitMQ 版计费的常见问题。向10个Queue发送同一条消息，为什么收10次API调用费？将1条消息发送给10个Queue，实际上是10次API调用。为什么删除的Vhost、Exchange、Queue会被自动重建并重新开始计费？虽然删除了...

计费FAQ

本文汇总了云消息队列 RabbitMQ 版计费的常见问题。向10个Queue发送同一条消息，为什么收10次API调用费？将1条消息发送给10个Queue，实际上是10次API调用。为什么删除的Vhost、Exchange、Queue会被自动重建并重新开始计费？虽然删除了...

数据流入规则管理

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

V2.x.x到V3.x.x的升级公告

升级说明云消息队列 MQTT 版的V3.x.x版本相比V2.x.x版本而言，实现了自身的消息独立存储，再也无需强制绑定云消息队列 RocketMQ 版，因此购买开通云消息队列 MQTT 版实例后即可直接创建资源，从而降低您的使用与理解成本。V3.x.x版本...

MQTT快速入门

步骤一：创建资源这里所说的资源包括：云消息队列 MQTT 版实例（用于客户端连接维持和消息转发）消息存储实例（用于消息的存储，目前只支持云消息队列 RocketMQ 版实例）Topic（用于消息发送和订阅的消息一级主题，即父级Topic）Group ...

实例使用变更

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

直播互动解决方案

MQTT服务器云消息队列 MQTT 版提供的MQTT协议交互的服务端节点，用于完成与MQTT客户端和云消息队列 RocketMQ 版各自的消息收发。MQTT客户端用于和MQTT服务器交互的移动端节点，全称为云消息队列 MQTT 版客户端。父级Topic（Parent ...

数据流出规则管理

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

开通服务并授权

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

迁移概述

重要 消息队列的特点是，数据一旦被消费，则已经完成使命。因此，除了需要将自建Kafka集群的数据备份云消息队列 Kafka 版实例的情况外，一般情况下不推荐您迁移数据。查看迁移进度：查看自建Kafka集群迁移到云消息队列 Kafka 版的进度...

概述

混合云场景：您既有部署在IDC的开源RocketMQ，也有部署在阿里云公有云上的云消息队列 RocketMQ 版，且需要同时访问两种部署模式下的消息队列服务端。您有两套环境，测试环境和线上环境；其中测试环境部署的是开源RocketMQ，线上环境部署的...

评估规格

本文说明迁移前如何使用云消息队列 Kafka 版的规格评估功能为迁移上云的自建Kafka集群选择合适的实例规格。前提条件注册阿里云账号并完成实名认证。详细信息，请参见注册阿里云账号。使用说明云消息队列 Kafka 版提供的规格评估功能...

退款说明

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

开通消息队列服务并授权

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

调用方式

Action：要执行的操作，如调用 ListInstances 查询已创建的云消息队列 RabbitMQ 版实例。Version：要使用的API版本，云消息队列 RabbitMQ 版的API版本是 2019-12-12。Parameters：请求参数，每个参数之间用“&”分隔。请求参数由公共...

开通消息队列服务并授权

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

上下线通知规则管理

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

死信队列

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

消息队列的作用

新品推荐