CN117201601A - 物联网设备接入方法、装置、设备及存储介质 - Google Patents

Abstract

本发明涉及数据处理技术领域，公开了一种物联网设备接入方法、装置、设备及存储介质，该方法包括：构建数据转换层，数据转换层包括至少一个数据解析协议包；连接物联网设备；检测是否接收到基于私有协议的上行数据报文，同时检测是否基于MQTT协议的下行数据报文；如果接收到基于私有协议的上行数据报文，就解析基于私有协议的上行数据报文的业务事件，将写入业务事件的基于MQTT协议的上行数据报文发送给物联网平台；如果接收到基于MQTT协议的下行数据报文，就对基于MQTT协议的下行数据报文的功能控制信息进行编码，生成功能控制指令，将写入功能控制指令的基于私有协议的下行数据报文发送给物联网设备。本发明有利于提高物联网设备接入物联网平台的效率。

Description

物联网设备接入方法、装置、设备及存储介质

技术领域

本发明涉及数据处理技术领域，尤其涉及一种物联网设备接入方法、装置、设备及存储介质。

背景技术

MQTT(Message Queuing Telemetry Transport，消息队列遥测传输)是一个即时通讯协议，在万物互联的时代，越来越多的物联网平台出现，MQTT已经成为物联网平台的标准协议。

然而，现有平台网关无法实现私有协议和MQTT协议的数据转换，不利于提高物联网设备接入物联网平台的效率。其原因在于，物联网设备为了安全性，会采用基于私有协议的数据报文，而物联网平台采用的是MQTT协议的数据报文，由于私有协议和MQTT协议不同，且物联网平台的平台网关无法将基于私有协议的数据报文转换成基于MQTT协议的数据报文，也无法将基于MQTT协议的数据报文转换成基于私有协议的数据报文，因此，现有平台网关无法实现私有协议和MQTT协议的数据转换，现有平台网关也无法将物联网设备直接接入物联网平台，因此，不利于提高物联网设备接入物联网平台的效率。

发明内容

为了对披露的实施例的一些方面有基本的理解，下面给出了简单的概括。所述概括不是泛泛评述，也不是要确定关键/重要组成元素或描绘这些实施例的保护范围，而是作为后面的详细说明的序言。

鉴于以上所述现有技术的缺点，本发明公开了一种物联网设备接入方法、装置、设备及存储介质，以克服现有平台网关无法实现私有协议和MQTT协议的数据转换，不利于提高物联网设备接入物联网平台的效率。

本发明提供了一种物联网设备接入方法，应用于平台网关，物联网设备接入方法包括：构建数据转换层，所述数据转换层包括至少一个数据解析协议包；获取物联网设备接入物联网平台的请求，根据所述请求连接所述物联网设备；检测是否接收到所述物联网设备向所述物联网平台发送的基于私有协议的上行数据报文，同时检测是否接收到所述物联网平台向所述物联网设备发送的基于MQTT协议的下行数据报文；如果接收到所述基于私有协议的上行数据报文，就采用所述数据解析协议包对应的解析接口，解析所述基于私有协议的上行数据报文的业务事件，将基于所述私有协议的上行数据报文转换成基于所述MQTT协议的上行数据报文，在基于所述MQTT协议的上行数据报文的事件位置写入所述业务事件，将写入所述业务事件的基于所述MQTT协议的上行数据报文发送给所述物联网平台，以指示所述物联网平台基于所述业务事件进行业务处理；如果接收到所述基于MQTT协议的下行数据报文，就采用所述数据解析协议包对应的编码接口，对所述基于MQTT协议的下行数据报文的功能控制信息进行编码，生成功能控制指令，将基于所述MQTT协议的下行数据报文转换成基于所述私有协议的下行数据报文，在基于所述私有协议的下行数据报文的指令位置写入所述功能控制指令，将写入所述功能控制指令的基于所述私有协议的下行数据报文发送给所述物联网设备，以指示所述物联网设备根据所述功能控制指令执行相应的功能控制操作。

可选地，所述构建数据转换层，所述数据转换层包括至少一个数据解析协议包，包括：

获取数据解析协议包；

对所述数据解析协议包进行测试；

测试成功后，构建所述数据转换层，所述数据转换层包括至少一个测试成功的所述数据解析协议包。

可选地，所述对所述数据解析协议包进行测试，包括：

获取测试模板，在所述测试模板上填入测试数据，通过所述测试模板对所述数据解析协议包进行测试，生成测试结果；

判断所述测试结果是否为预设结果；

如果所述测试结果为预设结果，就保存测试成功的所述数据解析协议包，如果所述测试结果不为预设结果，就调整所述数据解析协议包的参数。

可选地，所述获取数据解析协议包，包括：

获取所述数据解析协议包的数量，判断所述数量是否大于预设值；

如果所述数量大于所述预设值，就获取每个所述数据解析协议包的分数，按从高到低的顺序，对每个所述数据解析协议包的分数进行排名，获取排名第一的所述数据解析协议包。

可选地，所述检测是否接收到所述物联网设备向所述物联网平台发送的基于私有协议的上行数据报文，同时检测是否接收到所述物联网平台向所述物联网设备发送的基于MQTT协议的下行数据报文，包括：

