基于能源管理平台的数据传输系统及方法转让专利

申请号 : CN202210873957.1

文献号 : CN115086380B

文献日 :

基本信息:

PDF:

法律信息:

相似专利:

发明人 : 李明陈洪鑫刘艳清王伟兵郭春杰王中明

申请人 : 苏州思萃工业互联网技术研究所有限公司

摘要 :

本发明公开了基于能源管理平台的数据传输系统及方法,属于能源管理技术领域,本发明要解决的技术问题为能源设备存在的资源有限、网络质量不佳,采用的技术方案为:该系统包括能源路由器模块、MQTT服务器模块、数据接收模块和数据处理模块;能源路由器模块用于向下连接各种能源设备,并提供数据采集功能;还用于部署MQTT客户端,并将采集的数据通过MQTT客户端发布到MQTT服务器模块;MQTT服务器模块用于接收来自MQTT客户端的网络连接,并处理MQTT客户端的消息订阅和消息发布请求,同时把MQTT客户端发布的消息转发给消息订阅客户端;数据接收模块用于作为MQTT服务器模块的订阅客户端,订阅能源路由器模块中的MQTT客户端发布的消息。

权利要求 :

1.一种基于能源管理平台的数据传输系统,其特征在于,该系统包括能源路由器模块、MQTT服务器模块、数据接收模块和数据处理模块;

能源路由器模块用于向下连接各种能源设备,并提供数据采集功能;还用于部署MQTT客户端,并将采集的数据通过MQTT客户端发布到MQTT服务器模块;能源路由器模块的工作过程具体如下:(1)、能源路由器模块采用唯一标识SN码作为唯一网关注册到能源管理平台;

(2)、能源路由器模块获取能源管理平台发送的Token作为后续操作的连接令牌;

(3)、将连接到能源路由器模块的各种能源设备作为采集点设备注册到能源管理平台;

其中,能源设备包括储能设备、用电设备、光伏设备、传感器及计量表;

(4)、设备注册时,数据接收模块判断能源设备是否携带能源路由器模块的SN码以及Token作为验证条件:①、若是,则能源设备注册成功,下一步跳转至步骤(5);

②、若否,则能源设备注册失败;

(5)、数据上传时,数据接收模块判断能源设备是否携带能源路由器模块的SN码以及Token作为验证条件:①、若是,则将能源设备采集到的能源数据上传到能源管理平台;

②、若否,则上传数据失败;

MQTT服务器模块用于接收来自MQTT客户端的网络连接,并处理MQTT客户端的消息订阅和消息发布请求,同时把MQTT客户端发布的消息转发给消息订阅客户端;

数据接收模块用于作为MQTT服务器模块的订阅客户端,订阅能源路由器模块中的MQTT客户端发布的消息;

数据处理模块用于针对数据接收模块接收到的数据做分类处理并存入能源管理平台的后端数据库,为能源管理平台的后台系统提供数据支撑。

2.根据权利要求1所述的基于能源管理平台的数据传输系统,其特征在于,所述数据接收模块的工作过程具体如下:(1)、数据接收模块接收到网关注册的消息后,数据接收模块解密SN码,并判断解密SN码是否成功:①、若解密SN码失败,则结束网关注册流程,能源路由器模块中MQTT客户端接收不到token信息;

②、若解密SN码成功,则执行步骤(2);

(2)、数据接收模块发布token主题,能源路由器模块中MQTT客户端接收到token信息,下一步执行步骤(3);

(3)、数据接收模块接收到设备注册的消息后,数据接收模块校验SN码,并判断校验SN码是否通过:①、若校验SN码通过,则执行步骤(4);

②、若校验SN码未通过,则结束设备注册流程,发布设备注册的返回结果主题,能源路由器模块中的MQTT客户端接收到设备注册失败的消息后,进行检查并重新注册;

(4)、数据接收模块接收到设备注册的消息且校验SN码通过后,数据接收模块校验token信息,并判断校验token信息是否成功;

①、若校验token信息失败,则结束设备注册流程,发布设备注册的返回结果主题,能源路由器模块中的MQTT客户端接收到设备注册失败的消息后,进行检查并重新注册;

