概述
使用说明 社区版SDK仅在开源RocketMQ迁移上云且不希望修改代码时使用，其他场景推荐您使用阿里云 云消息队列 RocketMQ 版 提供的商业版SDK进行接入。和社区版SDK相比，商业版SDK提供了更加丰富的功能特性并具有更高的稳定性保障。更多信息...
通知
消息服务MNS 不再提供Android SDK，...阿里云消息队列（MQ）推出 微消息队列MQTT，适用于移动互联网以及物联网应用，连接端（浏览器、Android、iOS、智能设备、互动直播、车联网）与云，实现双向通信，万物互联。更多信息，请参见 Demo工程。
通知
消息服务MNS 不再提供Objective-C ...阿里云消息队列（MQ）推出 微消息队列MQTT，适用于移动互联网以及物联网应用，连接端（浏览器、Android、iOS、智能设备、互动直播、车联网）与云，实现双向通信，万物互联。更多信息，请参见 Demo工程。
概述
使用说明 社区版SDK仅在开源RocketMQ迁移上云且不希望修改代码时使用，其他场景推荐您使用阿里云 云消息队列 RocketMQ 版 提供的商业版SDK进行接入。和社区版SDK相比，商业版SDK提供了更加丰富的功能特性并具有更高的稳定性保障。更多信息...
消息队列
当区块链服务监听到链上事件时，会自动生成MQ消息并发布到MQ的主题上，您可以订阅MQ中的这些事件消息做进一步处理。集成消息队列 RocketMQ 说明 注意：集成阿里云消息队列Rocket MQ服务，需要您先参考安装云服务集成章节完成云服务集成的...
权限策略
AliyunMQPubOnlyAccess 云消息队列 MQTT 版 的发布权限，被授予该权限的RAM用户具有使用阿里云账号所有资源通过SDK发送消息的权限。AliyunMQSubOnlyAccess 云消息队列 MQTT 版 的订阅权限，被授予该权限的RAM用户具有使用阿里云账号所有...
开通服务并授权
AliyunMQSubOnlyAccess 云消息队列 MQTT 版 的订阅权限，被授予该权限的RAM用户具有使用阿里云账号所有资源通过SDK订阅消息的权限。AliyunMQReadOnlyAccess 云消息队列 MQTT 版 的只读权限，被授予该权限的RAM用户仅有通过访问控制台或调用...
商业化服务条款
在您使用阿里云MQ服务前，您应仔细阅读阿里云就该服务在阿里云网站上的服务说明，依照相关操作指引进行操作，请您自行把握风险谨慎操作。如未按照相关指引操作可能导致包括但不限于数据库被删除、计算结果错误、计算性能低下等后果；您理解...
MQ配置
MQ配置提供了一套通过阿里云RocketMQ产品订阅云价签产品消息的机制。前提条件 使用MQ订阅云价签产品消息，您需要先开通 RocketMQ产品 并创建实例。开通权限 云价签需要获取用户发送MQ消息的权限，需在 RAM控制台 创建一个新角色，角色名为...
MQ 事务消息纳入全局事务管理样例
前提条件 在把 MQ 事务消息的发送纳入 GTS 管理的全局事务，请先完成以下工作：准备一个可用的 MySQL 环境（可以是阿里云的 RDS）。准备一个可用的 Maven 环境。样例说明 样例工程模拟了资金转账的应用。包含 2 个数据源，和 1 个 MQ 事务...
MQ消息回执通知
本文以异步查询OSS数据为例，介绍如何在DLA中使用MQ做消息回执通知。前提条件 开通OSS服务 说明 在DLA中异步执行SQL时，必须开通OSS服务，存储SQL执行结果。创建目录 OSS数据源 创建MQ实例、Topic、Group 操作步骤 新建RAM角色。使用DLA...
调用方式
OpenAPI开发者门户调用 使用OpenAPI开发者门户的API调试功能，您可以通过网页或者命令行调用各云产品以及API市场上开放的API，查看每次的API请求和返回结果，并生成相应SDK调用示例。您可以直接访问 OpenAPI开发者门户 调用API，也可以通过...
事件推送
在使用消息队列MQ时，请注意以下网络访问限制：Topic和GroupID创建在同一个地域（Region）下的同一个实例中才能互通。地域的详细介绍，请参见地域和可用区介绍。完成以下操作，在新建队列实例下，新建Topic。在左侧导航栏，单击Topic管理页...
权限策略
AliyunMQPubOnlyAccess 云消息队列 MQTT 版 的发布权限，被授予该权限的RAM用户具有使用阿里云账号所有资源通过SDK发送消息的权限。AliyunMQSubOnlyAccess 云消息队列 MQTT 版 的订阅权限，被授予该权限的RAM用户具有使用阿里云账号所有...
配额与限制
建议您使用阿里云提供的 云消息队列 MQTT 版 服务，其功能更完整。Apache RocketMQ EventBridge组件 云消息队列 RocketMQ 版 暂不支持提供托管的Apache RocketMQ EventBridge组件服务。建议您使用阿里云的 事件总线EventBridge 服务，其...
查询消息轨迹
当消息收发结果不符合预期或您需要对特定消息进行追踪时，您可通过查看消息轨迹获取指定消息在各个环节的处理状态。消息轨迹数据 云消息队列 RocketMQ 版 系统中，一条消息的完整链路包含生产者、服务端、消费者三个角色，每个角色处理消息...
开发场景：基于消息队列RocketMQ版实现环境隔离
如果您使用阿里云 消息队列RocketMQ版，需要使用铂金版，且Ons Client使用1.8.0.Final及以上版本。更多信息，请参见 快速入门概述。开启RocketMQ消息灰度后，消息的Consumer Group会被修改。例如原来的Consumer Group为 group1，环境标签为...
云消息队列 RocketMQ 版
说明 如果您的MQ消息为二进制格式，则DDL中只能定义一个字段，且字段类型必须为VARBINARY。创建将 keys 和 tags 字段指定为RocketMQ消息的key和tag的结果表 RocketMQ 5.x CREATE TABLE mq_sink(id INTEGER,len BIGINT,content VARCHAR,keys...
授权信息
操作（Action）下表是 消息队列 MQ（Ons）定义的操作，这些操作可以在RAM权限策略语句的 Action 元素中使用，用来授予执行该操作的权限。下面对表中的具体项提供说明：操作：是指具体的权限点。API：是指操作对应的API接口。访问级别：是指...
快速入门
具体解析设置请参考：阿里云（万网）域名使用阿里邮箱如何设置解析?非阿里云（万网）域名使用阿里邮箱如何设置解析？Step7：钉邮绑定与同步 如果需要进行钉邮绑定与通讯录同步，请参考 钉邮绑定和通讯录同步。Step8：启用阿里邮箱 为保障...
阿里云电子政务云产品全家福
阿里云电子政务云平台提供弹性计算类、网络、数据库、存储、大数据、中间件、IoT等品类丰富的产品及高标准的安全合规服务，用以支撑多种政务类业务场景，例如：城市大脑，合规应用平台等。截至文档发布时间，阿里云电子政务云共计上线95款...
OnsDLQMessageGetById-根据Message ID查询死信消息
接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。根据 Message ID 查询死信消息的方式属于...
快速使用MQTT的Java SDK收发消息（终端和终端消息收发...
本文介绍如何快速使用 云消息队列 MQTT 版 的Java SDK实现MQTT终端与终端消息的收发。前提条件 创建资源 获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。下载安装 JDK。背景信息 云消息队列 MQTT ...
配置消息日志
查看消息的消费者或消费次数。查看一个月前或者更久之前的消息操作日志。注意事项 如果您删除Project、Logstore，或者将授予 云消息队列 RabbitMQ 版 的权限取消，日志将无法正常推送。为方便查询消息日志，建议您在使用SDK收发消息时设置...
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
SDK 使用说明
消费托管MQ的使用说明 在Java项目中使用BaaS REST进行消费托管MQ之前，请参见本文上方的 SDK 通用说明 获取REST身份、下载 REST SDK、添加依赖及修改配置项。说明 在修改配置项时，无需进行链账户相关的额外配置。SDK 版本需升级至2.15.3及...
MQTT和RocketMQ进行数据互通（跨产品数据流入）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
调用TCP协议的SDK收发普通消息
查看消息是否发送成功 消息发送后，您可以在 云消息队列 RocketMQ 版 控制台 查看消息发送状态，步骤如下：在实例所在页面的左侧导航栏，单击 消息查询。在 消息查询 页面，按需选择查询条件，单击 查询。存储时间 表示 云消息队列 ...
查询Group ID内所有死信消息
接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。按 Group ID 查询死信消息的方式属于范围...
MQTT和RocketMQ进行数据互通（客户端上下线通知）
MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息，云消息队列 MQTT 版 支持将该条消息数据导出至其他阿里云产品，并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的 云消息队列 RocketMQ 版 数据互通...
通过RocketMQ客户端消费设备消息
在 实例详情 页面单击右上方的 查看开发配置，在 开发配置 面板查看接入域名。实例的更多详细说明，请参见 管理实例终端节点。取消以下代码的注释符号，调用 aiot_mqtt_pub，向指定的Topic：/k0*/MQdevice/user/data 发送消息。MQTT 发布...
通过RocketMQ客户端消费设备消息
在 实例详情 页面单击右上方的 查看开发配置，在 开发配置 面板查看接入域名。实例的更多详细说明，请参见 管理实例终端节点。取消以下代码的注释符号，调用 aiot_mqtt_pub，向指定的Topic：/k0*/MQdevice/user/data 发送消息。MQTT 发布...
收发普通消息
消息内容。MessageTag:"",/消息标签。Properties:map[string]string{},/消息属性。}/设置消息的Key。msg.MessageKey="MessageKey"/设置消息自定义属性。msg.Properties["a"]=strconv.Itoa(i)ret,err:=mqProducer.PublishMessage(msg)if ...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Python SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Python SDK。更多信息，请参见 ...
OnsMessageTrace-查看消息消费结果
调用OnsMessageTrace根据Message ID来判断...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsMessageTrace 接口，您还可以通过云消息队列 RocketMQ 版控制台查看消息的消费状态。具体操作，请参见 查询消息轨迹。
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的C#SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装C#SDK。更多信息，请参见 准备环境。...
OnsMessageGetByMsgId-通过MsgId查询消息
通过传入 Message ID 查询指定消息的信息...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsMessageGetByMsgId 接口，您还可以通过消息队列 RocketMQ 版控制台查看消息的详细信息。具体操作，请参见 消息查询。
OnsMessageGetByKey-根据Message Key查询消息
根据 Topic 和 Message Key 模糊查询消息...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsMessageGetByKey 接口，您还可以通过云消息队列 RocketMQ 版控制台查看消息的详细信息。具体操作，请参见 消息查询。
快速入门
Resource":"acs:oss:*:*:*"},{"Effect":"Allow","Action":"mq:QueryInstanceBaseInfo","Resource":"acs:mq:*:*:*"}]} 在 RAM控制台 的 身份管理>用户 中，找到RAM子账户，单击操作列的 添加权限，选择上一步创建的自定义策略，和 系统策略...
授权信息
操作（Action）下表是 消息队列 MQ（RocketMQ）定义的操作，这些操作可以在RAM权限策略语句的 Action 元素中使用，用来授予执行该操作的权限。下面对表中的具体项提供说明：操作：是指具体的权限点。API：是指操作对应的API接口。访问级别...
- 产品推荐
- 这些文档可能帮助您