建立所述平台网关与所述物联网设备之间的第一连接会话，建立所述平台网关与所述物联网平台之间的第二连接会话；

在所述第一连接会话中，检测是否接收到所述物联网设备向所述物联网平台发送的基于私有协议的上行数据报文，同时在所述第二连接会话中，检测是否接收到所述物联网平台向所述物联网设备发送的基于MQTT协议的下行数据报文。

可选地，所述如果接收到所述基于私有协议的上行数据报文，就采用所述数据解析协议包对应的解析接口，解析所述基于私有协议的上行数据报文的业务事件，将基于所述私有协议的上行数据报文转换成基于所述MQTT协议的上行数据报文，在基于所述MQTT协议的上行数据报文的事件位置写入所述业务事件，将写入所述业务事件的基于所述MQTT协议的上行数据报文发送给所述物联网平台，以指示所述物联网平台基于所述业务事件进行业务处理，包括：

如果接收到所述基于私有协议的上行数据报文，就获取所述数据解析协议包对应的私有协议列表，在所述私有协议列表中查询是否存在所述私有协议；

如果存在，就采用所述数据解析协议包对应的解析接口，解析所述基于私有协议的上行数据报文的业务事件，将基于所述私有协议的上行数据报文转换成基于所述MQTT协议的上行数据报文，在基于所述MQTT协议的上行数据报文的事件位置写入所述业务事件，将写入所述业务事件的基于所述MQTT协议的上行数据报文发送给所述物联网平台，以指示所述物联网平台基于所述业务事件进行业务处理。

可选地，所述如果接收到所述基于MQTT协议的下行数据报文，就采用所述数据解析协议包对应的编码接口，对所述基于MQTT协议的下行数据报文的功能控制信息进行编码，生成功能控制指令，将基于所述MQTT协议的下行数据报文转换成基于所述私有协议的下行数据报文，在基于所述私有协议的下行数据报文的指令位置写入所述功能控制指令，将写入所述功能控制指令的基于所述私有协议的下行数据报文发送给所述物联网设备，以指示所述物联网设备根据所述功能控制指令执行相应的功能控制操作，包括：

如果接收到所述基于MQTT协议的下行数据报文，就获取所述数据解析协议包对应的设备列表，在所述设备列表中查询是否存在所述物联网设备；

如果存在，就采用所述数据解析协议包对应的编码接口，对所述基于MQTT协议的下行数据报文的功能控制信息进行编码，生成功能控制指令，将基于所述MQTT协议的下行数据报文转换成基于所述私有协议的下行数据报文，在基于所述私有协议的下行数据报文的指令位置写入所述功能控制指令，将写入所述功能控制指令的基于所述私有协议的下行数据报文发送给所述物联网设备，以指示所述物联网设备根据所述功能控制指令执行相应的功能控制操作。

本发明提供了一种物联网设备接入装置，应用于平台网关，物联网设备接入装置包括：

协议包构建模块，用于构建数据转换层，所述数据转换层包括至少一个数据解析协议包；连接模块，用于获取物联网设备接入物联网平台的请求，根据所述请求连接所述物联网设备；检测模块，检测是否接收到所述物联网设备向所述物联网平台发送的基于私有协议的上行数据报文，同时检测是否接收到所述物联网平台向所述物联网设备发送的基于MQTT协议的下行数据报文；解析模块，如果接收到所述基于私有协议的上行数据报文，就采用所述数据解析协议包对应的解析接口，解析所述基于私有协议的上行数据报文的业务事件，将基于所述私有协议的上行数据报文转换成基于所述MQTT协议的上行数据报文，在基于所述MQTT协议的上行数据报文的事件位置写入所述业务事件，将写入所述业务事件的基于所述MQTT协议的上行数据报文发送给所述物联网平台，以指示所述物联网平台基于所述业务事件进行业务处理；编码模块，用于如果接收到所述基于MQTT协议的下行数据报文，就采用所述数据解析协议包对应的编码接口，对所述基于MQTT协议的下行数据报文的功能控制信息进行编码，生成功能控制指令，将基于所述MQTT协议的下行数据报文转换成基于所述私有协议的下行数据报文，在基于所述私有协议的下行数据报文的指令位置写入所述功能控制指令，将写入所述功能控制指令的基于所述私有协议的下行数据报文发送给所述物联网设备，以指示所述物联网设备根据所述功能控制指令执行相应的功能控制操作。

本发明提供了一种电子设备，包括：处理器及存储器；所述存储器用于存储计算机程序，所述处理器用于执行所述存储器存储的计算机程序，以使所述电子设备执行上述的方法。

本发明提供了一种计算机可读介质，其上存储有计算机程序，所述计算机程序用于使计算机执行上述的方法。

本发明的有益效果：

