服务端消息-服务端消息文档介绍内容-阿里云

配置连接器

application/json：表示服务端消息主体是序列化后的JSON字符串。x-www-form-urlencoded：提交的数据按key1=val1&key2=val2的方式进行编码，key和val都进行了URL转码。Response（响应参数）说明响应参数支持以application/json格式输出。...

CreateUpstreamAppKeyRelations

批量创建上行消息客户端与服务端映射关系批量创建上行消息客户端与服务端映射关系调试您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求参数名称类型 ...

ListUpstreamAppKeyRelations

调用ListUpstreamAppKeyRelations根据服务端应用ID，查询上行消息客户端与服务端映射列表。调试您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求参数名称 ...

QueryConsumerGroupStatus

使用AMQP服务端订阅时，调用该接口查询某个消费组的状态，包括在线客户端信息、消息消费速率、消息堆积数、最近消息消费时间。QPS限制单个阿里云账号调用该接口的每秒请求数（QPS）最大限制为5。说明 RAM用户共享阿里云账号配额。调试您...

快速入门

如果您是首次使用云消息队列 RocketMQ 版，您可以参考快速入门文档，了解如何购买实例并接入云消息队列 RocketMQ 版 服务端完成基本的消息收发流程。使用流程快速使用云消息队列 RocketMQ 版收发消息的流程如下图所示。详细操作，请...

5.x系列版本发布日志

本文为您介绍云消息队列 RocketMQ 版 服务端版本的变更说明。如何查看实例版本您可以在云消息队列 RocketMQ 版控制台实例详情页面的基本信息或版本管理页签查看当前实例的版本和服务端最新版本。版本升级更多信息，请参见版本...

QPS限制

本文介绍云消息队列 MQTT 版 服务端各接口的调用限制。云消息队列 MQTT 版 服务端接口的调用有QPS控制，分为两类：API的QPS限制。超过了该限制则会被限流，只保证符合SLA的流量。单个IP出口QPS控制。超过了该限制则会被完全拉黑。具体的...

DeleteUpstreamAppKeyRelation

调用DeleteUpstreamAppKeyRelation根据关系ID删除上行消息应用端与服务端的关系映射记录。调试您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求参数名称 ...

步骤三：调用SDK收发消息

本文以Java SDK为例，说明如何将开源SDK客户端接入云消息队列 RabbitMQ 版 服务端，并完成消息收发。前提条件创建资源安装IDEA 您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA Ultimate为例。安装JDK 安装Maven 安装Java依赖...

静态用户名密码管理

重要您的客户端在调用SDK收发消息时，请尽可能使用长期存活的Connection，以免每次收发消息时都需要创建新的Connection，消耗大量的网络资源和服务端资源，甚至引起服务端SYN Flood防护。更多信息，请参见 Connection。注意事项登录云...

版本管理

云消息队列 RocketMQ 版为您提供全托管的版本管理服务，服务端版本更新后，系统会在后台自动完成升级，不影响消息收发，业务侧无感知。您可以根据波峰谷时间修改后台升级的执行时间和可维护时间段。使用限制仅铂金版实例支持版本管理功能...

物联网平台AMQP服务端订阅支持转发哪些数据？

本文介绍AMQP服务端订阅支持转发的消息类型。消息类型 Topic说明相关文档设备上报消息：自定义Topic 操作权限为发布的自定义Topic。转发自定义数据格式消息的Topic，与原始自定义Topic的格式相同。使用自定义Topic通信设备上报消息：...

客户端连接常见问题

本文介绍云消息队列 MQTT 版客户端连接服务端时的常见问题。使用安卓的Demo，返回连接失败报错。问题描述资源填写正确，且网络可以连通。AK（AccessKey ID）、SK（AccessKey Secret）填写正确且已授权。可能原因接入点格式不正确，正确...

证书管理概述

云消息队列 MQTT 版支持基于X.509证书的双向认证，分别通过服务器证书和设备证书完成服务端和客户端的认证，本文介绍如何在云消息队列 MQTT 版控制台管理证书。注意事项仅铂金版、专业版实例支持双向认证能力，基础版和Serverless版...

客户端证书认证

