阿里云mq队列如何使用-阿里云mq队列如何使用文档介绍内容-阿里云

云监控

前提条件创建服务关联角色角色名称：AliyunServiceRoleForAlikafka 角色策略名称：AliyunServiceRolePolicyForAlikafka 权限说明：允许云消息队列 Kafka 版使用该角色访问您的服务（云监控和ARMS服务）以完成云监控相关功能。...

直播互动解决方案

本文以单直播间、一名老师、两名学生的场景为例，说明如何使用云消息队列 MQTT 版实现直播互动消息、禁言、成员上下线通知以及系统消息通知，其中，老师和学生的客户端以HTML网页为例，后端应用以Java为例。背景信息在直播互动的场景下...

计费常见问题

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

创建FC Sink Connector

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

MqttInstanceAccess mq:QueryToken ApplyToken mq:MqttInstanceAccess mq:ApplyToken CreateGroupId mq:MqttInstanceAccess mq:CreateGroupId DeleteGroupId mq:MqttInstanceAccess mq:DeleteGroupId ListGroupId mq:MqttInstanceAccess mq...

网络访问与安全设置

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

计费常见问题

我没有使用云消息队列 RocketMQ 版服务，为什么会扣费？我在控制台上看到没有开通云消息队列 RocketMQ 版服务，为什么会有扣费？如何关闭云消息队列 RocketMQ 版服务？我该如何为我的云消息队列 RocketMQ 版企业铂金版实例续费？...

微消息队列MQTT版

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

函数计算

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

应用场景

本文为您介绍云消息队列 RocketMQ 版的应用场景，以便您更好地判断如何在业务中使用云消息队列 RocketMQ 版。例如，针对一家互联网电商企业，其业务涉及广泛，如注册、订单、库存、物流等；同时，也会涉及许多业务峰值时刻，如秒杀活动...

创建RocketMQ Source Connector

MQ_INST_115964845466*_ByBeUp3p Topic 选择生产消息队列RocketMQ版消息的Topic。topic Tag 配置源实例中用于过滤消息的Tag。test Group ID 选择源实例中的消费组名称。请使用独立的消费组来创建事件源，不要和已有的业务混用消费组，...

云端开发概述

本文介绍云消息队列 MQTT 版提供的云端SDK和管控SDK的使用场景。使用说明使用云消息队列 MQTT 版的云端SDK收发消息时，需要和终端SDK搭配使用。例如，使用云端SDK发送消息，终端SDK接收消息；或使用终端SDK发送消息，云端SDK接收消息...

云消息队列 RocketMQ 版

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

联系我们

如果您准备使用或正在使用云消息队列 MQTT 版，有任何疑问和建议，欢迎您搜索钉钉群号 35228338加入钉钉群与我们交流。

计费概述

云消息队列 MQTT 版 V2.x.x版本的存储依赖于云消息队列 RocketMQ 版，您在使用云消息队列 MQTT 版时，同时会收取云消息队列 RocketMQ 版的Topic资源占用费及API接口的调用费。因此，您的阿里云产品消费汇总中，会出现云消息队列 ...

监控报警

前提条件创建服务关联角色角色名称：AliyunServiceRoleForOns 角色策略名称：AliyunServiceRolePolicyForOns 权限说明：允许云消息队列 RocketMQ 版使用该角色访问您的服务（云监控和ARMS服务）以完成监控报警和Dashboard相关功能。...

使用ACL功能进行访问控制

当需要对不同的用户或用户组授予不同级别的访问权限时，您可以使用云消息队列 Kafka 版专业版或V3系列Serverless 实例的访问控制列表（ACL）功能，为SASL用户赋予对Topic、Group等资源的操作权限，实现细粒度的权限管理。背景信息企业A...

联系我们

如果您准备使用或正在使用云消息队列 RabbitMQ 版，有任何产品相关疑问和建议，欢迎自行搜索以下群号加入钉钉群与我们交流。钉钉群号：31735582

使用云消息队列 Kafka 版时出现消息堆积

使用云消息队列 Kafka 版时，可能会发现Group中出现消息堆积。本文介绍如何判断消息堆积是否属于正常情况，以及处理方法。客户端消费流程了解客户端消费流程，有助于理解消息是否堆积。一般情况下，客户端消费流程大致如下：判断消息...

云消息队列 Kafka 版自定义权限策略参考

本文介绍云消息队列 Kafka 版使用自定义权限策略的场景和策略示例。什么是自定义权限策略在基于RAM的访问控制体系中，自定义权限策略是指在系统权限策略之外，您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您来...

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

音视频管控服务收到参数后将参数封装成邀请入会的消息，发送到云消息队列 RocketMQ 版，经过云消息队列 MQTT 版路由后消息会投递给发起者用户A使用的终端App，用户A的终端App根据参数加入会议频道完成入会操作。音视频管控服务还需要...

云消息队列 MQTT 版

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

获取SDK

