CN118733301A - 一种数据传输的处理方法和装置、存储介质和电子设备 - Google Patents

Abstract

本申请公开一种数据传输的处理方法和装置、存储介质和电子设备；所述数据传输的处理方法包括：接收待发送的目标指令分片；所述目标指令分片是对任务指令中已有数据分片进行改装处理后的指令分片；确定通信连接通道中指令队列的状态是否为空；若是，根据所述目标指令分片的属性数据中分片类型，确定所述目标指令分片要执行的操作为发送还是排队等待；若否，根据所述目标指令分片与所述指令队列中当前任务指令之间的关联关系，确定对所述目标指令分片要执行的操作为发送还是排队等待。本方法通过对已有数据分片进行改装形成多个独立指令分片单元，在较为复杂的任务指令场景下，依然能够保持指令分片发送的有序性。

Description

一种数据传输的处理方法和装置、存储介质和电子设备

技术领域

本申请涉及一种网络数据传输技术领域，具体涉及一种数据传输的处理方法和装置。本申请同时涉及一种计算机存储介质和电子设备。

背景技术

物联网(Internet of Things，IoT)技术的产生是信息技术发展到一定阶段的必然产物，它的出现极大地推动了智能化、自动化和网络化的发展。物联网技术已广泛应用于智能家居、智能交通、智慧农业、工业自动化、智慧城市、运动健康、智能零售、能源管理、智能医疗等多个领域。

网关是(Gateway)在物联网(IoT)系统或者在人工智能与物联网相结合的场景中扮演着至关重要的角色，例如：通过有线或无线的方式将数据传输到云端或本地服务器。这种传输能力使得物联网系统能够跨越地理限制，实现远程监控和控制。物联网系统通常包含大量设备，每个设备都可能产生大量的数据。网关能够收集来自多个设备的数据，并进行初步的处理和整合，然后将整合后的数据发送到云端或其他中央处理系统。另外，随着物联网技术的发展，越来越多的计算任务被转移到设备的边缘进行，即边缘计算。网关作为物联网系统的边缘节点，可以承担一部分计算任务，如数据处理、分析、决策等。总之，网关在物联网系统中发挥着至关重要的作用，它不仅是不同协议和设备之间的桥梁，还是数据聚合、传输、安全和管理的关键节点。

由于网关能够支持数千万级设备连接的关键枢纽，每秒实时处理数据量较大，该过程会涉及到庞大的资源消耗和负责的系统协调工作，随着任务场景日益丰富，服务端需传输至设备端的数据内容变得更加庞杂，对于设备网关而言，意味着要同时管理和协调众多内容传输，这样会导致下行通道拥塞问题的出现，进而造成系统资源的浪费和传输效率的降低

发明内容

本申请提供一种数据传输的处理方法，以解决现有技术中通过通道锁保证数据传输的连贯性和顺序性导致性能开销并降低系统吞吐量的问题。

本申请提供一种数据传输的处理方法，包括：

接收待发送的目标指令分片；所述目标指令分片是对任务指令中已有数据分片进行改装处理后的指令分片；

确定通信连接通道中指令队列的状态是否为空；

若是，根据所述目标指令分片的属性数据中分片类型，确定所述目标指令分片要执行的操作为发送还是排队等待；

若否，根据所述目标指令分片与所述指令队列中当前任务指令之间的关联关系，确定对所述目标指令分片要执行的操作为发送还是排队等待；其中，所述当前任务指令为所述通信连接通道正在执行发送的任务指令。

可选的，所述根据所述目标指令分片的属性数据中的分片类型，确定所述目标指令分片要执行的操作为发送还是排队等待，包括：

当所述指令队列状态为空时，根据所述目标指令分片的属性数据中类型标识，确定所述目标指令分片的所述分片类型；

当所述分片类型为指令头分片时，发送所述指令头分片；

当所述分片类型为指令附件分片时，根据所述属性数据中分片指令标识，确定与所述指令附件分片具有关联关系的任务指令中的指令头分片是否已发送；

若是，则发送所述指令附件分片。

可选的，所述当所述分片类型为指令头分片时，发送所述指令头分片，还包括：

根据所述属性数据中附件分片标识，确定与所述指令头分片具有关联关系的任务指令中，是否包括所述指令附件分片；

若是，对已执行发送的所述指令头分片进行标记。

可选的，所述当所述分片类型为指令附件分片时，根据所述属性数据中分片指令标识，确定与所述指令附件分片具有关联关系的任务指令中的指令头分片是否已发送，还包括：

若否，则根据所述分片指令标识，确定所述指令队列中是否有与所述指令附件分片相关联的排队任务指令队列；

若有排队任务指令队列，则将所述指令附件分片放入所述排队任务指令队列中进行所述排队等待。

可选的，所述根据所述目标指令分片与所述指令队列中当前任务指令之间的关联关系，确定对所述目标指令分片要执行的操作为发送还是排队等待，包括：

当所述指令队列状态为非空时，根据所述目标指令分片的属性数据中分片指令标识，确定所述目标指令分片所属任务指令是否为所述指令队列中的所述当前任务指令；

若是，则根据所述当前指令分片的属性数据中类型标识，确定所述目标指令分片的分片类型；

当所述分片类型为所述指令头分片时，发送所述指令头分片；以及发送与所述当前任务指令在所述指令队列中的指令附件分片，并对已执行发送的所述指令头分片进行标记；

当所述分片类型为所述指令附件分片时，确定所述当前任务指令中的指令头分片是否已发送；

若是，则发送所述指令附件分片。

可选的，还包括：

所述当所述分片类型为所述指令附件分片时，确定所述当前任务指令中的指令头分片是否已发送，为否时，则根据所述指令附件分片的属性数据中分片排序标识，将所述指令附件分片插入到所述指令队列相应的位置进行排队等待。

可选的，还包括：

