阿里alibaba 消息队列怎么用-阿里alibaba 消息队列怎么用文档介绍内容-阿里云

消费重试

消费者出现异常，云消息队列 RocketMQ 版会根据消费重试策略重新投递该消息进行故障恢复。本文介绍消费重试的应用场景、原理机制、版本兼容性和使用建议。应用场景云消息队列 RocketMQ 版的消费重试主要解决的是业务处理逻辑失败导致的...

跨云产品的数据流出

您可通过配置云消息队列 MQTT 版的数据流出规则来自定义数据从云消息队列 MQTT 版流出至其他阿里云产品。本文介绍数据流出的原理、应用场景、使用限制以及云消息队列 MQTT 版与其他阿里云产品的资源映射关系。基本原理如需将云消息...

跨云产品数据流入

您可通过配置云消息队列 MQTT 版的数据流入规则来自定义数据从其他阿里云产品流入到云消息队列 MQTT 版。本文介绍跨产品数据流入的原理、应用场景、使用限制以及云消息队列 MQTT 版与其他阿里云产品的资源映射关系。基本原理如需将...

默认配置映射关系

映射关系如下：消息服务MNS 默认入参目标端类型模式值云消息队列 Kafka 版部分事件$.data.value 云消息队列 RocketMQ 版部分事件$.data.body 云消息队列 RabbitMQ 版部分事件$.data.body 云消息队列 MQTT 版部分事件$.data.body ...

默认配置映射关系

映射关系如下：消息服务MNS 默认入参目标端类型模式值云消息队列 Kafka 版部分事件$.data.value 云消息队列 RocketMQ 版部分事件$.data.body 云消息队列 RabbitMQ 版部分事件$.data.body 云消息队列 MQTT 版部分事件$.data.body ...

默认配置映射关系

映射关系如下：消息服务MNS 默认入参目标端类型模式值云消息队列 Kafka 版部分事件$.data.value 云消息队列 RocketMQ 版部分事件$.data.body 云消息队列 RabbitMQ 版部分事件$.data.body 云消息队列 MQTT 版部分事件$.data.body ...

基于Flink的资讯场景实时数仓

部署架构图选用的产品云消息队列 Kafka 版云消息队列 Kafka 版是阿里云基于Apache Kafka构建的高吞吐量、高可扩展性的分布式消息队列服务，广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等，是大数据生态中不可或缺的...

Topic使用变更

云消息队列 MQTT 版从V2.x.x升级至V3.x.x后，实现了独立存储，Topic资源不再依赖于云消息队列 RocketMQ 版，因此两个产品的Topic将完全彼此独立。本文介绍两个版本中Topic资源控制台操作的差异并提供相应控制台截图进行对比。变更说明 ...

视频专区

本文为您介绍云消息队列 RocketMQ 版的操作视频。云消息队列 RocketMQ 版5.x系列快速使用云消息队列 RocketMQ 版5.x系列的Java SDK收发消息云消息队列 RocketMQ 版4.x系列快速使用云消息队列 RocketMQ 版4.x系列的Java SDK收发消息

默认配置映射关系

映射关系如下：消息服务MNS 默认入参源端类型模式值云消息队列 Kafka 版部分事件$.data.value 云消息队列 RocketMQ 版部分事件$.data.body 云消息队列 RabbitMQ 版部分事件$.data.body 云消息队列 MQTT 版部分事件$.data.body 数据...

产品架构

云消息队列 Kafka 版系统架构如云消息队列 Kafka 版的系统架构所示，一个云消息队列 Kafka 版集群包括Producer、Kafka Broker、Group、ZooKeeper。图 1.云消息队列 Kafka 版的系统架构 Producer 通过push模式向云消息队列 Kafka 版...

消息存储和清理机制

本文为您介绍云消息队列 RocketMQ 版中消息的存储机制，包括消息的存储粒度、判断依据及后续处理策略等。背景信息参考云消息队列 RocketMQ 版中队列的定义，消息按照达到服务器的先后顺序被存储到队列中，理论上每个队列都支持无限...

RAM主子账号授权

在阿里云控制台首页顶部，找到搜索文本框输入并单击 消息队列for Apache RocketMQ，即可访问云消息队列 RocketMQ 版的控制台。使用RAM用户的AccessKey调用API。在代码中使用RAM用户的AccessKey ID和AccessKey Secret即可，获取方式，请...

产品概述

本文介绍云消息队列 Kafka 版的产品动态、产品简介及产品计费。云消息队列 Kafka 版动态与公告产品简介产品计费云消息队列 Confluent 版什么是云消息队列 Confluent 版？产品计费

什么是消息队列RabbitMQ版？

云消息队列 RabbitMQ 版是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品。云消息队列 RabbitMQ 版兼容开源RabbitMQ客户端，解决开源各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等云...

快速入门

如果您是首次使用云消息队列 RocketMQ 版，您可以参考快速入门文档，了解如何购买实例并接入云消息队列 RocketMQ 版服务端完成基本的消息收发流程。使用流程快速使用云消息队列 RocketMQ 版收发消息的流程如下图所示。详细操作，请...

开通服务并授权

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

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

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

网络访问与安全设置