②、若校验token信息成功,则把数据传给数据处理模块进行处理;

(5)、数据接收模块接收到数据上传的消息后,数据接收模块校验SN码,并判断校验SN码是否成功:①、若校验SN码失败,则结束上传数据流程;

②、若校验SN码通过,则执行步骤(6);

(6)、数据接收模块接收到数据上传的消息且校验SN码通过后,数据接收模块进行校验token信息,并判断校验token信息是否成功:①、若校验token信息成功,则把数据传给数据处理模块进行处理;

②、若校验token信息失败,则结束上传数据流程。

3.根据权利要求1或2所述的基于能源管理平台的数据传输系统,其特征在于,所述数据处理模块的工作过程具体如下:(1)、数据处理模块接收到网关注册数据,将网关数据做入库处理,并存储token信息,下一步执行步骤(2);

(2)、数据处理模块接收到设备注册数据,对设备信息进行分类处理,并根据不同的设备类型进行入库处理;并判断该设备信息是否已经注册:①、若该设备信息已存在,则进行更新操作,下一步执行步骤(3);

②、若该设备信息不存在,则进行插入操作,下一步执行步骤(3);

(3)、数据处理模块接收到数据上传数据,对上传的数据进行分类处理,根据不同的设备类型存储到不同的数据表里,为能源管理平台提供数据进行展示。

4.一种基于能源管理平台的数据传输方法,其特征在于,该方法是通过能源路由器模块中的MQTT客户端分别发布不同的主题,经过MQTT服务器模块发送给数据接收模块,数据接收模块根据不同的主题接收到不同的消息,初步做网关注册、设备注册和上传数据的分类,并发送给数据处理模块,数据处理模块根据不同的数据类型和设备类型做进一步的分类处理并入库;具体如下:S1、网关注册;具体如下:

S101、能源路由器模块中部署的MQTT客户端使用MQTT的账号连接MQTT服务器模块;其中,能源路由器模块采用唯一标识SN码作为唯一网关注册到能源管理平台;

S102、MQTT客户端发布网关注册的主题,消息体为网关唯一标识SN码;其中,SN码采用SM4国密算法,加密和解密使用相同的密钥;

S103、与步骤S102同时进行的操作为:MQTT客户端订阅网关注册token下发主题;

S104、数据接收模块使用MQTT账号连接MQTT服务器模块,订阅网关注册的主题,MQTT服务器模块将注册网关信息转发给数据接收模块;

S105、数据接收模块接收到网关注册信息后,数据接收模块解密SN码,并判断解密SN码是否成功:①、若解密SN码失败,则结束网关注册,能源路由器模块中MQTT客户端接收不到token信息;

②、若解密SN码成功,则执行步骤S106;

S106、数据处理模块发布网关注册token下发主题,能源路由器模块中MQTT客户端接收到token信息,并跳转至步骤S103;同时,数据处理模块将网关数据做入库处理,并存储token信息;

S2、设备注册;具体如下:

S201、网关注册成功后,能源路由器模块中部署的MQTT客户端进行设备注册,将连接到能源路由器模块上的储能设备、用电设备、光伏设备、传感器及计量表设备注册到能源管理平台;

S202、与步骤S201同时进行的操作为:MQTT客户端发布设备注册的主题,主题中包含网关唯一标识SN码;

S203、数据接收模块使用MQTT账号连接MQTT服务器模块,订阅设备注册的主题,MQTT服务器模块将注册设备信息转发给数据接收模块;

S204、数据接收模块接收到设备注册的消息后,数据接收模块校验SN码,并判断校验SN码是否通过:①、若校验SN码通过,则执行步骤S205;

②、若校验SN码未通过,则结束设备注册流程,发布设备注册返回结果主题,并执行步骤S202;

S205、设备注册的消息体中包含能源路由器接收到的token信息,数据接收模块校验token信息,并判断校验token信息是否成功:①、若校验token信息失败,则结束设备注册的流程,发布设备注册的返回结果主题,能源路由器模块中的MQTT客户端接收到设备注册失败的消息后,进行检查并重新注册,并执行步骤S202;

②、校验token成功,则执行步骤S206;