当所述确定所述目标指令分片所属任务指令，是否为所述指令队列中当前任务指令，为否时，根据所述目标指令分片的属性数据中分片排序标识和分片指令标识，确定所述目标指令分片在所述指令队列中是否存在对应的位置；

若是，将所述目标指令分片插入到所述指令队列中对应的位置。

可选的，所述根据所述目标指令分片属性数据中分片排序标识和分片指令标识，确定所述目标指令分片在所述指令队列中是否存在对应的位置，包括：

根据所述目标指令分片属性数据中分片指令标识，确定所述指令队列中是否存在与所述目标指令分片相关联的排队任务指令队列；

若是，则根据所述目标指令分片属性数据分片排序标识，确定所述目标指令分片在所述排队任务指令队列中的位置。

可选的，还包括：

根据所述目标指令分片属性数据中分片排序标识，确定所述目标指令分片是否为所属任务指令在所述指令队列中的末尾分片；

若是，则在所述目标指令分片发送完成后，接收新的待发送的目标指令分片继续执行所述确定通信连接通道中指令队列的状态是否为空的步骤，直到所有任务指令完成；或者，从所述指令队列中提取首个任务指令的指令分片作为所述目标指令分片，继续执行所述根据所述目标指令分片与所述指令队列中当前任务指令之间的关联关系，确定对所述目标指令分片要执行的操作为发送还是排队等待的步骤，直到所述指令队列为空。

可选的，还包括：

对所述任务指令进行解析，确定所述任务指令中指令头分片和指令附件分片；

在所述指令头分片和所述指令附件分片中分别记录所述属性数据。

本申请还提供一种数据传输的处理装置，包括：

接收单元，用于接收待发送的目标指令分片；所述目标指令分片是对任务指令中已有指令分片进行改装处理后的指令分片；

判断单元，用于确定长连接通道中指令队列的状态是否为空；

第一确定单元，用于根据所述判断单元的判断结果为是时，根据所述目标指令分片的属性数据中分片类型，确定所述目标指令分片要执行的操作为发送还是排队等待；

第二确定单元，用于根据所述判断单元的判断结果为否时，根据所述目标指令分片与所述指令队列中当前任务指令之间的关联关系，确定对所述目标指令分片要执行的操作为发送还是排队等待；其中，所述当前任务指令为所述长连接通道正在执行发送的任务指令。

本申请还提供一种智能互联数据传输系统，包括：服务端、网关和电子设备；

所述服务端对待发送到所述电子设备的任务指令进行数据分片改装处理，并将改装后的目标指令分片发送到所述网关；

所述网关确定通信连接通道中指令队列的状态是否为空，若是，则根据接收的所述目标指令分片的属性数据中分片类型，确定所述目标指令分片要执行的操作为发送还是排队等待；若否，则根据所述目标指令分片与所述指令队列中当前任务指令之间的关联关系，确定对所述目标指令分片要执行的操作为发送还是排队等待；其中，所述当前任务指令为所述通信连接通道正在执行发送的任务指令。

本申请还提供一种计算机存储介质，用于存储网络平台产生数据，以及对应所述网络平台产生数据进行处理的程序；

所述程序在被处理器读取执行时，执行如上述技术方案所述的数据传输的处理方法。

本申请还提供一种电子设备，包括：

处理器；

存储器，用于存储对网络平台产生数据进行处理的程序，所述程序在被所述处理器读取执行时，执行如上述任一项技术方案所述的数据传输的处理方法。

与现有技术相比，本申请具有以下优点:

本申请提供的一种数据传输的处理方法通过对任务指令进行解析并对已有数据分片进行改装形成多个独立指令分片单元，再分别根据通信连接通道中指令对应的状态分别对接收的目标指令分片进行相应的发送或排队等待处理，通过目标指令分片的属性数据能够区别指令分片的类型以及确保同一任务指令中内部指令分片发送的顺序，并且通过通信连接通道中的指令队列存放排队等待发送的指令分片，实现服务线程与IO线程的解耦，提升并发场景下的传输处理能力，以及通过指令分片的类型驱动发送执行，也能够提升指令队列中处于排队等待的指令分片的发送效率，在较为复杂的任务指令场景下，依然能够保持指令分片发送的有序性。在人工智能或者人工智能+物联网等场景下，能够提升网关的整体性能，对于用户无感知进而提高用户体验。

附图说明

图1是本申请提供的一种数据传输的处理方法流程图；

图2是本申请提供的一种数据传输的处理方法中关于指令分片处理实施例的结构示意图；

图3是本申请提供的一种数据传输的处理方法中关于数据传输实施例的示意图；

图4是本申请提供的一种数据传输的处理装置的结构示意图；

图5是本申请提供的一种智能互联数据传输系统的结构示意图；

图6是本申请提供的一种电子设备的结构示意图。

具体实施方式

在下面的描述中阐述了很多具体细节以便于充分理解本申请。但是本申请能够以很多不同于在此描述的其它方式来实施，本领域技术人员可以在不违背本申请内涵的情况下做类似推广，因此本申请不受下面公开的具体实施的限制。

本申请中使用的术语是仅仅出于对特定实施例描述的目的，而非旨在限制本申请。在本申请中和所附权利要求书中所使用的描述方式例如：“一种”、“第一”、和“第二”等，并非对数量上的限定或先后顺序上的限定，而是用来将同一类型的信息彼此区分。

基于上述背景技术可知通过设备网关进行数据传输的过程中，会因为存在下行通道拥塞问题而造成系统资源的浪费和传输效率的降低。在服务端和设备端的通信过程中，为适应网络传输的要求，服务端通常会将完整的较大的消息内容分割为多个数据片段进行串行发送。以语音响应系统为例，一个完整的语音响应指令会被拆分为一个文本帧和多个连续的语音帧，这些帧构成了一个复合消息，它融合了多种数据类型，并最终在设备端被集成和解析为一条完整的语义指令。在处理请求的过程中，服务端常常采用异步多线程以提升处理效率。然而，这些异步操作可能导致文本帧与随后的语音帧之间出现时序混乱。而设备端按照消息的接收顺序来消费数据，若无法保证各帧之间的正确顺序，例如：协议要求连续的语音帧必须组合成一个完整的语义指令时，就会导致设备端出现语义解析错误，甚至系统崩溃的严重后果。因此，确保消息帧的准确时序排列对于维护系统稳定性和确保内容正确传递至关重要。

