CN111083102A - 一种物联网数据处理方法、装置及设备 - Google Patents

Abstract

本发明公开了一种物联网数据处理方法、装置及设备，其中，物联网数据处理方法包括：确定数据终端的类型；根据数据终端的类型，确定传输层通道；接收数据终端上传的操作请求和身份信息；根据操作请求和身份信息生成的扩展协议报文上传至服务器；接收服务器对数据终端的安全认证结果；当安全认证结果对应的数据终端为合法数据终端，根据操作请求向数据终端开通操作权限。该物联网数据处理方法可在通过传输层通道复用、边缘处理技术减轻服务器的连接处理压力的同时，避免了数据泄密、隐私泄露以及身份冒用等安全隐患，使物联网通信系统中的数据传输更加安全，提高了物联网通信系统的安全性。

Description

一种物联网数据处理方法、装置及设备

技术领域

本发明涉及物联网通信技术领域，具体涉及一种物联网数据处理方法、装置及设备。

背景技术

物联网(The Internet of Things，IoT)是将各种信息传感设备与互联网结合起来而形成的网络，可实现在任何时间、任何地点的人、机、物的互联互通。随着物联网技术的普及，构建不同的物联网通信环境以实现人、机、物之间的信息共享已成为一种趋势。常用的物联网通信协议包括消息队列遥测传输协议(Message Queuing Telemetry TransportProtocol，MQTT)。

相关物联网通信技术中，多个数据终端基于物联网通信协议，通过传输层通道分别与服务器端建立会话连接，继而进行发布、订阅消息操作。由于通信连接方式中每个数据终端需要独自占用一条传输层通道与服务器连接，海量终端的接入将给服务器带来巨大的连接压力；同时通信协议没有安全访问机制，使得基于通信协议建立的物联网通信系统存在数据泄密、隐私泄露、身份冒用等安全隐患。

发明内容

因此，本发明要解决的技术问题在于克服相关技术中物联网通信系统存在服务器连接处理压力大、数据泄密、隐私泄露、身份冒用等安全隐患的缺陷，从而提供一种物联网数据处理方法、装置及设备。

根据第一方面，本发明实施例提供了一种物联网数据处理方法，包括：确定数据终端的类型；根据所述数据终端的类型，确定传输层通道；接收所述数据终端上传的操作请求和身份信息；根据所述操作请求和身份信息生成的扩展协议报文上传至服务器；接收所述服务器对所述数据终端的安全认证结果；当所述安全认证结果对应的所述数据终端为合法数据终端，根据所述操作请求向所述数据终端开通操作权限。

结合第一方面，在第一方面的第一实施方式中，所述接收所述服务器对所述数据终端的安全认证结果之前，所述方法还包括：确定所述数据终端是否首次接入所述传输层通道；当所述数据终端非首次接入所述传输层通道，获取所述数据终端连接端口号，所述连接端口号包括历史连接端口号和当前连接端口号；获取所述数据终端连接端口号分别与所述数据终端的类型、所述数据终端的身份信息、所述数据终端的协议客户端标识符的对应关系中的至少一种对应关系；将所述对应关系上传至所述服务器。

结合第一方面第一实施方式，在第一方面的第二实施方式中，所述将所述对应关系上传至所述服务器之前，所述方法还包括：根据权限信息表，确定所述操作请求是否越限；当所述操作权限请求越限，丢弃所述操作请求；当所述操作权限请求不越限，更新所述权限信息表。

结合第一方面第二实施方式，在第一方面的第三实施方式中，所述确定所述数据终端是否首次接入传输层通道，包括：根据所述数据终端的身份信息，确定预存的传输层通道连接表中是否包含对应所述数据终端的传输层通道，所述预存的传输层通道连接表由一一对应的身份信息与传输层通道组成；当预存的传输层通道连接表中包含对应所述数据终端的传输层通道，确定所述数据终端为非首次接入所述传输层通道。

结合第一方面，在第一方面的第四实施方式中，所述数据终端上传的操作请求包括数据订阅请求，所述当所述安全认证结果对应的所述数据终端为合法数据终端，根据所述操作请求向所述数据终端开通操作权限之后，所述方法还包括：更新权限信息表和所述传输层通道连接表；根据所述数据终端的身份信息，向所述数据终端发送满足所述数据订阅请求的目标数据。

根据第二方面，本发明实施例提供了一种物联网数据处理方法，包括：接收扩展协议报文，所述扩展协议报文包括数据终端的身份信息；根据所述扩展协议报文，对所述数据终端进行安全认证，得到安全认证结果；发送所述安全认证结果。

