消息队列消息服务-消息队列消息服务文档介绍内容-阿里云

创建资源

在调用TCP协议的SDK收发消息前，您需在云消息队列 RocketMQ 版控制台创建相关资源。您在调用SDK时需填写这些资源信息。前提条件开通消息队列服务并授权背景信息针对TCP和HTTP两种通信协议，云消息队列 RocketMQ 版分别提供了多语言...

创建资源

创建实例实例是用于云消息队列 RocketMQ 版服务的虚拟机资源，会存储消息主题（Topic）和客户端ID（Group ID）信息。登录云消息队列 RocketMQ 版控制台。在左侧导航栏，单击实例列表。在顶部菜单栏，选择地域，如华东1（杭州）。在 ...

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

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

开服地域

本文介绍云消息队列 Kafka 版的服务地域和各地域功能（Connector、数据处理和消息检索等）开通情况。下表中的表示该功能已在该地域支持，表示暂不支持指定地域。公共云地域名称 RegionId Connector（公测中）数据处理（公测中）消息...

CA证书管理

云消息队列 MQTT 版支持使用设备证书进行客户端的接入认证，CA证书可用于签发设备证书、服务器证书和验证证书，客户端使用设备证书进行认证时，服务端将使用设备证书关联的CA证书来验证设备证书是否正确，CA证书必须在云消息队列 MQTT 版...

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

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

关于HTTP服务不再支持经典网络的公告

为了提供更优质的服务质量，云消息队列 RocketMQ 版提供的HTTP服务将于2021年05月31日后，不再支持经典网络ECS实例的访问。如果您的应用部署在经典网络ECS实例上，且访问的是云消息队列 RocketMQ 版的HTTP服务，请尽快将应用迁移到VPC...

配置消息队列Kafka版实例的参数

端口填入阿里云消息队列Kafka版实例的服务端口，默认为9092。数据库账号仅开启ACL的阿里云消息队列Kafka版实例才需要填写数据库账号和数据库密码。说明关于开启ACL的信息，请参见 SASL用户授权。请在 SASL用户管理页签，查看 ...

关于HTTP服务不再支持跨地域访问的公告

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

SetQueueAttributes

metaoverride=true HTTP/1.1 URI参数 metaoverride=true 将会修改消息队列的属性。特有Request Header 无。Request Body Request Body为XML格式，XML中包含创建Queue的属性，这些属性都为可选属性。参数名称类型是否必选示例值描述 ...

ListQueue

说明如果本次请求结果返回的消息队列总数超过本次请求的 x-mns-ret-number 参数值，返回的XML结果中包含的 NextMarker 表示下一页开始位置，在下一次请求时将该值赋予 x-mns-marker 参数以返回下一页的结果。请求消息请求消息由请求行、...

BatchSendMessage

发送消息时指定 DelaySeconds 参数的优先级高于延时消息队列的 DelaySeconds 属性，即两个 DelaySeconds 属性设置的值不同的时候以发送消息时指定的值为准。使用BatchSendMessage接口时，BatchSendMessage接口每秒最大并发请求数=限流比对...

ChatAppAudit

您可以通过MNS消息队列接收 Chat App 消息服务 模板审核报告（ChatAppAudit）。前提条件您已经注册阿里云账号并生成访问密钥（AccessKey），详情请参见创建AccessKey。您已仔细阅读回执消息简介与配置流程，了解回执消息模式、类型和...

主题与队列命名长度变更公告

自2021年01月13日起，新建的 消息服务MNS 主题或队列的命名长度不可超过120个字符，超过该限制会导致主题或队列创建失败。该限制不会影响在2021年01月13日前已创建的主题或队列，但会影响在2021年01月13日后新增的主题或队列。

服务支持

本文汇总了云消息队列 Kafka 版的常见问题与以及服务等级协议。服务支持常见问题相关协议

数据传输服务DTS

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

Token应用服务器接口

本文介绍云消息队列 MQTT 版提供的应用服务器Token OpenAPI接口。API 描述 ApplyToken 调用 ApplyToken 申请临时访问的Token。QueryToken 调用 QueryToken 校验Token的有效性。RevokeToken 调用 RevokeToken 吊销Token。

Token应用服务器接口

本文介绍云消息队列 MQTT 版提供的应用服务器Token OpenAPI接口。OpenAPI 描述 ApplyToken 调用ApplyToken申请临时访问的Token。QueryToken 调用QueryToken校验Token的有效性。RevokeToken 调用RevokeToken吊销Token。

SmsUp

您可以通过MNS消息队列拉取短信上行消息（SmsUp）。前提条件您已经注册阿里云账号并生成访问密钥（AccessKey），详情请参见创建AccessKey。确保您可以在本地成功Ping以下三个地址：dysmsapi.aliyuncs.com或mns.cn-hangzhou.aliyuncs.com...

数据流入规则管理

注意事项云消息队列 MQTT 版通过配置的流入规则和云消息队列 RocketMQ 版进行跨云产品的消息交互时，若云消息队列 RocketMQ 版的服务端进行升级，则在升级期间，可能会造成云消息队列 MQTT 版客户端消费消息延迟。产品升级动态，请...

直播互动解决方案

Client ID 云消息队列 MQTT 版的Client ID是每个客户端的唯一标识，要求全局唯一，使用相同的Client ID连接云消息队列 MQTT 版服务会被拒绝。Client ID由两部分组成，组织形式为<GroupID>@。Client ID的长度限制为64个字符，不允许使用...

