如果说传统的消息队列中间件一般应用于微服务之间,那么适用于物联网的 云消息队列 MQTT 版 则实现了端与云之间的消息传递和真正意义上的万物互联。本文介绍 云消息队列 MQTT 版 的消息收发模型、产品优势和应用场景。核心概念 Topic:消息...
在左侧导航栏,选择 中间件>消息队列>消息查询 在 消息查询 页面,您可单击以下任一页签,然后按页面提示输入相应信息。按 Message ID 查询:Message ID 是由服务端生成的 32 位字符串,用于标识一条消息。按 Message ID 查询,即根据 ...
除了异步解耦功能,消息队列还有挡住前端数据洪峰的重要功能,以此保证后端系统的稳定性。这要求消息队列具有一定的消息堆积能力。消息队列能支持 10 亿级别的消息堆积,不会因为消息堆积导致性能明显下降。问题描述 在消息队列控制台的...
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。说明 您在调用SDK收发消息时需注意, 云消息队列 RocketMQ 版 提供的四种消息类型所对应的Topic不能混用,例如,您创建的普通...
消息收发为 云消息队列 MQTT 版 最基本的功能,云消息队列 MQTT 版 支持终端和云端服务接入 云消息队列 MQTT 版 服务器,实现终端和终端、终端和云端的消息通信。本文介绍消息收发功能的基本场景和示例代码。背景信息 云消息队列 MQTT 版 ...
云消息队列 RocketMQ 版 提供的分布式事务消息适用于所有对数据最终一致性有强需求的场景。本文介绍 云消息队列 RocketMQ 版 事务消息的概念、优势、典型场景、交互流程、使用规则以及示例代码。概念介绍 事务消息:云消息队列 RocketMQ 版...
更正文档 概述 消息队列是一种任务间传递数据的有效方式。消息队列使用环形缓冲池(ring buffer)来管理消息的队列缓冲区,并使用类似信号量的机制进行任务间的同步。任务通过消息队列可以发送消息,也可以通过它接收消息,从而实现数据的...
在左侧导航栏,选择 中间件>消息队列 消息路由。单击 创建路由任务,然后在 创建路由任务 对话框配置任务信息:源 Topic:输入需要同步的消息所属 Topic 名称。目标单元 选择消息将被同步到的 Topic 所属单元。目标 Topic:输入消息将被...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已购买并部署 云消息队列 ...
如果您对发送到 云消息队列 RabbitMQ 版 的消息有问题,您可以在 云消息队列 RabbitMQ 版 控制台查询消息。背景信息 云消息队列 RabbitMQ 版 支持以下查询方式:按Queue查询:适用于只知道消息发送到的Queue,不知道发送消息时设置的...
云消息队列 RocketMQ 版 提供了三种消息查询的方式,分别是按Message ID、Message Key以及Topic查询。查询方式说明 由于消息在 云消息队列 RocketMQ 版 中存储的时间默认为3天(不建议修改),即只能查询从当前查询时间算起3天内的消息。...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 RabbitMQ 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已购买并部署 云消息队列 ...
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息,本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下,异构系统间需要维持强一致的状态同步,...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流入源为 云消息队列 Kafka 版 的消息流入任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已购买并部署 云消息队列 Kafka...
物联网络管理平台支持数据出口至阿里云中间件消息队列MQ,本文介绍如何在物联网络管理平台上配置数据流转至消息队列MQ。配置出口数据 登录 物联网络管理平台控制台。在左侧导航栏选择 节点管理>节点分组,单击一条节点分组对应 操作 栏下的...
您可以使用 云消息队列 RabbitMQ 版 的日志管理功能将 云消息队列 RabbitMQ 版 实例的消息操作日志推送到日志服务。当消息的发送、消费、确认出现异常时,您可在日志服务查询并分析消息的操作日志,进行异常诊断。前提条件 在将 云消息队列...
消息轨迹是指一条消息从生产者发送到消息队列服务端,再到消费者消费处理,整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。本文介绍如何快速查询消息轨迹。前提条件 您的消息已从生产者发送。操作步骤 登录 SOFAStack...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 RocketMQ 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。创建消息流出任务 登录 云...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流入任务,实现将其他数据源中的数据快速导入 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。创建...
本文介绍如何使用 云消息队列 MQTT 版 的消息轨迹查询功能。当消息的收发不符合预期时,您可以使用消息轨迹查询功能,查询消息的收发轨迹。操作步骤 登录 云消息队列 MQTT 版 控制台,并在左侧导航栏单击 实例列表。在顶部菜单栏选择目标...
本文介绍如何通过 云消息队列 RocketMQ 版 的Java SDK订阅消息。订阅方式 云消息队列 RocketMQ 版 支持以下两种订阅方式:集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息,一个Group ID有3个...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 消息服务MNS 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已创建 消息服务MNS 队列。具体步骤,...
本文介绍什么是全球消息路由以及如何管理全球消息路由任务,以便您按需同步消息,实现不同实例、不同Vhost间的消息路由。背景信息 全球消息路由的功能和使用方式和开源Shovel插件保持一致,支持不同实例和Vhost间的Queue到Queue、Queue到...
该tag会用于mns消息队列名称的生成,多个tag即对应多个mns消息队列。查看服务端应用映射列表操作步骤:1.进入CMNS-上行消息页面。2.选择服务端应用,点击“映射列表”链接,打开映射列表页面。查看服务端应用映射列表操作步骤:1.进入CMNS-...
在分布式应用中,云消息队列 RocketMQ 版 作为全链路中异步解耦的关键服务,提供的消息轨迹数据可有效将业务上下游信息串联起来,帮助您更好地排查异常信息,定位问题。本文介绍消息轨迹的使用场景、云消息队列 RocketMQ 版 定义的轨迹参数...
您已向 云消息队列 RabbitMQ 版 发送消息,或已从 云消息队列 RabbitMQ 版 中消费消息。操作步骤 登录 云消息队列 RabbitMQ 版 控制台,然后在左侧导航栏选择 实例列表。在 实例列表 页面的顶部菜单栏选择地域,然后在实例列表中,单击目标...
云消息队列 RocketMQ 版 支持消息重试功能,即Consumer消费某条消息失败或消费超时,云消息队列 RocketMQ 版 会根据消息重试机制重新投递消息。本文介绍 云消息队列 RocketMQ 版 分别在HTTP协议和TCP协议下的消息重试策略。注意事项 一条...
集成消息队列 RocketMQ 说明 注意:集成阿里云消息队列Rocket MQ服务,需要您先参考安装云服务集成章节完成云服务集成的安装。登录 阿里云BaaS控制台。在 我的组织 中找到目标组织,单击右侧的 云服务集成。将云服务集成页面的标签切换到 ...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务,将 消息服务MNS 中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已创建 消息服务MNS 队列。具体步骤,请参见 开通消息服务MNS并授权。您已购买 云消息队列 ...
云消息队列 RocketMQ 版 支持以下两种订阅方式:集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息,一个Group ID有3个Consumer实例,那么在集群消费模式下每个实例平均分摊,只消费其中的3条消息。...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流出任务,将 云消息队列 RabbitMQ 版 的数据导出至 消息服务MNS。前提条件 您已购买 云消息队列 RabbitMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已创建 ...
云消息队列 MQTT 版 支持多语言的消息收发。本文提供单独使用 云消息队列 MQTT 版 收发消息以及与 云消息队列 RocketMQ 版 结合使用时需使用的代码示例的链接。单独使用 云消息队列 MQTT 版 收发消息 语言 链接 Java ...Python ...
Tag,可理解为Gmail中的标签,对消息进行再归类,方便Consumer指定过滤条件在消息队列RocketMQ版服务器过滤。tag",/ Message Body可以是任何二进制形式的数据,消息队列RocketMQ版不做任何干预,需要Producer与Consumer协商好一致的序列化...
智能对话分析服务作为消息的生产者,通过向您的阿里云消息队列RocketMQ服务中发送消息的方式推送相关信息给您,您作为消息的消费者从RocketMQ中接收并消费消息,从而实现低延迟、高并发、高可用的消息推送。视频讲解 授权 需要您授权,允许...
本文介绍 云消息队列 RabbitMQ 版 消息存活时间的核心概念、应用场景、注意事项和设置方式。什么是消息存活时间 在 云消息队列 RabbitMQ 版 中,消息存活时间用于限制消息在Queue中可以存在的时间,如果消息在Queue中存在的时间超过了设置...
背景信息 定时消息:Producer将消息发送到 云消息队列 RocketMQ 版 服务端,但并不期望立马投递这条消息,而是推迟到在当前时间点之后的某一个时间投递到Consumer进行消费,该消息即定时消息。延时消息:Producer将消息发送到 云消息队列 ...
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。说明 对于新手用户,建议在正式收发消息前,阅读 Demo工程 来了解搭建 云消息队列 RocketMQ 版 工程的...
当 云消息队列 Kafka 版 控制台提供的按位点查询和按时间查询消息的功能无法满足您搜索消息的需求时,您可以使用 云消息队列 Kafka 版 消息检索功能。消息检索支持按Topic分区、位点范围、时间范围以及消息Key和Value关键字检索。本文介绍...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流入任务,实现将其他数据源中的数据快速导入 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已购买...
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Java SDK收发普通消息的示例代码。前提条件 您已完成以下操作:安装Java SDK。更多信息,请参见 准备...