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

SDK参考概述

RocketMQ 4.x/3.x SDK 兼容云消息队列 RocketMQ 版 4.x版本实例的功能完整支持。RocketMQ ONS TCP 1.x/2.x SDK 兼容 RocketMQ ONS HTTP SDK 兼容 RocketMQ 5.x系列SDK（推荐）协议语言相关文档 TCP协议 Java SDK 版本说明环境准备示例...

包年包月

包年包月计费是一种需要先付费才能使用资源的计费方式，主要适用于长时间稳定的业务运行场景。...如果停机后168小时依然欠费，云消息队列 Confluent 版实例将会释放，实例释放后数据不可恢复，即您不能再使用云消息队列 Confluent 版服务。

通过可观测性能力进行故障处理最佳实践

本文为您介绍如何将云消息队列 RocketMQ 版可观测性功能应用于云消息队列 RocketMQ 版的故障管理场景中，为您的日常运维和故障处理提供实践方案。设计思路核心问题运维场景下，故障处理的核心问题如下：服务出现异常如何预警并上报 ...

消息存活时间

什么是消息存活时间在云消息队列 RabbitMQ 版中，消息存活时间用于限制消息在Queue中可以存在的时间，如果消息在Queue中存在的时间超过了设置的消息存活时间，消息将会被进行如下处理：若您未给Queue设置死信Exchange，消息将被Queue...

关于TCP内网接入点设置的公告

为了进一步提升云消息队列 RocketMQ 版服务的稳定性，并以此保障您应用的稳定性，针对部署在某地域（Region）的应用，如果您使用的是TCP协议下的SDK，则需使用该地域的云消息队列 RocketMQ 版服务的TCP内网接入点。本文提供对应地域的...

消息堆积和延迟问题

本文主要介绍云消息队列 RocketMQ 版 TCP协议的Java客户端使用过程中，经常会出现的消息堆积和消息延迟的问题。通过了解云消息队列 RocketMQ 版客户端的消费原理和消息堆积的主要原因，帮助您可以在业务部署前更好的规划资源和配置，或...

实例管理

实例是用于云消息队列 RocketMQ 版服务的虚拟机资源，会存储消息主题（Topic）和客户端ID（Group ID）信息。使用云消息队列 RocketMQ 版进行消息收发，必须先创建云消息队列 RocketMQ 版实例。本文介绍如何在云消息队列 RocketMQ 版...

能否通过公网访问云消息队列 Kafka 版实例？

网络类型为公网/VPC的云消息队列 Kafka 版实例支持通过公网访问。云消息队列 Kafka 版提供VPC和公网/VPC两种网络类型的实例。如需通过公网访问，请购买公网/VPC实例。如果已购买VPC实例，请升级实例配置，变更VPC实例为公网/VPC实例。更...

MQTT与RocketMQ的消息结构映射

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

开源对比

在通信协议完全兼容的前提下，为了提供更丰富的消息管控和治理功能，云消息队列 Kafka 版会对使用习惯作出一些限制，具体说明如下。项目云消息队列 Kafka 版 Apache Kafka 差异原因 Topic 创建方式云消息队列 Kafka 版控制台云消息...

快速入门概述

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

订阅关系清理

本文介绍如何在云消息队列 MQTT 版控制台为指定Topic配置订阅关系清理功能。背景信息订阅关系清理功能的相关背景信息和计费说明如下：某个Topic配置了订阅关系清理功能后，当订阅者的客户端离线并超过指定时间后，云消息队列 MQTT 版会...

Group导入/导出

云消息队列 RocketMQ 版支持将指定实例的Group列表信息导出，再导入至其他的云消息队列 RocketMQ 版实例，实现Group的跨实例迁移。你可以在更换实例或者克隆实例时，使用Group导入/导出功能快速批量创建出相同的Group。背景信息您可以...

Group导入/导出

云消息队列 RocketMQ 版支持将指定实例的Group列表信息导出，再导入至其他的云消息队列 RocketMQ 版实例，实现Group的跨实例迁移。你可以在更换实例或者克隆实例时，使用Group导入/导出功能快速批量创建出相同的Group。背景信息您可以...

服务关联角色

角色名称角色权限策略角色权限 AliyunServiceRoleForOns AliyunServiceRolePolicyForOns 云消息队列 RocketMQ 版通过扮演该RAM角色，可获得如下权限：访问云监控的权限，以实现监控报警相关功能。访问阿里云Prometheus监控的权限，...

在Knative上实现Kafka消息推送

Knative已支持Kafka事件源，您可将Knative与云消息队列 Kafka 版对接，在Knative上实现Kafka消息推送。前提条件部署Knative 购买并部署云消息队列 Kafka 版实例重要云消息队列 Kafka 版实例和Knative必须处于同一VPC内。云消息队列...

MQTT快速入门

作为使用和熟悉产品功能的入门指导，本文提供如何快速使用云消息队列 MQTT 版通过默认支持的MQTT协议收发消息的步骤。对于非MQTT协议的接入，例如新能源，您必须首先购买云消息队列 MQTT 版企业铂金版，并通过专属通道享受对应的文档和...

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

RocketMQ 4.x/3.x SDK 兼容云消息队列 RocketMQ 版 4.x版本实例的功能完整支持。RocketMQ ONS TCP 1.x/2.x SDK 兼容 RocketMQ ONS HTTP SDK 兼容 4.x和5.x功能兼容说明云消息队列 RocketMQ 版 5.x版本实例基于大规模企业客户的生产实践...

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

