如何开启事件推送
注意：在使用消息队列MQ时，请注意以下网络访问限制：Topic和GroupID创建在同一个地域（Region）下的同一个实例中才能互通，目前只有上海Region支持内网访问，其他Region仅支持公网访问。地域的详细介绍，请参见 地域和可用区介绍。实例...
为什么Topic有分区时间显示1970或“-”？
问题现象 Topic的分区更新时间显示为1970或者为“-”。可能原因 出现此问题的原因可能...如果是Local存储引擎，您可以使用消息查询功能查看正确消息生产时间。如果是云存储引擎，并且缓存过期，您可以使用消息查询功能查看正确消息生产时间。
消息轨迹
本文介绍消息轨迹的使用场景、云消息队列 RocketMQ 版 定义的轨迹参数以及如何查看消息轨迹。使用场景 云消息队列 RocketMQ 版 将消息收发流程中的关键数据定义为轨迹参数，并支持可视化查询，通过查看轨迹信息可快速获取当前业务处理的...
数据出口
Link WAN支持通过阿里云物联网平台流转数据，也支持用户自建云服务流转数据。数据出口至 物联网平台控制台，...节点分组N:1映射到产品设备列表 节点分组N:1映射到MQ消息队列的Topic 说明 N:1汇聚到消息队列MQ的Topic，数据流转至自建云服务
商业化服务条款
本服务条款是阿里云计算有限公司（以下简称“阿里云”）与您就消息队列服务（Message Queue，简称MQ）的相关事项所订立的有效合约。您通过盖章、网络页面单击确认或以其他方式选择接受本服务条款，包括但不限于未单击确认本服务条款而事实...
设备报警事件
IoT云端订阅设备alarmEvent事件和上下线的MQ消息，将其转换为DOP数据模型，由上层应用订阅获取设备消息。模型ID：DeviceAlarmEventBasic 模型版本：1.0 属性名称 属性标识符 数据类型 数据描述 租户id tenantId String 租户id 事件时间 ...
MQ配置
前提条件 使用MQ订阅云价签产品消息，您需要先开通 RocketMQ产品 并创建实例。开通权限 云价签需要获取用户发送MQ消息的权限，需在 RAM控制台 创建一个新角色，角色名为：CloudEslNotificationRole，并在选择信任的阿里云账号一栏，填入...
产品概述
平台组件：是指产品对平台提供的服务目录的依赖项，例如：一个办公软件，依赖MQ消息中间件，如果用户希望由ADP平台提供该中间件，则他应该在产品依赖中，声明对该MQ组件的依赖。用户组件：是指用户自身代码构建的业务应用，打包上传至ADP...
服务关联角色
应用场景 物联网无线连接服务的MQ消息推送功能，需要访问消息队列RocketMQ版云服务的资源，通过服务关联角色功能获取访问权限。关联角色介绍 角色名称：AliyunServiceRoleForLinkcard 权限说明：{"Version":"1","Statement":[{"Effect":...
MQ推送
MQ推送用于监控物联网卡的状态变化以及流量使用情况，并可以直接将消息推送到用户自己的系统中，帮助用户实时接收物联网卡的状态变化、套餐用量等信息。使用说明 MQ推送与自动化规则都是用于监控物联网卡的状态变化以及流量使用情况，主要...
事件推送
在使用消息队列MQ时，请注意以下网络访问限制：Topic和GroupID创建在同一个地域（Region）下的同一个实例中才能互通。地域的详细介绍，请参见地域和可用区介绍。完成以下操作，在新建队列实例下，新建Topic。在左侧导航栏，单击Topic管理页...
查询消息轨迹
云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...
日志管理概述
日志查看：查看日志。在为LogStore创建索引时，请选择合理的数据保存时间，该属性后续只支持缩短，不支持延长。如果您将LoggingBucket对应的 SLS 的Project、LogStore删除，或者将授予 消息服务MNS 的权限取消，日志将无法正常推送。日志...
MQ消息回执通知
本文以异步查询OSS数据为例，介绍如何在DLA中使用MQ做消息回执通知。前提条件 开通OSS服务 说明 在DLA中异步执行SQL时，必须开通OSS服务，存储SQL执行结果。创建目录 OSS数据源 创建MQ实例、Topic、Group 操作步骤 新建RAM角色。使用DLA...
查看消息清单
消息发送后您可以通过 ChatApp消息服务 控制台查看消息发送和接收详情、状态报告、批量发送详情等信息。本文为您介绍如何在 ChatApp消息服务 控制台查看消息发送和接收详情等操作。查看消息清单 登录 ChatApp消息服务控制台。在左侧导航栏...
sample-txc-mq 样例
本样例介绍如何把 MQ 事务消息的发送纳入 GTS 管理的全局事务。前提条件 在使用 sample-txc-mq 样例前，请先完成以下工作：开通 GTS（创建事务分组）。开通 MQ。...可以消费掉刚刚 sample-txc-mq 工程生产出来的 MQ 消息。
什么是全局事务服务GTS
可以与RDS、MySQL、PostgreSQL等数据源，Spring Cloud、Dubbo、HSF及其他RPC框架，MQ消息队列等中间件产品配合使用，轻松实现分布式数据库事务、多库事务、消息事务、服务链路级事务及各种组合。为什么需要全局事务服务 一个完整的业务往往...
搭建与管理网络
凭证入网 网关配置完成，并分配入网凭证给自己后，您就可以用这个凭证来使用网络，并且可以将消息队列（MQ）作为数据出口。登录 物联网络管理平台控制台。在左侧导航栏，选择 节点管理>节点分组。在 节点分组 页面，单击 创建分组。在 创建...
Topic与Tag最佳实践
消息量级是否相当：有些业务消息虽然量小但是实时性要求高，如果跟某些万亿量级的消息使用同一个Topic，则有可能会因为过长的等待时间而“饿死”，此时需要将不同量级的消息进行拆分，使用不同的Topic。总的来说，针对消息分类，您可以选择...
应用场景
通用分布式事务管理 提供通用的分布式事务管理能力，支持微服务框架（Spring Cloud、Dubbo 和 HSF）、数据库（DRDS、RDS、MySQL、Oracle等）、消息中间件（MQ）的组合使用，灵活方便。多业务场景：通过混合事务，GTS可以应用到金融、电信、...
主题（Topic）
正确拆分示例：线上商品购买场景下，订单交易如订单创建、支付、取消等流程消息使用一个主题，物流相关消息使用一个主题，积分管理相关消息使用一个主题。错误拆分示例：拆分粒度过粗：会导致业务隔离性差，不利于独立运维和故障处理。例如...
RESTful API概览
BatchSendMessage 批量发送消息 API调用 ReceiveMessage 消费消息 控制台、API调用 BatchReceiveMessage 批量消费消息 API调用 DeleteMessage 删除消息 控制台、API调用 BatchDeleteMessage 批量删除消息 API调用 PeekMessage 查看消息 API...
查看消费明细
本文主要为您介绍如何查看 云消息队列 RocketMQ 版 4.x系列标准版实例的费用明细，帮助您解决如下问题：如何查看每个Topic每天的费用明细和使用量？如何查看每个Topic计费项的资源包抵扣明细？如何查看每个Topic每小时的用量明细？为什么...
使用Canal将MySQL的数据同步至云消息队列 Kafka 版
本教程介绍如何使用Canal将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Canal的主要用途是基于MySQL数据库增量日志解析，提供增量数据订阅和消费。Canal伪装自己为MySQL Slave，向MySQL Master发送dump请求。MySQL Master收到dump...
快速入门概述
本文介绍通过两种协议的多语言SDK收发普通消息的流程和使用须知。背景信息 云消息队列 RocketMQ 版 提供了四种消息类型，更多信息，请参见 消息类型列表。...后续步骤 使用TCP协议的SDK收发消息 使用HTTP协议的SDK收发消息
消息队列
当区块链服务监听到链上事件时，会自动生成MQ消息并发布到MQ的主题上，您可以订阅MQ中的这些事件消息做进一步处理。集成消息队列 RocketMQ 说明 注意：集成阿里云消息队列Rocket MQ服务，需要您先参考安装云服务集成章节完成云服务集成的...
MNS提供哪些可用的操作？
API调用 PeekMessage 查看消息 API调用 BatchPeekMessage 批量查看消息 API调用 ChangeMessageVisibility 修改消息下次可消费时间 API调用 消息服务MNS 主题模型支持的操作指令如下：接口 功能描述 支持方式 CreateTopic 创建主题 控制台、...
服务等级协议
消息服务MNS 规定了阿里云向客户提供的 消息服务MNS 的服务可用性等级指标及赔偿方案。如需查看 消息服务MNS 的服务可用性等级指标及赔偿方案，请参见 消息服务MNS服务等级协议。
P2P消息收发模式（MQTT）
发送P2P消息 使用MQTT SDK发送P2P消息时，需将二级Topic设为“p2p”，将三级Topic设为目标接收者的Client ID。Java示例 String p2pTopic=topic+"/p2p/GID_xxxx@DEVICEID_001;sampleClient.publish(p2pTopic,message);使用 云消息队列 ...
常见问题
计费相关 删除队列后，是否继续计费 删除主题后，是否继续计费 消息问题 消息服务MNS的订阅成功后收不到消息 删除消息时报“message not exist”的错误 HttpEndpoint接口接收不到消息 使用消息服务MNS的HTTPEndpoint接口时签名认证失败 ...
P2P消息收发模式（MQTT）
发送P2P消息 使用MQTT SDK发送P2P消息时，需将二级Topic设为“p2p”，将三级Topic设为目标接收者的Client ID。Java示例 String p2pTopic=topic+"/p2p/GID_xxxx@DEVICEID_001;sampleClient.publish(p2pTopic,message);使用 云消息队列 ...
直播互动解决方案
您可以将一个直播间与一个MQTT的Topic对应，例如客户端发送消息使用的Topic为roomSend/message，订阅消息使用的Topic为room/message/123456，其中：roomSend为直播间所有客户端发送消息使用的父级Topic，需要在 云消息队列 MQTT 版 控制台...
C# SDK收发消息
SaslMechanism 收发消息使用的安全机制。SSL接入点：取值为 SaslMechanism.Plain。SASL接入点：PLAIN机制时，取值为 SaslMechanism.Plain；SCRAM机制时，取值为 SaslMechanism.ScramSha256。SecurityProtocol 收发消息使用的安全协议。SSL...
消息服务MNS的订阅成功后收不到消息
关于如何查看消息服务MNS的日志，请参见 日志管理。检查订阅时是否设置了 FilterTag 参数。根据实际情况，选择是否继续保留该参数。关于该参数的介绍，请参见 订阅接口规范。如果您的问题仍未解决，您可以在阿里云社区 免费咨询。
普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。说明 您在调用SDK收发消息时需注意，云消息队列 RocketMQ 版 提供的四种消息类型所对应的Topic不能混用，例如，您创建的普通消息...
云存储网关利用MQTT服务实现统一管控
业务方设计用于消息收发的Topic时，需要遵循以下原则：上行消息（CSG实例发给管控服务的消息）和下行消息（管控服务发给CSG实例的消息）使用不同的父级Topic。不同优先级或者消息量级差别比较大的消息使用不同的父级Topic。对于上文描述的...
音视频通信解决方案（MQTT）
业务方设计用于消息收发的Topic时，需要遵循以下原则：上行消息（终端App发给管控服务的消息）和下行消息（管控服务发给终端App的消息）使用不同的父级Topic。不同优先级或者消息量级差别比较大的消息使用不同的父级Topic。对于上文描述的...
配置消息日志
您可以使用 云消息队列 RabbitMQ 版 的日志管理功能将 云消息队列 RabbitMQ 版 实例的消息操作日志推送到日志服务。当消息的发送、消费、确认出现异常时，您可在日志服务查询并分析消息的操作日志，进行异常诊断。前提条件 创建 云消息队列...
sample-txc-edas 样例
DJM.LOG.RETAIN.COUNT=7-DJM.LOG.FILE.SIZE=300MB"在 sample-txc-edas/txc-client-mq/client/bin 目录下执行 run.sh，查看 MQ 的 Provider 执行结果。将 sample-mq-consumer 工程上传到 ECS。在 sample-mq-consumer/src/main/java/...
权限策略
mq:QueryMqttMsgTransTrend 根据Topic查询消息的收发报表 mq:SendMqttMessageByConsole 控制台发消息测试 mq:CreateMqttTopic 创建Topic mq:DeleteMqttTopic 删除Topic mq:ListMqttTopic 查询Topic mq:UpdateMqttTopic 更新Topic备注信息 ...
- 产品推荐
- 这些文档可能帮助您