本发明构建的数据解析协议包，能够在处理私有协议的数据报文时，根据私有协议的数据报文的传输方向，匹配数据解析协议包相应的解析接口，对私有协议的数据报文进行解析处理，相比传统数据解析方案，本发明极大提高了数据解析的效率与性能；同时，将对所述基于MQTT协议的下行数据报文的功能控制信息进行编码，生成功能控制指令，将基于所述MQTT协议的下行数据报文转换成基于所述私有协议的下行数据报文，在基于所述私有协议的下行数据报文的指令位置写入所述功能控制指令，将写入所述功能控制指令的基于所述私有协议的下行数据报文发送给所述物联网设备，这样，一方面，使得数据解析协议包可以在平台网关使用，平台网关可以将基于私有协议的数据报文转换成基于MQTT协议的数据报文，有利于提高物联网设备接入物联网平台的效率，另一方面，采用所述数据解析协议包对应的解析接口，解析所述基于私有协议的上行数据报文的业务事件，采用所述数据解析协议包对应的编码接口，对所述基于MQTT协议的下行数据报文的功能控制信息进行编码，生成功能控制指令，使得上行数据报文和下行数据报文都可以在私有协议和MQTT协议之间进行转换，增强了物联网设备和物联网平台之间的便利性。

附图说明

图1是本发明的一示例性实施例示出的物联网设备接入方法的流程示意图；

图2是本发明的一示例性实施例示出的物联网设备接入装置的结构示意图；

图3是本发明的一示例性实施例示出的适于用来实现本发明电子设备的计算机系统的结构示意图。

具体实施方式

以下通过特定的具体实例说明本发明的实施方式，本领域技术人员可由本说明书所揭露的内容轻易地了解本发明的其他优点与功效。本发明还可以通过另外不同的具体实施方式加以实施或应用，本说明书中的各项细节也可以基于不同观点与应用，在没有背离本发明的精神下进行各种修饰或改变。需说明的是，在不冲突的情况下，以下实施例及实施例中的子样本可以相互组合。

需要说明的是，以下实施例中所提供的图示仅以示意方式说明本发明的基本构想，遂图式中仅显示与本发明中有关的组件而非按照实际实施时的组件数目、形状及尺寸绘制，其实际实施时各组件的型态、数量及比例可为一种随意的改变，且其组件布局型态也可能更为复杂。

在下文描述中，探讨了大量细节，以提供对本发明实施例的更透彻的解释，然而，对本领域技术人员来说，可以在没有这些具体细节的情况下实施本发明的实施例是显而易见的，在其他实施例中，以方框图的形式而不是以细节的形式来示出公知的结构和设备，以避免使本发明的实施例难以理解。

本公开实施例的说明书和权利要求书及上述附图中的术语“第一”、“第二”等是用于区别类似的对象，而不必用于描述特定的顺序或先后次序。应该理解这样使用的数据在适当情况下可以互换，以便这里描述的本公开实施例的实施例。此外，术语“包括”和“具有”以及他们的任何变形，意图在于覆盖不排他的包含。除非另有说明，术语“多个”表示两个或两个以上。本公开实施例中，字符“/”表示前后对象是一种“或”的关系。例如，A/B表示：A或B。术语“和/或”是一种描述对象的关联关系，表示可以存在三种关系。例如，A和/或B，表示：A或B，或，A和B这三种关系。

请参阅图1，为本发明的一示例性实施例示出的物联网设备接入方法的流程示意图。结合图1所示，在一示例性的实施例中，物联网设备接入方法至少包括步骤S101至步骤S105，详细介绍如下：

S101，构建数据转换层，所述数据转换层包括至少一个数据解析协议包；

其中，所述数据解析协议包用于将基于私有协议的数据报文转换成基于MQTT协议的数据报文。

S102，获取物联网设备接入物联网平台的请求，根据所述请求连接所述物联网设备；

其中，网关平台下联所述物联网设备，网关平台上联物联网平台。

S103，检测是否接收到所述物联网设备向所述物联网平台发送的基于私有协议的上行数据报文，同时检测是否接收到所述物联网平台向所述物联网设备发送的基于MQTT协议的下行数据报文；

其中，需说明的是，S103，包括：

检测是否接收到所述物联网设备发送的私有协议的数据报文，如果接收到所述物联网设备发送的私有协议的数据报文且私有协议的数据报文的接收方为所述物联网平台，就识别接收到所述物联网设备向所述物联网平台发送的基于私有协议的上行数据报文。

其中，需说明的是，S103，包括：

检测是否接收到所述物联网平台发送的基于MQTT协议的数据报文，如果接收到所述物联网平台发送的基于MQTT协议的数据报文且基于MQTT协议的数据报文的接收方为所述物联网设备，就识别接收到所述物联网平台向所述物联网设备发送的基于MQTT协议的下行数据报文；

其中，所述上行数据报文为所述物联网设备向所述物联网平台发送的数据报文。

其中，所述下行数据报文为所述物联网平台向所述物联网设备发送的数据报文。

S104，如果接收到所述基于私有协议的上行数据报文，就采用所述数据解析协议包对应的解析接口，解析所述基于私有协议的上行数据报文的业务事件，将基于所述私有协议的上行数据报文转换成基于所述MQTT协议的上行数据报文，在基于所述MQTT协议的上行数据报文的事件位置写入所述业务事件，将写入所述业务事件的基于所述MQTT协议的上行数据报文发送给所述物联网平台，以指示所述物联网平台基于所述业务事件进行业务处理；