为确保服务端下发指令的顺序性，现有技术中提供一种通道锁机制进行控制数据帧的发送顺序，例如：线程A和线程B共同负责发送一个完整的指令内容；线程C独立发送一个完整的指令内容；而线程D和线程E则负责发送另一个完整的指令内容。在发送每一个完整指令前，线程必须获取得到设备长连接通道锁，从而获得发送数据权限。一旦获取发送权限，线程可向通道推送数据帧，而在通道锁被当前线程占用期间，任何其他指令都无法发送，必须等待当前指令发送完成才能进行。此外，在面对具有时序性要求的发送数据而言，还需要保证指令内部各个数据片段的顺序性，以保证发送指令的连贯性和顺序性。该现有技术存在的问题如下：

1、对于需要向通道中推送数据的所有线程，首先必须通过竞争获得通道锁，而锁机制通常需要在内核空间进行操作，这可能导致性能开销并降低系统吞吐量。尤其在高并发场景下，频繁的获取和释放锁会使得CPU时间过多地花费在锁的竞争和上下文切换上；

2、多指令发送场景下，多个线程竞争同一锁时，未能获取锁的线程将被阻塞，这将导致线程任务延迟，增加系统的响应时间，浪费线程资源；

3、在处理由多个数据帧构成的指令时(如语音指令)，为确保数据帧按序传输并维持指令完整性，需保持对通道锁的控制直至整个指令发送完毕。这一过程中，线程必须等待所有相关的异步线程或任务执行完毕，随后才能释放锁资源。虽能够保障传输顺序的一致性，但会导致线程资源的持续占用，进而造成处理器资源的无效利用。此外，还会存在超时和异常处理的问题，进而导致系统开发和维护的复杂性。

基于上述现有技术中因为通道锁机制而造成线程阻塞，从而导致系统性能瓶颈和线程切换开销等问题，本申请提供一种数据传输的处理方法，允许服务端线程向通道直接发起消息推送的过程中，无需依赖于阻塞同步或锁竞争机制，进一步的，还能够保证向通道推送消息的过程中维持任务执行的顺序性。下面对本申请提供的一种数据传输的处理方法进行详细描述。

如图1所示，图1是本申请提供的一种数据传输的处理方法的流程图，该方法包括：

步骤S101：接收待发送的目标指令分片；所述目标指令分片是对任务指令中已有指令分片进行改装处理后的指令分片；

步骤S102：确定长连接通道中指令队列的状态是否为空；

步骤S103：若是，根据所述目标指令分片的属性数据中分片类型，确定所述目标指令分片要执行的操作为发送还是排队等待；

步骤S104：若否，根据所述目标指令分片与所述指令队列中当前任务指令之间的关联关系，确定对所述目标指令分片要执行的操作为发送还是排队等待；其中，所述当前任务指令为所述长连接通道正在执行发送的任务指令。

在对上述步骤S101到步骤S104进行详细描述之前，对本实施例后续描述中所涉及的技术名词进行解释，以便更好的理解本申请所要保护的技术方案内容。

长连接：为一种网络通信机制，具体是指在网络通信中，客户端与服务器之间建立的一种持久的连接状态，允许连续的双向数据交换，而无需频繁建立和断开连接，能够减少频繁建立连接和断开连接的开销，提高数据传输的效率。

短连接：是指在网络通信中，客户端与服务器之间建立的一种短暂的连接状态。与长连接不同，短连接在每次数据传输完成后都会立即关闭连接，不会长时间保持连接状态。

任务指令：一般指长连接通信中，服务端给设备端发送的消息。

帧：网络传输协议中定义的基本传输单元，包含数据的头部、数据内容和数据的尾部。

线程阻塞：在程序执行过程中，线程因等待某些条件(如I/O操作完成、资源可用或同步锁释放)而暂停执行，直到条件满足才能继续。

关于步骤S101：接收待发送的目标指令分片；所述目标指令分片是对任务指令中已有指令分片进行改装处理后的指令分片。

所述步骤S101中待发送目标指令分片是对任务指令中已有指令分片改装后得到的指令分片，也就是说，本实施例中，需要对任务指令进行指令分片改装，形成目标指令分片。所述目标指令分片作为待发送的指令分片会被发送到通信连接通道中。因此，还包括：

步骤S101-1：对所述任务指令进行解析，确定所述任务指令中指令头分片和指令附件分片。

步骤S101-2：在所述指令头分片和所述指令附件分片中分别记录所述属性数据。

如图2所示，图2是本申请提供的一种数据传输的处理方法中关于指令分片处理实施例的结构示意图。其中，任务指令中根据携带的数据类型的不同，数据帧可以包括不同类型，例如：文本帧(Text-Frame)、语音帧、二进制帧(Binary-Frame)和连续帧(Continuation-Frame)等。本实施例中可以根据任务指令中数据帧数量和类型，分别对指令分片进行改造，如图3中所示的任务指令为语音任务指令和非语音任务指令，可以理解的是，对于语音任务指令其所包括的数据分片之间会存在顺序性，例如：语音任务指令中可以包括文本帧1-语音帧2-语音帧3，文本帧5-语音帧6。非语音任务指令中包括文本帧4。根据应用场景的不同的任务指令之间可以存在顺序性也可以不存在顺序性，例如：服务端同时收到两个语音任务指令。