本文介绍如何获取和使用云消息队列 RabbitMQ 版多语言SDK。SDK下载云消息队列 RabbitMQ 版的多语言SDK的下载地址及说明文档如下。语言下载地址说明文档 Java Alibaba Cloud AMQP SDK for Java 开始使用 Go Alibaba Cloud AMQP SDK ...

使用云消息队列 Kafka 版时出现“Not authorized to ...

问题描述使用云消息队列 Kafka 版时出现“Not authorized to access group”的错误信息。问题原因没有创建Consumer Group时会遇到此报错信息。解决方案您可以选择如下任意一种方式创建Consumer Group。在云消息队列 Kafka 版的控制台...

基本概念

本文介绍云消息队列 RocketMQ 版的基本概念，以便您更好地理解和使用云消息队列 RocketMQ 版。主题（Topic）云消息队列 RocketMQ 版中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题通过TopicName来做唯一标识和区分。...

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

注意事项上述流程简要描述了如何使用云消息队列 MQTT 版和云消息队列 RocketMQ 版来搭建电子价签系统，具体的SDK说明，请参见云消息队列 MQTT 版以及云消息队列 RocketMQ 版文档。其中使用云消息队列 MQTT 版和云消息队列 ...

包年包月

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

云消息队列 RocketMQ 版自定义权限策略

本文介绍云消息队列 RocketMQ 版使用自定义权限策略的场景和策略示例。什么是自定义权限策略在基于RAM的访问控制体系中，自定义权限策略是指在系统权限策略之外，您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您...

CreateSaslUser-创建SASL用户

消息队列 Kafka 版使用 SCRAM-SHA-256。默认值为 plain。plain Mechanism string 否加密方式。取值：SCRAM-SHA-512（默认选中）SCRAM-SHA-256 说明该参数仅支持 V3 系列（Serverless）实例。SCRAM-SHA-256 返回参数名称类型描述示例...

RAM鉴权

说明如需访问云消息队列 MQTT 版的OpenAPI，则需有访问云消息队列 MQTT 版实例的权限，即mq:MqttInstanceAccess权限。更多信息请参见权限策略。API Resource命名格式 Resource命名示例 Action描述 RevokeToken*mq:MqttInstanceAccess...

版本说明

重要推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面地功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x系列SDK和ONS系列SDK后续仅做...

云监控

前提条件创建服务关联角色角色名称：AliyunServiceRoleForAlikafka 角色策略名称：AliyunServiceRolePolicyForAlikafka 权限说明：允许云消息队列 Kafka 版使用该角色访问您的服务（云监控和ARMS服务）以完成云监控和仪表盘相关功能。...

云消息队列 RocketMQ 版

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

什么是云消息队列 MQTT 版

根据以上两种消息收发模型，可以将使用云消息队列 MQTT 版的开发人员分为终端和云端两大类。两类开发人员所需的二次开发内容请分别参见终端开发指南和云端开发指南。产品优势无缝迁移兼容任何支持MQTT 3.1.1协议的SDK，支持...

快速入门概述

本文为您介绍快速使用云消息队列 RabbitMQ 版进行消息收发的操作流程。操作流程后续步骤步骤一：（可选）RAM用户授权步骤二：创建资源步骤三：调用SDK收发消息

消息收发常见问题

本文介绍使用云消息队列 MQTT 版进行消息收发时的常见问题。为什么会出现一条消息同一时间重试多次？为什么消息会一直重试？消息发送时提示GroupID没有权限。使用RocketMQ数据流入MQTT功能时，为什么子级Topic后会多了一个“/”?消息发送...

监控报警

前提条件创建服务关联角色角色名称：AliyunServiceRoleForOns 角色策略名称：AliyunServiceRolePolicyForOns 权限说明：允许云消息队列 RocketMQ 版使用该角色访问您的服务（云监控和ARMS服务）以完成监控报警和Dashboard相关功能。...

计费概述

云消息队列 RabbitMQ 版提供包年包月预付费和Serverless按量后付费计费方式，每种计费方式的计费项和计费规则都有所差异，您可以按照不同的使用场景和业务规模选择合适计费方式及实例类型，达到成本最优化的效果。实例类型和计费模式说明...

应用场景

本文为您介绍云消息队列 RabbitMQ 版的应用场景，以便您更好地判断如何在业务中使用云消息队列 RabbitMQ 版。异步解耦云消息队列 RabbitMQ 版可用于单体应用被拆解为微服务后不同微服务间的通信。应用解耦的好处是不同应用的迭代不再...

MNS消息回执通知

语法/*+run_async=true,mq-notify-by=mns,mq-queue=${您的mns队列}*/select*from xxxx.;示例/*+run-async=true,mq-notify-by=mns,mq-queue=dla*/select*from oss_schema.oss_json;执行上述SQL，得到SQL任务ID ASYNC_TASK_ID，例如 q...

阿里云mq队列如何使用

新品推荐