云消息队列 MQTT 版支持基于X.509证书的双向认证，分别通过服务器证书和设备证书完成服务端和客户端的认证，保证客户端和服务端通信链路的安全性和可靠性。本文介绍客户端证书认证的原理和流程。使用限制仅铂金版、专业版实例支持双向...

什么是服务端订阅

使用MNS服务端订阅消息物联网平台将订阅的消息推送到消息服务（MNS）的队列中，您的服务器MNS客户端通过监听MNS队列接收设备消息。MNS服务端订阅消息流转流程如下图所示。使用消息服务订阅设备消息的具体配置方法，请参见使用消息服务...

如何使用消息服务？

服务端下发消息：服务端数据通过CMNS下发到应用客户端，默认消息体2K，可以根据应用需求进行调整，自定义数据最大支持10K。客户端上行数据到服务端：通过CMNS可靠而省电的连接通道，将位置信息等非重要数据从设备发回至您的服务器，应用...

API概览

当消息的收发不符合预期时，您可以通过该接口查看订阅该消息的客户端、消息的投递时间等详细信息，帮助您快速定位异常原因。CA证书 API 标题 API概述 RegisterCaCertificate 注册CA证书云消息队列 MQTT 版支持X.509证书认证，客户端可通过...

跨账号RAM用户授权服务端订阅

物联网平台服务端订阅功能支持通过RAM角色授权跨账号操作，即使用企业A的阿里云主账号创建RAM角色并...开发AMQP客户端接收服务端订阅消息：企业B开发AMQP客户端接入企业A阿里云账号的物联网平台，接收企业A物联网平台下服务端订阅的设备消息。

在线教育的视频直播

同时，该方案还支持手机间通过MQTT协议互相发送消息，在信息的服务端对信息内容进行安全审核，不合规内容不能转发，消息内容在服务端保存供后续查看。场景概述通过阿里云视频直播服务实现移动端的推拉流能力，同时移动端利用MQTT消息服务...

消息（Message）

模型关系在整个云消息队列 RocketMQ 版的领域模型中，消息所处的流程和位置如下：消息由生产者初始化并发送到云消息队列 RocketMQ 版 服务端。消息按照到达云消息队列 RocketMQ 版服务端的顺序存储到队列中。消费者按照指定的订阅...

AMQP客户端接收不到实时消息，为什么？

本文介绍通过物联网平台配置的AMQP服务端订阅消息无法接收的常见问题及解决方法。配置AMQP服务端订阅后，为什么在线消费端收不到消息？问题描述 AMQP服务端订阅完成后，消费组对应在线AMQP客户端没有接收到消息。可能原因当前设备通信的...

数据压缩

decompTopic 列表：指定Topic用于设备上报消息到服务端，设备端进行数据压缩，服务端要相应地进行数据解压缩，设备端会有 hit data compression case 的debug级别的日志。重要已设置的压缩和解压缩关系会保存在服务端，需设备端SDK执行 ...

事务消息

半事务消息：暂不能投递的消息，生产者已经成功地将消息发送到了云消息队列 RocketMQ 版 服务端，但是云消息队列 RocketMQ 版 服务端未收到生产者对该消息的二次确认，此时该消息被标记成“暂不能投递”状态，处于该种状态下的消息即半...

整体联调运行

在控制台左侧，选择消息转发>服务端订阅，单击消费组列表，单击消费组充电宝业务数据处理对应的查看，进入消费组详情页面，可看到消息处理速率、堆积量、最后一条消息处理时间，以及服务端（即下图中的客户端）的信息。服务端下发...

消费者（Consumer）

模型关系在云消息队列 RocketMQ 版的领域模型中，消费者的位置和流程如下：消息由生产者初始化并发送到云消息队列 RocketMQ 版 服务端。消息按照到达云消息队列 RocketMQ 版服务端的顺序存储到主题的指定队列中。消费者按照指定的...

通用WebSocket接入指南

