消息队列的功能实现-消息队列的功能实现文档介绍内容-阿里云

配额与限制

您可以使用云消息队列 RocketMQ 版提供的消息集成功能实现消息数据的流入和流出。实例规格限制标准版主系列下所有实例、以及专业版主系列下单节点版实例不支持突发弹性计算能力，您需要提前规划好资源用量，避免高水位运行时出现突发...

云存储网关利用MQTT服务实现统一管控

同时基于云消息队列 MQTT 版的推送功能也实现了输出API用于对每个CSG实例的管理。整体架构如方案架构所示。图 2.方案架构方案优势本方案的优势如下所述：服务能力强，可弹性伸缩。云消息队列 MQTT 版消息传输能力无限扩展，CSG实例...

事务消息

事务消息为云消息队列 RocketMQ 版中的高级特性消息，本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景分布式事务的诉求分布式系统调用的特点为一个核心业务逻辑的执行，同时需要调用多个下游业务...

消息过滤

主题订阅添加消息过滤标签本示例介绍通过设置订阅的标签值，将主题（TopicA）中标签值为tag-a的消息推送到队列（QueueB），实现消息过滤的功能。关于主题订阅的具体操作，请参见创建订阅。在创建订阅面板消息过滤标签中填写主题...

新功能发布记录

本文介绍云消息队列 RabbitMQ 版的产品功能动态及对应的文档。2024-03-14 功能名称功能描述功能类型相关文档新增开服地域马来西亚（吉隆坡）和美国（硅谷）地域新增支持创建Serverless实例和企业版实例。新增开服地域预付费实例...

消费进度管理

云消息队列 RocketMQ 版重置消费位点功能只能重置对消费者可见的消息，不能重置定时中、重试等待中的消息。更多信息，请参见定时/延时消息和消费重试。版本兼容性关于消费者分组的消费位点初始值，不同的服务端版本中定义如下：服务端...

服务关联角色

AliyunServiceRoleForAmqpLogDelivery：云消息队列 RabbitMQ 版通过扮演该RAM角色，获取日志服务的访问权限，以实现自身的消息日志功能。您在云消息队列 RabbitMQ 版控制台首次使用消息日志时，系统会提示您完成...

Topic使用变更

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

实例使用变更

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

服务关联角色

AliyunServiceRoleForAlikafkaConnector：云消息队列 Kafka 版通过扮演该RAM角色，获取各类与Connector相关的产品的访问权限，以实现Connector的功能。如果您是在云消息队列 Kafka 版控制台首次创建Connector，系统会提示您完成...

应用场景

下文先以用户注册为场景说明云消息队列 RocketMQ 版如何实现以下功能：异步解耦分布式事务的数据一致性 消息的顺序收发最后，再以电商的秒杀场景和价格同步场景分别说明云消息队列 RocketMQ 版所实现的削峰填谷和大规模机器的缓存...

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

V3.x.x版本除了独立存储之外，还对V2.x.x版本实现的云消息队列 MQTT 版和云消息队列 RocketMQ 版互通的功能进行抽象，使得云消息队列 MQTT 版的数据可以根据您配置相应规则转发到其他阿里云产品，也可以配置规则从其他阿里云产品导入...

消息检索

当云消息队列 Kafka 版控制台提供的按位点查询和按时间查询消息的功能无法满足您搜索消息的需求时，您可以使用云消息队列 Kafka 版消息检索功能。消息检索支持按Topic分区、位点范围、时间范围以及消息Key和Value关键字检索。本文介绍...

可观测性体系概述

本文介绍云消息队列 RocketMQ 版可观测体系的主要功能。云消息队列 RocketMQ 版的可观测体系主要由指标（Metrics）、轨迹（Tracing）和日志（Logging）组成。指标云消息队列 RocketMQ 版中定义了详细的Metrics指标，这些指标覆盖生产...

新功能发布记录

本文介绍云消息队列 Kafka 版的产品功能动态及对应的文档。2024-04-08 功能名称功能描述功能类型相关文档升级...新增消息检索功能迭代历史记录云消息队列 Kafka 版 2022年之前的功能迭代记录，请参见功能发布记录（2022年之前）。

基本概念

本文主要对云消息队列 RocketMQ 版涉及的专有名词及术语进行定义和...云消息队列 RocketMQ 版的全球消息路由功能依托阿里云优质基础设施实现的高速通道专线，可以高效地实现不同地域之间的消息同步复制。更多信息，请参见全球消息路由。

OnsMessageTrace-查看消息消费结果

本接口的实现基于云消息队列 RocketMQ 版的内部位点机制，在大部分场景下判断结果可信，但如果应用方进行过重置位点已经清除消息等操作，则判断结果可能有误。调试您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行...

计费概述

消息收发费用消息收发为云消息队列 RocketMQ 版的基础功能，您只要开通云消息队列 RocketMQ 版服务，则默认使用消息收发功能，标准版实例会计算相应费用。具体计费详情，请参见消息收发定价详情。公网费用云消息队列 RocketMQ 版 ...

