云消息队列 MQTT 版 支持多语言的消息收发。本文提供单独使用 云消息队列 MQTT 版 收发消息以及与 云消息队列 RocketMQ 版 结合使用时需使用的代码示例的链接。单独使用 云消息队列 MQTT 版 收发消息 语言 链接 Java ...Python ...
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息,本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下,异构系统间需要维持强一致的状态同步,...
集成消息队列 RocketMQ 说明 注意:集成阿里云消息队列Rocket MQ服务,需要您先参考安装云服务集成章节完成云服务集成的安装。登录 阿里云BaaS控制台。在 我的组织 中找到目标组织,单击右侧的 云服务集成。将云服务集成页面的标签切换到 ...
更正文档 概述 消息队列是一种任务间传递数据的有效方式。消息队列使用环形缓冲池(ring buffer)来管理消息的队列缓冲区,并使用类似信号量的机制进行任务间的同步。任务通过消息队列可以发送消息,也可以通过它接收消息,从而实现数据的...
您已向 云消息队列 RabbitMQ 版 发送消息,或已从 云消息队列 RabbitMQ 版 中消费消息。操作步骤 登录 云消息队列 RabbitMQ 版 控制台,然后在左侧导航栏选择 实例列表。在 实例列表 页面的顶部菜单栏选择地域,然后在实例列表中,单击目标...
如果您对发送到 云消息队列 RabbitMQ 版 的消息有问题,您可以在 云消息队列 RabbitMQ 版 控制台查询消息。背景信息 云消息队列 RabbitMQ 版 支持以下查询方式:按Queue查询:适用于只知道消息发送到的Queue,不知道发送消息时设置的...
在分布式应用中,云消息队列 RocketMQ 版 作为全链路中异步解耦的关键服务,提供的消息轨迹数据可有效将业务上下游信息串联起来,帮助您更好地排查异常信息,定位问题。本文介绍消息轨迹的使用场景、云消息队列 RocketMQ 版 定义的轨迹参数...
该tag会用于mns消息队列名称的生成,多个tag即对应多个mns消息队列。查看服务端应用映射列表操作步骤:1.进入CMNS-上行消息页面。2.选择服务端应用,点击“映射列表”链接,打开映射列表页面。查看服务端应用映射列表操作步骤:1.进入CMNS-...
当 云消息队列 Kafka 版 控制台提供的按位点查询和按时间查询消息的功能无法满足您搜索消息的需求时,您可以使用 云消息队列 Kafka 版 消息检索功能。消息检索支持按Topic分区、位点范围、时间范围以及消息Key和Value关键字检索。本文介绍...
您可以登录消息队列控制台,根据业务需求创建跨地域的消息同步任务。操作步骤如下:登录 SOFAStack 控制台。在左侧导航栏,选择 中间件>消息队列 消息路由。单击 创建路由任务,然后在 创建路由任务 对话框配置任务信息:源 Topic:输入...
如果您希望消息被投递后延迟一段时间被消费者消费,您可以使用 云消息队列 RabbitMQ 版 的延时消息。云消息队列 RabbitMQ 版 原生支持延时消息,使用方式比开源RabbitMQ更简单。什么是延时消息 延时消息是指在指定时间段之后才被消费者消费...
除了异步解耦功能,消息队列还有挡住前端数据洪峰的重要功能,以此保证后端系统的稳定性。这要求消息队列具有一定的消息堆积能力。消息队列能支持 10 亿级别的消息堆积,不会因为消息堆积导致性能明显下降。问题描述 在消息队列控制台的...
普通消息为 云消息队列 RocketMQ 版 中最基础的消息,区别于有特性的顺序消息、定时/延时消息和事务消息。本文为您介绍普通消息的应用场景、功能原理、使用方法和使用建议。应用场景 普通消息一般应用于微服务解耦、事件驱动、数据集成等...
本文介绍如何通过 云消息队列 RocketMQ 版 的C/C++ SDK订阅消息。订阅方式 云消息队列 RocketMQ 版 支持以下两种订阅方式: 集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息,一个Group ID有3个...
本文介绍如何通过 云消息队列 RocketMQ 版 的Java SDK订阅消息。订阅方式 云消息队列 RocketMQ 版 支持以下两种订阅方式:集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息,一个Group ID有3个...
云消息队列 RocketMQ 版 提供了三种消息查询的方式,分别是按Message ID、Message Key以及Topic查询。查询方式说明 由于消息在 云消息队列 RocketMQ 版 中存储的时间默认为3天(不建议修改),即只能查询从当前查询时间算起3天内的消息。...
云消息队列 Kafka 版 控制台支持按位点查询和按时间查询。背景信息 您可根据具体情况按以下推荐方式查询消息:如果您确定消息所在Topic的分区ID以及消息位点,则推荐您使用 按位点查询消息。位点的相关概念,请参见 基本概念 如果您不确定...
本文介绍 SOFAStack 消息队列各个消息类型的概念、适用场景以及使用过程中的注意事项等。普通消息 定时和延时消息 顺序消息 事务消息 普通消息 普通消息是指消息队列中无特性的消息,区别于有特性的定时/延时消息、顺序消息和事务消息。TCP...
出现该现象是由于客户端本身并没有升级到支持轨迹功能的版本,因此消息队列轨迹查询后端仅仅能够拿到部分不完整的轨迹数据,展现结果不正常。建议尽快升级客户端,详情请参见 查询消息轨迹。Group 列表中为什么没有我的 Group ID?出现该...
云消息队列 RocketMQ 版 支持以下两种订阅方式:集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息,一个Group ID有3个Consumer实例,那么在集群消费模式下每个实例平均分摊,只消费其中的3条消息。...
事务消息为 云消息队列 RocketMQ 版 中的高级特性消息,本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 分布式事务的诉求 分布式系统调用的特点为一个核心业务逻辑的执行,同时需要调用多个下游业务...
SOFAStack 消息队列提供了三种消息查询的方式,分别是按 Message ID、Message Key 以及 Topic 查询。操作步骤 登录 SOFAStack 控制台。在左侧导航栏,选择 中间件>消息队列>消息查询 在 消息查询 页面,您可单击以下任一页签,然后按页面...
消费者订阅了某个主题后,云消息队列 RocketMQ 版 会将该主题中的所有消息投递给消费者。若消费者只需要关注部分消息,可通过设置过滤条件在 云消息队列 RocketMQ 版 服务端进行过滤,只获取到需要关注的消息子集,避免接收到大量无效的...
消息消费异常进行消费重试时,达到最大重试次数后会转为死信状态,云消息队列 RocketMQ 版 支持将这些死信消息保存至指定Topic,方便后续进行业务恢复或回溯。本文介绍死信消息的应用场景、死信策略、使用限制、配置方法和使用建议。应用...
事务消息队列 消息存活时间小于消息延时时间。当消息发送成功、事务操作成功时,生产者修改消息延迟时间,消息对消费者可见。当消息发送成功、事务操作失败时,生产者不修改消息延迟时间,消息对消费者不可见。操作日志队列 记录事务消息的...
重要 在使用前,请先开通 消息队列 RocketMQ 服务。概述 智能对话分析服务作为消息的生产者,通过向您的阿里云消息队列RocketMQ服务中发送消息的方式推送相关信息给您,您作为消息的消费者从RocketMQ中接收并消费消息,从而实现低延迟、高...
重要 在使用前,请先开通 消息队列 RocketMQ 服务。概述 智能对话分析服务作为消息的生产者,通过向您的阿里云消息队列RocketMQ服务中发送消息的方式推送相关信息给您,您作为消息的消费者从RocketMQ中接收并消费消息,从而实现低延迟、高...
本文介绍如何通过 SOFAStack 消息队列的 Java SDK 订阅消息。订阅方式 消息队列支持以下两种订阅方式:集群订阅同一个 Group ID 所标识的所有 Consumer 平均分摊消费消息。例如某个 Topic 有 9 条消息,一个 Group ID 有 3 个 Consumer ...
与顺序消息相关的常见问题如下:...支持消息队列所有部署的地域。顺序消息的使用范围是什么?关于顺序消息的使用范围,包括适用场景和使用限制等,请参见 消息类型>顺序消息。顺序消息支持哪种消息发送方式?顺序消息只支持可靠同步发送方式。
您可以使用 云消息队列 RabbitMQ 版 的日志管理功能将 云消息队列 RabbitMQ 版 实例的消息操作日志推送到日志服务。当消息的发送、消费、确认出现异常时,您可在日志服务查询并分析消息的操作日志,进行异常诊断。前提条件 创建 云消息队列...
消费者订阅了某个Topic后,云消息队列 RocketMQ 版 会将该Topic中的所有消息投递给消费端进行消费。若消费者只需要关注部分消息,可通过设置过滤条件在 云消息队列 RocketMQ 版 服务端完成消息过滤,只消费需要关注的消息。本文介绍消息...
由于 云消息队列 MQTT 版 V2.x.x和V3.x.x相比,V3.x.x实现了独立存储,对 云消息队列 RocketMQ 版 没有强依赖,因此消息收发流程有相应的变更。云消息队列 MQTT 版 V2.x.x版本强依赖 云消息队列 RocketMQ 版 作为消息存储,因此 云消息队列...
本文描述 SOFAStack 消息队列的消费者如何根据 Tag 在消息队列服务端完成消息过滤,以确保消费者最终只消费到其关注的消息类型。Tag,即消息标签,用于对某个 Topic 下的消息进行分类。消息队列的生产者在发送消息时,已经指定消息的 Tag,...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已购买并部署 云消息队列 ...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 RabbitMQ 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已购买并部署 云消息队列 ...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流入任务,实现将其他数据源中的数据快速导入 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已购买...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流入源为 云消息队列 Kafka 版 的消息流入任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已购买并部署 云消息队列 Kafka...
本文介绍如何使用 云消息队列 MQTT 版 的消息轨迹查询功能。当消息的收发不符合预期时,您可以使用消息轨迹查询功能,查询消息的收发轨迹。操作步骤 登录 云消息队列 MQTT 版 控制台,并在左侧导航栏单击 实例列表。在顶部菜单栏选择目标...
To":"20"} 使用 使用消息队列必须同时指定 MNS 主题名称(Name)、MNS 私网 Endpoint(Endpoint)和关注的事件 (Events)。以下我们将展示通过 SDK 展示如何使用 MNS 消息队列,其中 MNS 主题名称为 test,MNS私网 Endpoint 为 ...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 RocketMQ 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。创建消息流出任务 登录 云...