EdgeServer上传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

创建数据接收主题线程