问题描述 AMQP服务端订阅完成后，消费组对应在线AMQP客户端没有接收到消息。可能原因 当前设备通信的消息类型，不在AMQP服务端订阅的消息类型内。实时消息推送限流了，超过限流的消息不能实时消费，物联网平台会重试推送。AMQP客户端的一个...
AMQP客户端仅支持接收已订阅的设备消息，不支持下发指令给设备。如果您需下发指令给设备，可在业务服务器侧集成物联网平台云端SDK，调用云端API发送消费给设备。具体内容，请参见 云端开发指南。相关文档 什么是服务端订阅：了解AMQP服务端...
开发AMQP客户端接收服务端订阅的设备消息，请参见 通过RAM角色授权的RAM用户接收服务端订阅消息。本账号接收服务端订阅消息 下载Demo代码包，并解压。打开IntelliJ IDEA，导入Demo包中的示例工程 amqp-demo。在 pom.xml 文件中，已添加...
客户端接收到消息撤回的指令后，会将通知栏中展示的消息删除，同时显示“消息已撤回”。小米 是 覆盖消息。客户端接收到消息撤回的指令后，会将通知栏中展示的消息删除，同时显示“消息已撤回”。OPPO 是 覆盖消息。客户端接收到消息撤回的...
如果多个AMQP客户端同时消费一个消费组，设备消息会随机推送到任意一个客户端，即单独的某个客户端接收到的消息是不全的。相关文档 什么是服务端订阅：了解AMQP服务端订阅应用场景和使用优势。配置AMQP服务端订阅：了解如何配置推送到AMQP...
原理框架 控制台根据不同的诊断通道（消息推送或移动同步）下发日志诊断指令，客户端接收到诊断指令后，将诊断日志上报到日志网关，当诊断文件上报成功后，在控制台可以下载诊断文件。基本框架如下所示：接入和使用 Android 端的接入及使用...
不可以。如果AMQP客户端不在线，AMQP服务端订阅消息会堆积，AMQP客户端重新上线后，物联网平台重新推送消息。如果不需要消费AMQP客户端不...相关文档 AMQP客户端接入说明：了解AMQP客户端接收设备消息的消息策略、消息时序以及消息回执说明。
接收流量 VPN网关通过SSL-VPN连接从客户端接收的流量。单位：Byte。发送流量 VPN网关通过SSL-VPN连接向客户端发送的流量。单位：Byte。状态 客户端与阿里云之间SSL-VPN连接的状态。仅取值：运行中，表示客户端和阿里云已成功建立SSL-VPN...
物联网平台推送到消费端（AMQP客户端）的消息不保序，即AMQP客户端接收到消息的时间顺序不一定是消息实际产生的时间顺序。您可根据以下方法，对消费端接收消息进行排序。设备上下线消息：收到消息的顺序不是实际设备上下线时间排序。设备...
③发送命令 传送数据时，客户端会在命令链路上向服务器发送PORT命令，命令中包含了客户端接收数据的端口。传送数据时，客户端会在命令链路上向服务器发送PASV命令。服务器收到命令后，随机开启一个端口并向客户端发送端口信息。④传送数据 ...
ClientBytes int 从客户端接收到的数据字节数，单位：Byte。ClientCountryCode string 从客户端IP地址解析出的ISO-3166 Alpha-2 Code。ClientIP string 与 ESA 节点建连的客户端IP地址。ClientISP string 从客户端IP地址解析出的运营商信息...
准备开发环境 本文使用Java开发环境如下：操作系统：Windows 10 64位 JDK版本：JDK8 集成开发环境：IntelliJ IDEA社区版 业务服务器接收设备数据 服务器通过AMQP客户端接收消息，需配置AMQP客户端接入物联网平台，监听设备消息，请参见 ...
动作说明 accepted：服务端接收客户端发起的连接请求。not authorized：客户端访问的实例权限校验失败导致TCP连接断开。clientId conflict：客户端标识冲突导致TCP连接断开。topic auth failed：客户端访问的Topic资源权限校验失败导致TCP...
AMQP客户端认证过程、认证参数配置和消息处理逻辑，请参见本文的 连接认证过程、连接配置说明 和 客户端接收消息逻辑。Java SDK接入示例.NET SDK接入示例 Node.js SDK接入示例 Python 2.7 SDK接入示例 Python3 SDK接入示例 PHP SDK接入示例...
ClientBytes int 从客户端接收到的数据字节数，单位：Byte。ClientCountryCode string 从客户端IP地址解析出的ISO-3166 Alpha-2 Code。ClientIP string 与 ESA 节点建连的客户端IP地址。ClientISP string 从客户端IP地址解析出的运营商信息...
说明 accepted：服务端接收客户端发起的连接请求。not authorized：客户端访问的实例权限校验失败导致TCP连接断开。clientId conflict：客户端标识冲突导致TCP连接断开。topic auth failed：客户端访问的Topic资源权限校验失败导致TCP连接...
自定义响应行为：添加或修改自定义头部信息，可以根据业务需求调整客户端接收到的响应内容和格式，实现特定的功能或跟踪目的。注意事项 在添加了多条配置的情况下，配置的执行顺序是按配置列表从上到下的顺序逐条执行，响应头名称相同的...
（Chunk：一批待处理数据分片集合）执行阶段：客户端接收到通知后拉取数据进行处理，处理完后继续拉取新的数据，直到数据都处理完成。拓扑任务 任务拓扑 是一种特殊的任务，是由许多通过事件触发的任务的集合。任务拓扑本身可以通过 CRON ...
clientIp 调用者客户端IP exception 后端返回的具体错信息 exchangeTimestamp 整个请求链路的IO时间点 FrontRequestStart：API网关开始接收到客户端请求的时间点 FrontRequestEnd：API网关完成接收客户端请求的时间点 BackendRequestStart...
本文为您介绍通过配置AMQP服务端订阅，实现企业服务器通过接入AMQP客户端，接收路灯设备数据的完整流程。前提条件 已接入设备和上报数据。具体操作，请参见 设备接入和上报数据。准备开发环境 本文AMQP客户端示例使用Java开发语言，推荐...
clientIp 调用者客户端IP exception 后端返回的具体错信息 exchangeTimestamp 整个请求链路的IO时间点 FrontRequestStart：API网关开始接收到客户端请求的时间点 FrontRequestEnd：API网关完成接收客户端请求的时间点 BackendRequestStart...
8.XX.XX.15 ReceiveBytes long 指 VPN 网关通过 SSL-VPN 连接从客户端接收的流量。单位：Byte。60782 Port string 客户端与阿里云建立 SSL-VPN 连接时，客户端实际使用的端口号。4*示例 正常返回示例 JSON 格式 {"RequestId":"885E117D-06A...
8.XX.XX.15 ReceiveBytes long 指 VPN 网关通过 SSL-VPN 连接从客户端接收的流量。单位：Byte。60782 Port string 客户端与阿里云建立 SSL-VPN 连接时，客户端实际使用的端口号。4*示例 正常返回示例 JSON 格式 {"RequestId":"885E117D-06A...
E2E跟踪诊断 请求从客户端应用进程发起，通过网络环境，进入OSS服务端被处理，然后响应从服务端回到网络环境，被客户端接收。整个过程，是一个端到端的跟踪过程。关联客户端应用程序日志、网络跟踪日志和服务端日志，有助于排查问题的详细...
所有配置完成，设备上报订阅数据并被AMQP客户端接收后，您可以登录 物联网平台控制台，进入对应实例查看消息运行日志。在 监控运维 日志服务 云端运行日志 页签，查看设备上报数据、物联网平台转发数据到AMQP客户端和AMQP客户端返回ACK的...
客户端接收消息显示Topic mqttRealTopic 业务上希望客户端收到消息时显示的子级字符串 云消息队列 RocketMQ 版 发给 云消息队列 MQTT 版 客户端消息时如果希望客户端收到消息后显示成指定的子级Topic名称，则可以设置；一般用于P2P消息，若...
public class MQTTClientStatusNoticeProcessDemo { public static void main(String[]args){/*初始化消息队列RocketMQ版接收客户端，实际业务中一般部署在服务端应用中。Properties properties=new Properties();设置RocketMQ客户端的...
dt SDK客户端接收到数据的当前时间戳，单位为毫秒。DefaultUserRecordQueue 序列化后，当前数据缓存队列的大小。保存和查询消费位点 当SDK客户端首次启动、重启或者发生内部重试时，您需要查询并传入消费位点，开始或重新消费数据。下文将...
public class MQTTClientStatusNoticeProcessDemo { public static void main(String[]args){/*初始化消息队列RocketMQ版接收客户端，实际业务中一般部署在服务端应用中。Properties properties=new Properties();设置RocketMQ客户端的...
准备开发环境 本文使用Java开发环境如下：操作系统：Windows 10 64位 JDK版本：JDK8 集成开发环境：IntelliJ IDEA社区版 业务服务器接收设备数据 服务器通过AMQP客户端接收消息，需配置AMQP客户端接入物联网平台，监听设备消息，请参见 ...
dt SDK客户端接收到数据的当前时间戳，单位为毫秒。DefaultUserRecordQueue 序列化后，当前数据缓存队列的大小。管理消费位点 当SDK客户端首次启动、重启或者发生内部重试时，您需要查询并传入 消费位点，开始或重新消费数据。下文将介绍在...
AMQP客户端接收到消息的时间顺序不一定是消息的产生时间顺序 AMQP客户端接收不到实时消息，为什么？如果AMQP客户端不在线，可以设置消息不转发到AMQP吗？相关API API 描述 CreateSubscribeRelation 创建服务端订阅为指定产品关联消费组以及...
执行阶段：客户端接收到通知后拉取数据进行处理，处理完后继续拉取新的数据，直到数据都处理完成。拓扑任务 一种特殊的任务，由许多通过事件触发的任务组成的集合。任务拓扑本身可以通过 CRON 表达式或者事件触发，但其包含的子任务必须是...
所有配置完成，设备上报订阅数据并被AMQP客户端接收后，您可以登录 物联网平台控制台，进入对应实例查看消息运行日志。在 监控运维 日志服务 云端运行日志 页签，查看设备上报数据、物联网平台转发数据到AMQP客户端和AMQP客户端返回ACK的...
取值说明如下：accepted：服务端接收客户端发起的连接请求。not authorized：客户端访问的实例权限校验失败导致 TCP 连接断开。clientId conflict：客户端标识冲突导致 TCP 连接断开。resource auth failed：客户端访问的 Topic 或 Group ...
使用 SOFARPC Bolt 协议的回调方式时，需要先实现这个接口，该接口提供以下三个方法：onAppResponse：当客户端接收到服务端的正常返回的时候，SOFARPC 会回调这个方法。onAppException：当客户端接收到服务端的异常响应的时候，SOFARPC 会...
物联网平台服务端订阅功能支持通过RAM角色授权RAM用户操作，本文档介绍如何通过RAM角色授权RAM用户接收物联网平台配置的...开发AMQP客户端接收服务端订阅消息：RAM用户开发AMQP客户端接入物联网平台，接收物联网平台下服务端订阅的设备消息。
本文介绍 旧版 公共实例下产品和设备迁移到企业版实例后，各功能使用说明。背景信息 实例迁移的详细说明，请参见 使用前必读。物联网平台产品功能的详细说明，请参见 功能特性。...保证两个实例同时存在AMQP客户端接收数据，防止数据丢失。
result.put("message","客户端接收到参数："+param1+","+param2+"返回 Demo 当前包名："+apiContext.getActivity().getPackageName());将结果返回给小程序 callback.sendJSONResponse(result);} } 客户端注册自定义 API。容器初始化完成后...
clientIp 调用者客户端IP exception 后端返回的具体错信息 exchangeTimestamp 整个请求链路的IO时间点 FrontRequestStart：API网关开始接收到客户端请求的时间点 FrontRequestEnd：API网关完成接收客户端请求的时间点 BackendRequestStart...