S206、数据处理模块接收到设备注册的消息后,对设备信息进行分类处理,并根据不同的设备类型进行入库处理,并判断该设备信息是否已存在:①、若是,则进行更新操作;

②、若否,则进行插入操作;

S3、上传数据;具体如下:

S301、设备注册流程结束后,能源路由器模块定时采集设备上传的数据信息,并通过MQTT客户端发布上传数据的主题,上传数据的主题中包含网关唯一标识SN码;

S302、数据接收模块使用MQTT账号连接MQTT服务器模块,订阅上传数据的主题,MQTT服务器模块将上传数据信息转发给数据接收模块;

S303、数据接收模块接收到上传数据的消息后,数据接收模块校验SN码,并判断校验SN码是否通过:①、若校验SN码通过,则执行步骤S304;

②、若校验SN码未通过,则结束上传数据流程;

S304、上传数据的消息体中包含能源路由器接收到的token信息,数据接收模块订阅到数据上传的消息后,数据接收模块校验token信息,并判断校验token信息是否成功:①、若校验token信息失败,则结束上传数据流程;

②、若校验token信息成功,则执行步骤S305;

S305、数据处理模块接收到数据上传的消息后,对上传的数据进行分类处理,根据不同的设备类型存储到不同的数据表里,为能源管理平台提供数据进行展示。

5.根据权利要求4所述的基于能源管理平台的数据传输方法,其特征在于,步骤S1中的网关注册和步骤S2中的设备注册均完成后,才能进行步骤S3中的上传数据;否则,数据上传会失败。

6.一种电子设备,其特征在于,包括:存储器和至少一个处理器;

其中,所述存储器上存储有计算机程序;

所述至少一个处理器执行所述存储器存储的计算机程序,使得所述至少一个处理器执行如权利要求4或5所述的基于能源管理平台的数据传输方法。

说明书 :

基于能源管理平台的数据传输系统及方法

技术领域

[0001] 本发明涉及能源管理技术领域,具体地说是一种基于能源管理平台的数据传输系统及方法。

背景技术

[0002] 新型数字能源平台成为业内焦点,利用大数据、物联网、云计算、AI等技术把生产企业的能源消耗使用过程数据进行监测记录,实时监控生产企业的各种能源使用情况,赋能企业节能减排,为企业实现低碳零碳智能化转型提供科学依据,提升企业的综合能源和碳资产管理能力。
[0003] 能源管理平台主要包含前端数据采集、数据传输、后台系统三个部分,数据传输作为连接前端数据采集和后台系统的桥梁,起着至关重要的作用,传统的数据传输对资源需求和网络延迟要求较高,同时能源管理平台中的设备往往分散在不同的工厂、车间等区域,可能存在网络延迟较高、质量不佳的网络环境。
[0004] 故能源设备存在的资源有限、网络质量不佳是目前亟待解决的技术问题。

发明内容