在本实施例中，任务指令中仅包括单一数据帧时，则表示任务指令中只存在一个数据帧表示完整指令含义，例如：对于应用场景为人工智能或者是人工智能+物联网场景下，任务指令可以包括语音指令和/或非语音指令(如文本帧)，如果是非语音指令则包括完整指令含义，进而能够作为指令头分片。当任务指令包括语音指令和非语音指令时，所述非语音指令为指令头分片，语音指令为指令附件分片。如果语音指令包括多个，则每个语音指令均可以定义为指令附件分片。本实施例中，对于同一个任务指令，可以包括文本帧和语音帧，其中文本帧，即非语音帧为指令头分片，语音帧为指令附件分片。对于不同的任务指令可以包括不同类型的数据帧，例如：任务指令1可以包括非语音帧1(文本帧)、语音帧2和语音帧3；任务指令2可以包括非语音帧4；任务指令3可以包括非语音帧5和语音帧6。具体结合数据传输时的应用场景，此处仅以人工智能或者是人工智能+物联网场景为例，在进行数据传输过程中所涉及到的任务指令为语音指令和/或非语音指令的情况，并不限于该种场景。例如：在其他一些需要通过数据分片完成的数据传输的场景均可。

本实施例中，对于同一任务指令所述指令附件分片(parts)位于指令头分片(head)之后，也就是说，同一任务指令中可以包括不同类型和/或相同类型的分片类型，本实施例中包括指令头分片类型和指令附件分片类型。每个指令分片包括对应的数据内容和属性数据，所述属性数据中可以包括：分片指令标识(id)，具有同一连接下的唯一性，用于区分不同任务指令和/或确定指令分片所属任务指令，即指令分片与任务指令之间的关联关系。所述指令分片的属性数据中包括：指令分片是否为指令附件部分分片(isParts)。所述指令分片的属性数据中包括：分片排序标识，即指令分片为所属任务指令的第几个分片(numberOfCommand)；和/或指令分片是否为所属任务指令的最后一个分片(finalFragment)。所述指令头分片属性数据中还可以包括：是否包括指令附件部分的标识。

本实施例中，经过分片改造后的完整任务指令中包括可以指令头分片、以及与指令头分片对应属性数据和数据内容，或者可以是指令头分片和指令附件分片，指令附件分片可以是一个或多个，指令头分片和指令附件分片分别包括对应的属性数据和数据内容。被分片改造后的完整任务指令会通过指令分片的方式发送到连接通道中，通过连接通道转发到对应的电子设备。也就是说，本实施例中，在人工智能或者是人工智能+物联网的应用场景下，服务端的任务指令经改造后，以指令分片的形式发送到连接通道，作为网关可响应的指令。

本实施例中，改装后的每个任务指令中相同类型的指令分片通过同一线程向所述长连接通道进行发送，不同类型的指令分片分别有不同的线程向所述长连接通道进行发送。所述任务指令的改装可以是通过线程完成也可以是在服务端完成，具体不限。

以上对任务指令中分片改造的描述，可以理解的是，在不同应用场景下可以结合具体需要传输的数据内容和/或传输协议进行分片改造，并不限于上述内容。

通过上述对任务指令中已有分片的改造，能够建立任务指令中每个分片与所属任务指令之间的关联关系，实现指令分片之间的划分和排序，以及任务指令之间的划分，使得指令附件分片能够跟随指令头分片，保证同一任务指令内消息的顺序性。

关于步骤S102：确定通信连接通道中指令队列的状态是否为空。

所述步骤S102中通信连接通道是用于将指令进行发送传输的通道，例如：网关通道。根据数据传输的通信需求可采用长连接通道、短连接通道等。本实施例中，主要以长连接通道为例，即确定长连接通道中指令队列的状态是否为空，指令队列中没有需要等待发送的指令分片。需要在对不同设备、不同请求区分的同时，保持同一设备、同一会话下的任务指令和/或数据流等顺序的有序性，通常是通过队列或其他方式保证指令的顺序传输。本实施例中，通过两种队列状态实现数据的顺序传输，即指令队列为空状态和非空状态。本实施例中，通过长连接通道中I/O线程执行指令队列中指令分片传输处理，进而能够实现与任务指令服务线程的解耦，有效提升服务数据并发场景下的传输处理能力。下面对指令队列为空和非空两种状态进行描述，即步骤S103和步骤S104。

关于步骤S103：若是，根据所述目标指令分片的属性数据中分片类型，确定所述目标指令分片要执行的操作为发送还是排队等待。

如图3所示，图3是本申请提供的一种数据传输的处理方法中关于数据传输实施例的示意图。所述步骤S103是步骤S102中指令队列的状态为空的处理过程。所述指令队列为空，说明在长连接通道的指令队列中不存在等待发送的指令分片，因此，所述步骤S103的具体实现过程可以包括：

步骤S103-1：当所述指令队列状态为空时，根据所述目标指令分片的属性数据中类型标识，确定所述当前指令分片的所述分片类型；例如：根据所述属性数据中记录的当前分片是否为指令附件部分分片的类型标识(isParts)，如果isParts：false，则说明所述目标指令分片的分片类型为指令头分片，如果isParts：true，则说明所述目标指令分片的分片类型为指令附件分片。

步骤S103-2：当所述分片类型为指令头分片时，发送所述指令头分片；即：当isParts：false说明所述目标指令分片为指令头分片，直接发送即可。

步骤S103-3：当所述分片类型为指令附件分片时，根据所述属性数据中分片指令标识，确定与所述指令附件分片具有关联关系的任务指令中的指令头分片是否已发送；即：当isParts：true说明所述目标指令分片为指令附件分片，需要先确定所述目标指令分片所属任务指令中的指令头分片是否发送，可以根据对已发送指令头分片的标记进行确定。

步骤S103-4：若是，则发送所述指令附件分片。

还包括：

步骤S103-51：所述步骤S103-3的结果若为否，则根据所述分片指令标识，确定所述指令队列中是否有与所述指令附件分片相关联的排队任务指令队列；所述长连接通道中的指令队列中可以包括多个尚未发送完结的排队任务指令队列。

