AMQP客户端接收不到实时消息,为什么?

问题描述 AMQP服务端订阅完成后,消费组对应在线AMQP客户端没有接收到消息。可能原因 当前设备通信的消息类型,不在AMQP服务端订阅的消息类型内。实时消息推送限流了,超过限流的消息不能实时消费,物联网平台会重试推送。AMQP客户端的一个...

AMQP客户端发布消息,设备为什么接收不到?

AMQP客户端仅支持接收已订阅的设备消息,不支持下发指令给设备。如果您需下发指令给设备,可在业务服务器侧集成物联网平台云端SDK,调用云端API发送消费给设备。具体内容,请参见 云端开发指南。相关文档 什么是服务端订阅:了解AMQP服务端...

Java SDK接入示例

开发AMQP客户端接收服务端订阅的设备消息,请参见 通过RAM角色授权的RAM用户接收服务端订阅消息。本账号接收服务端订阅消息 下载Demo代码包,并解压。打开IntelliJ IDEA,导入Demo包中的示例工程 amqp-demo。在 pom.xml 文件中,已添加...

消息撤回

客户端接收到消息撤回的指令后,会将通知栏中展示的消息删除,同时显示“消息已撤回”。小米 是 覆盖消息。客户端接收到消息撤回的指令后,会将通知栏中展示的消息删除,同时显示“消息已撤回”。OPPO 是 覆盖消息。客户端接收到消息撤回的...

AMQP服务端订阅后收到的数据条数不全,为什么?

如果多个AMQP客户端同时消费一个消费组,设备消息会随机推送到任意一个客户端,即单独的某个客户端接收到的消息是不全的。相关文档 什么是服务端订阅:了解AMQP服务端订阅应用场景和使用优势。配置AMQP服务端订阅:了解如何配置推送到AMQP...

客户端诊断介绍

原理框架 控制台根据不同的诊断通道(消息推送或移动同步)下发日志诊断指令,客户端接收到诊断指令后,将诊断日志上报到日志网关,当诊断文件上报成功后,在控制台可以下载诊断文件。基本框架如下所示:接入和使用 Android 端的接入及使用...

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

不可以。如果AMQP客户端不在线,AMQP服务端订阅消息会堆积,AMQP客户端重新上线后,物联网平台重新推送消息。如果不需要消费AMQP客户端不...相关文档 AMQP客户端接入说明:了解AMQP客户端接收设备消息的消息策略、消息时序以及消息回执说明。

查看SSL客户端的连接信息

接收流量 VPN网关通过SSL-VPN连接从客户端接收的流量。单位:Byte。发送流量 VPN网关通过SSL-VPN连接向客户端发送的流量。单位:Byte。状态 客户端与阿里云之间SSL-VPN连接的状态。仅取值:运行中,表示客户端和阿里云已成功建立SSL-VPN...

物联网平台通过消息组转发消息为什么存在延迟?

物联网平台推送到消费端(AMQP客户端)的消息不保序,即AMQP客户端接收到消息的时间顺序不一定是消息实际产生的时间顺序。您可根据以下方法,对消费端接收消息进行排序。设备上下线消息:收到消息的顺序不是实际设备上下线时间排序。设备...

FTP客户端使用说明

发送命令 传送数据时,客户端会在命令链路上向服务器发送PORT命令,命令中包含了客户端接收数据的端口。传送数据时,客户端会在命令链路上向服务器发送PASV命令。服务器收到命令后,随机开启一个端口并向客户端发送端口信息。传送数据 ...

服务端开发

准备开发环境 本文使用Java开发环境如下:操作系统:Windows 10 64位 JDK版本:JDK8 集成开发环境:IntelliJ IDEA社区版 业务服务器接收设备数据 服务器通过AMQP客户端接收消息,需配置AMQP客户端接入物联网平台,监听设备消息,请参见 ...

设备轨迹查询

动作说明 accepted:服务端接收客户端发起的连接请求。not authorized:客户端访问的实例权限校验失败导致TCP连接断开。clientId conflict:客户端标识冲突导致TCP连接断开。topic auth failed:客户端访问的Topic资源权限校验失败导致TCP...