需说明的是，解析所述基于私有协议的上行数据报文的业务事件，包括：

读取所述基于私有协议的上行数据报文的消息体；

判断所述消息体是否加密；

如果所述消息体加密，对所述消息体进行解密，按字节编码规范读取解密后的所述消息体的数据，得到业务事件。

需说明的是，在基于所述MQTT协议的上行数据报文的事件位置写入所述业务事件，包括：

提取所述业务事件的业务元素，根据所述MQTT协议的格式，获取所述MQTT协议的上行数据报文中的事件位置，在所述事件位置写入所述业务元素。

其中，不同的业务事件对应的业务元素不同。

其中，业务事件包括设备状态事件、设备数据上报事件、设备功能事件、设备日志事件、设备元数据事件、设备同步事件、设备OTA升级事件中的其中一种或其组合。

其中，设备状态事件对应的业务元素包括：上线、激活、离线。

其中，设备数据上报事件对应的业务元素包括：上报时序数据、上报属性数据、上报告警数据。

其中，设备功能事件对应的业务元素包括：读属性、写属性、远程过程调用、功能调用回复。

其中，设备日志事件对应的业务元素包括：数据解析错误、数据检验失败、数据无效。

其中，设备元数据事件对应的业务元素包括：自动创建设备、设备物模型上报、设备配置上报。

其中，设备同步事件对应的业务元素包括：同步设备拓扑、同步设备物模型、同步设备配置。

其中，以充电桩的设备物模型为例，充电桩的设备物模型包括充电桩标识、充电桩类型、充电枪数量、充电枪端口号、充电枪标识。

其中，设备OTA升级事件对应的业务元素包括：设备固件信息上报，下行更新固件，固件升级状态。

为便于说明，举例如下：

物联网设备进行业务操作时，生成业务事件，将业务事件写入基于私有协议的上行数据报文中，发送基于私有协议的上行数据报文到网关平台；

网关平台将收到的基于私有协议的上行数据报文转换成基于MQTT协议的上行数据报文；

网关平台将转换后的基于MQTT协议的上行数据报文发送给物联网平台。

S105，如果接收到所述基于MQTT协议的下行数据报文，就采用所述数据解析协议包对应的编码接口，对所述基于MQTT协议的下行数据报文的功能控制信息进行编码，生成功能控制指令，将基于所述MQTT协议的下行数据报文转换成基于所述私有协议的下行数据报文，在基于所述私有协议的下行数据报文的指令位置写入所述功能控制指令，将写入所述功能控制指令的基于所述私有协议的下行数据报文发送给所述物联网设备，以指示所述物联网设备根据所述功能控制指令执行相应的功能控制操作。

需说明的是，在基于所述私有协议的下行数据报文的指令位置写入所述功能控制指令，包括：

提取所述功能控制指令，根据所述私有协议的格式，获取所述基于所述私有协议的下行数据报文中的指令位置，在所述指令位置写入所述功能控制指令。

需说明的是，对所述基于MQTT协议的下行数据报文的功能控制信息进行编码，生成功能控制指令,包括：

判断基于MQTT协议的下行数据报文是否包括功能控制信息；

如果包括，对所述基于MQTT协议的下行数据报文的功能控制信息进行编码，生成功能控制指令。

其中，判断基于MQTT协议的下行数据报文是否包括功能控制信息的指令为：if(message is Function Invoke Message)。

为便于说明，举例如下：

物联网平台在进行功能控制时，生成功能控制信息，将功能控制信息写入基于MQTT协议的下行数据报文中，发送基于MQTT协议的下行数据报文到网关平台；

网关平台将收到的基于MQTT协议的下行数据报文转换成基于私有协议的下行数据报文；

网关平台将转换后的基于私有协议的下行数据报文发送给物联网设备。

本发明有益效果在于两方面，一方面，使得数据解析协议包可以在平台网关使用，平台网关可以将基于私有协议的数据报文转换成基于MQTT协议的数据报文，有利于提高物联网设备接入物联网平台的效率，另一方面，采用所述数据解析协议包对应的解析接口，解析所述基于私有协议的上行数据报文的业务事件，采用所述数据解析协议包对应的编码接口，对所述基于MQTT协议的下行数据报文的功能控制信息进行编码，生成功能控制指令，使得上行数据报文和下行数据报文都可以在私有协议和MQTT协议之间进行转换，增强了物联网设备和物联网平台之间的便利性。

在另一些实施例中，所述构建数据转换层，所述数据转换层包括至少一个数据解析协议包，包括：

获取数据解析协议包；

对所述数据解析协议包进行测试；

测试成功后，构建所述数据转换层，所述数据转换层包括至少一个测试成功的所述数据解析协议包。

在另一些实施例中，所述对所述数据解析协议包进行测试，包括：

获取测试模板，在所述测试模板上填入测试数据，通过所述测试模板对所述数据解析协议包进行测试，生成测试结果；

判断所述测试结果是否为预设结果；

如果所述测试结果为预设结果，就保存测试成功的所述数据解析协议包，如果所述测试结果不为预设结果，就调整所述数据解析协议包的参数。