数据流出规则管理

重要在云消息队列 MQTT 版中Topic是多级结构，而云消息队列 RocketMQ 版的Topic仅有一级，因此，云消息队列 MQTT 版中的一级Topic映射到云消息队列 RocketMQ 版的Topic，而子级Topic，包括二级、三级、n级Topic则映射到云消息队列...

上下线通知规则管理

参数取值示例说明目标服务类型 消息队列 RocketMQ 版指定您需将云消息队列 MQTT 版客户端上下线通知流转至哪个目标云产品。说明当前仅支持云消息队列 RocketMQ 版。RocketMQ 实例 MQ_INST_13801563067*_BbyOD2jQ 指定目标云产品的...

音视频通信解决方案（MQTT）

数据交互数据流所展示的是基于云消息队列 MQTT 版和音视频通信RTC实现一次音视频通话会议的调用流程，其中灰色部分为您的自建开发程序或服务，蓝色部分是云消息队列 MQTT 版、云消息队列 RocketMQ 版以及音视频通信RTC所提供的服务。...

新零售电子价签解决方案（MQTT）

新零售电子价签解决方案由阿里云云消息队列 MQTT 版推出，通过MQTT以实现商场超市、公共场所电子标签、多媒体屏幕的数据更新管理。本文将以电子价签为例详细描述该解决方案的系统架构、数据流设计以及注意事项，其他类似行业可参考该方案...

内容分割

支持的消息服务包括 消息队列 RocketMQ、消息队列 RabbitMQ、消息服务 MNS 和 消息队列 Kafka 等。资源配置配置项说明源地域本文选择华东1（杭州）。版本选择RocketMQ的版本，本文选择 RocketMQ 5.x。RocketMQ 实例选择生产消息的...

内容映射

支持的消息服务包括 消息队列 RocketMQ、消息队列 RabbitMQ、消息服务 MNS 和 消息队列 Kafka 等。资源配置配置项说明源地域本文选择华东1（杭州）。版本选择RocketMQ的版本，本文选择 RocketMQ 5.x。RocketMQ 实例选择生产消息的...

名词解释

基本概念实例（Instance）创建购买云消息队列 MQTT 版服务的实体单元，每个云消息队列 MQTT 版实例都对应一个全局唯一的服务接入点URL。使用云消息队列 MQTT 版前都需要在对应的地域（Region）创建一个实例，并使用对应的接入点来...

内容富化

支持的消息服务包括 消息队列 RocketMQ、消息队列 RabbitMQ、消息服务 MNS 和 消息队列 Kafka 等。资源配置配置项说明源地域本文选择华东1（杭州）。版本选择RocketMQ的版本，本文选择 RocketMQ 5.x。RocketMQ 实例选择生产消息的...

动态路由

支持的消息服务包括 消息队列 RocketMQ、消息队列 RabbitMQ、消息服务 MNS 和 消息队列 Kafka 等。资源配置配置项说明源地域本文选择华东1（杭州）。版本选择RocketMQ的版本，本文选择 RocketMQ 5.x。RocketMQ 实例选择生产消息的...

MQTT和RocketMQ进行数据互通（跨产品数据流入）

如果您的云端应用需要使用云消息队列 RocketMQ 版产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将云消息队列 MQTT 版和云消息队列 RocketMQ 版数据进行流转。本文介绍如何将云消息队列 RocketMQ...

MQTT和RocketMQ进行数据互通（跨产品数据流出）

如果您的云端应用需要使用云消息队列 RocketMQ 版产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将云消息队列 MQTT 版和云消息队列 RocketMQ 版数据进行流转。本文介绍如何将云消息队列 MQTT 版 ...

短轮询和长轮询

消息服务MNS 提供短轮询（Short Polling）和长轮询（Long Polling）两种方式来获取队列中的消息。短轮询创建队列时，长轮询时间设置为0，且发起popMessage请求时 waitSeconds 设置为0。使用短轮询获取队列中的消息，popMessage请求会向...

MQTT和RocketMQ进行数据互通（客户端上下线通知）

MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息，云消息队列 MQTT 版支持将该条消息数据导出至其他阿里云产品，并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的云消息队列 RocketMQ 版数据互通...

旧版本Token鉴权服务升级

云消息队列 MQTT 版早期提供的Token鉴权服务即将于2020年12月31日下线，Token鉴权服务提供的Token服务接口已经迁移到新的云端服务网关。识别旧版本的Token鉴权服务如果您获取Token的调用地址为 https://{tokenServerUrl}/token/apply ，...

创建MNS Sink Connector

开服地域在消息集成中创建消息流出任务时，支持将 消息服务MNS 作为消息流出任务目标端的地域有华东1（杭州）、华东2（上海）、华北1（青岛）、华北2（北京）、华北3（张家口）、华北5（呼和浩特）、华南1（深圳）、西南1（成都）、中国...

创建MNS Source Connector

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

消息服务MNS

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

消息服务MNS

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

Token鉴权概述

云消息队列 MQTT 版通过Token鉴权模式向MQTT客户端提供临时访问权限。您可通过MQTT Token服务来给本地账号系统管理的用户颁发临时的访问凭证，并限制访问权限，以实现对单一客户端、单一资源的细粒度权限控制。本文介绍使用流程以及相关...

消息队列消息服务

新品推荐