根据第三方面，本发明实施例提供了一种物联网数据处理装置，包括：第一确定模块，用于确定数据终端的类型；第二确定模块，用于根据所述数据终端的类型，确定传输层通道；第一接收模块，用于所述接收数据终端上传的操作请求和身份信息；生成上传模块，用于根据所述操作请求和身份信息生成的扩展协议报文上传至服务器；第二接收模块，用于接收所述服务器对所述数据终端的安全认证结果；权限开通模块，用于当所述安全认证结果对应的所述数据终端为合法数据终端，根据所述操作请求向所述数据终端开通操作权限。

根据第四方面，本发明实施例提供了一种物联网数据处理装置，包括：第三接收模块，用于接收扩展协议报文，所述扩展协议报文包括数据终端的身份信息；认证模块，用于根据所述扩展协议报文，对所述数据终端进行安全认证，得到安全认证结果；发送模块，用于发送所述安全认证结果。

根据第五方面，本发明实施例提供了一种物联网数据处理设备，包括存储器和处理器，所述存储器和所述处理器之间互相通信连接，所述存储器中存储有计算机指令，所述处理器通过执行所述计算机指令，从而执行第一方面或第一方面任一实施方式或第二方面中所述的物联网数据处理方法。

根据第六方面，本发明实施例提供了一种计算机可读存储介质，所述计算机可读存储介质存储有计算机指令，所述计算机指令用于使所述计算机执行实现第一方面或第一方面任一实施方式中所述的物联网数据处理方法，或者执行实现第二方面中所述的物联网数据处理方法。

本发明技术方案，具有如下优点：

本发明提供的物联网数据处理方法、装置及设备，边缘物联代理终端确定数据终端的类型，根据数据终端的类型，确定传输层通道，接收数据终端上传的操作请求和身份信息，根据操作请求和对应的数据终端的身份信息，生成扩展协议报文，将该扩展协议报文上传至服务器，服务器接收扩展协议报文，根据该扩展协议报文，对数据终端进行安全认证，将安全认证结果发送到边缘物联代理终端，边缘物联代理终端接收服务器对数据终端的安全认证结果，为对应的数据终端开通操作权限，完成对报文的安全转发和访问。此方法实现了物联网通信系统中将同种类型的数据终端复用到同一传输层通道，通过边缘物联代理的边缘处理节省了带宽资源，缓解了服务器的连接、处理压力，同时保证了物联网通信系统中数据传输的安全，避免了数据泄密、隐私泄露以及身份冒用等安全隐患，提高了物联网通信系统的安全性。

附图说明

为了更清楚地说明本发明具体实施方式或现有技术中的技术方案，下面将对具体实施方式或现有技术描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图是本发明的一些实施方式，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。

图1为本发明实施例提出的一种物联网数据处理方法的流程图；

图2为本发明实施例提出的一种物联网数据处理方法的流程图；

图3为本发明实施例提出的一种物联网数据处理方法的流程图；

图4为本发明实施例提出的一种物联网数据处理方法的流程图；

图5为本发明实施例提出的一种物联网数据处理装置的框图；

图6为本发明实施例提出的一种物联网数据处理装置的框图；

图7为本发明实施例提出的一种物联网数据处理设备的结构示意图。

具体实施方式

下面将结合附图对本发明的技术方案进行清楚、完整地描述，显然，所描述的实施例是本发明一部分实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都属于本发明保护的范围。

在本发明的描述中，需要说明的是，术语“第一”、“第二”、“第三”仅用于描述目的，而不能理解为指示或暗示相对重要性。

此外，下面所描述的本发明不同实施方式中所涉及的技术特征只要彼此之间未构成冲突就可以相互结合。

本实施例提供了一种物联网数据处理方法，可用于物联网通信系统中的边缘物联代理终端中，边缘物联代理终端可以为数据终端生成对应的协议客户端，数据终端通过通信协议客户端与服务器建立连接进行数据交互。本申请实施例中的通信协议以MQTT协议为例进行说明，边缘物联代理终端可以接收来自数据终端的MQTT会话的连接请求。如图1所示，该物联网数据处理方法包括：

S11：确定数据终端的类型。