在另一些实施例中，所述获取数据解析协议包，包括：

获取所述数据解析协议包的数量，判断所述数量是否大于预设值；

如果所述数量大于所述预设值，就获取每个所述数据解析协议包的分数，按从高到低的顺序，对每个所述数据解析协议包的分数进行排名，获取排名第一的所述数据解析协议包。

在另一些实施例中，所述检测是否接收到所述物联网设备向所述物联网平台发送的基于私有协议的上行数据报文，同时检测是否接收到所述物联网平台向所述物联网设备发送的基于MQTT协议的下行数据报文，包括：

建立所述平台网关与所述物联网设备之间的第一连接会话，建立所述平台网关与所述物联网平台之间的第二连接会话；

在所述第一连接会话中，检测是否接收到所述物联网设备向所述物联网平台发送的基于私有协议的上行数据报文，同时在所述第二连接会话中，检测是否接收到所述物联网平台向所述物联网设备发送的基于MQTT协议的下行数据报文。

在另一些实施例中，所述如果接收到所述基于私有协议的上行数据报文，就采用所述数据解析协议包对应的解析接口，解析所述基于私有协议的上行数据报文的业务事件，将基于所述私有协议的上行数据报文转换成基于所述MQTT协议的上行数据报文，在基于所述MQTT协议的上行数据报文的事件位置写入所述业务事件，将写入所述业务事件的基于所述MQTT协议的上行数据报文发送给所述物联网平台，以指示所述物联网平台基于所述业务事件进行业务处理，包括：

如果接收到所述基于私有协议的上行数据报文，就获取所述数据解析协议包对应的私有协议列表，在所述私有协议列表中查询是否存在所述私有协议；

其中，私有协议列表为用户自设或系统默认，在此不做限制。

如果存在，就采用所述数据解析协议包对应的解析接口，解析所述基于私有协议的上行数据报文的业务事件，将基于所述私有协议的上行数据报文转换成基于所述MQTT协议的上行数据报文，在基于所述MQTT协议的上行数据报文的事件位置写入所述业务事件，将写入所述业务事件的基于所述MQTT协议的上行数据报文发送给所述物联网平台，以指示所述物联网平台基于所述业务事件进行业务处理。

在另一些实施例中，所述如果接收到所述基于MQTT协议的下行数据报文，就采用所述数据解析协议包对应的编码接口，对所述基于MQTT协议的下行数据报文的功能控制信息进行编码，生成功能控制指令，将基于所述MQTT协议的下行数据报文转换成基于所述私有协议的下行数据报文，在基于所述私有协议的下行数据报文的指令位置写入所述功能控制指令，将写入所述功能控制指令的基于所述私有协议的下行数据报文发送给所述物联网设备，以指示所述物联网设备根据所述功能控制指令执行相应的功能控制操作，包括：

如果接收到所述基于MQTT协议的下行数据报文，就获取所述数据解析协议包对应的设备列表，在所述设备列表中查询是否存在所述物联网设备；

其中，设备列表为用户自设或系统默认，在此不做限制。

如果存在，就采用所述数据解析协议包对应的编码接口，对所述基于MQTT协议的下行数据报文的功能控制信息进行编码，生成功能控制指令，将基于所述MQTT协议的下行数据报文转换成基于所述私有协议的下行数据报文，在基于所述私有协议的下行数据报文的指令位置写入所述功能控制指令，将写入所述功能控制指令的基于所述私有协议的下行数据报文发送给所述物联网设备，以指示所述物联网设备根据所述功能控制指令执行相应的功能控制操作。

请参阅图2，为本发明的一示例性实施例示出的物联网设备接入装置的结构示意图。结合图2所示，该示例性的物联网设备接入装置包括：协议包构建模块201、连接模块202、检测模块203，解析模块204以及编码模块205，其中：

协议包构建模块201，用于构建数据转换层，所述数据转换层包括至少一个数据解析协议包；

连接模块202，用于获取物联网设备接入物联网平台的请求，根据所述请求连接所述物联网设备；

检测模块203，检测是否接收到所述物联网设备向所述物联网平台发送的基于私有协议的上行数据报文，同时检测是否接收到所述物联网平台向所述物联网设备发送的基于MQTT协议的下行数据报文；

解析模块204，如果接收到所述基于私有协议的上行数据报文，就采用所述数据解析协议包对应的解析接口，解析所述基于私有协议的上行数据报文的业务事件，将基于所述私有协议的上行数据报文转换成基于所述MQTT协议的上行数据报文，在基于所述MQTT协议的上行数据报文的事件位置写入所述业务事件，将写入所述业务事件的基于所述MQTT协议的上行数据报文发送给所述物联网平台，以指示所述物联网平台基于所述业务事件进行业务处理；

编码模块205，用于如果接收到所述基于MQTT协议的下行数据报文，就采用所述数据解析协议包对应的编码接口，对所述基于MQTT协议的下行数据报文的功能控制信息进行编码，生成功能控制指令，将基于所述MQTT协议的下行数据报文转换成基于所述私有协议的下行数据报文，在基于所述私有协议的下行数据报文的指令位置写入所述功能控制指令，将写入所述功能控制指令的基于所述私有协议的下行数据报文发送给所述物联网设备，以指示所述物联网设备根据所述功能控制指令执行相应的功能控制操作。

