什么是云消息队列 MQTT 版
云消息队列 MQTT 版 是阿里云推出的一款面向移动互联网以及物联网领域的轻量级消息中间件。如果说传统的消息队列中间件一般应用于微服务之间，那么适用于物联网的 云消息队列 MQTT 版 则实现了端与云之间的消息传递和真正意义上的万物互联...
常见问题
为什么消息发送不成功？消息发送失败会有多种原因，您可以参考 API错误码 页面定位错误。除代码问题外，除代码问题外，某些通道类型对个别国家或地区也存在发送限制。目前以下国家手机号码无法发送、接收WhatsApp消息：朝鲜、叙利亚、伊朗...
发送普通消息（三种方式）
TagA",/Message Body可以是任何二进制形式的数据，消息队列RocketMQ版不做任何干预。需要Producer与Consumer协商好一致的序列化和反序列化方式。Hello MQ".getBytes());设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法...
收发顺序消息
TagA",/Message Body，可以是任何二进制形式的数据，消息队列RocketMQ版不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式。send order global msg".getBytes());设置代表消息的业务关键属性，请尽可能全局唯一。以...
收发延时消息
tag",/Message Body可以是任何二进制形式的数据，消息队列RocketMQ版不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式。Hello MQ".getBytes());设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常...
发送消息（多线程）
TagA",/Message Body可以是任何二进制形式的数据，消息队列RocketMQ版不做任何干预。需要Producer与Consumer协商好一致的序列化和反序列化方式。Hello MQ".getBytes());SendResult sendResult=producer.send(msg);同步发送消息，只要不抛...
示例代码
云消息队列 RocketMQ 版 5.x版本实例可兼容Java ONS 1.x SDK客户端接入，您可以使用ONS 1.x SDK的接入5.x实例进行消息收发。本文为您介绍Java ONS 1.x SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力...
消息服务消息批量操作注意事项
如果您不指定，那么默认消息会做Base64编码（会放大原始消息体），所以实际发送的消息大小不要超过47 KB。您也可以指定不使用Base64编码，使用原始消息体：message.setMessageBody("message_body",Message.MessageBodyType.RAW_STRING);...
为什么发送给Topic的消息在分区中分布不均衡
分区中消息量可以在 Topic详情 页面的 分区状态 页签查看，位点数即是消息数。以下图为例，分区 2 消息比较多，其他分区消息少甚至没有，消息分布不均衡。可能原因 发送消息时指定了分区，导致未指定的分区没有消息。发送消息时指定了消息...
客户端连接常见问题
根据MQTT协议，Topic存在多级，定义第一级Topic为父级Topic，使用 云消息队列 MQTT 版 前，需先在控制台创建该父级Topic，可以在 云消息队列 MQTT 版 控制台创建，或者直接在 云消息队列 RocketMQ 版 的控制台创建。子级Topic（Subtopic）...
消息过滤
消息服务MNS 的消息过滤功能是指将一个主题的消息通过不同的标签推送到不同的订阅渠道。本文介绍消息过滤的功能以及如何设置消息过滤标签。背景信息 通常情况下，在主题中创建订阅可以将消息推送至已订阅的推送目标。即消息没有设置消息...
常见问题
产品功能常见问题 云消息队列 RocketMQ 版5.0系列相比4.0系列实例有什么优势？云消息队列 RocketMQ 版5.0系列实例兼容哪些版本客户端？云消息队列 RocketMQ 版支持哪些语言客户端？云消息队列 RocketMQ 版如何开通公网访问？顺序消息和普通...
常见问题
产品功能常见问题 消息队列RocketMQ版5.x系列相比4.x系列实例有什么优势？消息队列RocketMQ版5.x系列实例兼容哪些版本客户端？消息队列RocketMQ版支持哪些语言客户端？消息队列RocketMQ版如何开通公网访问？顺序消息和普通消息的区别是什么...
消息幂等
如果消息重复消费会影响您的业务处理，请对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 在数学与计算机学中，幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。在消息领域，幂等是...
队列使用手册
} 步骤四：接收和删除消息 队列里已经有了一条消息，现在可以尝试接收消息。NextVisibleTime是 消息服务MNS 的消息的一个重要属性。更多信息，请参见 QueueMessage。receiptHandle=NULL;try {/1.直接调用receiveMessage函数。...
回执消息简介与配置流程
名称 描述 MNS消息队列消费模式 HTTP批量推送模式 ChatAppInbound（上行消息）上行消息指用户发送给企业号码的消息，通过订阅ChatAppInbound上行消息，可以获知终端用户发送消息的内容。ChatAppInbound ChatAppInbound ChatAppStatus（下行...
消息优先级为1，就一定优先吗？
消息服务MNS 消费消息时尽量做到先进先出，因为消息队列的分布式特性，消息服务MNS 不能保证按照消息的发送顺序去消费消息，所以如果业务必须先进先出，建议在消息中加入序号信息以便消费消息后进行重新排序。如果您要求消息顺序必须先进先...
消息优先级为1，就一定优先吗？
消息服务MNS 消费消息时尽量做到先进先出，因为分布式消息队列的一些特性，消息服务MNS 不能保证按照消息的发送顺序去消费消息，所以如果业务必须先进先出，建议在消息中加入序号信息以便消费消息后进行重新排序。如果您要求消息顺序必须...
Demo工程
在 云消息队列 RocketMQ 版 控制台，按Topic 查询消息，可以看到消息已经发送至Topic。接收消息。接收普通消息：以纯Java方式接收普通消息：运行 SimpleMQConsumer 类。以Spring方式接收普通消息：运行 ConsumerClient 类。以Spring Boot...
音视频通信解决方案（MQTT）
收发消息参数设计 由于移动App可能存在应用切入后台被杀死（Kill）导致移动App不在线的情况，需对终端App做以下配置，以确保终端App离线重连后可以收到之前的消息：cleanSession 参数设置为“false”QoS 设置成“1”终端App应该对收到的...
SDK FAQ
如果您需追踪和识别消息，可以在 云消息队列 RabbitMQ 版 的Producer客户端设置Message ID属性，为每条消息设置唯一标识符。在 云消息队列 RabbitMQ 版 的Producer客户端设置 Basic.Properties 的 message-id 属性。示例代码如下：Java ...
消息过滤
场景示例 以下图电商交易场景为例，从客户下单到收到商品这一过程会生产一系列消息，按照类型将消息分为订单消息和物流消息，其中给物流消息定义地域属性，按照地域分为杭州和上海：订单消息 物流消息 物流消息且地域为杭州 物流消息且地域...
TopicMessage
用户发布消息到主题时，可以指定消息体、消息标签和消息额外属性。主题消息的最长保留时间为1天，超过这个时间，不论消息是否成功推送给用户都将被垃圾回收器回收。消息属性 MessageId 消息的编号。一个主题中每个消息都有唯一的MessageId...
计费FAQ
向10个Queue发送同一条消息，为什么收10次API调用费？将1条消息发送给10个Queue，实际上是10次API调用。为什么删除的Vhost、Exchange、Queue会被自动重建并重新开始计费？虽然删除了Vhost、Exchange、Queue，但Producer和Consumer依然与 云...
计费FAQ
向10个Queue发送同一条消息，为什么收10次API调用费？将1条消息发送给10个Queue，实际上是10次API调用。为什么删除的Vhost、Exchange、Queue会被自动重建并重新开始计费？虽然删除了Vhost、Exchange、Queue，但Producer和Consumer依然与 云...
消息轨迹查询
当消息的收发不符合预期时，您可以使用消息轨迹查询功能，查询消息的收发轨迹，确保数据正常流转、快速定位异常。操作步骤 登录 云消息队列 MQTT 版 控制台，并在左侧导航栏单击 实例列表。在顶部菜单栏选择目标地域，然后在实例列表中单击...
消息队列Kafka版删除Group后仍然收到消息堆积的告警...
问题描述 使用阿里云消息队列Kafka版时，删除Group后，仍然收到消息堆积的告警信息，如何过滤某个Group的消费堆积告警...相关文档 为什么Group不存在但能消费消息 消息堆积了怎么办 使用消息队列Kafka版时出现消息堆积 适用于 消息队列Kafka版
常见问题
MNS提供哪些可用的操作 主题订阅的使用限制 MNS是否支持长轮询 MNS是否提供对消息的先入先出（FIFO）访问 MNS是否可以与其他阿里云产品协作使用 MNS相对于自主研发、商用或开源的消息队列系统有什么优势 计费相关 删除队列后，是否继续计费...
迁移消费者程序
启动消费者程序 通过实例迁移功能，目标实例将源实例的全量数据追平并开始追加增量后：若您创建消费者程序时使用Subscribe方式消费消息，可以直接在目标实例启动新的消费者程序。新消费者程序启动后，目标实例会阻止迁移组件继续同步消费...
如何快速测试云消息队列 Kafka 版服务端是否正常？
在创建并部署 云消息队列 Kafka 版 实例后，您可以使用 云消息队列 Kafka 版 控制台直接发送消息，快速测试服务端是否正常。前提条件 您已创建并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。操作流程 快速测试 云消息队列 ...
消息查询
您可以通过消息查询验证消息是否发送成功、验证消息发送的内容是否正确、以及进一步查看消息的轨迹信息。查询方式说明 由于消息在 云消息队列 RocketMQ 版 中存储的时间默认为3天（不建议修改），即只能查询从当前查询时间算起3天内的消息...
怎样让Consumer不立即消费消息并使消息重入队列？
您可以通过basicReject或basicNack方法否定应答消息，使消息重入队列，从而是其他Consumer可以消费消息。使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。...
怎样让Consumer不立即消费消息并使消息重入队列？
您可以通过basicReject或basicNack方法否定应答消息，使消息重入队列，从而是其他Consumer可以消费消息。使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。...
使用须知
云消息队列 RocketMQ 版 提供了通过HTTP协议的多语言SDK接入的能力，并支持公网访问。...多语言支持 云消息队列 RocketMQ 版 支持RESTful风格...您可以自行采用Base64编码对发送的消息进行编（解）码，以适用于此类不符合XML规范的消息收发场景。
基本概念
消息堆积量=处理中消息量+已就绪消息量，具体的指标含义，可参考以下说明：上图表示指定主题的某一队列中各消息的状态，云消息队列 RocketMQ 版 将处于不同处理阶段的消息数量和耗时进行统计，这些指标可直接反映队列中消息的处理速率和...
主题使用手册
步骤七：取消订阅 不需要再接收消息，可以在MNS Server取消订阅。try {$topic->unsubscribe($subscriptionName);echo"Unsubscribe Succeed!} catch(MnsException$e){ echo"Unsubscribe Failed:".$e;return;} 步骤八：删除主题 最后删除...
为什么Topic有分区时间显示1970或“-”？
问题现象 Topic的分区更新时间显示为1970或者为“-”。可能原因 出现此问题的原因可能...如果是Local存储引擎，您可以使用消息查询功能查看正确消息生产时间。如果是云存储引擎，并且缓存过期，您可以使用消息查询功能查看正确消息生产时间。
MQTT快速入门
云消息队列 MQTT 版 实例和存储实例之间会建立一一绑定关系，因此，创建的Topic其实是创建到存储实例上，在 云消息队列 MQTT 版 控制台仅仅做一层映射关系，所有的Topic操作都可以同时使用存储实例的操作习惯完成。如果之前在使用 云消息...
Demo工程
本文以社区版Apache RocketMQ Client为例，提供操作示例帮助您从零开始搭建阿里云 云消息队列 RocketMQ 版 收发消息的测试工程。Demo工程包含普通消息、顺序消息、事务消息的测试代码。前提条件 安装IDE。您可以使用IntelliJ IDEA或者...
消息存储和清理机制
根据统一地存储时长管理消息，可以帮助消费者业务清晰地判断每条消息的生命周期。只要消息在有效期内可以随时被消费，或通过 重置消费位点 功能使消息可被消费多次。消息过期清理机制 开源的Apache RocketMQ中，消息保存时长并不能完整控制...
- 产品推荐
- 这些文档可能帮助您