示例性地，数据终端可以为一个，也可以为多个。数据终端类型可以为电表类终端，可以为视频采集类终端，还可以是配电变压器监测终端，也可以为通信费用采集类终端，不同的数据终端对应不同类型的数据，本申请实施例对数据终端的类型不作限定，本领域技术人员可以根据实际使用需要确定。相同类型的数据终端可以采用同一标识符，边缘物联代理终端可以根据标识符确认数据终端的类型。例如，可以将电表类终端的标识符设置为A，视频采集类终端的标识符设置为B，则当数据终端在上传操作请求时，代表其类型的标识符可以封装在报文中，边缘物联代理终端可以根据该标识符确定该接入数据终端的类型。

S12：根据数据终端的类型，确定传输层通道。

在确定数据终端类型后，可以将同一类型的数据终端上传的数据复用到同一TCP连接通道上进行传输，也可以将功能性相同的数据终端上传的数据复用到同一TCP连接通道上进行传输，比如通话费数据终端，流量费数据终端等功能性相同的通信费用数据终端可以复用到同一TCP连接通道上进行传输，本申请实施例对复用到同一TCP连接通道上的数据终端上传的数据类型不作限定，本领域技术人员可以根据实际使用需要确定。

S13：接收数据终端上传的操作请求和身份信息。

示例性地，数据终端上传的操作请求可以为发布数据请求，也可以为订阅数据请求，还可以同时进行数据发布和订阅请求。数据终端的身份信息可以是任一可用于表征数据终端身份的信息，例如数据终端的账号和密码信息。数据终端的身份信息可用于生成与边缘物联代理终端的MQTT会话的连接请求。本申请实施例对数据终端上传的数据请求中的请求信息的类型和身份信息的类型不作限定，本领域技术人员可以根据实际使用需要确定。

S14：根据操作请求和身份信息生成的扩展协议报文上传至服务器。

示例性地，边缘物联代理终端根据传输层通道连接表确定接收到MQTT会话连接请求后，为该数据终端建立通信连接。数据终端可以为多个同类型的数据终端，如数据终端均为电表类终端；数据终端也可以为不同类型的数据终端，比如数据终端包含电表类终端、配电变压器监测终端、视频采集类终端、通信费数据终端等，本申请实施例对数据终端类型不作限定，本领域技术人员可以根据实际使用需要确定。例如，接入的数据终端可以为电表类终端，则为该电表类终端建立相应的通信连接，同时获取该电表类终端的身份信息，比如用户名和密码等，根据电表类终端的操作请求和身份信息可以生成相应的扩展协议报文。

扩展协议报文可以通过修改标准协议报文生成，标准协议报文为根据数据终端的操作请求数据生成的协议，扩展协议报文可通过修改标准协议报文的格式，在标准协议报文中加入数据终端的扩展协议报文而得到。以MQTT协议报文为例，设置MQTT协议报文固定报头中的标志位，用于表征报文的类型，比如是扩展报文或者是标准报文，又或者是形成的其他报文。在该MQTT协议报文的有效载荷字段中增加与MQTT客户端相关的身份信息，如用户名和密码信息。按照MQTT协议补充完善MQTT协议报文的其他字段内容。

比如，当报文的主题为扩展发布报文，将报文中的固定报头中的服务质量(Quality of Service，QoS)等级设置为0x11表示这是一个扩展发布报文；将用户名、密码加入原主题名，对原报文可变报头中的主题名字段进行更新。若原报文的原有发布主题为“a/b”，则通过加入用户名和密码后可以将原有发布主题更新为“username/password/a/b”；按照报文格式更新报文其他字段。

当报文的主题为扩展订阅报文，将订阅报文固定报头中的保留位等级设置为0x0011表示这是一个扩展订阅报文；将用户名、密码作为第一个主题过滤器加入原报文的有效载荷中，例如原主题过滤器分别为“a/b”和“c/d”，扩展后的主题过滤器则分别为“username/password”、“a/b”和“c/d”，使得扩展的用户名、密码作为第一个主题过滤器；更新报文其他字段内容。扩展协议报文也可以根据扩展协议报文格式直接进行报文封装，使其包含MQTT客户端的身份信息，本申请实施例对扩展协议报文的生成方式不作限定，本领域技术人员可以根据实际使用需要确定。

S15：接收服务器对数据终端的安全认证结果。

示例性地，服务器端接收经过边缘物联代理终端处理的扩展协议报文，该扩展协议报文包括MQTT客户端的身份信息和有效载荷信息，服务器可以对该扩展协议报文进行解析，提取报文中的MQTT客户端的身份信息，即数据终端的身份信息，对此进行数据终端的安全认证，并将该安全认证结果以扩展协议报文形式传输至边缘物联代理终端。边缘物联代理终端可以接收的该扩展协议报文，提取安全认证结果。

