MQ消息回执通知
本文以异步查询OSS数据为例，介绍如何在DLA中使用MQ做消息回执通知。前提条件 开通OSS服务 说明 在DLA中异步执行SQL时，必须开通OSS服务，存储SQL执行结果。创建目录 OSS数据源 创建MQ实例、...关于MQ，请参见 什么是消息队列RocketMQ版？
MQ订阅消息
通过MQ订阅系统消息格式说明。消息定义 消息体 字段 类型 说明 EventCatgory String 事件分类，取值范围："DEVICE"：设备事件"BIZ":业务事件 Event String 事件说明："DEVICE_OFFLINE":设备下线"DEVICE_PROPERTY"：设备属性变更"BIZ_...
消息队列MQ的审计事件
消息队列MQ（AMQP）已与操作审计服务集成，您可以在操作审计中查询用户操作消息队列MQ产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中，满足实时审计、问题回溯分析等需求。操作审计记录了...
数据出口至消息队列MQ
物联网络管理平台支持数据出口至阿里云中间件消息队列MQ，本文介绍如何在物联网络管理平台上配置数据流转至消息队列MQ。配置出口数据 登录 物联网络管理平台控制台。在左侧导航栏选择 节点管理>节点分组，单击一条节点分组对应 操作 栏下的...
什么是云消息队列 MQTT 版
云消息队列 MQTT 版 是阿里云推出的一款面向移动互联网以及物联网领域的轻量级消息中间件。如果说传统的消息队列中间件一般应用于微服务之间，那么适用于物联网的 云消息队列 MQTT 版 则实现了端与云之间的消息传递和真正意义上的万物互联...
MQ 事务消息纳入全局事务管理样例
本样例介绍如何把 MQ 事务消息的发送纳入 GTS 管理的全局事务。前提条件 在把 MQ 事务消息的发送纳入 GTS 管理的全局事务，请先完成以下工作：准备一个可用的 MySQL 环境（可以是阿里云的 RDS）。准备一个可用的 Maven 环境。样例说明 样例...
什么是云消息队列 RocketMQ 版？
为什么选择云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 基于阿里云云原生优质的基础设施实现，兼容Apache RocketMQ的核心API和功能。相对于自建RocketMQ集群，云消息队列 RocketMQ 版 具有如下优势：架构先进性 全面采用存储和计算分离...
什么是消息队列RabbitMQ版？
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品。云消息队列 RabbitMQ 版 兼容开源RabbitMQ客户端，解决开源各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等云...
什么是云消息队列 RabbitMQ 版
三分钟了解阿里云 云消息队列 RabbitMQ 版。
消息存活时间
什么是消息存活时间 在 云消息队列 RabbitMQ 版 中，消息存活时间用于限制消息在Queue中可以存在的时间，如果消息在Queue中存在的时间超过了设置的消息存活时间，消息将会被进行如下处理：若您未给Queue设置死信Exchange，消息将被Queue...
消息幂等
什么是消息幂等 在数学与计算机学中，幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。在消息领域，幂等是指Consumer重复消费某条消息时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生...
消费幂等
什么是消息幂等 当出现消费者对某条消息重复消费的情况时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生任何负面影响，那么这个消费者的处理过程就是幂等的。例如，在支付场景下，消费者消费扣款消息，对一笔...
数据出口
Link WAN支持通过阿里云物联网平台流转数据，也支持用户自建云服务流转数据。数据出口至 物联网平台控制台，...节点分组N:1映射到产品设备列表 节点分组N:1映射到MQ消息队列的Topic 说明 N:1汇聚到消息队列MQ的Topic，数据流转至自建云服务
常见问题
顺序消息和普通消息的区别是什么？连接服务端时的用户名和密码在哪里获取？消息队列RocketMQ版订阅的Tag数量有限制吗？消息队列RocketMQ版集群消费和广播消费的区别是什么？多个Group订阅同一个Topic消息如何消费？消息队列RocketMQ版的...
常见问题
顺序消息和普通消息的区别是什么？连接服务端时的用户名和密码在哪里获取？连接服务端时的接入点（endpoint）在哪里获取？云消息队列 RocketMQ 版订阅的Tag数量有限制吗？云消息队列 RocketMQ 版集群消费和广播消费的区别是什么？多个Group...
授权信息
消息队列 MQ（Ons）的RAM代码（RamCode）为 mq，支持的授权粒度为 RESOURCE。权限策略通用结构 权限策略支持JSON格式，其通用结构如下：{"Version":"1","Statement":[{"Effect":"<Effect>","Action":"<Action>","Resource":"<Resource>",...
P2P消息收发模式（MQTT）
什么是P2P模式 P2P，顾名思义，是一对一的消息收发模式，即只有一个消息发送者和一个消息接收者。而Pub/Sub模式通常用于一对多或多对多的消息群发场景，即拥有一个或多个消息发送者和多个消息接收者的场景。在P2P模式中，发送者发送消息时...
P2P消息收发模式（MQTT）
什么是P2P模式 P2P，顾名思义，是一对一的消息收发模式，即只有一个消息发送者和一个消息接收者。而Pub/Sub模式通常用于一对多或多对多的消息群发场景，即拥有一个或多个消息发送者和多个消息接收者的场景。在P2P模式中，发送者发送消息时...
延时消息
什么是延时消息 延时消息是指在指定时间段之后才被消费者消费的消息。应用场景 延时消息适用于以下场景：对消息生产和消费有时间窗口要求的场景。例如，在电商交易中超时未支付关闭订单的场景，在订单创建时会发送一条延时消息。这条消息将...
顺序消息
什么是顺序消息 顺序消息是 云消息队列 RocketMQ 版 提供的一种对消息发送和消费顺序有严格要求的消息。对于一个指定的Topic，消息严格按照先进先出（FIFO）的原则进行消息发布和消费，即先发布的消息先消费，后发布的消息后消费。顺序消息...
产品概述
本文介绍 云消息队列 Kafka 版 的产品动态、产品简介及产品计费。云消息队列 Kafka 版 动态与公告 产品简介 产品计费 云消息队列 Confluent 版 什么是云消息队列 Confluent 版？产品计费
普通消息
功能原理 什么是普通消息 定义：普通消息是 云消息队列 RocketMQ 版 基本消息功能，支持生产者和消费者的异步解耦通信。普通消息生命周期 初始化 消息被生产者构建并完成初始化，待发送到服务端的状态。待消费 消息被发送到服务端，对消费...
授权信息
本文为您介绍 消息队列 MQ（RocketMQ）为RAM权限策略定义的操作（Action）、资源（Resource）和条件（Condition）。消息队列 MQ（RocketMQ）的RAM代码（RamCode）为 rocketmq，支持的授权粒度为 RESOURCE。权限策略通用结构 权限策略支持...
定时/延时消息
功能原理 什么是定时消息 定时消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型，消息被发送至服务端后，在指定时间后才能被消费者消费。通过设置一定的定时时间可以实现分布式场景的延时调度触发效果。定时时间设置原则 云消息队列 ...
顺序消息
功能原理 什么是顺序消息 顺序消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型，支持消费者按照发送消息的先后顺序获取消息，从而实现业务场景中的顺序处理。相比其他类型消息，顺序消息在发送、存储和投递的处理过程中，更多强调多...
事务消息
功能原理 什么是事务消息 事务消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型，支持在分布式场景下保障消息生产和本地事务的最终一致性。事务消息处理流程 事务消息交互流程如下图所示。生产者将消息发送至 云消息队列 RocketMQ 版...
MQTT与RocketMQ的消息结构映射
云消息队列 MQTT 版 的详细介绍，请参见 什么是微消息队列MQTT版 和 名词解释。消息结构映射 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 都是基于发布/订阅（Pub/Sub）模型的消息系统，两者概念上存在很多相似之处，下图列举了关键概念...
基本概念
更多信息，请参见 什么是云消息队列 Kafka 版？ZooKeeper 一款开源的分布式应用程序协调服务。在 云消息队列 Kafka 版 中，ZooKeeper主要用于集群管理、配置管理、Leader选举。ZooKeeper是 云消息队列 Kafka 版 的一部分，您无需感知...
全球消息路由
什么是全球消息路由 云消息队列 RocketMQ 版 的全球消息路由功能依托阿里云优质基础设施实现的高速通道专线（高速通道无需另行开通），高效地实现不同地域之间的消息同步复制。具体实现如下图所示。计费影响 全球消息路由为 云消息队列 ...
将云消息队列 Kafka 版接入阿里云Elasticsearch
更多信息，请参见 什么是云消息队列 Kafka 版。阿里云Elasticsearch Elasticsearch简称ES，是一个基于Lucene的实时分布式的搜索与分析引擎，是遵从Apache开源条款的一款开源产品，是当前主流的企业级搜索引擎。它提供了一个分布式服务，...
MQ配置
开通权限 云价签需要获取用户发送MQ消息的权限，需在 RAM控制台 创建一个新角色，角色名为：CloudEslNotificationRole，并在选择信任的阿里云账号一栏，填入授权的目标账号ID。具体的账号ID请向对口技术同学二次确认。创建成功后，在RAM...
设备报警事件
IoT云端订阅设备alarmEvent事件和上下线的MQ消息，将其转换为DOP数据模型，由上层应用订阅获取设备消息。模型ID：DeviceAlarmEventBasic 模型版本：1.0 属性名称 属性标识符 数据类型 数据描述 租户id tenantId String 租户id 事件时间 ...
sample-txc-mq 样例
本样例介绍如何把 MQ 事务消息的发送纳入 GTS 管理的全局事务。前提条件 在使用 sample-txc-mq 样例前，请先完成以下工作：开通 GTS（创建事务分组）。开通 MQ。...可以消费掉刚刚 sample-txc-mq 工程生产出来的 MQ 消息。
消息队列
当区块链服务监听到链上事件时，会自动生成MQ消息并发布到MQ的主题上，您可以订阅MQ中的这些事件消息做进一步处理。集成消息队列 RocketMQ 说明 注意：集成阿里云消息队列Rocket MQ服务，需要您先参考安装云服务集成章节完成云服务集成的...
API接口常见问题
3）外呼业务ID 4）RocketMQ消息队列实例信息 9、配置好RocketMQ消息队列后，无法获取外呼任务完成消息是怎么回事？需要检查自己建立的RocketMQ实例是否为公网实例，如果所建RocketMQ实例非公网实例则无法获取外呼任务完成的消息队列信息 10...
什么是全局事务服务GTS
可以与RDS、MySQL、PostgreSQL等数据源，Spring Cloud、Dubbo、HSF及其他RPC框架，MQ消息队列等中间件产品配合使用，轻松实现分布式数据库事务、多库事务、消息事务、服务链路级事务及各种组合。为什么需要全局事务服务 一个完整的业务往往...
使用Canal将MySQL的数据同步至云消息队列 Kafka 版
本教程介绍如何使用Canal将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Canal的主要用途是基于MySQL数据库增量日志解析，提供增量数据订阅和消费。Canal伪装自己为MySQL Slave，向MySQL Master发送dump请求。MySQL Master收到dump...
计费常见问题
每天扣除2元，这是什么费用？我昨天删除了Topic，为什么今天会收到账单并被扣费？我没有使用 云消息队列 RocketMQ 版 服务，为什么会扣费？我在控制台上看到没有开通 云消息队列 RocketMQ 版 服务，为什么会有扣费？如何关闭 云消息队列 ...
产品功能发布记录
当区块链服务监听到链上事件时，会自动生成MQ消息并发布到MQ的主题上，您可以订阅MQ中的这些事件消息做进一步处理。2020.02.27 相关文档 Hyperledger Fabric【云服务集成】数据库 如果您希望区块链上的数据能导出到关系型数据库，您可以将...
消息队列RocketMQ版是否能保证消息不重复？
绝大多数情况下，消息是不重复的。作为一款分布式消息中间件，在网络抖动、应用处理超时等异常情况下，无法保证消息不重复，但是能保证消息不丢失。
- 产品推荐
- 这些文档可能帮助您