阿里云消息 mq怎么用-阿里云消息 mq怎么用文档介绍内容-阿里云

MQ消息回执通知

本文以异步查询OSS数据为例，介绍如何在DLA中使用MQ做消息回执通知。前提条件开通OSS服务说明在DLA中异步执行SQL时，...MQ成功接收DLA消息后，您就可以通过MQ实时了解DLA异步执行SQL的任务详情。关于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。配置出口数据登录物联网络管理平台控制台。在左侧导航栏选择节点管理>节点分组，单击一条节点分组对应操作栏下的...

如何快速使用消息队列RocketMQ版的TCP Java SDK收发...

本文提供使用消息队列RocketMQ版的TCP Java SDK收发消息的快速入门视频。

本地IDC通过专线使用消息队列RocketMQ版处理消息

本文为您介绍本地IDC如何通过物理专线访问云上消息队列RocketMQ版，实现本地IDC使用消息队列RocketMQ版收发并处理消息。背景信息本文以下图场景为例，某企业在阿里云华北2（北京）地域部署了专有网络VPC（Virtual Private Cloud）和交换机...

MQ 事务消息纳入全局事务管理样例

本样例介绍如何把 MQ 事务消息的发送纳入 GTS 管理的全局事务。前提条件在把 MQ 事务消息的发送纳入 GTS 管理的全局事务，请先完成以下工作：准备一个可用的 MySQL 环境（可以是阿里云的 RDS）。准备一个可用的 Maven 环境。样例说明样例...

如何快速使用微消息队列MQTT版的Java SDK收发消息？

本文提供使用微消息队列MQTT版的Java SDK收发消息的快速入门视频。

如何快速使用消息队列RabbitMQ版的Java SDK收发消息

本文提供使用云消息队列 RabbitMQ 版的Java SDK收发消息的快速入门视频。

快速使用MQTT.fx模拟SDK收发消息

本文以Windows系统为例，介绍如何使用MQTT.fx模拟SDK接入云消息队列 MQTT 版并进行消息收发。前提条件下载并安装 MQTT.fx。背景信息云消息队列 MQTT 版最简单的使用场景即MQTT客户端消息的自发自收。如下图所示，您可以使用MQTT.fx...

快速使用MQTT的Java SDK收发消息（终端和终端消息收发...

本文介绍如何快速使用云消息队列 MQTT 版的Java SDK实现MQTT终端与终端消息的收发。前提条件创建资源获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。下载安装 JDK。背景信息云消息队列 MQTT ...

快速使用MQTT的Java SDK收发消息（终端和云端消息收发...

本文介绍如何快速使用云消息队列 MQTT 版的Java SDK实现MQTT终端和云端服务的消息收发。前提条件创建资源获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。下载安装 JDK。背景信息 MQTT终端和...

如何开启事件推送

注意：在使用消息队列MQ时，请注意以下网络访问限制：Topic和GroupID创建在同一个地域（Region）下的同一个实例中才能互通，目前只有上海Region支持内网访问，其他Region仅支持公网访问。地域的详细介绍，请参见地域和可用区介绍。实例...

事件推送

在使用消息队列MQ时，请注意以下网络访问限制：Topic和GroupID创建在同一个地域（Region）下的同一个实例中才能互通。地域的详细介绍，请参见地域和可用区介绍。完成以下操作，在新建队列实例下，新建Topic。在左侧导航栏，单击Topic管理页...

消息队列

当区块链服务监听到链上事件时，会自动生成MQ消息并发布到MQ的主题上，您可以订阅MQ中的这些事件消息做进一步处理。集成消息队列 RocketMQ 说明注意：集成阿里云消息队列Rocket MQ服务，需要您先参考安装云服务集成章节完成云服务集成的...

MQ配置

开通权限云价签需要获取用户发送MQ消息的权限，需在 RAM控制台创建一个新角色，角色名为：CloudEslNotificationRole，并在选择信任的阿里云账号一栏，填入授权的目标账号ID。具体的账号ID请向对口技术同学二次确认。创建成功后，在RAM...

