Kylin V3.2开发板+OneNET MQ消息队列+Java传输数据

时间:2024-04-10 21:45:19

Kylin V3.2开发板

移植mqtt type3 温湿度例程

OneNET MQ消息队列

MQ消息队列文档

消息队列MQ定位为OneNET设备接入服务使用的,用于实现应用层快速、即时、可靠地获取设备消息的物联网服务组件,服务模型如下:
Kylin V3.2开发板+OneNET MQ消息队列+Java传输数据
其中:
topic为队列实体,一个MQ服务中可以创建多个队列实体
sub(订阅 subscription)为实际消费代理,消费代理将数据消费后发送给client,一个队列可以支持多个消费代理,消费代理之间相互独立,可分别采用不同的模式消费队列中的数据

步骤

1、创建服务
Kylin V3.2开发板+OneNET MQ消息队列+Java传输数据
2、创建topic
Kylin V3.2开发板+OneNET MQ消息队列+Java传输数据
3、添加订阅
Kylin V3.2开发板+OneNET MQ消息队列+Java传输数据
4、创建规则引擎并关联MQ
Kylin V3.2开发板+OneNET MQ消息队列+Java传输数据

JAVA

请按照如下说明,根据在平台创建的资源参数,修改 MqClient.java 中的 MqClient 类

demo中30 - 32行:

String userName = “您的MQ实例名称”;
String mqTopic = “您创建的topic名称”;
String mqSub = “您创建的订阅名称”;
64 - 66行:

String userName = “您的MQ实例名称”;
String accessKey = “您的MQ access_key”;
String expirationTime = “您自定义的鉴权参数过期时间”;
运行后打印接收信息:Kylin V3.2开发板+OneNET MQ消息队列+Java传输数据

测试时延

硬件连接串口:

Kylin V3.2开发板+OneNET MQ消息队列+Java传输数据
固件中:每次上传数据都向串口打印一条语句,打开串口调试可见:
Kylin V3.2开发板+OneNET MQ消息队列+Java传输数据

问题:

串口打印字段的时间戳比java服务器端接收到onenet传来的数据的时间戳还要晚??
猜想问题出在串口传输数据的时间,可能在xxx ms级。
(未完待续)