[0005] 本发明的技术任务是提供一种基于能源管理平台的数据传输系统及方法,来解决能源设备存在的资源有限、网络质量不佳的问题。
[0006] 本发明的技术任务是按以下方式实现的,一种基于能源管理平台的数据传输系统,该系统包括能源路由器模块、MQTT服务器模块、数据接收模块和数据处理模块;
[0007] 能源路由器模块用于向下连接各种能源设备,并提供数据采集功能;还用于部署MQTT客户端,并将采集的数据通过MQTT客户端发布到MQTT服务器模块;
[0008] MQTT服务器模块用于接收来自MQTT客户端的网络连接,并处理MQTT客户端的消息订阅和消息发布请求,同时把MQTT客户端发布的消息转发给消息订阅客户端(订阅客户端为MQTT客户端的功能之一);
[0009] 数据接收模块用于作为MQTT服务器模块的订阅客户端,订阅能源路由器模块中的MQTT客户端发布的消息;
[0010] 数据处理模块用于针对数据接收模块接收到的数据做分类处理并存入能源管理平台的后端数据库,为能源管理平台的后台系统提供数据支撑。
[0011] 作为优选,所述能源路由器模块的工作过程具体如下:
[0012] (1)、能源路由器模块采用唯一标识SN码作为唯一网关注册到能源管理平台;
[0013] (2)、能源路由器模块获取能源管理平台发送的Token作为后续操作的连接令牌;
[0014] (3)、将连接到能源路由器模块的各种能源设备作为采集点设备注册到能源管理平台;其中,能源设备包括储能设备、用电设备、光伏设备、传感器及计量表;
[0015] (4)、设备注册时,数据接收模块判断能源设备是否携带能源路由器模块的SN码以及Token作为验证条件:
[0016] ①、若是,则能源设备注册成功,下一步跳转至步骤(5);
[0017] ②、若否,则能源设备注册失败;
[0018] (5)、数据上传时,数据接收模块判断能源设备是否携带能源路由器模块的SN码以及Token作为验证条件:
[0019] ①、若是,则将能源设备采集到的能源数据上传到能源管理平台;
[0020] ②、若否,则上传数据失败。
[0021] 作为优选,所述数据接收模块的工作过程具体如下:
[0022] (1)、数据接收模块接收到网关注册的消息后,数据接收模块解密SN码,并判断解密SN码是否成功:
[0023] ①、若解密SN码失败,则结束网关注册流程,能源路由器模块中MQTT客户端接收不到token信息;
[0024] ②、若解密SN码成功,则执行步骤(2);
[0025] (2)、数据接收模块发布token主题,能源路由器模块中MQTT客户端接收到token信息,下一步执行步骤(3);
[0026] (3)、数据接收模块接收到设备注册的消息后,数据接收模块校验SN码,并判断校验SN码是否通过:
[0027] ①、若校验SN码通过,则执行步骤(4);
[0028] ②、若校验SN码未通过,则结束设备注册流程,发布设备注册的返回结果主题,能源路由器模块中的MQTT客户端接收到设备注册失败的消息后,进行检查并重新注册;
[0029] (4)、数据接收模块接收到设备注册的消息且校验SN码通过后,数据接收模块校验token信息,并判断校验token信息是否成功;
[0030] ①、若校验token信息失败,则结束设备注册流程,发布设备注册的返回结果主题,能源路由器模块中的MQTT客户端接收到设备注册失败的消息后,进行检查并重新注册;
[0031] ②、若校验token信息成功,则把数据传给数据处理模块进行处理;
[0032] (5)、数据接收模块接收到数据上传的消息后,数据接收模块校验SN码,并判断校验SN码是否成功:
[0033] ①、若校验SN码失败,则结束上传数据流程;
[0034] ②、若校验SN码通过,则执行步骤(6);
[0035] (6)、数据接收模块接收到数据上传的消息且校验SN码通过后,数据接收模块进行校验token信息,并判断校验token信息是否成功:
[0036] ①、若校验token信息成功,则把数据传给数据处理模块进行处理;
[0037] ②、若校验token信息失败,则结束上传数据流程。
[0038] 更优地,所述数据处理模块的工作过程具体如下:
[0039] (1)、数据处理模块接收到网关注册数据,将网关数据做入库处理,并存储token信息,下一步执行步骤(2);
[0040] (2)、数据处理模块接收到设备注册数据,对设备信息进行分类处理,并根据不同的设备类型进行入库处理;并判断该设备信息是否已经注册:
[0041] ①、若该设备信息已存在,则进行更新操作,下一步执行步骤(3);
[0042] ②、若该设备信息不存在,则进行插入操作,下一步执行步骤(3);
[0043] (3)、数据处理模块接收到数据上传数据,对上传的数据进行分类处理,根据不同的设备类型存储到不同的数据表里,为能源管理平台提供数据进行展示。
[0044] 一种基于能源管理平台的数据传输方法,该方法是通过能源路由器模块中的MQTT客户端分别发布不同的主题,经过MQTT服务器模块发送给数据接收模块,数据接收模块根据不同的主题接收到不同的消息,初步做网关注册、设备注册和上传数据的分类,并发送给数据处理模块,数据处理模块根据不同的数据类型和设备类型做进一步的分类处理并入库;具体如下:
[0045] S1、网关注册;
[0046] S2、设备注册;
[0047] S3、上传数据。
[0048] 作为优选,步骤S1中的网关注册和步骤S2中的设备注册均完成后,才能进行步骤S3中的上传数据;否则,数据上传会失败。
[0049] 作为优选,步骤S1中的网关注册具体如下:
[0050] S101、能源路由器模块中部署的MQTT客户端使用MQTT的账号连接MQTT服务器模块;
[0051] S102、MQTT客户端发布网关注册的主题,消息体为网关唯一标识SN码;其中,SN码采用SM4国密算法,加密和解密使用相同的密钥;
[0052] S103、与步骤S102同时进行的操作为:MQTT客户端订阅网关注册token下发主题;
[0053] S104、数据接收模块使用MQTT账号连接MQTT服务器模块,订阅网关注册的主题,MQTT服务器模块将注册网关信息转发给数据接收模块;
[0054] S105、数据接收模块接收到网关注册信息后,数据接收模块解密SN码,并判断解密SN码是否成功:
[0055] ①、若解密SN码失败,则结束网关注册,能源路由器模块中MQTT客户端接收不到token信息;
[0056] ②、若解密SN码成功,则执行步骤S106;
[0057] S106、数据处理模块发布网关注册token下发主题,能源路由器模块中MQTT客户端接收到token信息,并跳转至步骤S103;同时,数据处理模块将网关数据做入库处理,并存储token信息。
[0058] 作为优选,步骤2中的设备注册具体如下:
[0059] S201、网关注册成功后,能源路由器模块中部署的MQTT客户端进行设备注册,将连接到能源路由器模块上的储能设备、用电设备、光伏设备、传感器及计量表设备注册到能源管理平台;
[0060] S202、与步骤S201同时进行的操作为:MQTT客户端发布设备注册的主题,主题中包含网关唯一标识SN码;
[0061] S203、数据接收模块使用MQTT账号连接MQTT服务器模块,订阅设备注册的主题,MQTT服务器模块将注册设备信息转发给数据接收模块;
[0062] S204、数据接收模块接收到设备注册的消息后,数据接收模块校验SN码,并判断校验SN码是否通过:
[0063] ①、若校验SN码通过,则执行步骤S205;
[0064] ②、若校验SN码未通过,则结束设备注册流程,发布设备注册返回结果主题,并执行步骤S202;
[0065] S205、设备注册的消息体中包含能源路由器接收到的token信息,数据接收模块校验token信息,并判断校验token信息是否成功:
[0066] ①、若校验token信息失败,则结束设备注册的流程,发布设备注册的返回结果主题,能源路由器模块中的MQTT客户端接收到设备注册失败的消息后,进行检查并重新注册,并执行步骤S202;
[0067] ②、校验token成功,则执行步骤S206;
[0068] S206、数据处理模块接收到设备注册的消息后,对设备信息进行分类处理,并根据不同的设备类型进行入库处理,并判断该设备信息是否已存在:
[0069] ①、若是,则进行更新操作;
[0070] ②、若否,则进行插入操作。
[0071] 更优地,步骤S3中的上传数据具体如下:
[0072] S301、设备注册流程结束后,能源路由器模块定时采集设备上传的数据信息,并通过MQTT客户端发布上传数据的主题,上传数据的主题中包含网关唯一标识SN码;
[0073] S302、数据接收模块使用MQTT账号连接MQTT服务器模块,订阅上传数据的主题,MQTT服务器模块将上传数据信息转发给数据接收模块;
[0074] S303、数据接收模块接收到上传数据的消息后,数据接收模块校验SN码,并判断校验SN码是否通过:
[0075] ①、若校验SN码通过,则执行步骤S304;
[0076] ②、若校验SN码未通过,则结束上传数据流程;
[0077] S304、上传数据的消息体中包含能源路由器接收到的token信息,数据接收模块订阅到数据上传的消息后,数据接收模块校验token信息,并判断校验token信息是否成功:
[0078] ①、若校验token信息失败,则结束上传数据流程;
[0079] ②、若校验token信息成功,则执行步骤S305;
[0080] S305、数据处理模块接收到数据上传的消息后,对上传的数据进行分类处理,根据不同的设备类型存储到不同的数据表里,为能源管理平台提供数据进行展示。
[0081] 一种电子设备,包括:存储器和至少一个处理器;
[0082] 其中,所述存储器上存储有计算机程序;
[0083] 所述至少一个处理器执行所述存储器存储的计算机程序,使得所述至少一个处理器执行如上述的基于能源管理平台的数据传输方法。
[0084] 本发明的基于能源管理平台的数据传输系统及方法具有以下优点:
[0085] (一)本发明通过采用轻量级协议MQTT,将分散在不同的工厂、车间等区域,同时可能存在网络延迟较高、质量不佳的网络环境中的设备信息,实时可靠的传输到能源管理平台,同时通过SN码和token保证传输过程中的安全性;
[0086] (二)通过采用本发明的方法策略保障了能源管理平台数据传输的可靠稳定高效传输;
[0087] (三)本发明适用于硬件性能低下的物联网设备以及网络状况糟糕的环境下的数据传输,保证能源数据的稳定可靠传输。

