物联网平台设备交互控制方法
技术领域
本发明属于物联网技术领域，尤其涉及一种物联网平台设备交互控制方法。
背景技术
物联网(The Internet of things)也称传感网，是通过射频识别(RFI D)、红外感应器、全球定位系统、激光扫描器等信息传感设备，按约定的协议，把任何物品与互联网连接起来，进行信息交换和通讯，以实现智能化识别、定位、跟踪、监控和管理的一种网络。物联网设备包括：条码、射频识别(RFI D)、传感器、全球定位系统、激光扫描器。
现有技术中，连接到物联网的设备数量通常很庞大，各个物联网设备主动上报数据(例如各个物联网设备的状态)到物联网平台，但由于物联网设备、用户不停地向物联网平台发布数据或指令，且采集物联网设备数据的时间间隔短，物联网平台需要承担巨大的数据处理量，将各种不同格式的数据进行处理、分析，很难做到大量高并发处理物联网设备数据，容易导致物联网平台处理数据的效率低下。
发明内容
本发明提供一种物联网平台设备交互控制方法，能够大量高并发处理物联网设备数据，提高物联网平台处理数据的效率。
本发明是这样实现的，一种物联网平台设备交互控制方法，包括：
实时接收物联网设备发送的设备数据和/或用户发送的用户指令数据；
根据负载均衡机制确定处理所述设备数据和/或用户指令数据的代理服务；
所述代理服务将所述设备数据和/或用户指令数据的数据类型转换成物联网平台可以处理的数据格式；
将数据格式转换后的设备数据和/或用户指令数据发送给所述物联网平台，以使得所述物联网平台处理所述数据类型转换后的设备数据和/或用户指令数据。
更进一步地，所述根据负载均衡机制确定处理所述设备数据和/或用户指令数据的代理服务，包括：
根据预先配置、轮询机制、代理服务的运行状态确定所述设备数据和/或用户指令数据的代理服务。
更进一步地，所述根据负载均衡机制确定处理所述设备数据和/或用户指令数据的代理服务之后，所述方法还包括：
若所述代理服务的运行状态不足以处理所述设备数据和/或用户指令数据，则所述代理服务将所述设备数据和/或用户指令数据转发给其他能够进行处理的代理服务。
更进一步地，所述实时接收物联网设备发送的设备数据和/或用户发送的用户指令数据，包括：
实时接收所述物联网设备通过设备通道发送的设备数据，所述设备通道是所述物联网设备预先注册的用于发送所述设备数据的通道；和/或
实时接收所述用户通过用户通道发送的用户指令数据，所述用户通道是所述用户预先注册的用于发送所述用户指令数据的通道。
更进一步地，所述设备通道按照所述物联设备的设备类型和/或所述设备数据的数据类型进行划分，不同的设备通道用于发送不同设备类型和/或数据类型的设备数据。
更进一步地，在实时接收所述物联网设备通过设备通道发送的设备数据，或实时接收所述用户通过用户通道发送的用户指令数据之前，所述方法还包括：
确定所述物联网设备是否具有使用所述设备通道的权限；或确定所述用户是否具有使用所述用户通道的使用权限；
若所述物联网设备具有使用所述设备通道的权限，则实时接收所述物联网设备通过设备通道发送的设备数据；或
若所述用户具有使用所述用户通道的使用权限，则实时接收所述用户通过用户通道发送的用户指令数据。
本发明还提供一种物联网平台设备交互控制装置，所述装置包括：
接收模块，用于实时接收物联网设备发送的设备数据和/或用户发送的用户指令数据；
第一确定模块，用于根据负载均衡机制确定处理所述设备数据和/或用户指令数据的代理服务；
转换模块，用于所述代理服务将所述设备数据和/或用户指令数据的数据类型转换成物联网平台可以处理的数据格式；
发送模块，用于将数据格式转换后的设备数据和/或用户指令数据发送给所述物联网平台，以使得所述物联网平台处理所述数据类型转换后的设备数据和/或用户指令数据。
更进一步地，所述第一确定模块，具体用于：
根据预先配置、轮询机制、代理服务的运行状态确定所述设备数据和/或用户指令数据的代理服务。
更进一步地，所述装置还包括：
转发模块，用于当所述代理服务的运行状态不足以处理所述设备数据和/或用户指令数据时，所述代理服务将所述设备数据和/或用户指令数据转发给其他能够进行处理的代理服务。
更进一步地，所述接收模块，具体用于：
实时接收所述物联网设备通过设备通道发送的设备数据，所述设备通道是所述物联网设备预先注册的用于发送所述设备数据的通道；和/或
实时接收所述用户通过用户通道发送的用户指令数据，所述用户通道是所述用户预先注册的用于发送所述用户指令数据的通道。
更进一步地，所述设备通道按照所述物联设备的设备类型和/或所述设备数据的数据类型进行划分，不同的设备通道用于发送不同设备类型和/或数据类型的设备数据。
更进一步地，所述装置还包括：
第二确定模块，用于确定所述物联网设备是否具有使用所述设备通道的权限；或确定所述用户是否具有使用所述用户通道的使用权限；
若所述物联网设备具有使用所述设备通道的权限，则实时接收所述物联网设备通过设备通道发送的设备数据；或
若所述用户具有使用所述用户通道的使用权限，则实时接收所述用户通过用户通道发送的用户指令数据。
本发明还提供一种计算机设备，所述计算机设备包括处理器，所述处理器用于执行存储器中存储的计算机程序实现所述的方法的步骤。
本发明还提供一种存储介质，所述存储介质上存储有计算机程序，所述计算机程序被一个或多个处理器执行时，实现所述的方法的步骤。
本发明的有益效果在于，根据负载均衡机制确定处理设备数据和/或用户指令数据对应的代理服务，再利用代理服务将设备数据和/或用户指令数据的数据类型转换成物联网平台可以处理的数据格式，实现将原本由物联网平台完成的数据格式处理交由代理服务来完成，减轻了物联网平台的数据处理压力，能够大量高并发处理物联网设备数据，提高物联网平台处理数据的效率。
附图说明
图1是本发明实施例一提供的物联网平台设备交互控制方法应用的环境示意图；
图2是本发明实施例一提供的物联网平台设备交互控制方法流程图；
图3是本发明实施例一提供的物联网平台设备交互控制方法交互时序图；
图4是本发明实施例二提供的物联网平台设备交互控制方法流程图；
图5是本发明实施例四提供的物联网平台设备交互控制方法流程图；
图6是本发明实施例七提供的物联网平台设备交互控制装置框图；
图7是本发明实施例九提供的物联网平台设备交互控制装置框图；
图8是本发明实施例十二提供的物联网平台设备交互控制装置框图。
具体实施方式
为了使本发明的目的、技术方案及优点更加清楚明白，以下结合附图及实施例，对本发明进行进一步详细说明。应当理解，此处所描述的具体实施例仅仅用以解释本发明，并不用于限定本发明。
本发明实施例提供一种物联网平台设备交互控制方法，实时接收物联网设备发送的设备数据和/或用户发送的用户指令数据；根据负载均衡机制确定处理设备数据和/或用户指令数据的代理服务；通过该代理服务将设备数据和/或用户指令数据的数据类型转换成物联网平台可以处理的数据格式；将数据格式转换后的设备数据和/或用户指令数据发送给物联网平台。实现了将原本由物联网平台完成的数据格式处理交由代理服务来完成，减轻了物联网平台的数据处理压力，能够大量高并发处理物联网设备数据，提高物联网平台处理数据的效率，物联网设备、物联网平台、用户通过负载及安全中心进行与代理服务进行数据交换，实现设备、平台、用户之间的实时通讯。
实施例一
图1示出了物联网平台设备交互控制方法应用的环境，包括物联网平台、物联网设备、用户及代理服务器，代理服务器中设置有负载及安全中心及多个代理服务，多个代理服务之间桥接，物联网设备发布设备数据和/或用户发送用户指令数据到代理服务器的负载及安全中心，负载及安全中心根据负载均衡机制确定处理设备数据和/或用户指令数据的代理服务后，由代理服务器中的代理服务将设备数据和/或用户指令数据的数据类型转换成物联网平台可以处理的数据格式，并通过负载及安全中心发送给物联网平台，物联网平台对据格式转换后的设备数据和/或用户指令数据进行分析处理，将分析处理结果发布到代理服务器中的负载及安全中心，再由负载及安全中心下发到设备和/或用户。
图2示出了一种物联网平台设备交互控制方法流程图，在代理服务器中实现，如图2所示，本实施例提供的物联网平台设备交互控制方法，包括如下步骤：
步骤S100、实时接收物联网设备发送的设备数据和/或用户发送的用户指令数据。
步骤S200、根据负载均衡机制确定处理设备数据和/或用户指令数据的代理服务。
步骤S300、该代理服务将设备数据和/或用户指令数据的数据类型转换成物联网平台可以处理的数据格式。
步骤S400、将数据格式转换后的设备数据和/或用户指令数据发送给物联网平台，以使得物联网平台处理数据类型转换后的设备数据和/或用户指令数据。
该物联网平台设备交互控制方法的交互时序如图3所示，原理如下：
物联网设备发布设备数据到代理服务器中的负载及安全中心，和/或用户发送用户指令数据到代理服务器的负载及安全中心，负载及安全中心根据负载均衡机制确定处理设备数据和/或用户指令数据的代理服务后，由代理服务器中的代理服务将设备数据和/或用户指令数据的数据类型转换成物联网平台可以处理的数据格式，代理服务将数据格式转换后的设备数据和/或用户指令数据通过负载及安全中心发送给物联网平台，物联网平台对据格式转换后的设备数据和/或用户指令数据进行分析处理，例如，数据类型的识别，然后，将分析处理结果发布到代理服务器中的负载及安全中心，再由负载及安全中心下发到设备和/或用户。
可以理解的是，物联网设备可以包括但不限于：用于环境监控的PM2.5传感器、温度传感器等，用户指令可以包括但不限于：控制某个传感器开启或关闭，由于各个传感器的数据格式不同，无论是仅获取到设备数据还是用户指令，或是同时获取到设备数据和用户指令，都可以采用上述方法，将数据发布到代理服务器中，由负载及安全中心根据负载均衡机制确定处理设备数据和/或用户指令数据的代理服务，再由代理服务将设备数据和/或用户指令数据的数据类型转换成物联网平台可以处理的数据格式后，以消息形式上传到平台，避免直接由平台接收数据而造成的通讯效率低下。
本实施例中，根据负载均衡机制确定处理设备数据和/或用户指令数据对应的代理服务，再利用代理服务将设备数据和/或用户指令数据的数据类型转换成物联网平台可以处理的数据格式，实现将原本由物联网平台完成的数据格式处理交由代理服务来完成，减轻了物联网平台的数据处理压力，能够大量高并发处理物联网设备数据，提高物联网平台处理数据的效率，物联网设备、物联网平台、用户通过负载及安全中心进行与代理服务进行数据交换，实现设备、平台、用户之间的实时通讯。
实施例二
图4示出一种物联网平台设备交互控制方法，如图4所示，本实施例提供一种物联网平台设备交互控制方法，在实施例一的基础上，其中的步骤S200，包括：
步骤S210、根据预先配置、轮询机制、代理服务的运行状态确定设备数据和/或用户指令数据的代理服务。
具体地，负载均衡机制可以是预先配置、轮询机制、根据代理服务的运行状态确定哪个代理服务工作的机制。其中，预先配置是按预设的代理服务执行顺序，依次处理设备数据和/或用户指令数据；轮询机制是利用各个代理服务逐个执行处理设备数据和/或用户指令数据的操作；代理服务的运行状态，可以是工作与非工作状态，当新的设备数据和/或用户指令数据来到时，确定非工作状态的任一代理服务来完成数据类型转换工作，本发明实施例不做具体限定。
本实施例中，根据预先配置、轮询机制、代理服务的运行状态等负载均衡机制为多个代理服务分配任务，确定设备数据和/或用户指令数据对应的代理服务，在大规模数据来临时，避免增加单个代理服务的负担和造成数据通讯延时，通过负载均衡机制的部署，能够提高数据并发处理能力。
实施例三
本实施例提供一种物联网平台设备交互控制方法，在实施例一或二的基础上，步骤S200之后，该方法还包括：
若代理服务的运行状态不足以处理设备数据和/或用户指令数据，则代理服务将设备数据和/或用户指令数据转发给其他能够进行处理的代理服务。
可以理解的是，在图1所示的应用环境中，通过将各代理服务桥接，能够实现中断机制，即：任一代理服务的运行状态不足以处理设备数据和/或用户指令数据时，该代理服务可以将将设备数据和/或用户指令数据转发给其他能够进行处理的代理服务，以实现负载均衡。
本实施例中，在当前代理服务执行数据处理任务过程中，如果存在不足以处理设备数据和/或用户指令数据的情形，此时当前代理服务将数据处理任务转移给其他代理服务来完成任务，避免造成数据处理任务中断进而数据通讯延时。
实施例四
图5示出了一种物联网平台设备交互控制方法，如图5所示，本实施例提供一种物联网平台设备交互控制方法，在实施例一的基础上，步骤S100，包括：
步骤S110、实时接收物联网设备通过设备通道发送的设备数据，设备通道是物联网设备预先注册的用于发送设备数据的通道；和/或
步骤S120、实时接收用户通过用户通道发送的用户指令数据，该用户通道是用户预先注册的用于发送用户指令数据的通道。
具体来说，在实时接收物联网设备发送的设备数据和/或用户发送的用户指令数据之前，物联网设备需要预先注册用于发送设备数据的通道，用户需要预先注册用于发送用户指令数据的通道，当实时接收数据时，通过预先注册的通道进行数据发送，设备数据和/或用户指令数据通过各自的通道进入负载及安全中心相应的队列中，再转送到相应的代理服务中。
本实施例中，通过预先注册通道，在进行数据传输时，可以有效地将数据进行分通道传输，各通道分工明确，可以实现多通道同步传输，互不影响，既能有效提高数据传输效率，又避免了通信延迟。
实施例五
本实施例提供一种物联网平台设备交互控制方法，在实施例四的基础上，设备通道按照物联设备的设备类型和/或设备数据的数据类型进行划分，不同的设备通道用于发送不同设备类型和/或数据类型的设备数据。
举例来说，可以将物联网设备分为环境监测类型和智能交互类型，此时可以按照此两种类型设置两个设备通道，第一通道用于发送环境监测类型的物联网设备数据，第二通道用于发送智能交互类型物联网设备数据。
进一步可以理解的是，用户指令数据可以按照指令内容划分，例如，可以分为开启或关闭指令，此时可以按照此两种类型设置两个用户指令通道，第三通道用于发送用户的开启指令，第四通道用于发送用户的关闭指令。
本实施例中，通过预先按照设备类型和/或数据类型对用于发送设备数据的通道进行划分，可以实现根据不同的用户需求及数据处理情形，在进行数据传输时，可以有效地将数据进行分通道传输，各通道分工明确，可以实现多通道同步传输，互不影响，既能有效提高数据传输效率，又避免了通信延迟。
实施例六
本实施例提供一种物联网平台设备交互控制方法，在实施例四的基础上，在实时接收物联网设备通过设备通道发送的设备数据，或实时接收用户通过用户通道发送的用户指令数据之前，该方法还包括：
确定物联网设备是否具有使用设备通道的权限；或确定用户是否具有使用用户通道的使用权限；
若物联网设备具有使用设备通道的权限，则实时接收物联网设备通过设备通道发送的设备数据；或
若用户具有使用用户通道的使用权限，则实时接收用户通过用户通道发送的用户指令数据。
本实施例中，通过在实时接收数据前对物联网设备或用户进行通道的权限判断，确保有通道权限仅对有权限的对象开放，在进行分通道数据传输以提高传输效率的基础上，进一步实现了数据传输的安全性。
实施例七
与实施例一对应地，本实施例提供一种物联网平台设备交互控制装置，如图6所示，该装置包括：
接收模块100，用于实时接收物联网设备发送的设备数据和/或用户发送的用户指令数据；
第一确定模块200，用于根据负载均衡机制确定处理设备数据和/或用户指令数据的代理服务；
转换模块300，用于代理服务将设备数据和/或用户指令数据的数据类型转换成物联网平台可以处理的数据格式；
发送模块400，用于将数据格式转换后的设备数据和/或用户指令数据发送给物联网平台，以使得物联网平台处理数据类型转换后的设备数据和/或用户指令数据。
可以理解的是，本实施例中各模块的执行步骤请参见实施例一的相关描述，此处不再赘述。
本实施例中，根据负载均衡机制确定处理设备数据和/或用户指令数据对应的代理服务，再利用代理服务将设备数据和/或用户指令数据的数据类型转换成物联网平台可以处理的数据格式，实现将原本由物联网平台完成的数据格式处理交由代理服务来完成，减轻了物联网平台的数据处理压力，能够大量高并发处理物联网设备数据，提高物联网平台处理数据的效率，物联网设备、物联网平台、用户通过负载及安全中心进行与代理服务进行数据交换，实现设备、平台、用户之间的实时通讯。
实施例八
与实施例二对应地，本实施例提供一种物联网平台设备交互控制装置，在实施例七的基础上，其中的第一确定模块100，具体用于：
根据预先配置、轮询机制、代理服务的运行状态确定所述设备数据和/或用户指令数据的代理服务。
本实施例中，根据预先配置、轮询机制、代理服务的运行状态等负载均衡机制为多个代理服务分配任务，确定设备数据和/或用户指令数据对应的代理服务，在大规模数据来临时，避免增加单个代理服务的负担和造成数据通讯延时，通过负载均衡机制的部署，能够提高数据并发处理能力。
实施例九
与实施例三对应地，本实施例提供一种物联网平台设备交互控制装置，如图7所示，在实施例七或实施例八的基础上，该装置还包括：
转发模块500，用于当代理服务的运行状态不足以处理设备数据和/或用户指令数据时，代理服务将设备数据和/或用户指令数据转发给其他能够进行处理的代理服务。
本实施例中，在当前代理服务执行数据处理任务过程中，如果存在不足以处理设备数据和/或用户指令数据的情形，此时当前代理服务将数据处理任务转移给其他代理服务来完成任务，避免造成数据处理任务中断进而数据通讯延时。
实施例十
与实施例四对应地，本实施例提供一种物联网平台设备交互控制装置，在实施例七的基础上，其中的接收模块100，具体用于：
实时接收物联网设备通过设备通道发送的设备数据，设备通道是物联网设备预先注册的用于发送设备数据的通道；和/或
实时接收用户通过用户通道发送的用户指令数据，用户通道是用户预先注册的用于发送用户指令数据的通道。
本实施例中，通过预先注册通道，在进行数据传输时，可以有效地将数据进行分通道传输，各通道分工明确，可以实现多通道同步传输，互不影响，既能有效提高数据传输效率，又避免了通信延迟。
实施例十一
与实施例五对应地，本实施例提供一种物联网平台设备交互控制装置，在实施例十的基础上，设备通道按照物联设备的设备类型和/或设备数据的数据类型进行划分，不同的设备通道用于发送不同设备类型和/或数据类型的设备数据。
本实施例中，通过预先按照设备类型和/或数据类型对用于发送设备数据的通道进行划分，可以实现根据不同的用户需求及数据处理情形，在进行数据传输时，可以有效地将数据进行分通道传输，各通道分工明确，可以实现多通道同步传输，互不影响，既能有效提高数据传输效率，又避免了通信延迟。
实施例十二
与实施例六对应地，本实施例提供一种物联网平台设备交互控制装置，如图8所示，在实施例十的基础上，该装置还包括：
第二确定模块600，用于确定物联网设备是否具有使用设备通道的权限；或确定用户是否具有使用用户通道的使用权限；
若物联网设备具有使用设备通道的权限，则实时接收物联网设备通过设备通道发送的设备数据；或
若用户具有使用用户通道的使用权限，则实时接收用户通过用户通道发送的用户指令数据。
本实施例中，通过在实时接收数据前对物联网设备或用户进行通道的权限判断，确保有通道权限仅对有权限的对象开放，在进行分通道数据传输以提高传输效率的基础上，进一步实现了数据传输的安全性。
实施例十三
本实施例提供一种计算机设备，该计算机设备包括处理器，所述处理器用于执行存储器中存储的计算机程序实现实施例一至实施例六任一实施例提供的方法的步骤。
其中的处理器可以是专用集成电路(Application Specific IntegratedCircuit，简称ASIC)、数字信号处理器(Digital Signal Processor，简称DSP)、数字信号处理设备(Digital Signal Processing Device，简称DSPD)、可编程逻辑器件(ProgrammableLogic Device，简称PLD)、现场可编程门阵列(Field Programmable Gate Array，简称FPGA)、控制器、微控制器、微处理器或其他电子元件实现。方法具体步骤请参见实施例一，此处不再赘述。
实施例十四
本实施例提供一种存储介质，该存储介质上存储有计算机程序，该计算机程序被一个或多个处理器执行时，实现实施例一至实施例六任一实施例提供的方法的步骤。
上述存储介质可以是闪存、硬盘、多媒体卡、卡型存储器(例如，SD或DX存储器等)、随机访问存储器(RAM)、静态随机访问存储器(SRAM)、只读存储器(ROM)、电可擦除可编程只读存储器(EEPROM)、可编程只读存储器(PROM)、磁性存储器、磁盘、光盘、服务器、App应用商城等等。方法的具体步骤请参见实施例一，此处不再赘述。
综上所述，本发明实施例提供的物联网平台设备交互控制方法、装置、计算机设备及存储介质，根据负载均衡机制确定处理设备数据和/或用户指令数据对应的代理服务，再利用代理服务将设备数据和/或用户指令数据的数据类型转换成物联网平台可以处理的数据格式，实现将原本由物联网平台完成的数据格式处理交由代理服务来完成，减轻了物联网平台的数据处理压力，物联网设备、物联网平台、用户通过负载及安全中心进行与代理服务进行数据交换，实现设备、平台、用户之间的实时通讯。进一步地，根据预先配置、轮询机制、代理服务的运行状态等负载均衡机制为多个代理服务分配任务，确定设备数据和/或用户指令数据对应的代理服务，在大规模数据来临时，避免增加单个代理服务的负担和造成数据通讯延时，通过负载均衡机制的部署，能够提高数据并发处理能力。进一步地，在当前代理服务执行数据处理任务过程中，如果存在不足以处理设备数据和/或用户指令数据的情形，此时当前代理服务将数据处理任务转移给其他代理服务来完成任务，避免造成数据处理任务中断进而数据通讯延时。进一步地，通过预先注册通道，在进行数据传输时，可以有效地将数据进行分通道传输，各通道分工明确，可以实现多通道同步传输，互不影响，既能有效提高数据传输效率，又避免了通信延迟。进一步地，通过预先按照设备类型和/或数据类型对用于发送设备数据的通道进行划分，可以实现根据不同的用户需求及数据处理情形进行数据传输。进一步地，通过在实时接收数据前对物联网设备或用户进行通道的权限判断，确保有通道权限仅对有权限的对象开放，在进行分通道数据传输以提高传输效率的基础上，实现了数据传输的安全性。
以上所述仅为本发明的较佳实施例而已，并不用以限制本发明，凡在本发明的精神和原则之内所作的任何修改、等同替换和改进等，均应包含在本发明的保护范围之内。