AMQP客户端接入说明

AMQP客户端认证过程、认证参数配置和消息处理逻辑,请参见本文的 连接认证过程、连接配置说明 和 客户端接收消息逻辑。Java SDK接入示例.NET SDK接入示例 Node.js SDK接入示例 Python 2.7 SDK接入示例 Python3 SDK接入示例 PHP SDK接入示例...

轨迹查询

说明 accepted:服务端接收客户端发起的连接请求。not authorized:客户端访问的实例权限校验失败导致TCP连接断开。clientId conflict:客户端标识冲突导致TCP连接断开。topic auth failed:客户端访问的Topic资源权限校验失败导致TCP连接...

修改响应头

自定义响应行为:添加或修改自定义头部信息,可以根据业务需求调整客户端接收到的响应内容和格式,实现特定的功能或跟踪目的。注意事项 在添加了多条配置的情况下,配置的执行顺序是按配置列表从上到下的顺序逐条执行,响应头名称相同的...

任务类型

(Chunk:一批待处理数据分片集合)执行阶段:客户端接收到通知后拉取数据进行处理,处理完后继续拉取新的数据,直到数据都处理完成。拓扑任务 任务拓扑 是一种特殊的任务,是由许多通过事件触发的任务的集合。任务拓扑本身可以通过 CRON ...

服务端订阅设备消息

本文为您介绍通过配置AMQP服务端订阅,实现企业服务器通过接入AMQP客户端接收路灯设备数据的完整流程。前提条件 已接入设备和上报数据。具体操作,请参见 设备接入和上报数据。准备开发环境 本文AMQP客户端示例使用Java开发语言,推荐...

日志字段详情

clientIp 调用者客户端IP exception 后端返回的具体错信息 exchangeTimestamp 整个请求链路的IO时间点 FrontRequestStart:API网关开始接收到客户端请求的时间点 FrontRequestEnd:API网关完成接收客户端请求的时间点 BackendRequestStart...

DescribeSslVpnClients-查询SSL-VPN连接的客户端的...