附图说明

[0088] 下面结合附图对本发明进一步说明。
[0089] 附图1为基于能源管理平台的数据传输系统的结构框图;
[0090] 附图2为网关注册的流程框图;
[0091] 附图3为设备注册的流程框图;
[0092] 附图4为上传数据的流程框图。

具体实施方式

[0093] 参照说明书附图和具体实施例对本发明的基于能源管理平台的数据传输系统及方法作以下详细地说明。
[0094] 实施例1:
[0095] 如附图1所示,本实施例提供了一种基于能源管理平台的数据传输系统,该系统包括能源路由器模块、MQTT服务器模块、数据接收模块和数据处理模块;
[0096] 能源路由器模块用于向下连接各种能源设备,并提供数据采集功能;还用于部署MQTT客户端,并将采集的数据通过MQTT客户端发布到MQTT服务器模块;
[0097] MQTT服务器模块用于接收来自MQTT客户端的网络连接,并处理MQTT客户端的消息订阅和消息发布请求,同时把MQTT客户端发布的消息转发给消息订阅客户端(订阅客户端为MQTT客户端的功能之一);
[0098] 数据接收模块用于作为MQTT服务器模块的订阅客户端,订阅能源路由器模块中的MQTT客户端发布的消息;
[0099] 数据处理模块用于针对数据接收模块接收到的数据做分类处理并存入能源管理平台的后端数据库,为能源管理平台的后台系统提供数据支撑。
[0100] 本实施例中的能源路由器模块的工作过程具体如下:
[0101] (1)、能源路由器模块采用唯一标识SN码作为唯一网关注册到能源管理平台;
[0102] (2)、能源路由器模块获取能源管理平台发送的Token作为后续操作的连接令牌;
[0103] (3)、将连接到能源路由器模块的各种能源设备作为采集点设备注册到能源管理平台;其中,能源设备包括储能设备、用电设备、光伏设备、传感器及计量表;
[0104] (4)、设备注册时,数据接收模块判断能源设备是否携带能源路由器模块的SN码以及Token作为验证条件:
[0105] ①、若是,则能源设备注册成功,下一步跳转至步骤(5);
[0106] ②、若否,则能源设备注册失败;
[0107] (5)、数据上传时,数据接收模块判断能源设备是否携带能源路由器模块的SN码以及Token作为验证条件:
[0108] ①、若是,则将能源设备采集到的能源数据上传到能源管理平台;
[0109] ②、若否,则上传数据失败。
[0110] 本实施例中的数据接收模块的工作过程具体如下:
[0111] (1)、数据接收模块接收到网关注册的消息后,数据接收模块解密SN码,并判断解密SN码是否成功:
[0112] ①、若解密SN码失败,则结束网关注册流程,能源路由器模块中MQTT客户端接收不到token信息;
[0113] ②、若解密SN码成功,则执行步骤(2);
[0114] (2)、数据接收模块发布token主题,能源路由器模块中MQTT客户端接收到token信息,下一步执行步骤(3);
[0115] (3)、数据接收模块接收到设备注册的消息后,数据接收模块校验SN码,并判断校验SN码是否通过:
[0116] ①、若校验SN码通过,则执行步骤(4);
[0117] ②、若校验SN码未通过,则结束设备注册流程,发布设备注册的返回结果主题,能源路由器模块中的MQTT客户端接收到设备注册失败的消息后,进行检查并重新注册;
[0118] (4)、数据接收模块接收到设备注册的消息且校验SN码通过后,数据接收模块校验token信息,并判断校验token信息是否成功;
[0119] ①、若校验token信息失败,则结束设备注册流程,发布设备注册的返回结果主题,能源路由器模块中的MQTT客户端接收到设备注册失败的消息后,进行检查并重新注册;
[0120] ②、若校验token信息成功,则把数据传给数据处理模块进行处理;
[0121] (5)、数据接收模块接收到数据上传的消息后,数据接收模块校验SN码,并判断校验SN码是否成功:
[0122] ①、若校验SN码失败,则结束上传数据流程;
[0123] ②、若校验SN码通过,则执行步骤(6);
[0124] (6)、数据接收模块接收到数据上传的消息且校验SN码通过后,数据接收模块进行校验token信息,并判断校验token信息是否成功:
[0125] ①、若校验token信息成功,则把数据传给数据处理模块进行处理;
[0126] ②、若校验token信息失败,则结束上传数据流程。
[0127] 本实施例中的数据处理模块的工作过程具体如下:
[0128] (1)、数据处理模块接收到网关注册数据,将网关数据做入库处理,并存储token信息,下一步执行步骤(2);
[0129] (2)、数据处理模块接收到设备注册数据,对设备信息进行分类处理,并根据不同的设备类型进行入库处理;并判断该设备信息是否已经注册:
[0130] ①、若该设备信息已存在,则进行更新操作,下一步执行步骤(3);
[0131] ②、若该设备信息不存在,则进行插入操作,下一步执行步骤(3);
[0132] (3)、数据处理模块接收到数据上传数据,对上传的数据进行分类处理,根据不同的设备类型存储到不同的数据表里,为能源管理平台提供数据进行展示。
[0133] 实施例2:
[0134] 本实施例提供了一种基于能源管理平台的数据传输方法,该方法是通过能源路由器模块中的MQTT客户端分别发布不同的主题,经过MQTT服务器模块发送给数据接收模块,数据接收模块根据不同的主题接收到不同的消息,初步做网关注册、设备注册和上传数据的分类,并发送给数据处理模块,数据处理模块根据不同的数据类型和设备类型做进一步的分类处理并入库;具体如下:
[0135] S1、网关注册;
[0136] S2、设备注册;
[0137] S3、上传数据。
[0138] 本实施例步骤S1中的网关注册和步骤S2中的设备注册均完成后,才能进行步骤S3中的上传数据;否则,数据上传会失败。
[0139] 如附图2所示,本实施例步骤S1中的网关注册具体如下:
[0140] S101、能源路由器模块中部署的MQTT客户端使用MQTT的账号连接MQTT服务器模块;
[0141] S102、MQTT客户端发布网关注册的主题,消息体为网关唯一标识SN码;其中,SN码采用SM4国密算法,加密和解密使用相同的密钥;
[0142] S103、与步骤S102同时进行的操作为:MQTT客户端订阅网关注册token下发主题;
[0143] S104、数据接收模块使用MQTT账号连接MQTT服务器模块,订阅网关注册的主题,MQTT服务器模块将注册网关信息转发给数据接收模块;
[0144] S105、数据接收模块接收到网关注册信息后,数据接收模块解密SN码,并判断解密SN码是否成功:
[0145] ①、若解密SN码失败,则结束网关注册,能源路由器模块中MQTT客户端接收不到token信息;
[0146] ②、若解密SN码成功,则执行步骤S106;
[0147] S106、数据处理模块发布网关注册token下发主题,能源路由器模块中MQTT客户端接收到token信息,并跳转至步骤S103;同时,数据处理模块将网关数据做入库处理,并存储token信息。
[0148] 如附图3所示,本实施例步骤2中的设备注册具体如下:
[0149] S201、网关注册成功后,能源路由器模块中部署的MQTT客户端进行设备注册,将连接到能源路由器模块上的储能设备、用电设备、光伏设备、传感器及计量表设备注册到能源管理平台;
[0150] S202、与步骤S201同时进行的操作为:MQTT客户端发布设备注册的主题,主题中包含网关唯一标识SN码;
[0151] S203、数据接收模块使用MQTT账号连接MQTT服务器模块,订阅设备注册的主题,MQTT服务器模块将注册设备信息转发给数据接收模块;
[0152] S204、数据接收模块接收到设备注册的消息后,数据接收模块校验SN码,并判断校验SN码是否通过:
[0153] ①、若校验SN码通过,则执行步骤S205;
[0154] ②、若校验SN码未通过,则结束设备注册流程,发布设备注册返回结果主题,并执行步骤S202;
[0155] S205、设备注册的消息体中包含能源路由器接收到的token信息,数据接收模块校验token信息,并判断校验token信息是否成功:
[0156] ①、若校验token信息失败,则结束设备注册的流程,发布设备注册的返回结果主题,能源路由器模块中的MQTT客户端接收到设备注册失败的消息后,进行检查并重新注册,并执行步骤S202;
[0157] ②、校验token成功,则执行步骤S206;
[0158] S206、数据处理模块接收到设备注册的消息后,对设备信息进行分类处理,并根据不同的设备类型进行入库处理,并判断该设备信息是否已存在:
[0159] ①、若是,则进行更新操作;
[0160] ②、若否,则进行插入操作。
[0161] 如附图4所示,本实施例步骤S3中的上传数据具体如下:
[0162] S301、设备注册流程结束后,能源路由器模块定时采集设备上传的数据信息,并通过MQTT客户端发布上传数据的主题,上传数据的主题中包含网关唯一标识SN码;
[0163] S302、数据接收模块使用MQTT账号连接MQTT服务器模块,订阅上传数据的主题,MQTT服务器模块将上传数据信息转发给数据接收模块;
[0164] S303、数据接收模块接收到上传数据的消息后,数据接收模块校验SN码,并判断校验SN码是否通过:
[0165] ①、若校验SN码通过,则执行步骤S304;
[0166] ②、若校验SN码未通过,则结束上传数据流程;
[0167] S304、上传数据的消息体中包含能源路由器接收到的token信息,数据接收模块订阅到数据上传的消息后,数据接收模块校验token信息,并判断校验token信息是否成功:
[0168] ①、若校验token信息失败,则结束上传数据流程;
[0169] ②、若校验token信息成功,则执行步骤S305;
[0170] S305、数据处理模块接收到数据上传的消息后,对上传的数据进行分类处理,根据不同的设备类型存储到不同的数据表里,为能源管理平台提供数据进行展示。
[0171] 实施例3:
[0172] 本实施例还提供了一种电子设备,包括:存储器和处理器;
[0173] 其中,存储器存储计算机执行指令;
[0174] 处理器执行所述存储器存储的计算机执行指令,使得处理器执行本发明任一实施例中的基于能源管理平台的数据传输方法。
[0175] 处理器可以是中央处理单元(CPU),还可以是其他通用处理器、数字信号处理器(DSP)、专用集成电路(ASIC)、现成可编程门阵列(FPGA)或者其他可编程逻辑器件、分立门或者晶体管逻辑器件、分立硬件组件等。通过处理器可以是微处理器或者该处理器也可以是任何常规的处理器等。
[0176] 存储器可用于储存计算机程序和/或模块,处理器通过运行或执行存储在存储器内的计算机程序和/或模块,以及调用存储在存储器内的数据,实现电子设备的各种功能。存储器可主要包括存储程序区和存储数据区,其中,存储程序区可存储操作系统、至少一个功能所需的应用程序等;存储数据区可存储根据终端的使用所创建的数据等。此外,存储器还可以包括高速随机存取存储器,还可以包括非易失性存储器,例如硬盘、内存、插接式硬盘,只能存储卡(SMC),安全数字(SD)卡,闪存卡、至少一个磁盘存储期间、闪存器件、或其他易失性固态存储器件。
[0177] 最后应说明的是:以上各实施例仅用以说明本发明的技术方案,而非对其限制;尽管参照前述各实施例对本发明进行了详细的说明,本领域的普通技术人员应当理解:其依然可以对前述各实施例所记载的技术方案进行修改,或者对其中部分或者全部技术特征进行等同替换;而这些修改或者替换,并不使相应技术方案的本质脱离本发明各实施例技术方案的范围。