需要说明的是，上述实施例所提供的物联网设备接入装置与上述实施例所提供的物联网设备接入方法属于同一构思，其中各个步骤执行操作的具体方式已经在系统实施例中进行了详细描述，此处不再赘述。

采用本公开实施例提供的物联网设备接入装置，构建的数据解析协议包，能够在处理私有协议的数据报文时，根据私有协议的数据报文的传输方向，匹配数据解析协议包相应的解析接口，对私有协议的数据报文进行解析处理，相比传统数据解析方案，本发明极大提高了数据解析的效率与性能；同时，将对所述基于MQTT协议的下行数据报文的功能控制信息进行编码，生成功能控制指令，将基于所述MQTT协议的下行数据报文转换成基于所述私有协议的下行数据报文，在基于所述私有协议的下行数据报文的指令位置写入所述功能控制指令，将写入所述功能控制指令的基于所述私有协议的下行数据报文发送给所述物联网设备，这样，一方面，使得数据解析协议包可以在平台网关使用，平台网关可以将基于私有协议的数据报文转换成基于MQTT协议的数据报文，有利于提高物联网设备接入物联网平台的效率，另一方面，采用所述数据解析协议包对应的解析接口，解析所述基于私有协议的上行数据报文的业务事件，采用所述数据解析协议包对应的编码接口，对所述基于MQTT协议的下行数据报文的功能控制信息进行编码，生成功能控制指令，使得上行数据报文和下行数据报文都可以在私有协议和MQTT协议之间进行转换，增强了物联网设备和物联网平台之间的便利性。

请参阅图3，示出了适于用来实现本发明实施例的电子设备的计算机系统的结构示意图。需要说明的是，图3示出的电子设备的计算机系统300仅是一个示例，不应对本发明实施例的功能和使用范围带来任何限制。

如图3所示，计算机系统300包括中央处理单元(Central Processing Unit，CPU)301，其可以根据存储在只读存储器(Read-Only Memory，ROM)302中的程序或者从储存部分308加载到随机访问存储器(Random Access Memory，RAM)303中的程序而执行各种适当的动作和处理，例如执行上述实施例中的方法。在RAM 303中，还存储有系统操作所需的各种程序和数据。CPU 301、ROM302以及RAM 303通过总线304彼此相连。输入/输出(Input/Output，I/O)接口305也连接至总线304。

以下部件连接至I/O接口305：包括键盘、鼠标等的输入部分306；包括诸如阴极射线管(Cathode Ray Tube，CRT)、液晶显示器(Liquid Crystal Display，LCD)等以及扬声器等的输出部分307；包括硬盘等的储存部分308；以及包括诸如LAN(Local Area Network，局域网)卡、调制解调器等的网络接口卡的通信部分309。通信部分309经由诸如因特网的网络执行通信处理。驱动器310也根据需要连接至I/O接口305。可拆卸介质311，诸如磁盘、光盘、磁光盘、半导体存储器等等，根据需要安装在驱动器310上，以便于从其上读出的计算机程序根据需要被安装入储存部分308。

特别地，根据本发明的实施例，上文参考流程图描述的过程可以被实现为计算机软件程序。例如，本发明的实施例包括一种计算机程序产品，其包括承载在计算机可读介质上的计算机程序，该计算机程序包含用于执行流程图所示的方法的计算机程序。在这样的实施例中，该计算机程序可以通过通信部分309从网络上被下载和安装，和/或从可拆卸介质311被安装。在该计算机程序被中央处理单元(CPU)301执行时，执行本发明的系统中限定的各种功能。

本发明还提供一种计算机可读写存储介质，存储有计算机程序，所述计算机程序被执行时实现上述针对物联网设备接入方法所描述的至少一种实施例，比如图1所描述的实施例。

所述功能如果以软件功能单元的形式实现并作为独立的产品销售或使用时，可以存储在一个计算机可读取存储介质中。基于这样的理解，本发明的技术方案本质上或者说对现有技术作出贡献的部分或者该技术方案的部分可以以软件产品的形式体现出来，该计算机软件产品存储在一个存储介质中，包括若干指令用以使得一台计算机设备(可以是个人计算机，服务器，或者网络设备等)执行本发明各个实施例所述方法的全部或部分步骤。

于本发明提供的实施例中，所述计算机可读写存储介质可以包括只读存储器、随机存取存储器、EEPROM、CD-ROM或其它光盘存储装置、磁盘存储装置或其它磁存储设备、闪存、U盘、移动硬盘、或者能够用于存储具有指令或数据结构形式的期望的程序代码并能够由计算机进行存取的任何其它介质。另外，任何连接都可以适当地称为计算机可读介质。例如，如果指令是使用同轴电缆、光纤光缆、双绞线、数字订户线(DSL)或者诸如红外线、无线电和微波之类的无线技术，从网站、服务器或其它远程源发送的，则所述同轴电缆、光纤光缆、双绞线、DSL或者诸如红外线、无线电和微波之类的无线技术包括在所述介质的定义中。然而，应当理解的是，计算机可读写存储介质和数据存储介质不包括连接、载波、信号或者其它暂时性介质，而是旨在针对于非暂时性、有形的存储介质。如申请中所使用的磁盘和光盘包括压缩光盘(CD)、激光光盘、光盘、数字多功能光盘(DVD)、软盘和蓝光光盘，其中，磁盘通常磁性地复制数据，而光盘则用激光来光学地复制数据。