步骤S103-52：若是，则将所述指令附件分片放入所述排队任务指令队列中进行所述排队等待；即将所述指令附件分片放入所述排队任务指令队列中进行缓存；当接收的目标指令分片为与所述指令附件分片归属于同一任务指令的指令头分片时，在执行发送后，所述指令附件也进行发送，即执行步骤S103-3，直到该任务指令下所有指令分片都发送完成后，将所述排队任务指令队列删除。或者，每发送完成一个指令分片则将其从所在的排队任务指令队列中删除。

步骤S103-53：若否，则在所述指令队列中建立所述指令附件分片具有关联关系的排队任务指令队列，将所述指令附件分片放入所述排队任务指令队列中进行缓存。

为保证指令分片发送的顺序性，所述步骤S103-2还可以包括：

步骤S103-21：根据所述属性数据中附件分片标识，确定与所述指令头分片具有关联关系的任务指令中，是否包括所述指令附件分片；

步骤S103-22：若是，对已执行发送的所述指令头分片进行标记。若否，则说明任务指令中仅包括指令头分片，则可以不用标记，直接发送即可。

关于步骤S104：若否，根据所述目标指令分片与所述指令队列中当前任务指令之间的关联关系，确定对所述目标指令分片要执行的操作为发送还是排队等待；其中，所述当前任务指令为所述长连接通道正在执行发送的任务指令

如图3所示，图3是本申请提供的一种数据传输的处理方法中关于数据传输实施例的示意图。所述步骤S104是步骤S102中指令队列的状态为非空的处理过程。所述指令队列为非空，说明在长连接通道的指令队列中存在等待发送的指令分片，因此，所述步骤S104的具体实现过程可以包括：

步骤S104-11：当所述指令队列状态为非空时，根据所述目标指令分片的属性数据中分片指令标识，确定所述目标指令分片所属任务指令是否为所述指令队列中的所述当前任务指令；具体可以是，在接收到所述目标指令分片时，从指令队列中获取长连接通道中正在执行发送的当前任务指令，根据所述目标指令分片属性数据中记录的分片指令标识与当前任务指令标识是否相同，如果相同，则说明所述目标指令分片属于所述当前任务指令中的分片，如果不相同，则说明所述目标指令分片与所述当前任务指令不存在关联关系。

步骤S104-12：若是，则根据所述当前指令分片的属性数据中类型标识，确定所述目标指令分片的分片类型；

步骤S104-13：当所述分片类型为所述指令头分片时，发送所述指令头分片；以及发送所述当前任务指令在所述指令队列中的指令附件分片，并对已执行发送的所述指令头分片进行标记；

步骤S104-14：当所述分片类型为所述指令附件分片时，确定所述当前任务指令中的指令头分片是否已发送；

步骤S104-15：若是，则发送所述指令附件分片。若否，则根据所述指令附件分片的属性数据中分片排序标识，将所述指令附件分片插入到所述指令队列相应的位置进行排队等待。例如：如果所述指令附件分片的分片排序标识为当前任务指令中的第2个分片，则将该指令附件分片插入到所述当前任务指令所在排队任务指令队列中的第二个位置。即将所述指令附件分片放入所述排队任务指令队列中进行缓存；当接收的目标指令分片为指令头分片，且与所述指令附件分片归属于同一任务指令时，在执行对指令头分片的发送后，所述指令附件也进行发送，即执行步骤S104-13，直到该任务指令下所有指令分片都发送完成后，将所述排队任务指令队列删除。或者，每发送完成一个指令分片则将其从所在长连接通道中的所述排队任务指令队列中删除。

以上是对所述目标指令分片所属任务指令为所述指令队列中的当前任务指令时，对指令分片的传输处理过程。

为保证数据传输过程的有序性，当所述目标指令分片所属任务指令并非所述指令队列中的当前任务指令时，还可以包括：

步骤S104-21：当所述确定所述目标指令分片所属任务指令，是否为所述指令队列中当前任务指令为否时，根据所述目标指令分片的属性数据中分片排序标识和分片指令标识，确定所述目标指令分片在所述指令队列中是否存在对应的位置；例如：所述目标指令分片的分片排序标识表示为所属任务指令中的最后一个分片，或者是第二个分片等，或者所述目标指令分片在中所述指令队列中没有所属任务指令的位置，即长连接通道接收的所述目标指令分片是所属任务指令中的第一个分片，因此在所述指令队列中还没有任务指令队列，即没有相应位置。

步骤S104-22：若是，将所述目标指令分片插入到所述指令队列中对应的位置。若否，则将所述指令队列的队尾确定为所述目标指令分片在所述指令队列中的位置，并将所述目标指令分片插入到所述队尾。

所述步骤S104-21的具体实现过程可以包括：

步骤S104-211：根据所述目标指令分片属性数据中分片指令标识，确定所述指令队列中是否存在与所述目标指令分片相关联的排队任务指令队列；

步骤S104-212：若是，则根据所述目标指令分片属性数据分片排序标识，确定所述目标指令分片在所述排队任务指令队列中的位置。若所述指令队列中不存在与所述目标指令分片相关联的排队任务指令队列，则将所述目标指令分片插入到所述指令队列的队尾。

不论上述指令队列为空还是非空，还包括：

根据所述目标指令分片属性数据中分片排序标识，确定所述目标指令分片是否为所属任务指令中的末尾分片；

若是，则在所述目标指令分片发送完成后，继续执行所述步骤S103或者步骤S104，直到所述指令队列为空。

