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

函数计算

本文介绍如何在云消息队列 RocketMQ 版控制台创建流出目标为云消息队列 Kafka 版的消息流出任务。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。您已开通函数计算服务，具体...

元数据导入

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

消息收发流程变更

云消息队列 MQTT 版 V2.x.x版本强依赖云消息队列 RocketMQ 版作为消息存储，因此云消息队列 MQTT 版消息和云消息队列 RocketMQ 版天然打通，创建了Topic后即可天然使用云消息队列 RocketMQ 版和云消息队列 MQTT 版的SDK相互通信...

发布者最佳实践

本文介绍云消息队列 Kafka 版发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息发送消息的示例代码如下：Future...

Topic导入/导出

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

Topic导入/导出

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

VPC接入

借助云消息队列 Kafka 版 ACL功能，您可以按需为SASL用户赋予向云消息队列 Kafka 版收发消息的权限，从而实现权限分割。当实例规格类型为专业版时需要配置该参数。禁用云盘加密选择是否需要开启实例加密。启用云盘密钥 ID 同地域的云...

公网和VPC接入

借助云消息队列 Kafka 版 ACL功能，您可以按需为SASL用户赋予向云消息队列 Kafka 版收发消息的权限，从而实现权限分割。禁用自定义用户名密码选择是否需要自定义用户名和密码。选择否则使用系统为每个实例分配的默认用户名和密码。...

资源使用变更

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

降低实例配置

如果您的云消息队列 Kafka 版实例的公网流量消耗远小于购买的公网流量配置，或者分区的使用量远小于购买的分区数量，您可以降低公网流量和分区数量配置，从而节约成本。本文介绍如何在云消息队列 Kafka 版控制台降低实例的公网流量、...

创建Tablestore Sink Connector

MQ_INST_115964845466*_ByBeUp3p Topic 选择生产云消息队列 Kafka 版 消息的Topic。topic Group ID 选择源实例的消费组名称。请使用独立的消费组来创建事件源，不要和已有的业务混用消费组，以免影响已有的消息收发。GID_http_1 并发配额...

公共参数

x-mq-version 是调用云消息队列 RocketMQ 版的版本号，当前版本为2015-06-06。Content-MD5 否 HTTP消息体的MD5值。具体格式，请参见 Content-MD5 Header Field。公共返回头参数说明 Content-Length HTTP响应Body的长度。Connection ...

OnsRegionList-获取地域信息列表

调用OnsRegionList获取云消息队列 RocketMQ 版目前开放服务的地域（Region）信息列表。接口说明注意阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖...

MQTT与RocketMQ的消息结构映射

云消息队列 RocketMQ 版和云消息队列 MQTT 版的消息负载（Payload）均是您的业务消息的数据序列化结果，云消息队列 RocketMQ 版和云消息队列 MQTT 版不会对业务消息再做进一步的编解码处理。属性字段映射目前，云消息队列 MQTT 版 ...

消息服务MNS

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

创建MNS Source Connector

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

使用须知

例如您的云消息队列 RocketMQ 版实例在华东1（杭州）地域，则只能使用华东1（杭州）地域的接入点来访问该地域的实例。您可以实现以下场景的资源访问：如果您的客户端在华东1（杭州）地域，为了最佳体验，请使用该实例的HTTP内网接入点...

迁移自建Kafka集群至新实例

借助云消息队列 Kafka 版的ACL功能，您可以按需为SASL用户赋予向云消息队列 Kafka 版收发消息的权限，从而实现权限分割。关于SASL用户授权具体操作，请参见 SASL用户授权。禁用：不开启实例ACL功能，使用实例的默认SASL用户仅提供身份...

消息队列Kafka版系统权限策略参考

本文描述消息队列Kafka版支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）...

接口和参数说明

云消息队列 RocketMQ 版提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从云消息队列 RocketMQ 版获取消息。本文介绍消息发送和订阅的接口和参数说明。背景信息云消息队列 RocketMQ 版支持以下两种消息获取方式：Push...

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

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

作为Output接入

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

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

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

Topic引流

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

RAM跨云账号授权

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

Group导入/导出

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

作为Output接入

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

使用Spring Cloud框架收发消息

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

RAM跨云账号授权

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

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

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

升级多可用区

前提条件您使用的云消息队列 Kafka 版实例类型为专业版。实例当前为单可用区部署。实例当前读写流量水位没有接近购买规格峰值。实例大版本必须为2.2.0或以上版本，小版本建议您使用最新版本。升级影响该操作服务不会中断，但可能导致...

仪表盘

消息堆积场景如下图所示，表示指定主题的某一队列中各消息的状态：上图表示指定主题的某一队列中各消息的状态，云消息队列 RocketMQ 版将处于不同处理阶段的消息数量和耗时进行统计，这些指标可直接反映队列中消息的处理速率和堆积情况，...

Group导入/导出

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

实例管理

实例是一个独立的云消息队列 RabbitMQ 版资源实体，可以被视为一个隔离的服务器或服务环境，执行消息的接收、存储和转发操作。实例包含Vhost、Exchange、Queue等基本的资源要素。本文介绍如何在云消息队列 RabbitMQ 版控制台创建实例、...

计费常见问题

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

产品架构

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

视频专区

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

跨云产品数据流入

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

跨云产品的数据流出

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

创建DTS Source Connector

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

mq消息队列的作用

新品推荐