同理，服务端发送消息给客户端，客户端收到消息之后也需要立即发送一条回执消息（该回执消息需要在处理消息之前立即发送，避免服务端误判客户端没有收到消息而导致重复发送该条消息）。回执消息格式：业务消息协议：消息内容：6{"messageId...

消息通信说明

上行通信：设备端到服务端设备端向通信Topic发布消息，服务端可通过物联网平台的AMQP订阅或云产品流转功能，接收来自设备端的消息。配置引擎规则时，您需注意以下事项：仅支持在新版云产品流转功能下，为云网关设备配置数据流转规则。具体...

生产者（Producer）

模型关系在云消息队列 RocketMQ 版的领域模型中，生产者的位置和流程如下：消息由生产者初始化并发送到云消息队列 RocketMQ 版 服务端。消息按照到达云消息队列 RocketMQ 版服务端的顺序存储到主题的指定队列中。消费者按照指定的...

如果AMQP客户端不在线，可以设置消息不转发到AMQP吗？

如果AMQP客户端不在线，AMQP服务端订阅消息会堆积，AMQP客户端重新上线后，物联网平台重新推送消息。如果不需要消费AMQP客户端不在线时堆积的消息，可在AMQP客户端上线前，在物联网平台控制台的消费组详情页面，清空堆积的消息。具体操作...

消息收发功能

终端设备和云端服务均需要通过云消息队列 MQTT 版的SDK接入云消息队列 MQTT 版 服务端进行消息通信。云消息队列 MQTT 版提供的SDK如下。终端SDK：MQTT的开源SDK，支持MQTT 3.1.1协议，适用于终端设备的开发。云端SDK：阿里云开发的SDK...

基本概念

消息堆积生产者已经将消息发送到云消息队列 RocketMQ 版的服务端，但由于消费者的消费能力有限，未能在短时间内将所有消息正确消费掉，此时在云消息队列 RocketMQ 版的服务端保存着未被消费的消息，该状态即消息堆积。事务消息事务...

Java SDK接入示例

本文介绍使用AMQP协议的JMS客户端接入阿里云物联网平台，接收服务端订阅消息的示例。前提条件已获取消费组ID，并订阅Topic消息。管理消费组：您可使用物联网平台默认消费组（DEFAULT_GROUP）或创建消费组。配置AMQP服务端订阅：您可通过...

消息发送重试和流控机制

重试触发条件触发消息发送重试机制的条件如下：客户端消息发送请求调用失败或请求超时网络异常造成连接失败或请求超时。服务端节点处于重启或下线等状态造成连接失败。服务端运行慢造成请求超时。服务端返回失败错误码系统逻辑错误：因...

消息类型

服务端收到 Rollback 状态则删除半事务消息，订阅方将不会接受该消息。事务消息回查步骤如下：在断网或者是应用重启的特殊情况下，上述步骤 4 提交的二次确认最终未到达服务端，经过固定时间后服务端将对该消息发起消息回查。发送方收到...

消费者分组（ConsumerGroup）

模型关系在云消息队列 RocketMQ 版的领域模型中，消费者分组的位置和流程如下：消息由生产者初始化并发送到云消息队列 RocketMQ 版 服务端。消息按照到达云消息队列 RocketMQ 版服务端的顺序存储到主题的指定队列中。消费者按照指定...

服务端订阅使用限制

ACK超时 AMQP服务端转发消息到客户端后，如果30秒内未收到客户端回执消息，计为ACK超时。失败推送重试策略由于消费客户端离线、消息消费慢等原因，消息不能实时消费，而进入堆积队列。消费客户端重新上线并恢复稳定消费能力后，物联网平台...

回调鉴权

如果开启回调鉴权，回调时会携带所有鉴权相关内容供消息接收服务端进行鉴权使用，这样可以有效过滤非法请求，增强系统安全性。鉴权参数在进行HTTP请求回调时，HTTP头部增加以下鉴权参数：参数描述 X-ICE-TIMESTAMP HTTP请求发起时间，用...

事务消息

云消息队列 RocketMQ 版 服务端将消息持久化成功之后，向生产者返回Ack确认消息已经发送成功，此时消息被标记为“暂不能投递”，这种状态下的消息即为半事务消息。生产者开始执行本地事务逻辑。生产者根据本地事务执行结果向服务端提交二次...

基于日志服务的日志说明

deliveryTag：服务端标识某个Channel上的唯一消息。说明仅 Action 为 PushMessage、BasicGet、DeleteMessage 或 SendDlqMessage 时，记录该字段。ResourceName 资源名称。说明 Action 为 ConnectionOpen、ConnectionClose、ChannelOpen 或...

服务端消息

新品推荐