S16：当安全认证结果对应的数据终端为合法数据终端，根据所述操作请求向数据终端开通操作权限。

示例性地，边缘物联代理终端可以根据接收来自服务器对数据终端的安全认证结果，确定数据终端是否为合法数据终端。当该数据终端为合法数据终端时，边缘物联代理终端可以根据接收的扩展协议报文，提取该扩展协议报文中包含的数据操作请求和对应数据终端的身份信息。边缘物联代理终端可以根据该身份信息和操作请求为该数据终端开通相应的数据操作权限。

本发明实施例提供的物联网数据处理方法，通过确定数据终端的类型，根据数据终端的类型，确定传输层通道，接收数据终端上传的操作请求和身份信息，根据操作请求和身份信息，生成扩展协议报文，将该扩展协议报文上传至服务器，并接收服务器对数据终端的安全认证结果，根据该安全认证结果为对应的数据终端开通数据操作请求权限。此方法实现了物联网通信系统中将同种类型的数据终端复用到同一传输层通道，缓解了建立多个TCP连接对服务端造成的处理压力，节省了带宽资源，提高了服务器的处理效率，同时保证了物联网通信系统中数据传输的安全，避免了数据泄密、隐私泄露以及身份冒用，提高了物联网通信系统的安全性。

作为本申请一个可选实施方式，如图2所示，步骤S15之前，包括：

S151，确定数据终端是否首次接入传输层通道。

示例性地，每个数据终端均有对应的MQTT客户端，边缘物联代理终端可以接收来自数据终端的MQTT会话的连接请求，可以根据传输层通道连接表判断接收到的MQTT会话连接请求是否为首次接入，如果该数据终端是首次接入传输层通道，可以为该MQTT会话建立相应的传输控制协议(Transmission Control Protocol，TCP)通信连接，如果该数据终端非首次接入，则获取该数据终端相应的TCP连接端口号，以供后续进行数据传输时备用。

S152，当所述数据终端非首次接入所述传输层通道，获取数据终端连接端口号，该连接端口号包括历史连接端口号和当前连接端口号。

示例性地，若数据终端并非首次接入传输层通道，可以获取数据终端的连接端口号。该连接端口号包含在套接字信息中，一个端口号一次只能对应一种进程，即端口号和进程之间是一一对应的。该端口号可以为历史连接端口号，也可以为当前连接端口号。比如，数据终端为通信费用采集类终端，首次接入时建立连接的端口号为1500，端口号1500对应流量费计算进程，那么当该通信费用类数据终端再次接入传输层通道时，操作请求变为获取短信费用，则对应短信费用计算进程端口号，假设该端口号为1600，那么此时该通信费用类数据终端的连接端口号为1600。获取非首次接入传输层通道的数据终端的历史连接端口号和当前连接端口号，以便后续该数据终端进行相同操作请求时的端口备用。

S153，获取数据终端连接端口号分别与数据终端的类型、数据终端的身份信息、数据终端的协议客户端标识符的对应关系中的至少一种对应关系。

示例性地，在已存在的传输层通道连接表中保存有非首次接入的数据终端的有关信息，包括数据终端类型、数据终端的身份信息以及数据终端的协议客户端标识符等信息。当该数据终端再次接入时，获取该数据终端的连接端口号，可以将该数据终端的端口号与数据终端的类型、数据终端的身份信息、数据终端的协议客户端标识符进行对应，获取其对应关系中至少一种对应关系。

S154，将该对应关系上传至服务器。

示例性地，对对应关系的具体说明参见上一实施方式对应部分的描述，本申请实施方式在此不再赘述。获取了数据终端的端口号与数据终端的类型、数据终端的身份信息、数据终端的协议客户端标识符的对应关系后，可以将该对应关系上传至服务器。对非首次接入的数据终端，获取其端口号与数据终端的有关信息的对应关系，将该对应关系上传至服务器，能够对接入的数据终端的身份进行确认，避免出现身份冒用这一安全隐患，进一步提高了系统数据的安全性。

作为本申请一个可选实施方式，步骤S154之前，还包括：

首先，根据权限信息表，确定操作请求是否越限。

示例性地，数据终端建立MQTT会话连接接入传输层通道后，可以获取对应的权限信息表。可以通过查询权限信息表获取接入数据终端的操作权限，在接收到操作权限请求后，可以对应权限信息表查询该接入的数据终端是否具有该操作权限请求。比如，数据终端为电表类终端，其操作权限可以为发布电表类终端数据，可以为订阅电表类终端数据，也可以为发布和订阅电表类终端数据，当电表类终端发出操作权限请求时，边缘物联代理终端可以通过查询权限信息表，确定该电表类终端是否具有该操作权限请求。

