订阅选项能够指定消息的最大服务质量（QoS）以及设备是否接收自己发布的消息，这些选项使得客户端可以更精细地管理自己的消息流和接收行为。MQTT 5.0支持的订阅选项如下：特性 说明 QoS level MQTT消息服务质量等级。No Local 设备是否接收...
SIMPLIFIED：消息体即用户发布的消息，不包含任何属性信息。JSON：消息体为JSON格式，包含消息正文和消息属性。XML：消息体为XML格式，包含消息正文和消息属性。步骤三：发布消息 在 主题列表 页面，找到目标主题，在其右侧操作列单击 发布...
接WhatsApp通知，自2025年10月7日起，将对WhatsApp发消息上限进行更改，具体更改内容如下：发消息上限由现在的基于每个号码更改为基于业务资产组合（Business Portfolio），业务资产组合下的所有 WABA号码共享同一个发消息上限。...
No Local 对于MQTT 3.1.1版本协议，如果设备订阅了自己发布消息的Topic，则设备会接收到自己发布的消息。而使用MQTT 5.0版本协议，此场景下，设备在订阅Topic时，可以设置此选项为 1，设备将不会接收到自己发布的消息。可取值：1：不接收。...
普通队列：普通消息的发送与消费，不保证消费的顺序。顺序队列：保证同一分组内的消息按照发送顺序进行消费。消息最大长度：发送到队列的消息体的最大长度。长轮询时间：当队列中没有消息时，该队列的ReceiveMessage请求的最大等待时长。设...
功能介绍 在MQTT协议中，遗嘱消息（Will Message）是一种由客户端在连接时指定的，当客户端异常断开连接时由代理代为发布的消息。客户端在连接时会提供遗嘱消息的内容、主题、QoS 级别等信息，代理会在客户端连接时保存这条信息，如果客户...
主题（Topic）发布消息的目标和存储地址。Account 用户的阿里云账号ID。发布者（Publisher）消息发布者，往主题发布消息的客户端。订阅者（Subscriber）消息订阅者，从主题接收消息的客户端，主题所有者默认拥有该主题的订阅权限。订阅...
取决于回调里的处理耗时以及 max.in.flight.requests.per.connection 的设置。Java客户端设置回调是否会...max.in.flight.requests.per.connection 的设置：在阻塞结束之前，最多能发的消息数由 max.in.flight.requests.per.connection 决定。
SIMPLIFIED：消息体即用户端发布的消息，不包含任何属性信息（精简格式，即文本格式）。更多信息，请参见：NotifyStrategy NotifyContentFormat 日志管理 支持查看每条消息发布进主题的记录和每次推送给用户端的记录，包括重试推送的记录和...
SIMPLIFIED：消息体即用户发布的消息，不包含任何属性信息。消息体示例：{1:"a",2:"b"} JSON：消息体为JSON格式，包含消息正文和消息属性。消息体示例：{"TopicOwner":"TopicOwner","TopicName":"TopicName","Subscriber":"Subscriber",...
QoS为1或2时，客户端连接服务端订阅有保留消息的主题时，保留消息至多重试1次。客户端连接并订阅主题后，服务端会正常推送1次保留消息，若服务端超时未收到消息确认，会重试推送，若该次重试推送仍未得到确认，则本次连接服务端不再重试推...
遗嘱消息的内容：与正常发布的消息内容基本相同，包括主题，消息内容，服务等级（Qos），保留标记（retain）、用户属性、消息过期等。遗嘱消息的管理：当设备和物联网平台保持连接时，不能修改遗嘱消息。如果需要修改，必须断开设备和平台...
发布的客户端类型 可选择发布到以下类型的客户端：Windows客户端（仅对V7.7或以上版本生效）macOS客户端（仅对V7.7或以上版本生效）发布周期 选择要显示该消息的开始时间和结束时间。发布范围 选择该消息的可见范围。可选项：全量发布 按...
取值：SIMPLIFIED：消息体即用户发布的消息，不包含任何属性信息。消息体示例：{1:"a",2:"b"} JSON：消息体为JSON格式，包含消息正文和消息属性。消息体示例：{"TopicOwner":"TopicOwner","TopicName":"TopicName","Subscriber":...
场景介绍 云数据库 Tair（兼容 Redis）发布的消息是“非持久”的，即消息发布者只负责发送消息，而不管消息是否有接收方，也不会保存之前发送的消息，即发布的消息“即发即失”；消息订阅者也只能得到订阅之后的消息，频道（channel）中...
示例说明如下：用户注册需要发送发验证码，以用户 ID 作为 Sharding Key，那么同一个用户发送的消息都会按照发布的先后顺序来消费。注意事项 使用顺序消息时，请注意以下几点：顺序消息暂不支持广播模式。建议同一个 Group ID 只对应一种...
同时发布的消息需要包含 hash-header 所选的Header，若未包含指定的Header，则全部消息将被路由到同一个任意队列中。若Routing Key和 hash-header 参数同时定义，则以 hash-header 参数值为输入进行Hash运算。x-consistent-hash Exchange...
设置该条发布消息的filterTag/msg.setMessageTag("filterTag");TopicMessage publishResultMsg=topic.publishMessage(msg);System.out.println("message publish.");System.out.println("reqId:"+publishResultMsg.getRequestId());System....
邮件 短信 钉钉 步骤四：结果验证 返回 轻量消息队列（原 MNS）控制台，在 主题列表 中找到 步骤一：创建轻量消息队列（原MNS）主题 中已创建的主题，单击其右侧 操作 列的 发布消息，执行以下操作。查看联系人邮箱、短信及钉钉机器人是否...
本文介绍在 云消息队列 MQTT 版 中常见的授权策略示例。注意事项 在阅读本文前，建议您可先查看在访问控制RAM中支持的 云消息队列 MQTT 版 相关的 权限策略。关于Resource的格式及格式说明，请参见 资源（Resource）。如需直接复制示例代码...
当消息的收发不符合预期时，您可以通过该接口查看消息的发布时间、发布客户端等详细信息，帮助您快速定位异常原因。接口说明 每成功调用一次 QueryMqttTraceMessagePublish 接口，都会计算为一次消息 TPS，从而影响您的计费。计费详情，请...
本文介绍在 云消息队列 MQTT 版 中常见的授权策略示例。注意事项 在阅读本文前，建议您先查看在访问控制RAM中支持的 云消息队列 MQTT 版 相关的 权限策略。如需直接复制示例代码，使用时请删除注释内容，即“/”及以后的文字说明。示例中的...
如果系统权限策略不能满足您的要求，您可以创建自定义权限策略实现最小授权。...}]} 授权信息参考 使用自定义权限策略，您需要了解业务的权限管控需求，并了解 云消息队列 RocketMQ 版 的授权信息。详细内容请参见 授权信息。
为提高数据安全性，云消息队列 RocketMQ 版 服务端会在客户端接入时对客户端进行身份验证，仅通过验证的客户端才能连接服务端进行消息收发。同时 云消息队列 RocketMQ 版 支持ACL身份识别，您可以按需为指定ACL用户赋予具体的Topic或Group...
当消息的收发不符合预期时，您可以通过该接口查看消息的发布时间、发布客户端等详细信息，帮助您快速定位异常原因。QueryMqttTraceMessageSubscribe 查询消息消费轨迹 查询指定消息的投递轨迹。当消息的收发不符合预期时，您可以通过该接口...
轻量消息队列（原 MNS）支持把发布的主题消息推送到 函数计算，本文为您介绍具体的操作步骤。前提条件 已创建接收消息的函数。具体操作请参见 创建函数。步骤一：创建主题 登录 轻量消息队列（原 MNS）控制台。在左侧导航栏，选择 主题模型...
本文为您介绍保留消息的概念、交互过程和使用场景。保留消息 更新保留消息：使用相同的Topic发布新的消息，Payload内容会被新的消息所覆盖。保留消息支持批量设备发布时携带保留标记，设备是否在线不影响保留消息发布。删除保留消息：重新...
发布延时消息的Java示例代码如下：Map String,Object headers=new HashMap();headers.put("delay","5000");表示消息延时5000毫秒。AMQP.BasicProperties props=new AMQP.BasicProperties.Builder().messageId(UUID.randomUUID().toString()...
消息保留时长 在磁盘容量充足的情况下，消息的最长保留时间。磁盘容量不足（即磁盘水位达到85%）时，将提前删除旧的消息，以确保服务可用性。默认值为72小时，取值范围为24小时~480小时。最大消息大小 云消息队列 Kafka 版 能收发的消息的...
SDK版本信息 本次发布的SDK客户端版本信息如下：协议 语言 版本号 TCP协议 Java V2.x.x.Final C++ V3.x.x 使用限制 地域限制 Java SDK V2.x.x.Final支持如下地域：华东1（杭州）、华北1（青岛）、华北2（北京）、华北3（张家口）、华北5...
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 版 服务端，消息被存储在服务端的主题中，消费者通过订阅...
典型场景 使用 Chat App 消息服务 推送版本发布、活动提醒、奖励领取和更新公告。玩家点击消息直接参与活动或领取奖励，无需切换到游戏客户端。通过流程编辑器编排常用问题FAQ，收集玩家活动反馈。行业场景示例 跨境电商 场景描述：订单...
接WhatsApp通知，自2025年7月1日起，WhatsApp消息计费规则将进行以下变动：WhatsApp将取消目前的按照会话进行计费的模式，变更为按照单条消息收费。在已打开的客服窗口时间内发送交易相关（Utility）的消息将免费。说明 客服窗口是指每当有...
调用PublishMessage接口向指定的主题发布消息，消息发布到主题后随即会被推送给Endpoint消费。请求头 该接口使用公共请求头，无特殊请求头。更多信息，请参见 公共参数。请求语法 POST/topics/$TopicName/messages HTTP/1.1 请求参数 参数 ...
重发消息 amqp:BasicGet amqp:BasicPublish acs:amqp:$region:$accountid:/instances/$instanceId/vhosts/$vhostName/queues/$queueName/messages/*重新发送消息 发送消息 amqp:BasicPublish acs:amqp:$region:$accountid:/instances/$...
Chat App 消息服务是阿里云为全球企业打造的一款高效触达用户的消息引擎，通过与WhatsApp平台合作，使您轻松地使用WhatsApp平台的消息服务，触达全球10亿+用户，通过丰富的消息类型，提升您与客户的互动体验，创造更大业务价值。
功 能介 绍 MQTT 3.3.1、5.0引入了共享订阅（Shared Subscription）特性，这是一种通过在多个客户端间分发消息的方式，使得负载均衡成为可能。在标准的MQTT协议中，每个订阅相同主题的客户端都会收到该主题的每条消息副本。共享订阅改变了...
轻量消息队列（原 MNS）支持把发布到主题的消息推送到队列。本文介绍如何将消息推送到队列。步骤一：创建主题 登录 轻量消息队列（原 MNS）控制台。在左侧导航栏，选择 主题模型 主题列表。在顶部菜单栏，选择地域。在 主题列表 页面，单击...
按Queue查询 在 消息查询 页面单击 切换，选择要查询消息的Vhost，然后单击 按 Queue 查询 页签。在 Queue 下拉列表中，选择要查询消息的Queue，设置查询 时间范围，然后单击 查询。参数 描述 ExchangeName 发送该消息的Exchange的名称。该...