8.XX.XX.15 ReceiveBytes long 指 VPN 网关通过 SSL-VPN 连接从客户端接收的流量。单位:Byte。60782 Port string 客户端与阿里云建立 SSL-VPN 连接时,客户端实际使用的端口号。4*示例 正常返回示例 JSON 格式 {"RequestId":"885E117D-06A...

DescribeSslVpnClients-查询SSL-VPN连接的客户端的...

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客户端和AMQP客户端返回ACK的...

MQTT客户端上下线事件数据流出

public class MQTTClientStatusNoticeProcessDemo { public static void main(String[]args){/*初始化消息队列RocketMQ版接收客户端,实际业务中一般部署在服务端应用中。Properties properties=new Properties();设置RocketMQ客户端的...

配置AMQP服务端订阅

AMQP客户端接收到消息的时间顺序不一定是消息的产生时间顺序 AMQP客户端接收不到实时消息,为什么?如果AMQP客户端不在线,可以设置消息不转发到AMQP吗?相关API API 描述 CreateSubscribeRelation 创建服务端订阅为指定产品关联消费组以及...

获取MQTT客户端在线状态

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客户端接入物联网平台,监听设备消息,请参见 ...

功能特性

执行阶段:客户端接收到通知后拉取数据进行处理,处理完后继续拉取新的数据,直到数据都处理完成。拓扑任务 一种特殊的任务,由许多通过事件触发的任务组成的集合。任务拓扑本身可以通过 CRON 表达式或者事件触发,但其包含的子任务必须是...

使用SDK示例代码消费订阅数据

dt SDK客户端接收到数据的当前时间戳,单位为毫秒。DefaultUserRecordQueue 序列化后,当前数据缓存队列的大小。保存和查询消费位点 当SDK客户端首次启动、重启或者发生内部重试时,您需要查询并传入 消费位点,开始或重新消费数据。下文将...

使用SDK示例代码消费订阅数据

dt SDK客户端接收到数据的当前时间戳,单位为毫秒。DefaultUserRecordQueue 序列化后,当前数据缓存队列的大小。管理消费位点 当SDK客户端首次启动、重启或者发生内部重试时,您需要查询并传入 消费位点,开始或重新消费数据。下文将介绍在...

数据转发到AMQP服务端订阅消费组消费

所有配置完成,设备上报订阅数据并被AMQP客户端接收后,您可以登录 物联网平台控制台,进入对应实例查看消息运行日志。在 监控运维>日志服务>云端运行日志 页签,查看设备上报数据、物联网平台转发数据到AMQP客户端和AMQP客户端返回ACK的...

服务网格工作原理

为了便于理解,本文将 MOSN 的流程简化为 12 个步骤,如下图所示:MOSN 在启动期间,会暴露本地 egress 端口接收客户端 App 的 RPC 请求。MOSN 会开启 2 个协程,分别死循环去对 TCP 进行读和写处理。MOSN 会通过读协程获取到请求字节流,...

QueryMqttTraceDevice-查询设备轨迹

取值说明如下:accepted:服务端接收客户端发起的连接请求。not authorized:客户端访问的实例权限校验失败导致 TCP 连接断开。clientId conflict:客户端标识冲突导致 TCP 连接断开。resource auth failed:客户端访问的 Topic 或 Group ...

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

物联网平台服务端订阅功能支持通过RAM角色授权RAM用户操作,本文档介绍如何通过RAM角色授权RAM用户接收物联网平台配置的...开发AMQP客户端接收服务端订阅消息:RAM用户开发AMQP客户端接入物联网平台,接收物联网平台下服务端订阅的设备消息。

Bolt 协议的调用方式

使用 SOFARPC Bolt 协议的回调方式时,需要先实现这个接口,该接口提供以下三个方法:onAppResponse:当客户端接收到服务端的正常返回的时候,SOFARPC 会回调这个方法。onAppException:当客户端接收到服务端的异常响应的时候,SOFARPC 会...

迁移后功能使用说明

本文介绍 旧版 公共实例下产品和设备迁移到企业版实例后,各功能使用说明。背景信息 实例迁移的详细说明,请参见 使用前必读。物联网平台产品功能的详细说明,请参见 功能特性。...保证两个实例同时存在AMQP客户端接收数据,防止数据丢失。

自定义 API

result.put("message","客户端接收到参数:"+param1+","+param2+"返回 Demo 当前包名:"+apiContext.getActivity().getPackageName());将结果返回给小程序 callback.sendJSONResponse(result);} } 客户端注册自定义 API。容器初始化完成后...

通过日志服务查看API调用日志

clientIp 调用者客户端IP exception 后端返回的具体错信息 exchangeTimestamp 整个请求链路的IO时间点 FrontRequestStart:API网关开始接收到客户端请求的时间点 FrontRequestEnd:API网关完成接收客户端请求的时间点 BackendRequestStart...

SSH服务的相关介绍

客户端对服务端公钥信息进行比对和确认,客户端接收到服务端公钥信息后,会进行如下比对,并让用户对相关信息进行确认。如果是首次连接服务端,客户端会收到类似如下信息,让用户确认公钥指纹的有效性。说明:公钥指纹:由于公钥一般较长...

配置节点HTTP响应头

自定义响应行为:添加或修改自定义头部信息,可以根据业务需求调整客户端接收到的响应内容和格式,实现特定的功能或跟踪目的。注意事项 在添加了多条配置的情况下,配置的执行顺序是按配置列表从上到下的顺序逐条执行,因此需要注意对名称...

客户端加密

客户端接收到KMS返回的数据明文密钥以及数据密文密钥后,将使用数据明文密钥对Object进行本地加密,并且将加密后的Object以及数据密文密钥上传至OSS。下载并解密Object 下载Object。客户端从OSS服务端下载加密的Object以及作为Object元数据...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
短信服务 检索分析服务 Elasticsearch版 钉钉会议 云存储网关 弹性公网IP 人工智能平台 PAI
新人特惠 爆款特惠 最新活动 免费试用