在一个或多个示例性方面，本发明所述方法的计算机程序所描述的功能可以用硬件、软件、固件或其任意组合的方式来实现。当用软件实现时，可以将这些功能作为一个或多个指令或代码存储或传送到计算机可读介质上。本发明所公开的方法或算法的步骤可以用处理器可执行软件模块来体现，其中处理器可执行软件模块可以位于有形、非临时性计算机可读写存储介质上。有形、非临时性计算机可读写存储介质可以是计算机能够存取的任何可用介质。

本发明上述的附图中的流程图和框图，图示了按照本发明各种实施例的系统、方法和计算机程序产品的可能实现的体系架构、功能和操作。基于此，流程图或框图中的每个方框可以代表一个模块、程序段、或代码的一部分，该模块、程序段、或代码的一部分包含一个或多个用于实现规定的逻辑功能的可执行指令。也应当注意，在有些作为替换的实现中，方框中所标注的功能也可以以不同于附图中所标注的顺序发生。例如，两个接连地表示的方框实际上可以基本并行地执行，它们有时也可以按相反的顺序执行，这根据所涉及的功能而定。也要注意的是，框图和/或流程图中的每个方框、以及框图和/或流程图中的方框的组合，可以通过执行规定的功能或操作的专用的基于硬件的系统来实现，或者可以通过专用硬件与计算机指令的组合来实现。

上述实施例仅例示性说明本发明的原理及其功效，而非用于限制本发明。任何熟悉此技术的人士皆可在不违背本发明的精神及范畴下，对上述实施例进行修饰或改变。因此，举凡所属技术领域中具有通常知识者在未脱离本发明所揭示的精神与技术思想下所完成的一切等效修饰或改变，仍应由本发明的权利要求所涵盖。

Claims (10)

1.一种物联网设备接入方法，其特征在于，应用于平台网关，所述方法包括：

构建数据转换层，所述数据转换层包括至少一个数据解析协议包；

获取物联网设备接入物联网平台的请求，根据所述请求连接所述物联网设备；

检测是否接收到所述物联网设备向所述物联网平台发送的基于私有协议的上行数据报文，同时检测是否接收到所述物联网平台向所述物联网设备发送的基于MQTT协议的下行数据报文；

如果接收到所述基于私有协议的上行数据报文，就采用所述数据解析协议包对应的解析接口，解析所述基于私有协议的上行数据报文的业务事件，将基于所述私有协议的上行数据报文转换成基于所述MQTT协议的上行数据报文，在基于所述MQTT协议的上行数据报文的事件位置写入所述业务事件，将写入所述业务事件的基于所述MQTT协议的上行数据报文发送给所述物联网平台，以指示所述物联网平台基于所述业务事件进行业务处理；

如果接收到所述基于MQTT协议的下行数据报文，就采用所述数据解析协议包对应的编码接口，对所述基于MQTT协议的下行数据报文的功能控制信息进行编码，生成功能控制指令，将基于所述MQTT协议的下行数据报文转换成基于所述私有协议的下行数据报文，在基于所述私有协议的下行数据报文的指令位置写入所述功能控制指令，将写入所述功能控制指令的基于所述私有协议的下行数据报文发送给所述物联网设备，以指示所述物联网设备根据所述功能控制指令执行相应的功能控制操作。

2.根据权利要求1所述的物联网设备接入方法，其特征在于，所述构建数据转换层，所述数据转换层包括至少一个数据解析协议包，包括：

获取数据解析协议包；

对所述数据解析协议包进行测试；

测试成功后，构建所述数据转换层，所述数据转换层包括至少一个测试成功的所述数据解析协议包。

3.根据权利要求2所述的物联网设备接入方法，其特征在于，所述对所述数据解析协议包进行测试，包括：

获取测试模板，在所述测试模板上填入测试数据，通过所述测试模板对所述数据解析协议包进行测试，生成测试结果；

判断所述测试结果是否为预设结果；

如果所述测试结果为预设结果，就保存测试成功的所述数据解析协议包，如果所述测试结果不为预设结果，就调整所述数据解析协议包的参数。

4.根据权利要求2所述的物联网设备接入方法，其特征在于，所述获取数据解析协议包，包括：

获取所述数据解析协议包的数量，判断所述数量是否大于预设值；

如果所述数量大于所述预设值，就获取每个所述数据解析协议包的分数，按从高到低的顺序，对每个所述数据解析协议包的分数进行排名，获取排名第一的所述数据解析协议包。