可以理解的是，对于指令队列为空的情况下，可以根据上述步骤S103的内容中执行，当执行步骤S103-51、步骤S103-52和步骤S103-53，则说明指令队列中从空状态转为非空状态，后续的执行可以按照步骤S104的内容进行。在指令队列非空状态时，需要将指令队列中的所有指令分片按照顺序依次传输，执行过程可以循环上述步骤S104中的步骤S104-11到步骤S104-22，直到指令队列中所有排队任务指令队列全部完成发送，即指令队列为空。也就是说，当所述目标指令分片为所属任务指令在所述指令队列中的末尾分片，且已发送完整，则需要获取下一个新的目标指令分片继续执行上述相应的发送操作，即：接收新的待发送的目标指令分片，继续执行所述确定通信连接通道中指令队列的状态是否为空的步骤，直到所有任务指令完成；或者，从所述指令队列中提取首个任务指令的指令分片作为所述目标指令分片，继续执行所述根据所述目标指令分片与所述指令队列中当前任务指令之间的关联关系，确定对所述目标指令分片要执行的操作为发送还是排队等待的步骤，直到所述指令队列为空。

可以理解的是，避免因网络或下游瓶颈等问题导致改装后的指令分片，在通信连接通道中生成阻塞，进而导致指令队列后续指令分片的发送受阻，所述指令分片的属性数据中还可以包括针对指令分片的发送时间范围，如果在发送时间范围内所述指令分片没有发送完成，则会跳转到该指令分片在所述指令队列中的下一个指令分片进行传输处理。

以上是对本申请提供的一种数据传输的处理方法的描述，该处理方法通过对任务指令进行解析并对已有数据分片进行改装形成多个独立指令分片单元，再分别根据通信连接通道中指令对应的状态分别对接收的目标指令分片进行相应的发送或排队等待处理，通过目标指令分片的属性数据能够区别指令分片的类型以及确保同一任务指令中内部指令分片发送的顺序，并且通过通信连接通道中的指令队列存放排队等待发送的指令分片，实现服务线程与IO操作线程的解耦，提升并发场景下的传输处理能力，以及通过指令分片的类型驱动发送执行，也能够提升指令队列中处于排队等待的指令分片的发送效率，在较为复杂的任务指令场景下，依然能够保持指令分片发送的有序性。在人工智能或者人工智能+物联网等场景下，能够提升网关的整体性能，对于用户无感知进而提高用户体验。

以上是对本申请提供的一种数据传输的处理方法实施例的具体描述，与前述提供的一种数据传输的处理方法实施例相对应，本申请还公开一种数据传输的处理装置实施例，请参看图4，由于装置实施例基本相似于方法实施例，所以描述得比较简单，相关之处参见方法实施例的部分说明即可。下述描述的装置实施例仅仅是示意性的。

如图4所示，图4是本申请提供的一种数据传输的处理装置的结构示意图，该装置包括：

接收单元401，用于接收待发送的目标指令分片；所述目标指令分片是对任务指令中已有指令分片进行改装处理后的指令分片；

判断单元402，用于确定长连接通道中指令队列的状态是否为空；

第一确定单元403，用于根据所述判断单元的判断结果为是时，根据所述目标指令分片的属性数据中分片类型，确定所述目标指令分片要执行的操作为发送还是排队等待；

第二确定单元404，用于根据所述判断单元的判断结果为否时，根据所述目标指令分片与所述指令队列中当前任务指令之间的关联关系，确定对所述目标指令分片要执行的操作为发送还是排队等待；其中，所述当前任务指令为所述长连接通道正在执行发送的任务指令。

进一步还包括：解析单元和记录单元；其中，所述解析单元，用于对所述任务指令进行解析，确定所述任务指令中指令头分片和指令附件分片。所述记录单元，用于在所述指令头分片和所述指令附件分片中分别记录所述属性数据。

方式一：

所述判断单元402包括：第一确定子单元、第一发送子单元、第二确定子单元和第二发送子单元；

所述第一确定子单元，用于当所述指令队列状态为空时，根据所述目标指令分片的属性数据中类型标识，确定所述目标指令分片的所述分片类型。

所述第一发送子单元，用于当所述分片类型为指令头分片时，发送所述指令头分片。

所述第二确定子单元，用于当所述分片类型为指令附件分片时，根据所述属性数据中分片指令标识，确定与所述指令附件分片具有关联关系的任务指令中的指令头分片是否已发送；

所述第二发送子单元，用于所述第二确定子单元的确定结果为是时，则发送所述指令附件分片。

所述第一发送子单元包括：附件分片确定子单元，用于根据所述属性数据中附件分片标识，确定与所述指令头分片具有关联关系的任务指令中，是否包括所述指令附件分片；标记子单元，用于所述附件分片确定子单元的确定结果为是时，对已执行发送的所述指令头分片进行标记。

所述第二确定子单元还包括：队列确定子单元，用于所述第二确定子单元的确定结果为否，则根据所述分片指令标识，确定所述指令队列中是否有与所述指令附件分片相关联的排队任务指令队列；放入子单元，用于若有排队任务指令队列，则将所述指令附件分片放入所述排队任务指令队列中进行所述排队等待。

方式二：

所述判断单元402包括：第一确定子单元，用于当所述指令队列状态为非空时，根据所述目标指令分片的属性数据中分片指令标识，确定所述目标指令分片所属任务指令是否为所述指令队列中的所述当前任务指令；所述第二确定子单元，用于基于所述第一确定子单元的确定结果为是，则根据所述当前指令分片的属性数据中类型标识，确定所述目标指令分片的分片类型；第一发送子单元，用于当所述分片类型为所述指令头分片时，发送所述指令头分片；以及发送与所述当前任务指令在所述指令队列中的指令附件分片，并对已执行发送的所述指令头分片进行标记；第三确定子单元，用于当所述分片类型为所述指令附件分片时，确定所述当前任务指令中的指令头分片是否已发送；第二发送子单元，用于基于所述第三确定子单元的确定结果是时，发送所述指令附件分片。

还包括：插入子单元，用于根据所述第三确定子单元的确定结果为否时，根据所述指令附件分片的属性数据中分片排序标识，将所述指令附件分片插入到所述指令队列相应的位置进行排队等待。