其次，当操作权限请求越限，丢弃该操作请求。

示例性地，边缘物联代理终端通过查询权限信息表，确定数据终端发送的操作权限请求已越限后，则丢弃该操作请求，不向服务器发送，从而间接节约带宽资源。比如，电表类终端的操作权限为发布电表类终端数据，当电表类终端发出获取通信费用操作请求，边缘物联代理终端通过查询权限信息表，得到该电表类终端不具有该操作权限请求，即丢弃该操作请求。

再次，当操作权限请求不越限，更新权限信息表。

示例性地，通过查询权限信息表，确定数据终端发送的操作权限请求不越限时，则更新权限信息表。操作权限请求不越限可以包括权限信息表不包含指定数据终端的主题操作权限，表示该数据终端对该主题为首次操作，也可以包括数据终端的操作请求与权限信息表两者完全匹配，表示该数据终端已经过认证、鉴权具有对指定主题的操作权限。对操作权限的具体说明参见本实施方式对应部分的描述，此处不再赘述。数据终端发送的操作权限请求不越限时，可以构建扩展协议报文与已建立的权限信息表关联，发送给服务器进行后续处理。

该物联网数据处理方法通过获取数据终端发送的操作请求，确定数据终端发送的操作请求是否越限，对接入传输层通道的数据终端的操作权限进行判断及更新，完善数据终端的操作权限，避免出现数据泄密以及隐私泄露等安全隐患，提高了物联网通信系统中数据传输的安全性。

作为本申请一个可选实施方式，如图3所示，步骤S151，包括：

S1511，根据数据终端的身份信息，确定预存的传输层通道连接表中是否包含对应该数据终端的传输层通道，预存的传输层通道连接表由一一对应的身份信息与传输层通道组成。

示例性地，数据终端的身份信息可以为数据终端的用户名，也可以为数据终端的类型标识符。本申请实施例对数据终端的身份信息不作限定，本领域技术人员可以根据实际使用需要确定。数据终端接入传输层通道后，传输层通道连接表对应更新，该传输层通道连接表中将会记录所接入的数据终端以及对应的传输层通道。

S1512，当预存的传输层通道连接表中包含对应该数据终端的传输层通道，确定该数据终端为非首次接入所述传输层通道。

示例性地，传输层通道连接表是由数据终端的身份信息与传输层通道组成的，且身份信息和传输层通道是一一对应的。通过查询该传输层通道连接表，可以确定当前请求接入的数据终端是否首次接入，当该传输层通道连接表中包括当前请求接入传输层通道的数据终端，可以确定该数据终端为非首次接入所述传输层通道，当该传输层通道连接表中包括当前请求接入传输层通道的数据终端，可以确定该数据终端为首次接入。

通过查询该传输层通道连接表，确定当前请求接入的数据终端是否首次接入，通过区分首次接入的数据终端和非首次接入的数据终端，将不同类型的数据终端接入对应的传输层通道，对两种接入方式不同的数据终端采取不同的处理方式，克服了接收到数据终端的连接请求时均为其建立通信连接，进而导致时间成本大、服务器处理压力增加的缺陷。

作为本申请一个可选实施方式，数据终端上传的数据包括订阅请求数据，步骤S16之后，还包括：

首先，更新权限信息表和传输层通道连接表。

示例性地，边缘物联代理终端可以接收来自服务器对数据终端的安全认证结果。当数据终端的安全认证结果为合法数据终端时，将该数据终端接入传输层通道，并对传输层通道连接表进行更新，同时为该首次接入的数据终端开通相应的数据订阅请求权限，更新权限信息表。

其次，根据数据终端的身份信息，向数据终端发送满足数据订阅请求的目标数据。

示例性地，当确认数据终端为合法数据终端时，边缘物联代理终端可以提取来自服务器的扩展协议报文中对应数据终端的身份信息，根据该身份信息和订阅请求数据，向对应的数据终端发送满足该订阅请求数据的目标数据。例如，首次接入的数据终端为视频采集类终端，该视频采集类终端需要订阅游戏攻略视频，边缘物联代理终端在接收到该数据操作请求时，通过查询传输层通道连接表确定该视频采集类终端为首次接入，则为该视频采集类终端分配相应的传输层通道，为其建立通信连接，并根据与其相关的信息更新传输层通道连接表，当服务器确认其为合法数据终端后，为其开通相应的游戏攻略视频订阅权限，同时更新权限信息表，边缘物联代理终端根据接收的服务器的安全认证结果，向该视频采集类终端发送满足其订阅请求的目标数据。本申请实施例对订阅请求数据类型不作限定，本领域技术人员可以根据实际使用需要确定。

