(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211284800.1 (22)申请日 2022.10.20 (71)申请人 安徽华速 达电子科技有限公司 地址 230088 安徽省合肥市高新区习友路 3333号中 国(合肥)国际智能语音产业 园研发中心 楼510室 申请人 国网安徽省电力有限公司宿州供电 公司 (72)发明人 苗晶晶　谢民　王韬　刘杰　 张功营　傅林　张见　刘波　 赵晓东　王宜福　张浩　徐艳红　 魏小梅　曹伟　白春光　李巍　 (74)专利代理 机构 合肥维可专利代理事务所 (普通合伙) 3413 5 专利代理师 吴明华(51)Int.Cl. H02J 13/00(2006.01) G06F 9/48(2006.01) (54)发明名称 一种基于MQTT通讯方式电力负荷监测方法 及系统 (57)摘要 本发明涉及电数字数据处理领域， 具体涉及 一种基于MQTT通讯方式电力负荷监测方法及系 统。 该方法包括接收来自需求侧监测端采集的用 电数据消息； 将需求侧监测端的用电数据消息以 MQTT通讯方式全部存储于服务器； 根据存储传输 的电压数据和电流数据计算每一需求侧监测端 的实时电力负荷， 生成每一需求侧监测端的电力 负荷曲线以及同一变电站监测区域的总电力负 荷曲线， 得到监测区域的总需求侧电力负荷监测 结果。 本发 明基于服务器对需求侧监测端的用电 数据消息进行存储， 计算获得总需求侧电力负荷 监测结果。 适用于对多需求侧监测端的用电数据 消息同步处理， 避免因开启大量的线程或者进程 会消耗很大的内存， 提升对数据处理的整体性 能。 权利要求书2页 说明书10页 附图6页 CN 115378142 A 2022.11.22 CN 115378142 A 1.一种基于MQTT通讯方式电力负荷监测方法， 其特征在于， 应用于与至少一个需求侧 监测端连接的服 务器， 所述方法包括以下步骤： 接收来自所述需求侧监测端采集的用电数据消息， 其中， 所述用电数据消息包括需求 侧监测端的电力传输导线上的电压数据和电流数据； 将所述需求侧监测端的用电数据消息以MQT T通讯方式全部存 储于所述 服务器； 根据存储传输的所述电压数据和电流数据计算每一需求侧监测端的实时电力负荷， 生 成每一需求侧监测端的电力负荷曲线以及同一变电站监测区域的总电力负荷曲线， 得到监 测区域的总需求侧电力负荷监测结果。 2.如权利要求1所述的基于MQTT通讯方式电力负荷监测方法， 其特征在于， 将所述需求 侧监测端的用电数据消息以MQT T通讯方式全部存 储于所述 服务器， 包括： 接收来自需求侧监测端采集的用电数据消息， 并将用电数据消息写入到所述服务器的 待办数据任务库中； 读取所述待办数据任务库中已写入的用电数据消息， 将读取的用电数据消息采用不同 的任务队列的方式进行分级后分发至不同的进程池 对应的缓存 池中； 设置固定进程数量的进程池分级处理所述缓存池中对应的用电数据消息； 将进程池分 级处理的用电数据消息以字符串形式写入数据库。 3.如权利要求2所述的基于MQTT通讯方式电力负荷监测方法， 其特征在于， 将读取的用 电数据消息采用不同的任务队列的方式进 行分级后分发至不同的进程池对应的缓存池中， 包括： 设置固定进程数量的进程池分级处 理用电数据消息； 将分级处 理后的任务队列全部存 储于缓存 池中； 将队列排队中不同的任务队列进行优先级划分， 得到不同的优先级的任务队列， 以在 进程池有可用进程时， 按照优先级选择任务队列执 行进程。 4.如权利要求3所述的基于MQTT通讯方式电力负荷监测方法， 其特征在于， 所述基于 MQTT通讯方式电力负荷监测方法， 还 包括： 在服务器宕机时， 保存并记录未处 理的用电数据消息； 在服务器启动 时， 获取存入缓存池中未处理的用电数据消息， 根据分级后所述用电数 据消息的优先级别排序进 行最高级别的未 处理所述用电数据消息获取， 继续执行最高级别 的未处理所述用电数据消息的任务队列进程。 5.如权利要求1所述的基于MQTT通讯方式电力负荷监测方法， 其特征在于， 将所述需求 侧监测端的用电数据消息以MQT T通讯方式全部存 储于所述 服务器， 还包括： 将所述服务器中用电数据消息运维管理进程反馈 至对应的需求侧监测端； 通过与所述需求侧监测端绑定的用户设备展示已发送的用电数据消息对应的处理进 程； 将用户指定设备与所述 服务器绑定， 并向用户指定设备推送通知 及提醒消息 。 6.一种基于MQTT通讯方式电力负荷监测系统， 其特征在于， 包括一个服务器及与所述 服务器连接的至少一个需求侧监测端； 所述 服务器包括： 消息处理模块， 用于接收来自需求侧监测端采集的用电数据消息， 并将用电数据消息 写入到所述 服务器的待办数据任务库中；权　利　要　求　书 1/2 页 2 CN 115378142 A 2任务分发模块， 用于读取所述待办数据任务库中已写入的用电数据消息， 将读取的用 电数据消息采用不同的任务队列的方式进行分级后分发至不同的进程池 对应的缓存 池中； 进程管理模块， 用于设置 固定进程数量的进程池分级处理所述缓存池中对应的用电数 据消息； 消息写入 模块， 用于将进程池分级处 理的用电数据消息以字符串形式写入数据库。 7.如权利要求6所述的基于MQTT通讯方式电力负荷监测系统， 其特征在于， 所述服务器 还包括： 进程反馈模块， 用于将所述服务器中用电数据消息运维管理进程反馈至对应的需求侧 监测端； 进程显示模块， 用于通过与 所述需求侧监测端绑定的用户设备展示已发送的用电数据 消息对应的处 理进程； 设备绑定模块， 用于将用户指定设备与所述服务器绑定， 并向用户指定设备推送通知 及提醒消息； 其中， 用户指定设备为电脑需求侧监测端、 手机需求侧监测端、 手机或邮箱收 发终端， 用于 接收所述 服务器推送的用电数据消息的处 理进程的通知 及待办提醒消息 。 8.如权利要求6所述的基于MQTT通讯方式电力负荷监测系统， 其特征在于， 所述消息处 理模块还用于基于TCP /IP协议远程接收需求侧监测端发布的订阅型消息， 以消息队列遥测 传输方式将用电数据消息写入到待办数据任务库中。 9.如权利要求8所述的基于MQTT通讯方式电力负荷监测系统， 其特征在于， 所述进程管 理模块， 包括： 进程池设置模块， 用于设置固定进程数量的进程池分级处 理用电数据消息； 队列储存模块， 用于将分级处 理后的任务队列全部存 储于缓存 池中； 优先级划分模块， 用于将队列排队中不同的任务队列进行优先级划分， 得到不同的优 先级的任务队列， 以在进程池有可用进程时， 按照优先级选择任务队列执 行进程。 10.如权利要求9所述的基于MQTT通讯方式电力负荷监测系统， 其特征在于， 所述进程 管理模块还 包括： 宕机管理模块， 用于在服务器宕机时， 保存并记录未处理的用电数据消息， 还用于在服 务器启动时， 获取存入缓存池中未处理的用电数据消息， 根据分级后所述用电数据消息的 优先级别排序进 行最高级别的未处理所述用电数据消息获取， 继续执行最高级别的未 处理 所述用电数据消息的任务队列进程。权　利　要　求　书 2/2 页 3 CN 115378142 A 3