阿里云VPC访问 VPC访问是指您在云消息队列 Confluent 版集群所在网络VPC内或者其它VPC访问和使用云消息队列 Confluent 版集群。此时，除Control Center提供公网访问方式外，其它集群组件无法从公网访问。公网访问公网访问是指您可以在...

MQTT与RocketMQ的消息结构映射

云消息队列 MQTT 版是一款面向移动端的网关产品，可通过数据互通规则实现与其他阿里云产品，例如云消息队列 RocketMQ 版的交互。规则的详细信息，请参见规则管理。如果单独使用云消息队列 MQTT 版，则无需关注本文提供的映射关系，...

开通消息队列服务并授权

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

Terraform

本文介绍Terraform的基本概念和针对云消息队列 Kafka 版的应用场景。什么是Terraform 基本功能 Terraform是IT基础架构自动化编排工具，可以用代码来管理维护IT资源。更多信息，请参见什么是Terraform。Terraform的命令行接口CLI...

删除Group后仍然收到消息堆积的告警信息

问题现象使用阿里云云消息队列 Kafka 版时，删除 Group 后，仍然收到消息堆积的告警信息。可能原因发生消息堆积告警信息的原因如下：2.0.0以前的Kafka服务端版本，开源Kafka未提供删除 Group 和消费位点的OpenAPI，因此删除 Group，...

使用限制

云消息队列 RocketMQ 版对某些具体指标进行了约束和规范，您在使用云消息队列 RocketMQ 版时不要超过对应的限制值，避免程序出现异常。云消息队列 RocketMQ 版5.x系列 5.x系列使用限制云消息队列 RocketMQ 版4.x系列 4.x系列使用限制

开通消息队列服务并授权

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

快速入门概述

本文为您介绍如何快速使用云消息队列 RocketMQ 版实现消息收发。使用流程快速使用云消息队列 RocketMQ 版收发消息的流程如下图所示。使用说明权限说明若您的账号为RAM用户，则必须先为该RAM用户进行授权，才能访问云消息队列 ...

快速入门

如果您首次使用云消息队列 Kafka 版，您可以参考快速入门文档。快速入门文档云消息队列 Kafka 版快速入门云消息队列 Confluent 版快速入门

消息检索

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

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

当您需要查看并分析庞杂的日志数据时，可通过阿里云Logstash将云消息队列 Kafka 版中的日志数据导入阿里云Elasticsearch，然后通过Kibana进行可视化展示与分析。本文介绍将云消息队列 Kafka 版接入阿里云Elasticsearch的操作方法。前提...

安装CPP动态库

使用C++ SDK接入阿里云云消息队列 RocketMQ 版收发消息前，您需按本文提供的操作步骤安装CPP动态库。重要推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更...

退款说明

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

产品计费

本文为您介绍云消息队列 RocketMQ 版的实例类型、计费方式、计费组成等信息。云消息队列 RocketMQ 版5.x系列 5.x系列计费概述云消息队列 RocketMQ 版4.x系列 4.x系列计费概述

迁移概述

本文介绍将自建Kafka集群迁移到云消息队列 Kafka 版实例的优势、原理、方案架构、迁移工具和操作流程。迁移优势将自建Kafka集群迁移到云消息队列 Kafka 版实例的优势，请参见产品优势。迁移原理对于消息队列来说，如果要实现集群...

收发定时消息和延时消息

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

操作指南

您可以在云消息队列 Kafka 版控制台创建实例、进行消息收发。云消息队列 Kafka 版 V3系列Serverless实例管理 V2系列实例管理 Topic Group Connector生态集成迁移权限管理云消息队列 Confluent 版集群资源规格评估实例管理权限管理 ...

调用TCP协议的SDK收发普通消息

在控制台创建完所有资源之后，您可以调用云消息队列 RocketMQ 版的TCP协议的SDK收发普通消息。前提条件创建资源说明本文以普通消息为例进行说明，因此您创建的普通消息的Topic不能用来收发其他类型的消息，包括定时、延时、顺序和事务...

开源SDK接入（主子账号授权）

阿里云的云消息队列 RabbitMQ 版支持AMQP 0-9-1协议，兼容开源的RabbitMQ客户端，您可以使用开源的客户端SDK接入云消息队列 RabbitMQ 版服务端进行消息收发。前提条件创建实例创建Vhost 背景信息借助访问控制RAM的RAM用户，您可以...

可观测性体系概述

作为一款典型的分布式中间件产品，云消息队列 RocketMQ 版被广泛应用于业务核心链路中，每条消息都关联着核心业务数据的变化，通过可观测能力及时发现问题、定位问题、解决问题对于业务运行是一项重要的保障能力。本文介绍云消息队列 ...

实践教程

针对各种业务需求，云消息队列 RocketMQ 版提供相关的实践教程，您可以根据实例版本选择对应的最佳实践教程进行参考。云消息队列 RocketMQ 版5.x系列 5.x系列最佳实践云消息队列 RocketMQ 版4.x系列 4.x系列最佳实践

概述

本文旨在以简单明了的方式引导您快速上手云消息队列 Kafka 版。操作流程根据网络类型不同，快速入门的操作流程有所不同，详情请参见云消息队列 Kafka 版快速入门操作流程。图 1.云消息队列 Kafka 版快速入门操作流程操作步骤具体操作...

阿里alibaba 消息队列怎么用

新品推荐