本发明实施例还提供了一种物联网数据处理方法，可用于物联网通信系统中的服务器，如图4所示，包括：

S21：接收扩展协议报文，扩展协议报文包括数据终端的身份信息。对扩展协议报文和数据终端的身份信息的具体说明参见上一实施例对应部分的描述，本申请实施例在此不再赘述。边缘物联代理终端根据数据终端的操作请求和身份信息生成扩展协议报文，将该扩展协议报文发送至服务器，服务器接收该扩展协议报文进行后续处理。

S22：根据扩展协议报文，对数据终端进行安全认证，得到安全认证结果。对数据终端进行安全认证的具体说明参见上一实施例对应部分的描述，本申请实施例在此不再赘述。

S23：发送安全认证结果。对安全认证结果发送的具体说明参见上一实施例对应部分的描述，本申请实施例在此不再赘述。

本发明实施例提供的物联网数据处理方法，通过接收扩展协议报文，根据扩展协议报文，对数据终端进行安全认证，将安全认证结果发送到边缘物联代理终端。此方法能够通过对扩展协议报文的处理，确定数据终端的安全认证结果，边缘物联代理终端根据该安全认证结果进行报文的转发和访问，使数据传输在物联网通信系统中更加安全，提高了物联网通信系统中数据传输的安全性。

本发明实施例还提供了一种物联网数据处理装置，如图5所示，包括：

第一确定模块31，用于确定数据终端的类型；

第二确定模块32，用于根据数据终端的类型，确定传输层通道；

第一接收模块33，用于接收数据终端上传的操作请求和身份信息。

生成上传模块34，用于根据操作请求和身份信息生成的扩展协议报文上传至服务器。

第二接收模块35，用于接收服务器对数据终端的安全认证结果。

权限开通模块36，用于当安全认证结果对应的数据终端为合法数据终端，根据操作请求向数据终端开通操作权限。

本发明提供了一种物联网数据处理装置，通过第一确定模块确定接入数据终端的类型，由第二确定模块将其接入对应的传输层通道，再通过第一接收模块接收数据终端上传的操作请求和身份信息，生成上传模块根据操作请求和对应数据终端的身份信息，生成扩展协议报文上传至服务器，由第二接收模块接收服务器对数据终端的安全认证结果，当数据终端对应的安全认证结果为合法数据终端，再由权限开通模块根据操作请求为该接入的数据终端开通操作权限。该物联网数据处理装置通过根据数据终端类型确定传输层通道，可以将同类型的数据终端接入同一传输层通道，节约了带宽资源，缓解了服务器的处理压力，提高了服务器的处理效率，同时通过对接入的数据终端进行安全认证使物联网通信系统中的数据传输更加安全，避免了数据泄密、隐私泄露以及身份冒用，提高了物联网通信系统数据传输的安全性。

作为本申请一个可选实施方式，第二接收模块35之前，还包括：

第一判断模块，用于确定所述数据终端是否首次接入所述传输层通道。

第一获取子模块，用于获取数据终端连接端口号，该连接端口号包括历史连接端口号和当前连接端口号。

第二获取子模块：获取数据终端连接端口号分别与数据终端的类型、数据终端的身份信息、数据终端的协议客户端标识符的对应关系中的至少一种对应关系。

上传子模块，将该对应关系上传至服务器。

作为本申请一个可选实施方式，上传子模块之前，还包括：

第二判断模块：根据权限信息表，确定操作请求是否越限。

丢弃模块：用于当操作权限请求越限，丢弃操作请求。

更新模块：用于当操作权限请求不越限，更新权限信息表。

作为本申请一个可选实施方式，第一判断模块包括：

判断子模块：用于根据数据终端的身份信息，确定预存的传输层通道连接表中是否包含对应数据终端的传输层通道，预存的传输层通道连接表由一一对应的身份信息与传输层通道组成。

确定子模块，用于当预存的传输层通道连接表中包含对应数据终端的传输层通道，确定数据终端为非首次接入传输层通道。

作为本申请一个可选实施方式，数据终端上传的操作请求包括数据订阅请求，权限开通模块36之后，还包括：

