标签管理
在 实例列表 页面，找到您想要添加标签的实例，在其 标签 列，将光标移动至 图标，在弹出的消息框中，单击+添加。在编辑标签面板，按要求输入 标签键 和 标签值，然后单击 确定。标签 列的浅灰色的 图标变为深灰色的 图标，则说明标签已被...
如何快速测试云消息队列 Kafka 版服务端是否正常？
普通消息：默认情况下，保证相同Key的消息分布在同一个分区中，且分区内消息按照发送顺序存储。集群中出现机器宕机时，可能会造成消息乱序。当 存储引擎 选择 云存储 时，默认选择 普通消息。分区顺序消息：默认情况下，保证相同Key的消息...
消息检索
背景信息 云消息队列 Kafka 版 消息检索借助 云消息队列 Kafka 版 的Connector功能及表格存储（Tablestore）实现，通过Connector对Topic中的消息进行转储，发送到表格存储中的数据表中，由表格存储索引功能提供消息检索的能力。开通消息...
作为Input接入
分区顺序消息：默认情况下，保证相同Key的消息分布在同一个分区中，且分区内消息按照发送顺序存储。集群中出现机器宕机时，仍然保证分区内按照发送顺序存储。但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 ...
作为Input接入
分区顺序消息：默认情况下，保证相同Key的消息分布在同一个分区中，且分区内消息按照发送顺序存储。集群中出现机器宕机时，仍然保证分区内按照发送顺序存储。但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 ...
作为Input接入
分区顺序消息：默认情况下，保证相同Key的消息分布在同一个分区中，且分区内消息按照发送顺序存储。集群中出现机器宕机时，仍然保证分区内按照发送顺序存储。但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 ...
作为Input接入
分区顺序消息：默认情况下，保证相同Key的消息分布在同一个分区中，且分区内消息按照发送顺序存储。集群中出现机器宕机时，仍然保证分区内按照发送顺序存储。但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 ...
在Knative上实现Kafka消息推送
在 消息内容 文本框输入测试的消息内容，例如 {"key":"test"}。设置 发送到指定分区，选择是否指定分区。单击 是，在 分区 ID 文本框中输入分区的ID，例如0。如果您需查询分区的ID，请参见 查看分区状态。单击 否，不指定分区。根据界面...
将云消息队列 Kafka 版接入阿里云Elasticsearch
分区顺序消息：默认情况下，保证相同Key的消息分布在同一个分区中，且分区内消息按照发送顺序存储。集群中出现机器宕机时，仍然保证分区内按照发送顺序存储。但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 ...
定时和延时消息
本文主要介绍 云消息队列 RocketMQ 版 的定时消息和延时消息的概念、适用场景以及使用过程中的注意事项。概念介绍 定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是推迟到在当前时间点...
将云消息队列 Kafka 版的数据迁移至MaxCompute
在 消息内容 文本框输入测试的消息内容，例如 {"key":"test"}。设置 发送到指定分区，选择是否指定分区。单击 是，在 分区 ID 文本框中输入分区的ID，例如0。如果您需查询分区的ID，请参见 查看分区状态。单击 否，不指定分区。根据界面...
收发定时消息和延时消息
设置发送的消息内容和消息Tag。res=await producer.publishMessage("hello mq.timer msg!TagA",msgProps);console.log("Publish message:MessageID:%s,BodyMD5:%s",res.body.MessageId,res.body.MessageBodyMD5);} } catch(e){/消息发送...
迁移上云操作
重要 开源Apache RocketMQ 4.x系列SDK的消息消费顺序在客户端中配置，阿里云 云消息队列 RocketMQ 版 5.x版本实例在服务端中控制Group的消费顺序，因此在元数据迁移时，您需要根据实际业务场景手动录入Group的消费顺序类型。如果消费顺序的...
顺序消息
如果是普通消息，订单A的消息可能会被轮询发送到不同的队列中，不同队列的消息将无法保持顺序，而顺序消息发送时 云消息队列 RocketMQ 版 支持将Sharding Key相同（例如同一订单号）的消息序路由到一个队列中。云消息队列 RocketMQ 版 服务...
短轮询和长轮询
消息服务MNS 提供短轮询（Short Polling）和长轮询（Long Polling）两种方式来获取队列中的消息。短轮询 创建队列时，长轮询时间设置为0，且发起popMessage请求时 waitSeconds 设置为0。使用短轮询获取队列中的消息，popMessage请求会向...
如何确保在MNS中存储的数据的可靠性？
本文介绍阿里云如何确保 消息服务MNS 中数据可靠性。消息服务MNS 将所有队列和消息存储在阿里云高可靠、高可用的数据中心组成的网络中。所有消息冗余地存储在多台服务器上，当某台服务器出现问题时，冗余数据将会被自动拷贝至其他服务器；...
如何配置MNS以支持更大的消息大小？
本文介绍如何配置 消息服务MNS 以支持更大的消息大小。要配置最大消息大小，请使用SetQueueAttributes方法设置MaximumMessageSize属性。此属性指定队列中的消息可以包含的字节数限值。可以设置为1024字节（1 KB）到最大65536字节（64 KB）...
消息过滤
功能描述 消息过滤功能指消息生产者向Topic中发送消息时，设置消息属性对消息进行分类，消费者订阅Topic时，根据消息属性设置过滤条件对消息进行过滤，只有符合过滤条件的消息才会被投递到消费端进行消费。消费者订阅Topic时若未设置过滤...
MQTT与RocketMQ的消息结构映射
本文针对使用 云消息队列 RocketMQ 版 SDK与 云消息队列 MQTT 版 交互的场景，提供交互中所涉及的消息结构和属性字段的映射关系，方便您更好的理解和组合使用这两个产品。云消息队列 MQTT 版 是一款面向移动端的网关产品，可通过数据互通...
重置消费位点
重置消费位点功能只能重置对消费者可见的消息，不能重置定时中、重试等待中的消息。重试消费位点只能在消费者在线时进行操作。操作步骤 登录 云消息队列 RocketMQ 版 控制台，在左侧导航栏单击 实例列表。在顶部菜单栏选择地域，如 华东1...
顺序消息
如上图所示，消息组1和消息组4的消息混合存储在队列1中，云消息队列 RocketMQ 版 保证消息组1中的消息G1-M1、G1-M2、G1-M3是按发送顺序存储，且消息组4的消息G4-M1、G4-M2也是按顺序存储，但消息组1和消息组4中的消息不涉及顺序关系。...
基本概念
具体的指标含义和计算公式如下：分类 指标 定义 计算公式 消息数量指标 处理中的消息（inflight messages）在消费者客户端正在处理，但客户端还未返回消费结果的消息。最晚一条拉取消息的位点－最晚一条提交消息的位点 已就绪的消息（ready...
如何保证我的消息队列中的消息是安全的？
本文介绍阿里云如何保证消息队列中的消息是安全的。消息服务MNS 提供了安全可靠的身份验证机制，确保您的队列受到保护，防止遭到未经授权的访问。只有阿里云账户拥有者才能访问其创建的队列。
消息超时和重试机制
本文介绍 云消息队列 RabbitMQ 版 服务端默认的消息重试机制，帮助您理解消费失败后的消息处理逻辑，并选择合适的消息处理策略。重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试...
仪表盘
消息堆积场景 如下图所示，表示指定主题的某一队列中各消息的状态：上图表示指定主题的某一队列中各消息的状态，云消息队列 RocketMQ 版 将处于不同处理阶段的消息数量和耗时进行统计，这些指标可直接反映队列中消息的处理速率和堆积情况，...
什么是云消息队列 MQTT 版
如果说传统的消息队列中间件一般应用于微服务之间，那么适用于物联网的 云消息队列 MQTT 版 则实现了端与云之间的消息传递和真正意义上的万物互联。本文介绍 云消息队列 MQTT 版 的消息收发模型、产品优势和应用场景。核心概念 Topic：消息...
什么是消息服务MNS
在创建订阅时指定消息过滤标签，然后PublishMessage时指定消息标签，消息服务MNS 在推送消息时会根据标签进行过滤，仅推送消息标签与订阅中指定的过滤标签匹配的消息到指定队列上。更多信息，请参见 主题接口规范。消息投递 消息服务MNS ...
消费失败是否支持重试？
云消息队列 RabbitMQ 版 默认支持消费失败后消息重试。重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置...目标Queue中的消息支持查询和导出。如何配置死信Exchange，请参见 死信Exchange。
消息存储和清理机制
本文为您介绍 云消息队列 RocketMQ 版 中消息的存储机制，包括消息的存储粒度、判断依据及后续处理策略等。背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义，消息按照达到服务器的先后顺序被存储到队列中，理论上每个队列都支持无限...
领域模型概述
一对一通信：基于消费匿名特点，下游消费者即使有多个，但都没有自己独立的身份，因此共享队列中的消息，每一条消息都只会被唯一一个消费者处理。因此点对点模型只能实现一对一通信。发布订阅模型 发布订阅模型具有如下特点：消费独立：...
订阅关系（Subscription）
订阅关系中设置消息过滤规则后，系统将按照过滤规则匹配主题中的消息，只将符合条件的消息投递给消费者消费，实现消息的再次分类。取值：TAG过滤：按照Tag字符串进行全文过滤匹配。SQL92过滤：按照SQL语法对消息属性进行过滤匹配。过滤表达...
BatchReceiveMessage
调用BatchReceiveMessage接口批量消费队列中的消息。授权信息 默认仅限阿里云账号使用本接口，RAM用户只有在被授予了相关API操作权限后方可使用。本接口的授权信息如下表所示。更多信息，请参见 授权策略和示例。Name Value API ...
查看消费者状态
查询结果说明 Group ID仪表盘主要展示当前Group在消费场景中涉及的相关指标，包括该Group在指定Topic中的消息堆积量、消费速率，以及指定Topic下消息堆积量和消息生产消费的变化趋势图表。如遇消费异常情况，您可以参考以下思路进行排查：...
快速使用MQTT.fx模拟SDK收发消息
在 Publish 页签中，在左侧Topic文本框输入 步骤三 中创建的Topic的名称，本示例以 MQTT_test_topic 为例，然后在下面的消息文本框中输入要发送的消息内容，例如：mqtt send message，然后单击Topic文本框右侧的 Publish 发送消息。...
ReceiveMessage
调用ReceiveMessage接口消费队列中的消息。授权信息 默认仅限阿里云账号使用本接口，RAM用户只有在被授予了相关API操作权限后方可使用。本接口的授权信息如下表所示。更多信息，请参见 授权策略和示例。Name Value API ReceiveMessage RAM...
消息服务MNS
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流出任务，以实现将 云消息队列 RocketMQ 版 的消息流出至 消息服务MNS。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已...
云消息队列 RocketMQ 版
数据提取：通过 JSONPath语法提取消息中的数据，将指定的消息内容路由到目标。配置规则，请参见 消息转换。数据清洗 服务及函数名称 默认创建名称为 RocketMQ_RocketMQ_Transform_<TemplateName>_的服务和函数。当 消息体（body）选择 数据...
集群消费和广播消费
集群消费 基本概念 集群消费模式下，同一Group下的多个消费者消费指定Topic中的消息时，云消息队列 RocketMQ 版 会将多条消息投递给不同的消费者处理，同一条消息只会被一个消费者消费到。适用场景 消息负载均衡：当业务消息量很大时，可以...
TCP协议客户端大版本发布
处理中消息量 top20 GroupIDs：统计处理中的消息量最多的前20个Group。消费处理耗时 top20 GroupIDs：统计消费处理耗时最长的前20个Group。在消费者本地等待处理耗时 top20 GroupIDs：统计消费者本地等待耗时最长的前20个Group。消息生产...
开源RabbitMQ迁移上云
迁移消息数据 使用Shovel插件迁移消息数据 Shovel迁移数据的原理是消费开源RabbitMQ集群中的消息，将消息生产到云上实例中，迁移后开源RabbitMQ集群中的消息被清空，完成迁移。在开源集群启动Shovel插件。创建Shovel任务，将Source配置为...
- 产品推荐
- 这些文档可能帮助您