EdgeServer上传MQTT数据处理流程
2021-07-14 18:11:41 0 举报关于上传mqtt服务器流程
作者其他创作
大纲/内容
1.获取ini配置2.topic3.线程数量
收到返回消息根据cmd_type判断消息返回类型
监听topic(neware_data)
cmd_type:0:请求接续消息1.数据写入成功
发送消息topic（ID_%(Edge唯一标识符)）到topic（neware_get）
是
对应ID数据设置is_finish=1
检测数据是否合法
1.获取ini配置2.topic
init
根据线程数量创建监听线程
等待消息返回收到返回消息根据cmd_type判断消息返回类型
写入数据库
根据收到的cmd_type == 0获取数据接续数据
初始化数据发送线程
监听topic（ID_%(Edge唯一标识符)）
监听topic（neware_get）
EdgeServer
获取is_finish=0的数据
监听到数据根据cmd_type调相应功能函数
本地DB
云DB
注册对应合法客户端
MQTTServer
初始化数据监听线程
MQTT
创建数据接收主题线程
0 条评论
下一页