更新模块：更新权限信息表和传输层通道连接表。

发送模块：根据数据终端的身份信息，向数据终端发送满足数据订阅请求的目标数据。

本施例还提供一种物联网数据处理装置，如图6所示，包括：

第三接收模块41，用于接收扩展协议报文，该扩展协议报文包括数据终端的身份信息。

认证模块42，用于根据扩展协议报文，对数据终端进行安全认证，得到安全认证结果。

发送模块43，发送所述安全认证结果。

本实施例提供的物联网数据处理装置，通过第三接收模块接收扩展协议报文，根据扩展协议报文，通过认证模块对数据终端进行安全认证，最后通过发送模块将安全认证结果发送到边缘物联代理终端。该物联网数据处理装置通过对扩展协议报文的处理，确定数据终端的安全认证结果，由边缘物联代理终端根据该安全认证结果对报文进行转发和访问，使数据传输在物联网通信系统中更加安全，提高了物联网通信系统中数据传输的安全性。

本发明实施例还提供了一种物联网数据处理设备，如图7所示，该物联网数据处理设备包括处理器51和存储器52，其中处理器51和存储器52可以通过总线或者其他方式连接，图7中以通过总线连接为例。

处理器51可以为中央处理器(Central Processing Unit，CPU)。处理器51还可以为其他通用处理器、数字信号处理器(Digital Signal Processor，DSP)、图形处理器(Graphics Processing Unit，GPU)、嵌入式神经网络处理器(Neural-network ProcessingUnit，NPU)或者其他专用的深度学习协处理器、专用集成电路(Application SpecificIntegrated Circuit，ASIC)、现场可编程门阵列(Field-Programmable Gate Array，FPGA)或者其他可编程逻辑器件、分立门或者晶体管逻辑器件、分立硬件组件等芯片，或者上述各类芯片的组合。

存储器52作为一种非暂态计算机可读存储介质，可用于存储非暂态软件程序、非暂态计算机可执行程序以及模块，如本发明实施例中的物联网数据处理方法对应的程序指令/模块(例如，图5所示的第一确定模块31、第二确定模块32、第一接收模块33、生成上传模块34、第二接收模块35和权限开通模块36；图6所示的第三接收模块41、认证模块42和发送模块43)。处理器51通过运行存储在存储器52中的非暂态软件程序、指令以及模块，从而执行处理器的各种功能应用以及数据处理，即实现上述方法实施例中的物联网数据处理方法。

存储器52可以包括存储程序区和存储数据区，其中，存储程序区可存储操作系统、至少一个功能所需要的应用程序；存储数据区可存储处理器51所创建的数据等。此外，存储器52可以包括高速随机存取存储器，还可以包括非暂态存储器，例如至少一个磁盘存储器件、闪存器件、或其他非暂态固态存储器件。在一些实施例中，存储器52可选包括相对于处理器51远程设置的存储器，这些远程存储器可以通过网络连接至处理器51。上述网络的实例包括但不限于互联网、企业内部网、局域网、移动通信网及其组合。

所述一个或者多个模块存储在所述存储器52中，当被所述处理器51执行时，执行如图1-图4所示实施例中的物联网数据处理方法。

通过边缘物联代理终端确定数据终端的类型，根据数据终端的类型，确定传输层通道，接收数据终端上传的操作请求和身份信息，根据操作请求和对应数据终端的身份信息，生成扩展协议报文，将该扩展协议报文上传至服务器，服务器接收扩展协议报文，根据该扩展协议报文，对数据终端进行安全认证，将安全认证结果发送到边缘物联代理终端，边缘物联代理终端接收服务器对数据终端的安全认证结果，当数据终端对应的安全认证结果为合法数据终端，根据操作请求向该数据终端开通操作权限，对相应报文进行安全的转发和访问。此种方法实现了物联网通信系统中将同种类型的数据终端复用到同一传输层通道，通过边缘物联代理的边缘处理节省了带宽资源，缓解了服务器的连接、处理压力，同时保证了物联网通信系统中数据传输的安全，避免了数据泄密、隐私泄露以及身份冒用等安全隐患，提高了物联网通信系统的安全性。

上述物联网数据处理设备具体细节可以对应参阅图1至图6所示的实施例中对应的相关描述和效果进行理解，此处不再赘述。