5.根据权利要求1所述的物联网设备接入方法，其特征在于，所述检测是否接收到所述物联网设备向所述物联网平台发送的基于私有协议的上行数据报文，同时检测是否接收到所述物联网平台向所述物联网设备发送的基于MQTT协议的下行数据报文，包括：

建立所述平台网关与所述物联网设备之间的第一连接会话，建立所述平台网关与所述物联网平台之间的第二连接会话；

在所述第一连接会话中，检测是否接收到所述物联网设备向所述物联网平台发送的基于私有协议的上行数据报文，同时在所述第二连接会话中，检测是否接收到所述物联网平台向所述物联网设备发送的基于MQTT协议的下行数据报文。

6.根据权利要求1所述的物联网设备接入方法，其特征在于，所述如果接收到所述基于私有协议的上行数据报文，就采用所述数据解析协议包对应的解析接口，解析所述基于私有协议的上行数据报文的业务事件，将基于所述私有协议的上行数据报文转换成基于所述MQTT协议的上行数据报文，在基于所述MQTT协议的上行数据报文的事件位置写入所述业务事件，将写入所述业务事件的基于所述MQTT协议的上行数据报文发送给所述物联网平台，以指示所述物联网平台基于所述业务事件进行业务处理，包括：

如果接收到所述基于私有协议的上行数据报文，就获取所述数据解析协议包对应的私有协议列表，在所述私有协议列表中查询是否存在所述私有协议；

如果存在，就采用所述数据解析协议包对应的解析接口，解析所述基于私有协议的上行数据报文的业务事件，将基于所述私有协议的上行数据报文转换成基于所述MQTT协议的上行数据报文，在基于所述MQTT协议的上行数据报文的事件位置写入所述业务事件，将写入所述业务事件的基于所述MQTT协议的上行数据报文发送给所述物联网平台，以指示所述物联网平台基于所述业务事件进行业务处理。

7.根据权利要求1所述的物联网设备接入方法，其特征在于，所述如果接收到所述基于MQTT协议的下行数据报文，就采用所述数据解析协议包对应的编码接口，对所述基于MQTT协议的下行数据报文的功能控制信息进行编码，生成功能控制指令，将基于所述MQTT协议的下行数据报文转换成基于所述私有协议的下行数据报文，在基于所述私有协议的下行数据报文的指令位置写入所述功能控制指令，将写入所述功能控制指令的基于所述私有协议的下行数据报文发送给所述物联网设备，以指示所述物联网设备根据所述功能控制指令执行相应的功能控制操作，包括：

如果接收到所述基于MQTT协议的下行数据报文，就获取所述数据解析协议包对应的设备列表，在所述设备列表中查询是否存在所述物联网设备；

如果存在，就采用所述数据解析协议包对应的编码接口，对所述基于MQTT协议的下行数据报文的功能控制信息进行编码，生成功能控制指令，将基于所述MQTT协议的下行数据报文转换成基于所述私有协议的下行数据报文，在基于所述私有协议的下行数据报文的指令位置写入所述功能控制指令，将写入所述功能控制指令的基于所述私有协议的下行数据报文发送给所述物联网设备，以指示所述物联网设备根据所述功能控制指令执行相应的功能控制操作。

8.一种物联网设备接入装置，应用于平台网关，其特征在于，所述物联网设备接入装置包括：

协议包构建模块，用于构建数据转换层，所述数据转换层包括至少一个数据解析协议包；

连接模块，用于获取物联网设备接入物联网平台的请求，根据所述请求连接所述物联网设备；

检测模块，检测是否接收到所述物联网设备向所述物联网平台发送的基于私有协议的上行数据报文，同时检测是否接收到所述物联网平台向所述物联网设备发送的基于MQTT协议的下行数据报文；

解析模块，如果接收到所述基于私有协议的上行数据报文，就采用所述数据解析协议包对应的解析接口，解析所述基于私有协议的上行数据报文的业务事件，将基于所述私有协议的上行数据报文转换成基于所述MQTT协议的上行数据报文，在基于所述MQTT协议的上行数据报文的事件位置写入所述业务事件，将写入所述业务事件的基于所述MQTT协议的上行数据报文发送给所述物联网平台，以指示所述物联网平台基于所述业务事件进行业务处理；

编码模块，用于如果接收到所述基于MQTT协议的下行数据报文，就采用所述数据解析协议包对应的编码接口，对所述基于MQTT协议的下行数据报文的功能控制信息进行编码，生成功能控制指令，将基于所述MQTT协议的下行数据报文转换成基于所述私有协议的下行数据报文，在基于所述私有协议的下行数据报文的指令位置写入所述功能控制指令，将写入所述功能控制指令的基于所述私有协议的下行数据报文发送给所述物联网设备，以指示所述物联网设备根据所述功能控制指令执行相应的功能控制操作。

9.一种电子设备，其特征在于，包括：处理器及存储器；

所述存储器用于存储计算机程序，所述处理器用于执行所述存储器存储的计算机程序，以使所述电子设备执行如权利要求1至7中任一项所述的方法。

10.一种计算机可读存储介质，其特征在于，其上存储有计算机程序，所述计算机程序用于使计算机执行如权利要求1至7中任一项所述的方法。