消费托管MQ接口

确认消息消费托管MQ消息成功后，进行确认，方法名称：ackMQMessage。函数原型 AckMQMessageResponse ackMQMessage(final AckMQMessageRequest request)请求参数参数必选说明 streamId 是队列ID，即数据导出服务中的任务ID。...

主题（Topic）

本文介绍云消息队列 RocketMQ 版中主题（Topic）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义主题是云消息队列 RocketMQ 版中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题的作用主要如下：...

旧版样例简介

sample-mq-consumer：该工程主要为上述案例中的 MQ 消息提供者（provider）提供一个消费者（consumer）案例，该工程不依赖 GTS，仅为方便用户理解 MQ 案例。sample-txc-edas：在 EDAS 上使用 GTS 的案例，该案例综合了 GTS、EDAS 及 MQ 的...

服务关联角色

应用场景物联网无线连接服务的MQ消息推送功能，需要访问消息队列RocketMQ版云服务的资源，通过服务关联角色功能获取访问权限。关联角色介绍角色名称：AliyunServiceRoleForLinkcard 权限说明：{"Version":"1","Statement":[{"Effect":...

快速入门概述

本文介绍通过两种协议的多语言SDK收发普通消息的流程和使用须知。背景信息云消息队列 RocketMQ 版提供了四种消息类型，更多信息，请参见消息类型列表。本文以收发普通消息为例进行说明，因此，您按照本文提供的步骤创建的普通消息的...

常见问题

您在使用消息服务产品时，如果收到系统提示的错误信息，可查阅错误代码汇总匹配错误信息。对于其他问题，您可根据下列分类匹配问题场景和解决方案。产品介绍什么是MNS 如何使用MNS MNS的使用场景什么是Account ID MNS不同地域的接入...

产品概述

平台组件：是指产品对平台提供的服务目录的依赖项，例如：一个办公软件，依赖MQ消息中间件，如果用户希望由ADP平台提供该中间件，则他应该在产品依赖中，声明对该MQ组件的依赖。用户组件：是指用户自身代码构建的业务应用，打包上传至ADP...

SDK概述

SDK Demo地址适用的协议参考文档说明文件 Java SDK Java SDK Demo PLAINTEXT SASL_SSL/PLAIN SASL_PLAINTEXT/PLAIN SASL_PLAINTEXT/SCRAM 使用实例接入点收发消息 README.md Python SDK Python SDK Demo PLAINTEXT SASL_SSL/PLAIN ...

超大消息传输

当消息内容大于64 KB以至于无法直接存入MNS队列时，不做消息切片，使用消息服务MNS 和对象存储OSS 来传递大于64 KB的消息。背景信息消息服务MNS 的队列的消息大小最大限制是64 KB，这个限制基本能够满足在正常情况下消息作为控制流信息...

什么是全局事务服务GTS

可以与RDS、MySQL、PostgreSQL等数据源，Spring Cloud、Dubbo、HSF及其他RPC框架，MQ消息队列等中间件产品配合使用，轻松实现分布式数据库事务、多库事务、消息事务、服务链路级事务及各种组合。为什么需要全局事务服务一个完整的业务往往...

产品功能发布记录

当区块链服务监听到链上事件时，会自动生成MQ消息并发布到MQ的主题上，您可以订阅MQ中的这些事件消息做进一步处理。2020.02.27 相关文档 Hyperledger Fabric【云服务集成】数据库如果您希望区块链上的数据能导出到关系型数据库，您可以将...

设备报警事件

IoT云端订阅设备alarmEvent事件和上下线的MQ消息，将其转换为DOP数据模型，由上层应用订阅获取设备消息。模型ID：DeviceAlarmEventBasic 模型版本：1.0 属性名称属性标识符数据类型数据描述租户id tenantId String 租户id 事件时间 ...

C# SDK收发消息

本文介绍如何使用C#SDK通过接入点接入云消息队列 Kafka 版并收发消息。环境配置您已安装.NET。更多信息，请参见安装.NET 。安装C#依赖库执行以下命令安装C#依赖库。dotnet add package-v 1.5.2 Confluent.Kafka 准备配置可选：下载...

消费重试

以下场景建议使用消息重试业务处理失败，且失败原因跟当前的消息内容相关，比如该消息对应的事务状态还未获取到，预期一段时间后可执行成功。消费失败的原因不会导致连续性，即当前消息消费失败是一个小概率事件，不是常态化的失败，后面...

顺序消息

本文介绍云消息队列 RocketMQ 版顺序消息的概念、适用场景、实现原理以及使用过程中的注意事项。什么是顺序消息顺序消息是云消息队列 RocketMQ 版提供的一种对消息发送和消费顺序有严格要求的消息。对于一个指定的Topic，消息严格按照...

OpenService

使用说明本接口用于第一次使用消息服务MNS 的场景。开通服务后，您才能使用消息服务MNS。只要调用任意可用地域的接入点就可以开通全地域。说明可用地域包括英国（伦敦）、美国（弗吉尼亚）、华东1（杭州）、华北2（北京）、华南1（深圳...

通过可观测性能力进行故障处理最佳实践

消费异常场景实践方案 使用消息处理延迟时间（ConsumerLagLatencyPerGidTopic）作为监控指标项并创建报警规则。具体操作，请参见监控报警。该指标可明确反映消费链路的健康情况，并直接关联业务影响程度，比消息堆积量更加准确且没有歧义...

消息队列Kafka版删除Group后仍然收到消息堆积的告警...

问题描述使用阿里云消息队列Kafka版时，删除Group后，仍然收到消息堆积的告警信息，如何过滤某个Group的消费堆积告警...相关文档为什么Group不存在但能消费消息消息堆积了怎么办 使用消息队列Kafka版时出现消息堆积适用于消息队列Kafka版

消费者负载均衡

消息粒度负载均衡：PushConsumer和SimpleConsumer默认负载策略队列粒度负载均衡：PullConsumer默认负载策略消息粒度负载均衡使用范围对于PushConsumer和SimpleConsumer类型的消费者，默认且仅使用消息粒度负载均衡策略。策略原理消息...

开源对比

通过插件或使用消息存活时间过期转移方式实现。事务消息不支持。支持。顺序消息不支持。支持。消息优先级不支持。支持。消息重试机制消息消费超过一定时间未响应会重新投递。超时时间和重试次数的详细解释，请参见消息超时和重试机制...

如何使用MNS？

本文介绍如何使用消息服务MNS。注册阿里云账号并开通消息服务MNS 服务。登录账号管理，在左侧导航栏单击安全设置，在安全设置页面获取账号ID。登录用户信息管理，在左侧导航栏单击安全信息管理，在安全信息管理页面获取访问密钥...

消息轨迹查询

当消息的收发不符合预期时，您可以使用消息轨迹查询功能，查询消息的收发轨迹，确保数据正常流转、快速定位异常。操作步骤登录云消息队列 MQTT 版控制台，并在左侧导航栏单击实例列表。在顶部菜单栏选择目标地域，然后在实例列表中单击...

功能与特性概述

概览云消息队列 RocketMQ 版在阿里云多个地域（Region）提供了高可用消息云服务。单个地域内采用多机房部署，可用性极高，即使整个机房都不可用，仍然可以为应用提供消息发布服务。云消息队列 RocketMQ 版提供TCP和HTTP协议的多语言接入...

模块开通

单地域双地域企业版RocketMQ 阿里云企业版MQ服务容灾模块，保证MQ消息收发的容灾调度与消息数据RPO。单地域双地域 DRDS服务 DRDS容灾模块，保障数据的RPO。双地域 OceanBase服务 OceanBase服务容灾模块，保障数据的RPO。双地域 PolarDB ...

阿里云消息 mq怎么用

新品推荐