本领域技术人员可以理解，实现上述实施例方法中的全部或部分流程，是可以通过计算机程序来指令相关的硬件来完成，所述的程序可存储于一计算机可读取存储介质中，该程序在执行时，可包括如上述各方法的实施例的流程。其中，所述存储介质可为磁碟、光盘、只读存储记忆体(Read-Only Memory，ROM)、随机存储记忆体(Random AccessMemory，RAM)、快闪存储器(Flash Memory)、硬盘(Hard Disk Drive，缩写：HDD)或固态硬盘(Solid-State Drive，SSD)等；所述存储介质还可以包括上述种类的存储器的组合。

虽然结合附图描述了本发明的实施例，但是本领域技术人员可以在不脱离本发明的精神和范围的情况下作出各种修改和变型，这样的修改和变型均落入由所附权利要求所限定的范围之内。

Claims (10)

1.一种物联网数据处理方法，其特征在于，包括：

确定数据终端的类型；

根据所述数据终端的类型，确定传输层通道；

接收所述数据终端上传的操作请求和身份信息；

根据所述操作请求和身份信息生成的扩展协议报文上传至服务器；

接收所述服务器对所述数据终端的安全认证结果；

当所述安全认证结果对应的所述数据终端为合法数据终端，根据所述操作请求向所述数据终端开通操作权限。

2.根据权利要求1所述的方法，其特征在于，所述接收所述服务器对所述数据终端的安全认证结果之前，所述方法还包括：

确定所述数据终端是否首次接入所述传输层通道；

当所述数据终端非首次接入所述传输层通道，获取所述数据终端连接端口号，所述连接端口号包括历史连接端口号和当前连接端口号；

获取所述数据终端连接端口号分别与所述数据终端的类型、所述数据终端的身份信息、所述数据终端的协议客户端标识符的对应关系中的至少一种对应关系；

将所述对应关系上传至所述服务器。

3.根据权利要求2所述的方法，其特征在于，所述将所述对应关系上传至所述服务器之前，所述方法还包括：

根据权限信息表，确定所述操作请求是否越限；

当所述操作权限请求越限，丢弃所述操作请求；

当所述操作权限请求不越限，更新所述权限信息表。

4.根据权利要求2所述的方法，其特征在于，所述确定所述数据终端是否首次接入传输层通道，包括：

根据所述数据终端的身份信息，确定预存的传输层通道连接表中是否包含对应所述数据终端的传输层通道，所述预存的传输层通道连接表由一一对应的身份信息与传输层通道组成；

当预存的传输层通道连接表中包含对应所述数据终端的传输层通道，确定所述数据终端为非首次接入所述传输层通道。

5.根据权利要求1所述的方法，其特征在于，所述数据终端上传的操作请求包括数据订阅请求，所述当所述安全认证结果对应的所述数据终端为合法数据终端，根据所述操作请求向所述数据终端开通操作权限之后，所述方法还包括：

更新权限信息表和传输层通道连接表；

根据所述数据终端的身份信息，向所述数据终端发送满足所述数据订阅请求的目标数据。

6.一种物联网数据处理方法，其特征在于，包括：

接收扩展协议报文，所述扩展协议报文包括数据终端的身份信息；

根据所述扩展协议报文，对所述数据终端进行安全认证，得到安全认证结果；

发送所述安全认证结果。

7.一种物联网数据处理装置，其特征在于，包括：

第一确定模块，用于确定数据终端的类型；

第二确定模块，用于根据所述数据终端的类型，确定传输层通道；

第一接收模块，用于接收所述数据终端上传的操作请求和身份信息；

生成上传模块，用于根据所述操作请求和身份信息生成的扩展协议报文上传至服务器；

第二接收模块，用于接收所述服务器对所述数据终端的安全认证结果；

权限开通模块，用于当所述安全认证结果对应的所述数据终端为合法数据终端，根据所述操作请求向所述数据终端开通操作权限。

8.一种物联网数据处理装置，其特征在于，包括：

第三接收模块，用于接收扩展协议报文，所述扩展协议报文包括数据终端的身份信息；

认证模块，用于根据所述扩展协议报文，对所述数据终端进行安全认证，得到安全认证结果；

发送模块，用于发送所述安全认证结果。

9.一种物联网数据处理设备，其特征在于，包括存储器和处理器，所述存储器和所述处理器之间互相通信连接，所述存储器中存储有计算机指令，所述处理器通过执行所述计算机指令，从而执行权利要求1-6中任一项所述的物联网数据处理方法。

10.一种计算机可读存储介质，其特征在于，所述计算机可读存储介质存储有计算机指令，所述计算机指令用于使所述计算机执行权利要求1-6中任一项所述的物联网数据处理方法。

Images