可观测性体系概述
指标 云消息队列 RocketMQ 版 中定义了详细的Metrics指标，这些指标覆盖生产者、消费者、服务端及消息收发关键接口和流程的统计数据，并支持从实例、Topic和Group等多个维度进行聚合展示，帮助您实时监控消息业务或 云消息队列 RocketMQ 版...
消息通信计费
服务端信息 服务端调用设备相关接口产生的各类消息，如服务端调用物模型接口。消息包计费规则 重要 补充消息包暂不提供独立购买方式。设备激活码和消息包将组合使用，您可以理解为购买激活码时所含默认消息包到期或不满足设备所需时，补充...
消息通信计费
服务端响应设备RPC的Response消息。服务端调用RRPC接口发的消息。服务端调用子设备相关接口产生的消息。服务端调用设备影子相关接口产生的消息。服务端调用物模型相关接口产生的消息。免费消息 Connect Connect ACK Disconnect PingReq ...
概述
物联网平台提供设备上云、设备上报消息、...服务端订阅设备消息：服务端通过订阅消息类型，接收设备相关消息，如设备上下线通知、设备生命周期变更、设备上报消息等。云端下发指令：使用物联网平台的在线调试功能，从控制台下发指令到设备端。
SendMessage-向云消息队列 MQTT 版发送单条消息
从服务端应用向云消息队列 MQTT 版发送单条消息。接口说明 SendMessage 接口为服务端应用调用，与 MQTT 客户端发送消息互补。服务端和客户端的使用场景区别，请参见 开发指南使用指引。调用 SendMessage 接口前，请确认您的云消息队列 MQTT...
定时/延时消息
应用场景 说明 定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻将消息投递给消费者消费。因此，下文统一用定时消息描述。在分布式定时调度触发、任务超时处理等场景，需要实现精准、可靠的定时事件触发。使用...
为什么消息已经过期还未被删除？
问题现象 您发送的消息在服务端保存的时间已经超过了 消息保留时长，但依然可以查询到消息。说明 消息保留时长 指在磁盘容量充足的情况下，消息的最长保留时间。默认值为72小时，取值范围为24小时~480小时。磁盘容量不足（即磁盘水位达到85...
通信消息相关问题
服务端订阅：使用物联网平台的服务端订阅功能，订阅一个或多个消息类型。物联网平台根据您设置的订阅，将产品下所有设备的该类型消息流转至您的服务器。支持以下两种方式的服务端订阅：AMQP服务端订阅：使用AMQP SDK接收物联网平台转发的...
普通消息
典型场景一：微服务异步解耦 如上图所示，以在线的电商交易场景为例，上游订单系统将用户下单支付这一业务事件封装成独立的普通消息并发送至 云消息队列 RocketMQ 版 服务端，下游按需从服务端订阅消息并按照本地消费逻辑处理下游任务。...
快速入门概述
云消息队列 MQTT 版 支持使用多种语言的SDK接入服务端实现消息收发，本文以Java为例介绍不同场景下的消息收发流程。操作流程 使用SDK收发消息流程如下图所示。具体操作步骤如下：开通服务并授权 开通消息队列服务，并授予RAM用户操作 云...
订阅关系（Subscription）
模型关系 在 云消息队列 RocketMQ 版 的领域模型中，订阅关系的位置和流程如下：消息由生产者初始化并发送到 云消息队列 RocketMQ 版 服务端。消息按照到达 云消息队列 RocketMQ 版 服务端的顺序存储到主题的指定队列中。消费者按照指定的...
Exactly-Once投递语义
因为真正意义上的Exactly-Once依赖消息系统的服务端、消息系统的客户端和用户消费逻辑这三者状态的协调。例如，当您的消费端完成一条消息的消费处理后出现异常宕机，而消费端重启后由于消费的位点没有同步到消息系统的服务端，该消息有可能...
用户身份识别
为提高数据安全性，云消息队列 RocketMQ 版 服务端会在客户端接入时对客户端进行身份验证，仅通过验证的客户端才能连接服务端进行消息收发。同时 云消息队列 RocketMQ 版 支持ACL身份识别，您可以按需为指定ACL用户赋予具体的Topic或Group...
现代IM系统中的消息系统—架构
接收方会主动的向服务端拉取所有未同步消息，但接收方何时来同步以及会在哪些端来同步消息对服务端来说是未知的，所以要求服务端必须保存所有需要同步到接收方的消息，这是消息同步库的主要作用。对于新的同步设备，会有消息漫游的需求，这...
开源MQTT迁移至云消息队列 MQTT 版
本文为您介绍如何将开源MQTT客户端从其他开源MQTT服务端迁移至阿里云的 云消息队列 MQTT 版 服务端上。背景信息 云消息队列 MQTT 版 拥有多协议、多语言平台的开发能力，并支持设备级权限控制以及SSL/TLS传输加密，您可以不变更开源客户端...
使用自定义Topic通信
设备端发送消息到服务端 设备端向自定义Topic发布消息，服务端可通过物联网平台的AMQP订阅或云产品流转功能，接收来自设备端的消息。设备与设备通信 设备端向自定义Topic发布消息，可通过物联网平台的云产品流转或Topic消息路由，将消息...
基础术语
消息堆积 Message accumulation Producer 已经将消息发送到消息队列的服务端，但由于 Consumer 消费能力有限，未能在短时间内将所有消息正确消费掉，此时在消息队列的服务端保存着未被消费的消息，该状态即消息堆积。消息过滤 Message ...
服务端订阅（MNS）
本文介绍如何配置服务端订阅，将产品下的设备状态变化消息推送到消息服务（MNS）队列中；服务器通过监听MNS队列接收设备状态变化消息。前提条件 开通阿里云产品：物联网平台。消息服务。准备开发环境，本示例使用Java开发环境如下：操作...
顺序消息
如需保证消息消费的顺序性，则必须满足以下条件：投递顺序 云消息队列 RocketMQ 版 通过客户端SDK和服务端通信协议保障消息按照服务端存储顺序投递，但业务方消费消息时需要严格按照接收—处理—应答的语义处理消息，避免因异步处理导致...
HTTP回调事件通知
回调消息接收端获取当前时间，与回调请求所带的X-VOD-TIMESTAMP字段时间相减，如果超过回调消息接收服务端所设定的指定时间（如5分钟，由回调消息接收服务端自行定义），则认为该请求无效。说明 由于时间设置等问题，时间差值可能会有误差...
云端Demo工程
MQTTProducerDemo 类：云端服务向 云消息队列 MQTT 版 服务端发送消息。MQTTConsumerDemo 类：云端服务从 云消息队列 MQTT 版 服务端接收消息。MQTTClientStatusNoticeProcessDemo 类：云端服务接收客户端上下线通知消息。将解压好的Demo...
基本概念
消息堆积 Producer已经将消息发送到 云消息队列 RocketMQ 版 的服务端，但由于Consumer消费能力有限，未能在短时间内将所有消息正确消费掉，此时在 云消息队列 RocketMQ 版 的服务端保存着未被消费的消息，该状态即消息堆积。消息堆积量=...
数据转发到消息服务（MNS）
当需要对设备数据进行复杂或精细化处理，且单个产品下所有设备或指定设备的消息量小于1,000 QPS时，可以使用云产品流转功能将物联网平台数据转发到消息服务（MNS）中，服务端再从消息服务主题中订阅消息，实现设备端与服务端之间高性能的...
云消息队列 Kafka 版何时删除旧消息？
磁盘使用率介于[85%,90%)区间：无论消息是否超过 消息保留时长，根据服务端存储消息的时间先后顺序直接清除消息。磁盘使用率≥90%：为了保证稳定性，服务开启禁写保护，暂时无法写入新消息。重要 一般情况下，为了保证您的业务健康性（拥有...
PHP SDK接入示例
配置AMQP服务端订阅：您可通过消费组订阅需要的Topic消息。下载SDK 本示例提供基于Stomp PHP库的代码示例，使用STOMP协议和物联网平台云端通信。请访问 Stomp PHP 下载客户端和查看使用说明。Stomp PHP SDK适用的PHP版本，请参见 Stomp ...
集群消费和广播消费
本文介绍 SOFAStack 消息...广播模式下服务端不维护消费进度，所以消息队列控制台不支持消息堆积查询、消息堆积报警和订阅关系查询功能。更多信息 集群消费模式和广播消费模式的具体配置方法，请参见以下文档：TCP 协议 Java SDK：订阅消息
发布者最佳实践
一个合适的Batch大小，可以减少发送消息时客户端向服务端发起的请求次数，在整体上提高消息发送的吞吐和延迟。Batch机制，云消息队列 Kafka 版 Producer端主要通过两个参数进行控制：batch.size:发往每个分区（Partition）的消息缓存量...
使用前必读
取消授权 AMQP服务端订阅 确认是否已配置AMQP服务端订阅或消息转发到AMQP。若已配置，对于AMQP客户端接入的SDK，需要复制新的企业版实例ID和接入域名，配置新的AMQP客户端，然后在灰度迁移后，复制更新消费组ID，启动新的AMQP客户端。AMQP...
快速入门
七、可靠消息上行 描述：上传消息到应用appKey关联的mns消息队列上，此接口会在服务端将消息放到mns后返回，会告知客户端消息是否成功上传。接口原型：/*@param tag String 上行消息的tag，服务端做过滤消息用*@param msg String 上行的...
消费者分类
使用方式 SimpleConsumer的使用涉及多个接口调用，由业务逻辑按需调用接口获取消息，然后分发给业务线程处理消息，最后按照处理的结果调用提交接口，返回服务端当前消息的处理结果。示例如下：/消费示例：使用SimpleConsumer消费普通消息，...
RRPC能力
物联网平台提供API给服务端，设备端只需要按照固定的格式回复PUB消息，服务端通过API，即可同步获取设备端的响应结果。服务端通过云端API发起一个RRPC调用后，设备端会收到一个同步请求的Topic,格式如/ext/rrpc/${messageId}/${rrpc_topic}...
Python3 SDK接入示例
本文介绍使用Python3 SDK接入阿里云物联网平台，接收服务端订阅消息的示例。前提条件 已获取消费组ID，并订阅Topic消息。管理消费组：您可使用物联网平台默认消费组（DEFAULT_GROUP）或创建消费组。配置AMQP服务端订阅：您可通过消费组订阅...
查询消息轨迹
消息轨迹是指一条消息从生产者发送到消息队列服务端，再到消费者消费处理，整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。本文介绍如何快速查询消息轨迹。前提条件 您的消息已从生产者发送。操作步骤 登录 SOFAStack...
生产者负载均衡
生产者发送消息到 云消息队列 RocketMQ 版 服务端时，云消息队列 RocketMQ 版 将根据生产者负载均衡策略将消息均匀的存储在多个队列中，避免产生热点队列和性能瓶颈。本文介绍 云消息队列 RocketMQ 版 生产者的负载均衡策略。背景信息 了解...
存储费用
存储空间主要为消息存储在服务端 云消息队列 RocketMQ 版 实例的空间占用量。此外，实例、Topic以及Group元数据也会占用少量存储空间。计费方式 按量付费 不管购买实例时选择的付费方式为包年包月还是按量付费，存储费用都按照按量付费方式...
什么是 mPaaS
服务端开发 消息推送 推送消息到客户端 App。移动网关 管理客户端与服务端连接。智能投放 提供应用内个性化投放和定向投放广告的能力。发布 实时发布 发布新版本。热修复 动态修复 Native 代码中的 bug。分析 实时日志 通过埋点进行用户...
顺序消息
如果发送方有多个生产者或者有多个线程并发发送消息，则此时只能以到达 云消息队列 RocketMQ 版 服务端的时序作为消息顺序的依据，和业务侧的发送顺序未必一致。顺序消息常见问题 同一条消息是否可以既是顺序消息，又是定时消息和事务消息...
名词解释
MQTT服务器 云消息队列 MQTT 版 提供的MQTT协议交互的服务端节点，用于完成与MQTT客户端和 云消息队列 RocketMQ 版 各自的消息收发。MQTT客户端 用于和MQTT服务器交互的移动端节点，全称为 云消息队列 MQTT 版 客户端。P2P消息 云消息队列 ...
消费者负载均衡
因此，即使多个消费者同时消费同一队列的消息，服务端也可保证消息不会被多个消费者重复消费。顺序消息负载机制 在顺序消息中，消息的顺序性指的是同一消息组内的多个消息之间的先后顺序。因此，顺序消息场景下，消息粒度负载均衡策略还...
Node.js SDK接入示例
本文介绍使用Node.js语言的AMQP SDK接入阿里云物联网平台，接收服务端订阅消息的示例。前提条件 已获取消费组ID，并订阅Topic消息。管理AMQP消费组：您可使用物联网平台默认消费组（DEFAULT_GROUP）或创建消费组。配置AMQP服务端订阅：您可...
- 产品推荐
- 这些文档可能帮助您