本文为您介绍保留消息的概念、交互过程和使用场景。保留消息 更新保留消息：使用相同的Topic发布新的消息，Payload内容会被新的消息所覆盖。保留消息支持批量设备发布时携带保留标记，设备是否在线不影响保留消息发布。删除保留消息：重新...
更多信息，请参见 云消息队列 Kafka 版的发布/订阅模型。订阅关系 Topic被 Group 订阅的情况。云消息队列 Kafka 版 支持查看订阅了指定Topic的在线 Group 的情况，非在线 Group 的情况无法查看。Producer 向 云消息队列 Kafka 版 发送消息...
SDK版本信息 本次发布的SDK客户端版本信息如下：协议 语言 版本号 TCP协议 Java V2.x.x.Final C++ V3.x.x 使用限制 地域限制 Java SDK V2.x.x.Final支持如下地域：华东1（杭州）、华北1（青岛）、华北2（北京）、华北3（张家口）、华北5...
消息队列RocketMQ版领域模型 如上图所示，云消息队列 RocketMQ 版 中消息的生命周期主要分为消息生产、消息存储、消息消费这三部分。生产者生产消息并发送至 云消息队列 RocketMQ 版 服务端，消息被存储在服务端的主题中，消费者通过订阅...
SDK版本信息 本次发布的SDK客户端版本信息如下：协议 语言 版本号 TCP协议 Java V2.x.x.Final C++ V3.x.x 使用限制 地域限制 Java SDK V2.x.x.Final支持如下地域：华东1（杭州）、华北1（青岛）、华北2（北京）、华北3（张家口）、华北5...
典型场景 使用 Chat App 消息服务 推送版本发布、活动提醒、奖励领取和更新公告。玩家点击消息直接参与活动或领取奖励，无需切换到游戏客户端。通过流程编辑器编排常用问题FAQ，收集玩家活动反馈。行业场景示例 跨境电商 场景描述：订单...
调用PublishMessage接口向指定的主题发布消息，消息发布到主题后随即会被推送给Endpoint消费。请求头 该接口使用公共请求头，无特殊请求头。更多信息，请参见 公共参数。请求语法 POST/topics/$TopicName/messages HTTP/1.1 请求参数 参数 ...
功 能介 绍 MQTT 3.3.1、5.0引入了共享订阅（Shared Subscription）特性，这是一种通过在多个客户端间分发消息的方式，使得负载均衡成为可能。在标准的MQTT协议中，每个订阅相同主题的客户端都会收到该主题的每条消息副本。共享订阅改变了...
重发消息 amqp:BasicGet amqp:BasicPublish acs:amqp:$region:$accountid:/instances/$instanceId/vhosts/$vhostName/queues/$queueName/messages/*重新发送消息 发送消息 amqp:BasicPublish acs:amqp:$region:$accountid:/instances/$...
轻量消息队列（原 MNS）支持把发布到主题的消息推送到队列。本文介绍如何将消息推送到队列。步骤一：创建主题 登录 轻量消息队列（原 MNS）控制台。在左侧导航栏，选择 主题模型 主题列表。在顶部菜单栏，选择地域。在 主题列表 页面，单击...
Chat App 消息服务是阿里云为全球企业打造的一款高效触达用户的消息引擎，通过与WhatsApp平台合作，使您轻松地使用WhatsApp平台的消息服务，触达全球10亿+用户，通过丰富的消息类型，提升您与客户的互动体验，创造更大业务价值。
按Queue查询 在 消息查询 页面单击 切换，选择要查询消息的Vhost，然后单击 按 Queue 查询 页签。在 Queue 下拉列表中，选择要查询消息的Queue，设置查询 时间范围，然后单击 查询。参数 描述 ExchangeName 发送该消息的Exchange的名称。该...
轻量消息队列（原 MNS）支持把发布到主题的消息推送到移动终端。本文介绍如何将消息推送到移动终端。前提条件 开通移动推送 创建应用 集成SDK 步骤一：创建主题 登录 轻量消息队列（原 MNS）控制台。在左侧导航栏，选择 主题模型 主题列表...
轻量消息队列（原 MNS）支持把发布到主题的消息推送到阿里短信。本文介绍如何将消息推送到阿里短信。前提条件 开通短信服务。更多信息，请参见 开通短信服务。申请短信签名和短信模板。更多信息，请参见 使用须知。步骤一：创建主题 登录 ...
轻量消息队列（原 MNS）支持把发布到主题的消息推送到队列。本文介绍如何将消息推送到队列。步骤一：创建队列 登录 轻量消息队列（原 MNS）控制台。在左侧导航栏，选择 队列模型 队列列表。在顶部菜单栏，选择地域。在 队列列表 页面，单击...
接口说明如下：putMessage 在向服务器发消息前，对消息体按指定的Key和加密算法加密。popMessage 在接收到服务端消息后，先按指定的方式解密，然后再返回解密后的消息体。SecurityKeyGenerator.java 用于生成加解密需要的 secretKey。...
我已经购买了包年包月微消息队列MQTT版实例，为什么发消息后，还会继续扣钱呢？包年包月（预付费）实例的费用只限于 云消息队列 MQTT 版 所支持的协议，即 云消息队列 MQTT 版 的消息传输以及消息存储。若您使用 云消息队列 MQTT 版 的数据...
当订阅设置了消息过滤标签时，只有当消息的消息标签和订阅的消息过滤标签一致时，消息才能被成功推送到推送目标。特殊情况下，当订阅没有设置消息过滤标签时，无论消息是否设置了消息标签，都可以成功推送消息到推送目标。功能说明 下图...
云消息队列 RocketMQ 版 控制台提供对死信消息的查询、导出和重发的功能。查询死信消息的方式 云消息队列 RocketMQ 版 提供的查询死信消息的方式对比如下表所示。查询方式 查询条件 查询类别 说明 按Group ID查询 Group ID+时间段 范围查询...
队列模型 队列模型消息流 队列模型特性 队列模型基本概念 主题模型：支持一对多的发布订阅模式。主题模型 主题模型消息流 主题模型特性 主题模型基本概念 队列模型快速入门 如 队列模型快速入门流程 所示，本教程以直接在控制台发送和接收...
我已经购买了包年包月微消息队列MQTT版实例，为什么发消息后，还会继续扣钱呢？包年包月（预付费）实例的费用只限于 云消息队列 MQTT 版 所支持的协议，即 云消息队列 MQTT 版 的消息传输以及消息存储。若您使用 云消息队列 MQTT 版 的数据...
Kafka Broker 用于存储消息的服务器。Kafka Broker支持水平扩展。Kafka Broker节点的数量越多，云消息队列 Kafka 版 集群的吞吐率越高。Group 通过pull模式从 云消息队列 Kafka 版 Broker订阅并消费消息。Zookeeper 管理集群的配置、选举...
本文介绍控制台上的消息数、可见消息数、延迟消息数分别表示哪些类型的消息。各消息数的概念如下：消息数：成功发送的和没有发送的所有消息数。可见消息数：未经处理的消息数。延迟消息数：设置了延迟时间的消息数。
解决直播中手机端互发消息和消息内容的安全审核问题，同时低成本保存消息。部署架构图 选用的产品 云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 是由阿里巴巴自研并捐赠给Apache基金会，并与开源社区共建的消息中间件，该产品服务于阿里...
在使用Kafka的过程中遇到无法正确消费消息、消息丢失、消息延迟等消费问题时，您可通过消息查询功能查看指定消息的详细内容和相关属性，帮助您排查异常原因。若确定消息所在Topic的分区ID以及消息位点，可采用按位点查询消息；若不确定消息...
云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的消息负载（Payload）均是您的业务消息的数据序列化结果，云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 不会对业务消息再做进一步的编解码处理。属性字段映射 目前，云消息队列 MQTT 版 ...
取值如下：成功 失败 消息基础信息 消息类型 普通消息 顺序消息 定时/延时消息 事务消息 消息ID 消息的全局唯一标识，由 云消息队列 RocketMQ 版 系统自动生成。Topic 消息所属的主题名称。消息Keys MessageKey，消息的业务标识，由消息...
顺序消息：消息消费根据Sharding Key负载均衡，不同Sharding Key的消息可被均衡的负载到多个Queue中消费，且为保证顺序消息的语义，相同Sharding Key的消息会被同一个消费者消费，具体示例如下图所示：说明：该图标背景色表示消息属于Queue...
本文为您介绍MQTT 5.0的新特性消息过期。功能介绍 MQTT 5.0中的消息过期（Message Expiry Interval）功能，允许设置一条消息在发布后能够在Broker中存活的最长时间。...消息过期间隔的主要好处是确保只有当前和最相关的信息被传递给订阅者。
FIFO：顺序消息，云消息队列 RocketMQ 版 通过消息分组MessageGroup标记一组特定消息的先后顺序，可以保证消息的投递顺序严格按照消息发送时的顺序。Delay：定时/延时消息，通过指定延时时间控制消息生产后不要立即投递，而是在延时间隔后...
参数 说明 消息来源 常量：其他云产品 方法 常量：Notify 发送时间 消息推送到队列的时间 结果 发送结果，显示"成功"或具体的错误信息 消息信息 普通消息 参数 说明 消息类型 常量：普通消息 消息 ID 消息的唯一标识符 队列 消息所在的队列...
背景信息 云消息队列 RocketMQ 版 通过消费位点管理消息的消费进度。每条消息被某个消费者消费完成后不会立即在队列中删除，云消息队列 RocketMQ 版 会基于每个Group维护一份消费记录，该记录指定了Group下的消费者消费指定Topic时，消费过...
消费者通常被集成在业务系统中，从 云消息队列 RocketMQ 版 服务端获取消息，并将消息转化成业务可理解的信息，供业务逻辑处理。更多信息，请参见 消费者（Consumer）。消费结果（ConsumeResult）云消息队列 RocketMQ 版 中PushConsumer...
方案二：将原Topic的信息设置到消息的自定义属性中。示例如下：messageBuilder.addProperty("originalTopic","testTopic")死信消息和主业务区分处理 死信消息是正常业务流程中消息重试仍然失败的消息，需要和主业务流程分开处理，避免影响...
通过主题、队列和位点就可以定位任意一条消息的位置，具体关系如下图所示：云消息队列 RocketMQ 版 定义队列中最早一条消息的位点为最小消息位点（MinOffset）；最新一条消息的位点为最大消息位点（MaxOffset）。虽然消息队列逻辑上是无限...
定义和模型关系 在 轻量消息队列（原 MNS）中，一个主题是一个存储消息的容器。主题里的消息可以被订阅到多种渠道进行消费，订阅类型包括队列、HTTP、短信服务、邮件推送、移动终端。每个订阅类型可以订阅主题里的所有消息，也可以配置消息...
应用场景 您在收发消息的过程中，是否遇到过以下问题：消息成功发送到队列，但消费端收不到消息，消息去哪儿了？消息被谁消费了？消费了几次？消费端宕机了，消费失败的消息什么时候可以再次被消费？消息发布到主题，Endpoint却迟迟收不到...
延时消息的具体信息，请参见 延时消息。消息存活时间的取值上限和实例的定时时长一致；且取值必须为非负整型数，单位为毫秒。如果消息存活时间被设置为0，则消息到达Queue时，除非立即被消费者消费，否则会被立即丢弃或转发到死信Exchange...
服务端发布重启：请检查您实例所在地域的发布公告，检查消费重复问题出现时是否有发布，若有发布，则服务端重启可能会导致少量消息重复。解决办法 问题定位 打开消息日志功能，针对消费重复的队列进行日志事件筛查。具体操作，请参见 配置...
消息示例 假设有一个MQTT客户端正在发布一个JSON格式的消息，它希望其他订阅这个主题的客户端知道这个消息的负载是一个UTF-8编码的JSON文本。PUBLISH Topic:sensor1/data Payload Format Indicator:1/消息负载是预定义的格式，UTF-8编码的 ...