轻量消息队列（原 MNS）支持把发布到主题的消息推送到移动终端。本文介绍如何将消息推送到移动终端。前提条件 开通移动推送 创建应用 集成SDK 步骤一：创建主题 登录 轻量消息队列（原 MNS）控制台。在左侧导航栏，选择 主题模型 主题列表...
轻量消息队列（原 MNS）支持把发布到主题的消息推送到阿里短信。本文介绍如何将消息推送到阿里短信。前提条件 开通短信服务。更多信息，请参见 开通短信服务。申请短信签名和短信模板。更多信息，请参见 使用须知。步骤一：创建主题 登录 ...
主题消息收发 SDK下载和使用 订阅管理 订阅类型：队列 支持把发布到主题的消息推送到队列。队列 订阅类型：HTTP/HTTPS 支持把发布到主题的消息推送到 HTTP 服务。HTTP 订阅类型：阿里短信 支持把发布到主题的消息推送到阿里短信服务。阿里...
轻量消息队列（原 MNS）支持把发布到主题的消息推送到队列。本文介绍如何将消息推送到队列。步骤一：创建队列 登录 轻量消息队列（原 MNS）控制台。在左侧导航栏，选择 队列模型 队列列表。在顶部菜单栏，选择地域。在 队列列表 页面，单击...
接口说明如下：putMessage 在向服务器发消息前，对消息体按指定的Key和加密算法加密。popMessage 在接收到服务端消息后，先按指定的方式解密，然后再返回解密后的消息体。SecurityKeyGenerator.java 用于生成加解密需要的 secretKey。...
我已经购买了包年包月微消息队列MQTT版实例，为什么发消息后，还会继续扣钱呢？包年包月（预付费）实例的费用只限于 云消息队列 MQTT 版 所支持的协议，即 云消息队列 MQTT 版 的消息传输以及消息存储。若您使用 云消息队列 MQTT 版 的数据...
云消息队列 RocketMQ 版 产品按量付费方式中，部分计费项提供一定的免费。以下项目暂时免费，正式收费前将以公告、短信、站内信等方式进行通知：说明 免费项目只针对按量付费，资源包与包年包月的付费方式不可享受以下项目。每个月免费拥有...
云消息队列 RocketMQ 版 控制台提供对死信消息的查询、导出和重发的功能。查询死信消息的方式 云消息队列 RocketMQ 版 提供的查询死信消息的方式对比如下表所示。查询方式 查询条件 查询类别 说明 按Group ID查询 Group ID+时间段 范围查询...
队列模型快速入门流程 队列模型在控制台发送和接收消息的流程如下：创建队列 发送消息 接收消息 删除队列 主题模型快速入门 主题模型支持消息投递到队列，如 主题模型快速入门流程 所示。图 2.主题模型快速入门流程 主题模型投递消息至队列...
我已经购买了包年包月微消息队列MQTT版实例，为什么发消息后，还会继续扣钱呢？包年包月（预付费）实例的费用只限于 云消息队列 MQTT 版 所支持的协议，即 云消息队列 MQTT 版 的消息传输以及消息存储。若您使用 云消息队列 MQTT 版 的数据...
本文介绍控制台上的消息数、可见消息数、延迟消息数分别表示哪些类型的消息。各消息数的概念如下：消息数：成功发送的和没有发送的所有消息数。可见消息数：未经处理的消息数。延迟消息数：设置了延迟时间的消息数。
解决直播中手机端互发消息和消息内容的安全审核问题，同时低成本保存消息。部署架构图 选用的产品 云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 是由阿里巴巴自研并捐赠给Apache基金会，并与开源社区共建的消息中间件，该产品服务于阿里...
建议您从以下几个方面进行判断：消息类型是否一致：如普通消息、事务消息、定时（延时）消息、顺序消息，不同的消息类型使用不同的Topic，无法通过Tag进行区分。业务是否相关联：没有直接关联的消息，如淘宝交易消息，京东物流消息使用不同...
在使用Kafka的过程中遇到无法正确消费消息、消息丢失、消息延迟等消费问题时，您可通过消息查询功能查看指定消息的详细内容和相关属性，帮助您排查异常原因。若确定消息所在Topic的分区ID以及消息位点，可采用按位点查询消息；若不确定消息...
云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的消息负载（Payload）均是您的业务消息的数据序列化结果，云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 不会对业务消息再做进一步的编解码处理。属性字段映射 目前，云消息队列 MQTT 版 ...
如果目标端实例的消息大小限制小于源端的限制，当消息的大小超过目标端实例的限制时，将导致消息路由失败，进而导致消息丢失。前提条件 云消息队列 RabbitMQ 版 源实例、源Vhost、源Exchange、源Queue以及目标实例、目标Vhost、目标...
顺序消息：消息消费根据Sharding Key负载均衡，不同Sharding Key的消息可被均衡的负载到多个Queue中消费，且为保证顺序消息的语义，相同Sharding Key的消息会被同一个消费者消费，具体示例如下图所示：说明：该图标背景色表示消息属于Queue...
使用建议 合理划分主题和Tag标签 从消息的过滤机制和主题的原理机制可以看出，业务消息的拆分可以基于主题进行筛选，也可以基于主题内消息的Tag标签及属性进行筛选。关于拆分方式的选择，应遵循以下原则：消息类型是否一致：不同类型的消息...
FIFO：顺序消息，云消息队列 RocketMQ 版 通过消息分组MessageGroup标记一组特定消息的先后顺序，可以保证消息的投递顺序严格按照消息发送时的顺序。Delay：定时/延时消息，通过指定延时时间控制消息生产后不要立即投递，而是在延时间隔后...
背景信息 云消息队列 RocketMQ 版 通过消费位点管理消息的消费进度。每条消息被某个消费者消费完成后不会立即在队列中删除，云消息队列 RocketMQ 版 会基于每个Group维护一份消费记录，该记录指定了Group下的消费者消费指定Topic时，消费过...
本文为您介绍MQTT 5.0的新特性消息过期。功能介绍 MQTT 5.0中的消息过期（Message Expiry Interval）功能，允许设置一条消息在发布后能够在Broker中存活的最长时间。...消息过期间隔的主要好处是确保只有当前和最相关的信息被传递给订阅者。
方案二：将原Topic的信息设置到消息的自定义属性中。示例如下：messageBuilder.addProperty("originalTopic","testTopic")死信消息和主业务区分处理 死信消息是正常业务流程中消息重试仍然失败的消息，需要和主业务流程分开处理，避免影响...
通过主题、队列和位点就可以定位任意一条消息的位置，具体关系如下图所示：云消息队列 RocketMQ 版 定义队列中最早一条消息的位点为最小消息位点（MinOffset）；最新一条消息的位点为最大消息位点（MaxOffset）。虽然消息队列逻辑上是无限...
参数 说明 消息来源 常量：其他云产品 方法 常量：Notify 发送时间 消息推送到队列的时间 结果 发送结果，显示"成功"或具体的错误信息 消息信息 普通消息 参数 说明 消息类型 常量：普通消息 消息 ID 消息的唯一标识符 队列 消息所在的队列...
消费者通常被集成在业务系统中，从 云消息队列 RocketMQ 版 服务端获取消息，并将消息转化成业务可理解的信息，供业务逻辑处理。更多信息，请参见 消费者（Consumer）。消费结果（ConsumeResult）云消息队列 RocketMQ 版 中PushConsumer...
定义和模型关系 在 轻量消息队列（原 MNS）中，一个主题是一个存储消息的容器。主题里的消息可以被订阅到多种渠道进行消费，订阅类型包括队列、HTTP、短信服务、邮件推送、移动终端。每个订阅类型可以订阅主题里的所有消息，也可以配置消息...
Value 消息的值（已强制转化为String类型），即消息的具体内容。消息创建时间 发送消息时，客户端自带的或是您指定的 ProducerRecord 中的消息创建时间。说明 如果配置了该字段，则按配置值显示。如果未配置该字段，则默认取消息发送时的...
消息包含数据和属性，可以分成普通消息和延时消息，在一个队列中能唯一标识一个消息的有Message ID和ReceiptHandle两个参数。普通队列 如果发送消息时不指定消息延时，消息发送到普通队列后可立即被消费。延时队列（Delayed Queue）如果...
应用场景 您在收发消息的过程中，是否遇到过以下问题：消息成功发送到队列，但消费端收不到消息，消息去哪儿了？消息被谁消费了？消费了几次？消费端宕机了，消费失败的消息什么时候可以再次被消费？消息发布到主题，Endpoint却迟迟收不到...
您在使用 轻量消息队列（原 MNS）产品时，如果收到系统提示的错误信息，可查阅 错误码 匹配错误信息。对于其他问题，您可根据下列分类匹配问题场景和解决方案。产品介绍 什么是轻量消息队列（原 MNS）如何使用轻量消息队列（原 MNS）轻量...
服务端发布重启：请检查您实例所在地域的发布公告，检查消费重复问题出现时是否有发布，若有发布，则服务端重启可能会导致少量消息重复。解决办法 问题定位 打开消息日志功能，针对消费重复的队列进行日志事件筛查。具体操作，请参见 配置...
消息示例 假设有一个MQTT客户端正在发布一个JSON格式的消息，它希望其他订阅这个主题的客户端知道这个消息的负载是一个UTF-8编码的JSON文本。PUBLISH Topic:sensor1/data Payload Format Indicator:1/消息负载是预定义的格式，UTF-8编码的 ...
当 云消息队列 Kafka 版 控制台提供的按位点查询和按时间查询消息的功能无法满足您搜索消息的需求时，您可以使用 云消息队列 Kafka 版 消息检索功能。消息检索支持按Topic分区、位点范围、时间范围以及消息Key和Value关键字检索。本文介绍...
源 Topic：选择需要同步消息的源Topic。消息目标 目标地域：选择消息同步的目标Topic所属实例的地域。目标实例：选择消息同步的目标Topic所属实例。目标 Topic：选择消息同步的目标Topic。过滤规则 输入过滤规则，按照该规则过滤后的消息才...
对于上文描述的交互流程，建议使用 云消息队列 MQTT 版 提供的P2P消息，P2P消息不需要订阅，发送方直接指定对端接收即可，P2P消息的详细信息，请参见 P2P消息收发模式（MQTT）。收发消息参数设计 由于移动App可能存在应用切入后台被杀死...
消息堆积场景 如下图所示，表示指定主题的某一队列中各消息的状态：上图表示指定主题的某一队列中各消息的状态，云消息队列 RocketMQ 版 将处于不同处理阶段的消息数量和耗时进行统计，这些指标可直接反映队列中消息的处理速率和堆积情况，...
在使用自建Kafka集群时，当您希望业务的成本更低、弹性更强、可靠性更高时，您可以将自建Kafka集群迁移上至 云消息队列 Kafka 版，云消息队列 Kafka 版 提供全托管、免运维的服务可以让您只需专注于业务开发，无需部署运维。注意事项 迁移...
高频率消息发布：当客户端需要频繁地发布消息到相同的几个主题时，使用主题别名可以极大地减少冗余信息的发送。例如股市行情跟踪或 IoT 数据收集系统，这些系统可能每秒都会发送大量的消息。节能：对于以电池供电的设备，减少必须通过无线...
消费者问题 消息的推送事件可以在 消息轨迹 内看到。若消息有推送事件，需要查看所在队列是否存在堆积，导致消息推送阻塞。若无堆积情况，或消息有推送事件，但是客户端一直未消费到，则需要针对消费者的运行情况进行排查。确认消费者运行...
MQTT消息的用户属性 mqtt5UserProperty 长度不能超过8K,例如：[{"key":"mQ","value":"test001"},{"key":"MQ","value":"test002"}]发送消息时指定的用户属性信息。MQTT消息的过期时间 mqtt5MsgExpireInterval 0-65535，单位s 发送消息时指定...