什么是云消息队列 MQTT 版

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

功能使用相关问题

本文汇总了云消息队列 MQTT 版功能使用相关的常见问题。离线消息最多能保留多久？3天。仅当 QoS=1且 cleanSession=false时，云消息队列 MQTT 版才会保留离线消息，最多保留3天，超过时间将自动滚动删除。铂金版实例可支持定制。如需定制...

评估规格

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

服务关联角色

AliyunServiceRoleForRMQMigration AliyunServiceRolePolicyForRMQMigration 云消息队列 RocketMQ 版通过扮演该RAM角色，获取访问专有网络VPC 的权限，以实现自建RocketMQ集群迁移上云 的功能。策略内容 AliyunServiceRoleForOns 服务...

消息收发功能

消息收发为云消息队列 MQTT 版最基本的功能，云消息队列 MQTT 版支持终端和云端服务接入云消息队列 MQTT 版服务器，实现终端和终端、终端和云端的消息通信。本文介绍消息收发功能的基本场景和示例代码。背景信息云消息队列 MQTT 版 ...

配置消息日志

您可以使用云消息队列 RabbitMQ 版的日志管理功能将云消息队列 RabbitMQ 版实例的消息操作日志推送到日志服务。当消息的发送、消费、确认出现异常时，您可在日志服务查询并分析消息的操作日志，进行异常诊断。前提条件创建云消息队列...

使用限制

本文为您介绍云消息队列 MQTT 版对某些具体指标的约束和规范，您在使用云消息队列 MQTT 版时请不要超过相应的限制值，以免程序出现异常。具体的限制项和限制值请参见下表。如果您购买了铂金版的云消息队列 MQTT 版实例，则可按需定制...

全球消息路由

什么是全球消息路由云消息队列 RocketMQ 版的全球消息路由功能依托阿里云优质基础设施实现的高速通道专线（高速通道无需另行开通），高效地实现不同地域之间的消息同步复制。具体实现如下图所示。计费影响全球消息路由为云消息队列 ...

全球消息路由定价详情

全球消息路由为云消息队列 RocketMQ 版的高级功能，若您开通了全球消息路由功能，云消息队列 RocketMQ 版会按照按量付费的方式进行计费，未使用该服务则不计费。高级功能不能单独使用，必须配合基础功能即消息收发功能一起使用。本文...

云消息队列 MQTT 版

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

消息队列Kafka版

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

云消息队列 RabbitMQ 版

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

开源RabbitMQ迁移上云

迁移前评估技术评估云消息队列 RabbitMQ 版和开源RabbitMQ在功能、服务和性能、Exchange和Queue等几个方面存在差异，在迁移至云消息队列 RabbitMQ 版之前，请查看差异项并评估云消息队列 RabbitMQ 版 的功能是否符合您的预期。...

网络访问与安全设置

本文介绍如何进行云消息队列 Confluent 版集群的网络访问与安全设置。网络访问类型云消息队列 Confluent 版集群提供阿里云VPC访问和公网访问方式。阿里云VPC访问 VPC访问是指您在云消息队列 Confluent 版集群所在网络VPC内或者其它...

什么是云消息队列 RocketMQ 版？

为什么选择云消息队列 RocketMQ 版云消息队列 RocketMQ 版基于阿里云云原生优质的基础设施实现，兼容Apache RocketMQ的核心API和功能。相对于自建RocketMQ集群，云消息队列 RocketMQ 版具有如下优势：架构先进性全面采用存储和计算分离...

消息收发定价详情

消息收发功能为云消息队列 RocketMQ 版的基础功能，您只要开通云消息队列 RocketMQ 版服务，则默认使用消息收发功能。本文介绍云消息队列 RocketMQ 版标准版实例的消息收发功能费用详情和计费示例。计费公式标准版实例根据消息收发...

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

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

订阅消息

本文介绍如何通过云消息队列 RocketMQ 版的Java SDK订阅消息。订阅方式云消息队列 RocketMQ 版支持以下两种订阅方式：集群订阅同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息，一个Group ID有3个...

消息服务MNS

本文介绍如何在云消息队列 RocketMQ 版控制台创建消息流出任务，以实现将云消息队列 RocketMQ 版 的消息流出至消息服务MNS。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。您已...

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

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

轨迹查询

本文介绍如何使用云消息队列 MQTT 版的轨迹查询功能排查设备在线问题和消息收发问题。当设备的状态出现异常时，您可以使用设备轨迹查询功能，查询设备的连接历史；当消息的收发不符合预期时，您可以使用消息轨迹查询功能，查询消息的收发...

应用场景

云消息队列 Kafka 版忽略掉文件的细节，可以将多台主机或应用的日志数据抽象成一个个日志或事件的消息流，异步发送到云消息队列 Kafka 版集群，从而实现非常低的RT。云消息队列 Kafka 版客户端可批量提交消息和压缩消息，对生产者而言...

消息队列的功能实现

新品推荐