当所述第一确定子单元的确定结果为否时，包括：第一位置确定子单元，用于根据所述目标指令分片的属性数据中分片排序标识和分片指令标识，确定所述目标指令分片在所述指令队列中是否存在对应的位置，具体为：根据所述目标指令分片属性数据中分片指令标识，确定所述指令队列中是否存在与所述目标指令分片相关联的排队任务指令队列；若是，则根据所述目标指令分片属性数据分片排序标识，确定所述目标指令分片在所述排队任务指令队列中的位置。所述插入子单元，用于所述目标指令分片插入到所述指令队列中对应的位置。

还包括：若所述指令队列中不存在与所述目标指令分片相关联的排队任务指令队列，则将所述指令队列的队尾确定为所述目标指令分片在所述指令队列中的位置。

还包括：根据所述目标指令分片属性数据中分片排序标识，确定所述目标指令分片是否为所属任务指令在所述指令队列中的末尾分片；若是，则在所述目标指令分片发送完成后，接收新的待发送的目标指令分片继续执行所述确定通信连接通道中指令队列的状态是否为空的步骤，直到所有任务指令完成；或者，从所述指令队列中提取首个任务指令的指令分片作为所述目标指令分片，继续执行所述根据所述目标指令分片与所述指令队列中当前任务指令之间的关联关系，确定对所述目标指令分片要执行的操作为发送还是排队等待的步骤，直到所述指令队列为空。

以上是对本申请提供的一种数据传输的处理装置实施例的描述，该是装置具体实施过程可以参考上述处理方法的具体实现过程，此处不再详述。

基于上述本申请还提供一种智能互联数据传输系统，如图5所示，图5是，包括：服务端501、网关502和电子设备503；

所述服务端501对待发送到所述电子设备503的任务指令进行数据分片改装处理，并将改装后的目标指令分片发送到所述网关502；

所述网关502确定通信连接通道中指令队列的状态是否为空，若是，则根据接收的所述目标指令分片的属性数据中分片类型，确定所述目标指令分片要执行的操作为发送还是排队等待；若否，则根据所述目标指令分片与所述指令队列中当前任务指令之间的关联关系，确定对所述目标指令分片要执行的操作为发送还是排队等待；其中，所述当前任务指令为所述通信连接通道正在执行发送的任务指令。

本实施例中，所述电子设备503可以为一个或多个。

关于上述智能互联数据传输系统的具体内容可以参考上述数据传输的处理方法实施例的描述，此处不再详述。

基于上述内容，本申请还提供一种计算机存储介质，用于存储网络平台产生数据，以及对应所述网络平台产生数据进行处理的程序；

所述程序在被处理器读取执行时，执行如上述数据传输的处理方法中的步骤。

基于上述内容，本申请还提供一种电子设备，如图6所示，包括：

处理器601；

存储器602，用于存储对网络平台产生数据进行处理的程序，所述程序在被所述处理器读取执行时，执行如上述数据传输的处理方法的步骤。

需要说明的是，本申请所涉及的用户信息(包括但不限于用户设备信息、用户个人信息等)和数据(包括但不限于用于分析的数据、存储的数据、展示的数据等)，均为经用户授权或者经过各方充分授权的信息和数据，并且相关数据的收集、使用和处理需要遵守相关国家和地区的相关法律法规和标准，并提供有相应的操作入口，供用户选择授权或者拒绝。

在一个典型的配置中，计算设备包括一个或多个处理器(CPU)、输入/输出接口、网络接口和内存。

内存可能包括计算机可读介质中的非永久性存储器，随机存取存储器(RAM)和/或非易失性内存等形式，如只读存储器(ROM)或闪存(flash RAM)。内存是计算机可读介质的示例。

1、计算机可读介质包括永久性和非永久性、可移动和非可移动媒体可以由任何方法或技术来实现信息存储。信息可以是计算机可读指令、数据结构、程序的模块或其他数据。计算机的存储介质的例子包括，但不限于相变内存(PRAM)、静态随机存取存储器(SRAM)、动态随机存取存储器(DRAM)、其他类型的随机存取存储器(RAM)、只读存储器(ROM)、电可擦除可编程只读存储器(EEPROM)、快闪记忆体或其他内存技术、只读光盘只读存储器(CD-ROM)、数字多功能光盘(DVD)或其他光学存储、磁盒式磁带，磁带磁磁盘存储或其他磁性存储设备或任何其他非传输介质，可用于存储可以被计算设备访问的信息。按照本文中的界定，计算机可读介质不包括非暂存电脑可读媒体(transitory media)，如调制的数据信号和载波。

2、本领域技术人员应明白，本申请的实施例可提供为方法、系统或计算机程序产品。因此，本申请可采用完全硬件实施例、完全软件实施例或结合软件和硬件方面的实施例的形式。而且，本申请可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、CD-ROM、光学存储器等)上实施的计算机程序产品的形式。

本申请虽然以较佳实施例公开如上，但其并不是用来限定本申请，任何本领域技术人员在不脱离本申请的精神和范围内，都可以做出可能的变动和修改，因此本申请的保护范围应当以本申请权利要求所界定的范围为准。

Claims (14)

1.一种数据传输的处理方法，其特征在于，包括：

接收待发送的目标指令分片；所述目标指令分片是对任务指令中已有数据分片进行改装处理后的指令分片；

确定通信连接通道中指令队列的状态是否为空；

若是，根据所述目标指令分片的属性数据中分片类型，确定所述目标指令分片要执行的操作为发送还是排队等待；

若否，根据所述目标指令分片与所述指令队列中当前任务指令之间的关联关系，确定对所述目标指令分片要执行的操作为发送还是排队等待；其中，所述当前任务指令为所述通信连接通道正在执行发送的任务指令。

2.根据权利要求1所述的数据传输的处理方法，其特征在于，所述根据所述目标指令分片的属性数据中的分片类型，确定所述目标指令分片要执行的操作为发送还是排队等待，包括：

当所述指令队列状态为空时，根据所述目标指令分片的属性数据中类型标识，确定所述目标指令分片的所述分片类型；

当所述分片类型为指令头分片时，发送所述指令头分片；

