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

无法ping通云消息队列 Kafka 版的接入点

问题描述无法ping通云消息队列 Kafka 版的接入点。本地客户端无法telnet Kafka或提示连接超时（Connection timed out）。问题原因为了保证安全，云消息队列 Kafka 版集群默认禁ping。连接VPC接入点时，客户端与Kafka不在同一VPC下。解决...

开发参考

OpenAPI是阿里云产品提供的开放应用程序接口，是除控制台之外，云消息队列 RocketMQ 版管理资源的主要方式之一。API参考汇总了云消息队列 RocketMQ 版所有对外公开的API接口。云消息队列 RocketMQ 版5.x系列 5.x系列SDK参考 5.x系列API...

QPS限制

云消息队列 MQTT 版服务端接口的调用有QPS限制，分为两类：单用户的API QPS限制：超过了该限制则会被限流，只保证符合SLA的流量。具体每个API的QPS限制如表1 所示。单个IP出口QPS限制。超过了该限制则会被完全拉黑。说明单个IP出口QPS为...

服务接入点

本文列出云消息队列 RabbitMQ 版 的API接入地域ID和接入点。地域地域ID（RegionId）接入点（Endpoint）华东1（杭州）cn-hangzhou amqp-open.cn-hangzhou.aliyuncs.com 华东2（上海）cn-shanghai amqp-open.cn-shanghai.aliyuncs.com 华北...

API概览

本产品（云消息队列 RocketMQ 5.0 版/2022-08-01）的OpenAPI采用 ROA 签名风格，签名细节参见签名机制说明。我们已经为开发者封装了常见编程语言的SDK，开发者可通过下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能...

API概览

本产品（云消息队列 Kafka 版/2019-09-16）的OpenAPI采用 RPC 签名风格，签名细节参见签名机制说明。我们已经为开发者封装了常见编程语言的SDK，开发者可通过下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用...

API概览

本产品（云消息队列 RocketMQ 4.0 版/2019-02-14）的OpenAPI采用 RPC 签名风格，签名细节参见签名机制说明。我们已经为开发者封装了常见编程语言的SDK，开发者可通过下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能...

授权信息

API：是指操作对应的API接口。访问级别：是指每个操作的访问级别，取值为写入（Write）、读取（Read）或列出（List）。资源类型：是指操作中支持授权的资源类型。具体说明如下：对于必选的资源类型，用背景高亮的方式表示。对于不支持资源...

订阅消息API

订阅者可通过调用订阅消息API来消费云消息队列 RocketMQ 版服务端中的消息。请求构造请求行 GET/topics/TopicName/messages?ns=INSTANCE_ID&consumer=GID&tag=taga&numOfMessages=3&waitseconds=3 HTTP/1.1 重要请求行总长度不能超过...

什么是云消息队列 Kafka 版？

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

什么是云消息队列 MQTT 版

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

消息（Message）

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

创建RabbitMQ Source Connector

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

调用方式

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

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

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

消息检索

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

顺序消息

在云消息队列 RocketMQ 版中，消息的顺序需要由以下三个阶段保证：消息发送如上图所示，A1、B1、A2、A3、B2、B3是订单A和订单B的消息产生的顺序，业务上要求同一订单的消息保持顺序，例如订单A的消息发送和消费都按照A1、A2、A3的顺序。...

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

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

计费FAQ

云消息队列 RabbitMQ 版处于欠费状态超过72小时，阿里云将暂停为您提供服务，即您不能再访问云消息队列 RabbitMQ 版控制台与云消息队列 RabbitMQ 版 的API。但是您的云消息队列 RabbitMQ 版服务被释放之前的欠费仍需结清。如何关闭云...

计费FAQ

云消息队列 RabbitMQ 版处于欠费状态超过72小时，阿里云将暂停为您提供服务，即您不能再访问云消息队列 RabbitMQ 版控制台与云消息队列 RabbitMQ 版 的API。但是您的云消息队列 RabbitMQ 版服务被释放之前的欠费仍需结清。如何关闭云...

集成概述

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

功能与特性概述

OpenAPI：提供开放的API便于将云消息队列 RocketMQ 版管理工具集成到自己的控制台。云消息队列 RocketMQ 版 的API的更多信息，请参见 OpenAPI参考。消息类型列表普通消息 消息队列RocketMQ版中无特性的消息，区别于有特性的定时和延时...

QueueMessage

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

发送消息API

使用发送消息API从生产者发送消息至云消息队列 RocketMQ 版服务端。请求构造请求行 POST/topics/TopicName/messages?ns=INSTANCE_ID HTTP/1.1 参数说明如下。参数是否必选说明 TopicName 是将消息发送至的Topic名称。ns 否实例ID，...

调用方式

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

自定义鉴权模式

MQTT服务器云消息队列 MQTT 版权限认证和消息收发服务器，用来处理应用服务器发起的鉴权相关的请求以及消息收发业务。使用说明无论使用何种鉴权模式，本质上可以归结为身份认证和资源权限两个基本功能。身份认证，即客户端的身份标识，...

队列控制台操作帮助

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

Dashboard

云消息队列 RabbitMQ 版的所有指标数据已保存到您的阿里云可观测监控 Prometheus 版中，您可以通过可观测监控 Prometheus 版提供的API将云消息队列 RabbitMQ 版的Dashboard指标接入到本地自建Grafana中。具体操作，请参见将Prometheus...

步骤二：创建资源

一个新的应用接入云消息队列 RabbitMQ 版服务端，您需要提前创建云消息队列 RabbitMQ 版的相关资源，包括创建云消息队列 RabbitMQ 版实例、创建Vhost、创建Exchange、创建Queue、绑定Exchange和Queue、创建用户名密码以及获取实例接...

概述

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

仪表盘

云消息队列 RocketMQ 版的所有指标数据已保存到您的阿里云可观测监控 Prometheus 版中，您可以通过可观测监控 Prometheus 版提供的API将云消息队列 RocketMQ 版的仪表盘的指标数据接入到本地自建Grafana中。具体操作，请参见将...

计费常见问题

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

仪表盘

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

仪表盘

云消息队列 Kafka 版的所有指标数据已保存到您的阿里云可观测监控 Prometheus 版中，您可以通过可观测监控 Prometheus 版提供的API将云消息队列 Kafka 版的仪表盘的指标数据接入到本地自建Grafana中。具体操作，请参见将Prometheus的...

RAM鉴权

可授权的云消息队列 MQTT 版 OpenAPI 下表列举了云消息队列 MQTT 版中可授权的OpenAPI及其描述方式。说明如需访问云消息队列 MQTT 版的OpenAPI，则需有访问云消息队列 MQTT 版实例的权限，即mq:MqttInstanceAccess权限。更多信息请...

队列（MessageQueue）

队列的主要作用如下：存储顺序性队列天然具备顺序性，即消息按照进入队列的顺序写入存储，同一队列间的消息天然存在顺序关系，队列头部为最早写入的消息，队列尾部为最新写入的消息。消息在队列中的位置和消息之间的顺序通过位点（Offset...

开通消息队列服务并授权

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

开通消息队列服务并授权

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

开通服务并授权

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

直播互动解决方案

后端应用将处理后的消息再次发送至云消息队列 RocketMQ 版的Topic。云消息队列 RocketMQ 版根据创建的数据流入规则将该消息转发至云消息队列 MQTT 版。云消息队列 MQTT 版将该消息推送至所有网页客户端，涉及成员老师、学生A以及学生B...

消息队列的api

新品推荐