产品架构
集群级别的高可用，是消息队列跟其他的消息服务器的主要区别，消息生产者发送一条消息到消息服务器，消息服务器会随机的选择一个消费者，只要这个消费者消费成功就认为是成功了。说明 文中所提及的消息队列的服务端或者服务器包含 Name ...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的Go SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的...
收发顺序消息
顺序消息FIFO（First In First Out）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的C/C++ SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，...
收发定时消息和延时消息
不同消息类型的Topic不能混用，例如普通消息的Topic只能用于收发普通消息，不能用于收发其他类型的消息。final String topic="${TOPIC};Topic所属的实例ID，在消息队列RocketMQ版控制台创建。若实例有命名空间，则实例ID必须传入；若实例无...
事务消息
半事务消息：暂不能投递的消息，生产者已经成功地将消息发送到了 云消息队列 RocketMQ 版 服务端，但是 云消息队列 RocketMQ 版 服务端未收到生产者对该消息的二次确认，此时该消息被标记成“暂不能投递”状态，处于该种状态下的消息即半...
MQTT与RocketMQ的消息结构映射
本文针对使用 云消息队列 RocketMQ 版 SDK与 云消息队列 MQTT 版 交互的场景，提供交互中所涉及的消息结构和属性字段的映射关系，方便您更好的理解和组合使用这两个产品。云消息队列 MQTT 版 是一款面向移动端的网关产品，可通过数据互通...
收发事务消息
本文提供使用TCP协议下的Java SDK收发事务消息的示例代码。云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。说明 对于新手用户，建议在正式收发消息前，...
消息收发计算规格费用
其他资源配额 每个实例规格除核心的消息收发TPS能力存在差异外，部分管控资源和配置限制也会存在差异。具体各规格的限制，请参见 实例规格。超过规格限制后行为 若您实际使用的消息收发TPS超过了购买的规格上限：如果实例开启了弹性TPS功能...
QueryMqttTraceMessagePublish-查询消息发送轨迹
69AD5550-BF22-438A-9202-A6E89185*MessageTraceLists object[]返回的消息发送轨迹列表。Time string 消息的发送时间。2021-05-21 15:08:19.210 Action string 消息动作。取值说明如下：pub_mqtt：表示消息的发送者是云消息队列 MQTT 版...
API概览
OnsGroupConsumerUpdate 配置消费集群的消息读取权限 配置指定Group ID对应的消费集群的消息读取权限。本接口一般用于禁止特定Group ID读取消息的场景。OnsGroupList 获取Group ID列表信息 查询指定实例下所有的Group ID信息。...
功能特性
消息类型 普通消息：消息队列中无特性的消息，区别于有特性的定时/延时消息、顺序消息和事务消息。事务消息：实现类似 X/Open XA 的分布事务功能，以达到事务最终一致性状态。定时和延时消息：允许消息生产者对指定消息进行定时（延时）...
消息负载均衡策略
消息队列的消息负载策略针对发布方和订阅方有所差异。对订阅方而言，消息负载策略在一定程度上影响消息堆积。发布方消息负载均衡策略 消息队列针对发布方采取的是轮询制，即 Producer 的消息以轮询的方式发送至 Queue，如下图所示。图中...
QueryMqttTraceMessageOfClient-查询消息轨迹
查询指定设备在一定时间段内的消息列表。当消息的收发不符合预期时，您可以通过该接口查看消息的收发状态等轨迹信息，帮助您快速定位异常原因。接口说明 每成功调用一次 QueryMqttTraceMessageOfClient 接口，都会计算为一次消息 TPS，从而...
功能与特性概述
消息过滤：云消息队列 RocketMQ 版 支持设置消息属性给消息进行分类，云消息队列 RocketMQ 版 服务端会根据您订阅消息时设置的过滤条件对消息进行过滤，您将只消费到需要关注的消息。消息功能 消息查询：云消息队列 RocketMQ 版 提供了三种...
快速入门概述
本文以收发普通消息为例进行说明，因此，您按照本文提供的步骤创建的普通消息的Topic，不能用于收发其他类型的消息。换言之，不同消息类型的Topic不能混用。使用流程 根据您选择的协议，使用流程如下。协议使用须知 由于 云消息队列 ...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的PHP SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格...
ChatAppStatus
取值：message：任意格式的消息，时间限制为在收到用户最后一条消息后的24小时内可发送此类消息。template：在控制台已被审核通过的消息模板，可以在任意时间发送。Type String 否 消息内容中多媒体资源类型。取值：image：图片 video：...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的C++ SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。不同消息类型所属的Topic不能混用，例如收发普通消息的Topic不能用来收发其他类型的消息。本文提供使用TCP协议下的C/C++ SDK收发...
推送到队列
消息服务MNS 支持把发布到主题的消息推送到队列。本文介绍如何将消息推送到队列。步骤一：创建队列 登录 消息服务MNS控制台。在左侧导航栏，单击 队列列表。在顶部菜单栏，选择地域。在 队列列表 页面，单击 创建队列。在 创建队列 面板...
默认配置映射关系
同构消息映射关系 当消息的流入方和流出方为同一服务类型时，配置详情，请参见下文：基于事件流实现RocketMQ消息路由 基于事件流实现Kafka消息路由 基于事件流实现RabbitMQ消息路由 基于事件流实现MNS消息路由 异构消息映射关系 当消息的...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Java SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Java SDK。更多信息，请参见 准备...
收发事务消息
当步骤1半事务消息发送完成，但本地事务返回状态为 TransactionStatus.Unknow 时，亦或是应用退出导致本地事务未提交任何状态时，从Broker的角度看，这条半状态的消息的状态是未知的，因此Broker会定期向消息发送方即消息生产者集群中的...
作为Output接入
云消息队列 Kafka 版 可以作为Output接入Logstash。...如需查看完整的消息内容，请下载相应的消息。下载的消息最大为10 MB。如果消息超过10 MB，则只下载10 MB的内容。更多信息 更多参数设置，请参见 Kafka output plugin。
收发事务消息
当步骤1中半事务消息发送完成，但本地事务返回状态为 LocalTransactionState.UNKNOW，或者应用退出导致本地事务未提交任何状态时，从Broker的角度看，这条Half状态的消息的状态是未知的。因此Broker会定期要求发送方能Check该Half状态消息...
消息队列Kafka版
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流入源为 云消息队列 Kafka 版 的消息流入任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已购买并部署 云消息队列 Kafka...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的Java SDK收发顺序消息的示例代码。前提条件 您已完成以下操作：下载1.2.7或以上版本的Java SDK。更多信息，请参见...
常见问题
如何配置MNS以支持更长的消息保留期 如何配置MNS以支持更大的消息大小 消息数、活跃消息数、延迟消息数分别表示哪些消息 消息服务消息批量操作注意事项 消息优先级为1，就一定优先吗 队列问题 不同地域中的同名队列是同一个队列吗 对于较长...
作为Output接入
云消息队列 Kafka 版 可以作为Output接入Filebeat。本文说明如何在VPC环境下通过Filebeat向 云消息队列 Kafka 版 发送消息。...如需查看完整的消息内容，请下载相应的消息。下载的消息最大为10 MB。如果消息超过10 MB，则只下载10 MB的内容。
Queue
如果发送消息时不指定消息延时，被发送到普通队列的消息立刻可以被消费，而发送到延时队列需要经过设定的延时时间后才能被消费。QueueURL 格式：http://$AccountId.mns.<Region>.aliyuncs.com/queues/$QueueName。mns.<Region>.aliyuncs....
消息轨迹查询
当消息的收发不符合预期时，您可以使用消息轨迹查询功能...您可以在查询结果列表中单击 操作 列的 消息轨迹 查看指定消息的消息轨迹。相关文档 如果需要查询设备的状态，请参见 设备状态查询。如果需要查询设备的轨迹，请参见 设备轨迹查询。
消息堆积
常见的消息堆积相关问题如下：如何处理消息堆积？除了异步解耦功能，消息队列还有挡住前端数据洪峰的重要功能，以此保证后端系统的稳定性。这要求消息队列具有一定的消息堆积能力。消息队列能支持 10 亿级别的消息堆积，不会因为消息堆积...
OnsMessagePush-向指定的消费者推送消息
通过传入的 MsgId 获取指定消息的消息体，再将消息体重新进行封装推送给消费者。此时重新发送的这条消息和原消息的消息内容相同，但并不是同一条消息且 MsgId 不同。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰...
队列模型快速入门
消息最大长度：发送到队列的消息体的最大长度。长轮询时间：当队列中没有消息时，该队列的ReceiveMessage请求的最大等待时长。消息可见性超时时间：消息从队列中取出后从Active状态变成Inactive状态后的持续时间。消息保存时长：消息在队列...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的社区版Java SDK收发顺序消息的示例代码供您参考。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，...
资源报表
生产者：查看某Topic在一个时间段内从消息生产者处接收到的消息的总量或者TPS。消费者：查看某Topic在一个时间段内投递给消费者的消息的总量或TPS。输入查询的筛选的条件，包括 父级Topic、子级Topic、QoS类型、消息类型 和 时间范围。单击...
发送消息（多线程）
Thread thread=new Thread(new Runnable(){@Override public void run(){ try { Message msg=new Message(/普通消息所属的Topic，切勿使用普通消息的Topic来收发其他类型的消息。TopicTestMQ",/Message Tag可理解为Gmail中的标签，对消息...
收发定时消息和延时消息
不同消息类型的Topic不能混用，例如普通消息的Topic只能用于收发普通消息，不能用于收发其他类型的消息。topic:="${TOPIC}"/Topic所属的实例ID，在消息队列RocketMQ版控制台创建。若实例有命名空间，则实例ID必须传入；若实例无命名空间，...
收发顺序消息
顺序消息（FIFO 消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的.NET SDK收发顺序消息的示例代码。顺序消息分类 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的C#SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的...
- 产品推荐
- 这些文档可能帮助您