当所述分片类型为指令附件分片时，根据所述属性数据中分片指令标识，确定与所述指令附件分片具有关联关系的任务指令中的指令头分片是否已发送；

若是，则发送所述指令附件分片。

3.根据权利要求2所述的数据传输的处理方法，其特征在于，所述当所述分片类型为指令头分片时，发送所述指令头分片，还包括：

根据所述属性数据中附件分片标识，确定与所述指令头分片具有关联关系的任务指令中，是否包括所述指令附件分片；

若是，对已执行发送的所述指令头分片进行标记。

4.根据权利要求2所述的数据传输的处理方法，其特征在于，所述当所述分片类型为指令附件分片时，根据所述属性数据中分片指令标识，确定与所述指令附件分片具有关联关系的任务指令中的指令头分片是否已发送，还包括：

若否，则根据所述分片指令标识，确定所述指令队列中是否有与所述指令附件分片相关联的排队任务指令队列；

若有排队任务指令队列，则将所述指令附件分片放入所述排队任务指令队列中进行所述排队等待。

5.根据权利要求1所述的数据传输的处理方法，其特征在于，所述根据所述目标指令分片与所述指令队列中当前任务指令之间的关联关系，确定对所述目标指令分片要执行的操作为发送还是排队等待，包括：

当所述指令队列状态为非空时，根据所述目标指令分片的属性数据中分片指令标识，确定所述目标指令分片所属任务指令是否为所述指令队列中的所述当前任务指令；

若是，则根据所述当前指令分片的属性数据中类型标识，确定所述目标指令分片的分片类型；

当所述分片类型为所述指令头分片时，发送所述指令头分片；以及发送与所述当前任务指令在所述指令队列中的指令附件分片，并对已执行发送的所述指令头分片进行标记；

当所述分片类型为所述指令附件分片时，确定所述当前任务指令中的指令头分片是否已发送；

若是，则发送所述指令附件分片。

6.根据权利要求5所述的数据传输的处理方法，其特征在于，还包括：

所述当所述分片类型为所述指令附件分片时，确定所述当前任务指令中的指令头分片是否已发送，为否时，则根据所述指令附件分片的属性数据中分片排序标识，将所述指令附件分片插入到所述指令队列相应的位置进行排队等待。

7.根据权利要求5所述的数据传输的处理方法，其特征在于，还包括：

当所述确定所述目标指令分片所属任务指令，是否为所述指令队列中当前任务指令，为否时，根据所述目标指令分片的属性数据中分片排序标识和分片指令标识，确定所述目标指令分片在所述指令队列中是否存在对应的位置；

若是，将所述目标指令分片插入到所述指令队列中对应的位置。

8.根据权利要求7所述的数据传输的处理方法，其特征在于，所述根据所述目标指令分片属性数据中分片排序标识和分片指令标识，确定所述目标指令分片在所述指令队列中是否存在对应的位置，包括：

根据所述目标指令分片属性数据中分片指令标识，确定所述指令队列中是否存在与所述目标指令分片相关联的排队任务指令队列；

若是，则根据所述目标指令分片属性数据分片排序标识，确定所述目标指令分片在所述排队任务指令队列中的位置。

9.根据权利要求1所述的数据传输的处理方法，其特征在于，还包括：

根据所述目标指令分片属性数据中分片排序标识，确定所述目标指令分片是否为所属任务指令在所述指令队列中的末尾分片；

若是，则在所述目标指令分片发送完成后，接收新的待发送的目标指令分片继续执行所述确定通信连接通道中指令队列的状态是否为空的步骤，直到所有任务指令完成；或者，从所述指令队列中提取首个任务指令的指令分片作为所述目标指令分片，继续执行所述根据所述目标指令分片与所述指令队列中当前任务指令之间的关联关系，确定对所述目标指令分片要执行的操作为发送还是排队等待的步骤，直到所述指令队列为空。

10.根据权利要求1所述的数据传输的处理方法，其特征在于，还包括：

对所述任务指令进行解析，确定所述任务指令中指令头分片和指令附件分片；

在所述指令头分片和所述指令附件分片中分别记录所述属性数据。

11.一种数据传输的处理装置，其特征在于，包括：

接收单元，用于接收待发送的目标指令分片；所述目标指令分片是对任务指令中已有指令分片进行改装处理后的指令分片；

判断单元，用于确定长连接通道中指令队列的状态是否为空；

第一确定单元，用于根据所述判断单元的判断结果为是时，根据所述目标指令分片的属性数据中分片类型，确定所述目标指令分片要执行的操作为发送还是排队等待；

第二确定单元，用于根据所述判断单元的判断结果为否时，根据所述目标指令分片与所述指令队列中当前任务指令之间的关联关系，确定对所述目标指令分片要执行的操作为发送还是排队等待；其中，所述当前任务指令为所述长连接通道正在执行发送的任务指令。

12.一种智能互联数据传输系统，其特征在于，包括：服务端、网关和电子设备；

所述服务端对待发送到所述电子设备的任务指令进行数据分片改装处理，并将改装后的目标指令分片发送到所述网关；

所述网关确定通信连接通道中指令队列的状态是否为空，若是，则根据接收的所述目标指令分片的属性数据中分片类型，确定所述目标指令分片要执行的操作为发送还是排队等待；若否，则根据所述目标指令分片与所述指令队列中当前任务指令之间的关联关系，确定对所述目标指令分片要执行的操作为发送还是排队等待；其中，所述当前任务指令为所述通信连接通道正在执行发送的任务指令。

13.一种计算机存储介质，用于存储网络平台产生数据，以及对应所述网络平台产生数据进行处理的程序；

所述程序在被处理器读取执行时，执行如上述权利要求1-11任一项所述的数据传输的处理方法。

14.一种电子设备，包括：

处理器；

存储器，用于存储对网络平台产生数据进行处理的程序，所述程序在被所述处理器读取执行时，执行如上述权利要求1-11任一项所述的数据传输的处理方法。