RocketMQ 4.x/3.x SDK 兼容云消息队列 RocketMQ 版 4.x版本实例的功能完整支持。RocketMQ ONS TCP 1.x/2.x SDK 兼容 RocketMQ ONS HTTP SDK 兼容 4.x和5.x功能兼容说明云消息队列 RocketMQ 版 5.x版本实例基于大规模企业客户的生产实践...

资源使用变更

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

消费者（Consumer）

定义消费者是云消息队列 RocketMQ 版中用来接收并处理消息的运行实体。消费者通常被集成在业务系统中，从云消息队列 RocketMQ 版服务端获取消息，并将消息转化成业务可理解的信息，供业务逻辑处理。在消息消费端，可以定义如下传输...

功能与特性概述

本文列举云消息队列 RocketMQ 版所支持的所有功能与特性。概览云消息队列 RocketMQ 版在阿里云多个地域（Region）提供了高可用消息云服务。单个地域内采用多机房部署，可用性极高，即使整个机房都不可用，仍然可以为应用提供消息发布...

迁移概述

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

SendMessage-向云消息队列 MQTT 版发送单条消息

从服务端应用向云消息队列 MQTT 版发送单条消息。接口说明 SendMessage 接口为服务端应用调用，与 MQTT 客户端发送消息互补。服务端和客户端的使用场景区别，请参见开发指南使用指引。调用 SendMessage 接口前，请确认您的云消息队列 MQTT...

Serverless实例计费说明

云消息队列 RocketMQ 版的Serverless实例支持根据实际使用的资源量按量后付费，您可以弹性使用资源无需提前预留，可帮助您有效提高资源利用率并降低业务成本。使用限制 Serverless实例暂时只支持华东1（杭州）、华东2（上海）、华北2...

作为Output接入

云消息队列 Kafka 版可以作为Output接入Filebeat。本文说明如何在公网环境下通过Filebeat向云消息队列 Kafka 版发送消息。前提条件在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 ...

实例管理

云消息队列 MQTT 版支持的实例类型及功能差异，请参见实例类型。在确认订单页面，根据提示完成支付。更新实例在实例列表中找到您需要更新的实例，单击实例名称或在其操作列单击详情。在实例详情页面的基础信息区域，分别单击 ...

调用方式

Version：要使用的API版本，云消息队列 MQTT 版的API版本是 2020-04-20。Parameters：请求参数，每个参数之间用“&”分隔。请求参数由公共请求参数和API自定义参数组成。公共参数中包含API版本号、身份验证等信息，详细信息，请参见公共...

企业铂金版和标准版实例相互转换

云消息队列 RocketMQ 版支持标准版和企业铂金版实例，实例类型可以相互转换。标准版实例计费方式为按量付费，适合消息量少或者波峰谷差异明显的业务场景；企业铂金版实例计费方式为包年包月适合高SLA要求或业务量较大且稳定的场景。当您的...

什么是消息队列RabbitMQ版？

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

Topic引流

您在升级云消息队列 Kafka 版实例的流量规格时，可能会触发集群横向扩容。集群横向扩容完成后，您需要进行Topic引流，使Topic流量重新均匀分布到扩容后的集群上。否则原有的Topic流量还是打在扩容前的集群节点上，原有的Topic的峰值流量...

RAM跨云账号授权

背景信息企业A开通了云消息队列 Kafka 版，该企业需要企业B代为操作云消息队列 Kafka 版的资源，例如实例、Topic、Group。企业A的需求如下：企业A希望能专注于业务系统，仅作为云消息队列 Kafka 版所有者。企业A希望可以授权企业B来...

元数据导入

本文介绍如何在云消息队列 Kafka 版控制台创建元数据导入任务，将元数据迁移至云消息队列 Kafka 版已有实例。前提条件下载JDK 8 购买并部署云消息队列 Kafka 版实例：购买并部署VPC实例购买并部署公网/VPC实例说明购买实例的规格可...

作为Output接入

云消息队列 Kafka 版可以作为Output接入Logstash。本文说明如何在公网环境下通过Logstash向云消息队列 Kafka 版发送消息。前提条件在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 ...

使用Spring Cloud框架收发消息

本文介绍如何使用Spring Cloud框架接入云消息队列 Kafka 版并收发消息。前提条件安装1.8或以上版本JDK。安装2.5或以上版本Maven。下载 kafka-spring-stream-demo，并将其上传在准备好的Linux操作系统。确保您的云消息队列 Kafka 版 ...

如何快速测试云消息队列 Kafka 版服务端是否正常？

在创建并部署云消息队列 Kafka 版实例后，您可以使用云消息队列 Kafka 版控制台直接发送消息，快速测试服务端是否正常。前提条件您已创建并部署云消息队列 Kafka 版实例，且实例处于服务中状态。操作流程快速测试云消息队列 ...

RAM跨云账号授权

背景信息企业A开通了云消息队列 RabbitMQ 版，该企业需要企业B代为操作云消息队列 RabbitMQ 版的资源，例如实例、Topic、Consumer Group。企业A的需求如下：企业A希望能专注于业务系统，仅作为云消息队列 RabbitMQ 版所有者。企业A...

IP白名单

IP白名单用于控制客户端是否可以连接云消息队列 RocketMQ 版服务端实例，您可以为指定实例设置IP白名单，允许特定IP地址段下的客户端连接云消息队列 RocketMQ 版实例。功能介绍云消息队列 RocketMQ 版实例创建后默认IP白名单地址段为...

计费常见问题

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

产品架构

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

消息队列的功能实现

新品推荐