CN111479293A - 数据处理方法及装置 - Google Patents
数据处理方法及装置 Download PDFInfo
- Publication number
- CN111479293A CN111479293A CN202010302059.1A CN202010302059A CN111479293A CN 111479293 A CN111479293 A CN 111479293A CN 202010302059 A CN202010302059 A CN 202010302059A CN 111479293 A CN111479293 A CN 111479293A
- Authority
- CN
- China
- Prior art keywords
- transmitted
- queue
- data packet
- data packets
- tcp
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Granted
Links
Images
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04W—WIRELESS COMMUNICATION NETWORKS
- H04W28/00—Network traffic management; Network resource management
- H04W28/02—Traffic management, e.g. flow control or congestion control
- H04W28/0289—Congestion control
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04W—WIRELESS COMMUNICATION NETWORKS
- H04W80/00—Wireless network protocols or protocol adaptations to wireless operation
- H04W80/06—Transport layer protocols, e.g. TCP [Transport Control Protocol] over wireless
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
- Mobile Radio Communication Systems (AREA)
Abstract
本申请实施例提供一种数据处理方法及装置,该方法应用于终端设备,包括:在所述终端设备处于数据包阻塞状态时,在第一待传输队列的多个数据包中确定重复的数据包;根据所述重复的数据包,对所述多个数据包进行去重操作,得到第二待传输队列,所述第二待传输队列中的任意两个数据包均不相同。本申请实施例提供的方案,针对终端设备处于数据包阻塞状态时存在大量重复和无效的数据包的情形,对多个数据包进行了去重操作,减小了大量的重复和无效的数据包的重传,从而减小了需要传输的数据包的数量,从而减小了终端设备的数据包的阻塞。
Description
技术领域
本申请实施例涉及通信技术领域,尤其涉及一种数据处理方法及装置。
背景技术
基站和终端之间经常需要进行数据传输,其中,终端向基站传输上行数据是基于基站为终端分配的上行调度资源来完成的。
当终端设备处于弱场环境下,例如处于基站覆盖的边缘区或人群密集区时,由于信号差等原因,基站分配给终端的上行调度资源比较小,每次终端发送分片数据包较小,剩余数据包需要等待下次基站分配上行调度资源。目前的方案中,在终端没有接收到数据包传输成功的信息时,终端内部仍然会持续将该数据包进行重传,从而将该数据包加入待传输队列中等待传输,导致终端的待传输队列中堆积大量等待传输的数据包。这在终端的上行调度资源较小的情况下,会导致数据包阻塞的发生,各个数据包无法及时上传到基站。
发明内容
本申请实施例提供一种数据处理方法及装置,以解决终端设备在数据包阻塞较大导致各个数据包无法及时上传的问题。
第一方面,本申请实施例提供一种数据处理方法,应用于终端设备,包括:
在所述终端设备处于数据包阻塞状态时,在第一待传输队列的多个数据包中确定重复的数据包;
根据所述重复的数据包,对所述多个数据包进行去重操作,得到第二待传输队列,所述第二待传输队列中的任意两个数据包均不相同。
在一种可能的实施方式中,所述数据包为传输控制/网络协议TCP/IP数据包,所述重复的数据包为包头关键信息相同的TCP/IP数据包。
在一种可能的实施方式中,所述第二待传输队列中包括至少一个TCP/IP协议数据包,所述至少一个TCP/IP协议数据包在所述第二待传输队列中的发送优先级高于所述第二待传输队列中除所述至少一个TCP/IP协议数据包外的其他TCP/IP数据包。
在一种可能的实施方式中,所述包头关键信息包括:
IP版本、源IP地址、目的IP地址、源端口号、目的端口号、TCP SEQ值、包头长度和数据长度。
在一种可能的实施方式中,所述数据包阻塞状态为所述第一待传输队列的长度大于或等于预设长度。
在一种可能的实施方式中,所述方法还包括:
根据预设时间间隔获取上行调度资源;
若连续M次获取的上行调度资源值均小于或等于预设值,则根据所述第一待传输队列的长度判断所述终端设备是否处于数据包阻塞状态,所述M为大于1的整数。
在一种可能的实施方式中,所述方法还包括:
向网络设备发送所述第二待传输队列中的数据包。
第二方面,本申请实施例提供一种数据处理装置,包括:
确定模块,用于在终端设备处于数据包阻塞状态时,在第一待传输队列的多个数据包中确定重复的数据包;
处理模块,用于根据所述重复的数据包,对所述多个数据包进行去重操作,得到第二待传输队列,所述第二待传输队列中的任意两个数据包均不相同。
在一种可能的实施方式中,所述数据包为传输控制协/网络议TCP/IP数据包,所述重复的数据包为包头关键信息相同的TCP/IP数据包。
在一种可能的实施方式中,所述第二待传输队列中包括至少一个TCP/IP协议数据包,所述至少一个TCP/IP协议数据包在所述第二待传输队列中的发送优先级高于所述第二待传输队列中除所述至少一个TCP/IP协议数据包外的其他TCP/IP数据包。
在一种可能的实施方式中,所述包头关键信息包括:
IP版本、源IP地址、目的IP地址、源端口号、目的端口号、TCP SEQ值、包头长度和数据长度。
在一种可能的实施方式中,所述数据包阻塞状态为所述第一待传输队列的长度大于或等于预设长度。
在一种可能的实施方式中,所述确定模块还用于:
根据预设时间间隔获取上行调度资源;
若连续M次获取的上行调度资源值均小于或等于预设值,则根据所述第一待传输队列的长度判断所述终端设备是否处于数据包阻塞状态,所述M为大于1的整数。
在一种可能的实施方式中,所述处理模块还用于:
向网络设备发送所述第二待传输队列中的数据包。
第三方面,本申请实施例提供一种数据处理设备,包括:
存储器,用于存储程序;
处理器,用于执行所述存储器存储的所述程序,当所述程序被执行时,所述处理器用于执行如第一方面中任一所述的数据处理方法。
第四方面,本申请实施例提供一种计算机可读存储介质,包括指令,当其在计算机上运行时,使得计算机执行如第一方面中任一所述的数据处理方法。
本申请实施例提供的数据处理方法及装置,应用于终端设备,在终端设备处于数据包阻塞状态时,在第一待传输队列的多个数据包中确定重复的数据包,然后根据重复的数据包,对多个数据包进行去重操作,得到第二待传输队列,且第二待传输队列中的任意两个数据包均不相同。本申请实施例提供的方案,针对终端设备处于数据包阻塞状态时存在大量重复和无效的数据包的情形,对多个数据包进行了去重操作,减小了大量的重复和无效的数据包的重传,从而减小了需要传输的数据包的数量,从而减小了终端设备的数据包的阻塞。
附图说明
为了更清楚地说明本发明实施例或现有技术中的技术方案,下面将对实施例或现有技术描述中所需要使用的附图作一简单地介绍,显而易见地,下面描述中的附图是本发明的一些实施例,对于本领域普通技术人员来讲,在不付出创造性劳动性的前提下,还可以根据这些附图获得其他的附图。
图1为本申请实施例提供的应用场景的示意图;
图2为本申请实施例提供的数据处理方法的流程示意图;
图3为本申请实施例提供的第一待传输队列的示意图;
图4为本申请实施例提供的判断终端设备的状态的流程示意图;
图5为本申请实施例提供的数据包去重示意图;
图6为本申请实施例提供的数据包优先级排列示意图;
图7为本申请实施例提供的一种数据处理装置的结构示意图;
图8为本申请实施例提供的数据处理设备的硬件结构示意图。
具体实施方式
为使本申请实施例的目的、技术方案和优点更加清楚,下面将结合本申请实施例中的附图,对本申请实施例中的技术方案进行清楚、完整地描述,显然,所描述的实施例是本申请一部分实施例,而不是全部的实施例。基于本申请中的实施例,本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例,都属于本申请保护的范围。
为了便于理解,首先,对本申请所涉及的概念进行说明。
终端设备:是一种具有无线收发功能的设备。终端设备可以部署在陆地上,包括室内或室外、手持、穿戴或车载;也可以部署在水面上(如轮船等);还可以部署在空中(例如飞机、气球和卫星上等)。
终端设备可以是手机(mobile phone)、平板电脑(Pad)、带无线收发功能的电脑、虚拟现实(virtual reality,简称VR)终端设备、增强现实(augmented reality,简称AR)终端设备、工业控制(industrial control)中的无线终端、车载终端设备、无人驾驶(selfdriving)中的无线终端、远程医疗(remote medical)中的无线终端设备、智能电网(smartgrid)中的无线终端设备、运输安全(transportation safety)中的无线终端设备、智慧城市(smart city)中的无线终端设备、智慧家庭(smart home)中的无线终端设备、可穿戴终端设备等。
本申请实施例所涉及的终端设备还可以称为终端、用户设备(user equipment,UE)、接入终端设备、车载终端、工业控制终端、UE单元、UE站、移动站、移动台、远方站、远程终端设备、移动设备、UE终端设备、无线通信设备、UE代理或UE装置等。终端设备也可以是固定的或者移动的。
网络设备:是一种部署在空中的、具有无线收发功能设备。网络设备可以具有移动特性,即,网络设备可以为移动的设备。可选的,网络设备可以为卫星、气球站。
例如,卫星可以为低地球轨道(low earth orbit,LEO)卫星、中地球轨道(mediumearth orbit,MEO)卫星、地球同步轨道(geostationary earth orbit,GEO)卫星、高椭圆轨道(High Elliptical Orbit,HEO)卫星等。
例如,LEO卫星的轨道高度范围通常为500km~1500km,轨道周期(围绕地球旋转的周期)约为1.5小时~2小时。用户间单跳通信的信号传播延迟约为20ms,用户间单跳通信时延是指终端设备到网络设备之间的传输时延,或者网络设备到传输设备之间的时延。最大卫星可视时间约为20分钟,最大可视时间是指卫星的波束覆盖地面某一片区域的最长时间,LEO卫星相对地面是移动的,随着卫星的移动,其覆盖到的地面区域也是变化的。LEO卫星的信号传播距离短,链路损耗少,对终端设备的发射功率要求不高。GEO卫星的轨道高度通常为35786km,轨道周期为24小时。用户间单跳通信的信号传播延迟约为250ms。为了保证卫星的覆盖以及提升通信网络的系统容量,卫星可以采用多波束覆盖地面,例如,一颗卫星可以形成几十或者几百个波束来覆盖地面,一个波束可以覆盖直径几十至几百公里的地面区域。
TCP/IP协议:Transmission Control Protocol/Internet Protocol,传输控制协议/网际协议,也叫作网络通讯协议,是一种基本的且成熟稳定的通信协议。
下面,结合图1,对本申请中的数据处理方法所适用的场景进行说明。
图1为本申请实施例提供的应用场景的示意图。请参见图1,包括网络设备101和终端设备102,网络设备101和终端设备102之间可以进行无线通信。
终端设备102需要向网络设备101传输上行数据包时,首先网络设备101需要为终端设备102分配上行调度资源,然后终端设备102根据网络设备101分配的上行调度资源来进行数据包的传输。
当终端设备102处于弱场环境下,例如处于网络设备101覆盖区域的边缘区时,或者处于人员密集区时,由于信号差等原因,网络设备101给终端设备102分配的上行调度资源十分有限,从而使得终端设备102的发送能力受限。
此时,终端设备102根据网络设备101上行调度资源有限资源进行分片数据包传输,每次终端设备102发送的分片数据包较小,剩余的数据包需要等待下次网络设备101分配上行调度资源。
图1示例了本申请提供的数据处理方法的一种适用的应用场景,下面结合附图对本申请的方案进行详细说明。
图2为本申请实施例提供的数据处理方法的流程示意图,如图2所示,该方法可以包括:
S21,在所述终端设备处于数据包阻塞状态时,在第一待传输队列的多个数据包中确定重复的数据包。
本申请实施例中的执行主体为终端设备,涉及的设备包括终端设备和网络设备。以网络设备为基站为例,基站具有一定的覆盖范围,在覆盖范围内的终端设备可以与基站进行通信。
当终端设备需要向基站传输上行数据时,需要基站为终端设备分配上行调度资源。当终端设备处于弱场环境下,例如处于基站的覆盖范围的边缘处,或者处于人群密集区时,此时基站分配给终端设备的上行资源十分有限。
在基站分配给终端设备的上行资源十分有限的前提下,终端设备需要发送分片数据包,例如将一个大的数据包进行拆分成多个小的数据包分别进行发送。当某个数据包在进行传输时,其他的数据包需要等待下次基站分配上行调度资源。当终端设备传输数据包成功后,终端设备可以收到确认信息,而当终端设备传输数据包失败后,终端设备不会收到确认信息。此时,在终端设备内部,会对该数据被进行重传操作,持续将该数据包加入待传输队列中,导致终端设备形成数据包阻塞状态。
终端设备的数据包阻塞状态在一定程度上是由于基站为终端设备分配的上行调度资源十分有限造成的,而有限的上行调度资源又会导致大量重复的数据包被加入到终端设备的待传输队列中,加剧终端设备的数据包阻塞。
因此,为缓解此种情形,本申请实施例中,在终端设备处于数据包阻塞状态时,首先在第一待传输队列的多个数据包中确定重复的数据包,第一待传输队列为目前终端设备中各个待传输的数据包组成的传输队列,第一待传输队列中的各个数据包可以通过加入第一待传输队列中的时间先后顺序排列。
当终端设备处于数据包阻塞状态时,在第一待传输队列中存在多个重复的数据包,第一待传输队列中重复的数据包可能是由于在之前终端设备传输某个数据包失败后,新加入的数据包,新加入的数据包与之前传输失败的数据包相同。此种机制是为了通过重复传输,将数据包成功传输到基站,但是在上行调度资源十分有限的情形下,此种机制导致了数据包阻塞。
S22,根据所述重复的数据包,对所述多个数据包进行去重操作,得到第二待传输队列,所述第二待传输队列中的任意两个数据包均不相同。
在确定了第一待传输队列中重复的数据包后,对多个数据包进行去重操作。例如,假设第一待传输队列中包括4个数据包A,则进行去重操作后,仅保留1个数据包A即可。假设第一待传输队列中包括5个数据包B和8个数据包C,则进行去重操作后,仅保留1个数据包B和1个数据包C即可。即,针对每个数据包,若存在多个与其重复的数据包,则在多个重复的数据包中仅保留一个,其他重复的数据包可以去除掉。
通过去重操作,得到第二待传输队列,第二待传输队列中的任意两个数据包均不相同。经过上述处理,去除了第一待传输队列中大量的重复和无效的数据包,最后终端设备可以根据第二待传输队列中的数据包进行数据包传输。
本申请实施例提供的数据处理方法,应用于终端设备,在终端设备处于数据包阻塞状态时,在第一待传输队列的多个数据包中确定重复的数据包,然后根据重复的数据包,对多个数据包进行去重操作,得到第二待传输队列,且第二待传输队列中的任意两个数据包均不相同。本申请实施例提供的方案,针对终端设备处于数据包阻塞状态时存在大量重复和无效的数据包的情形,对多个数据包进行了去重操作,减小了大量的重复和无效的数据包的重传,从而减小了需要传输的数据包的数量,从而减小了终端设备的数据包的阻塞。
下面结合附图对本申请实施例的方案进行详细说明。
在弱场环境下,由于信号差等原因,网络设备给终端设备分配的上行调度资源均较小,但是TCP/IP机制通过终端设备向核心网发送报文的过程中并没有获知终端设备的发送能力受限而停止发送报文,反而在没有收到确认信息的情形下进行数据包重传,从而导致终端设备堆积大量待传输的数据包,并且会阻塞有效的报文的传输。造成上述问题的原因是,TCP/IP协议栈与(LTE)协议栈非同步机制。
若通过增加消息机制使得TCP/IP协议栈与(LTE)协议栈同步,又会破坏TCP/IP协议栈的成熟性和稳定性,而TCP/IP协议栈的定时器众多且复杂,修改维护的成本较大,因此本申请实施例提供一种方案,在无需使得TCP/IP协议栈与(LTE)协议栈同步的前提下减小无效重传数据包,避免有效报文的堵塞。
图3为本申请实施例提供的第一待传输队列的示意图,如图3所示,在第一待传输队列30中,包括多个数据包,这些数据包均为TCP/IP数据包。
第一待传输队列30中的TCP/IP数据包根据进入第一待传输队列30中的时间先后顺序依次排列。例如在图3中,排在最靠前的TCP/IP数据包为数据包A,当基站为终端设备分配了上行调度资源后,此时先传输第一待传输队列30中的数据包A。
如上所述,当终端设备处于数据包阻塞状态时,需要对第一待传输队列中的数据包进行去重操作。在此之前,首先要判断终端设备是否处于数据包阻塞状态。
可选的,当第一待传输队列的长度大于或等于预设长度时,可认为终端设备处于数据包阻塞状态。本申请实施例中,第一待传输队列的长度指的是第一待传输队列中包括的数据包的字节数,每个数据包均需要占用一定的字节数,这些占用的字节数共同构成第一待传输队列的长度。
基于此,可以根据第一待传输队列的长度来判断终端设备是否处于数据包阻塞状态。
图4为本申请实施例提供的判断终端设备的状态的流程示意图,如图4所示,包括:
S41,根据预设时间间隔获取上行调度资源。
具体的,终端设备的(LTE)协议栈低层(MAC层)根据一定的时间间隔获取网络设备为终端设备分配的上行调度资源,时间间隔可以根据实际需要调整。
S42,判断是否连续M次获取的上行调度资源值均小于或等于预设值,若是,则执行S43,若否,则执行S45。
当终端设备的(LTE)协议栈低层(MAC层)检测到连续M次获取的上行调度资源值均小于或等于预设值时,进行数据包阻塞状态的判断。
S43,判断第一待传输队列的长度是否大于或等于预设长度,若是,则执行S44,若否,则执行S45。
S44,确定终端设备处于数据包阻塞状态。
当第一待传输队列的长度大于或等于预设长度时,可认为终端设备处于数据包阻塞状态,此时可由(LTE)协议栈低层(MAC层)通知(LTE)协议栈高层此时终端设备处于数据包阻塞状态,需要采取一定的措施。
S45,确定终端设备不处于数据包阻塞状态。
若不存在连续M次获取的上行调度资源值均小于或等于预设值时,或者第一待传输队列的长度小于预设长度,则终端设备不处于数据包阻塞状态。若终端设备不处于数据包阻塞状态,则可以不进行相应的处理。其中,M为大于1的正整数,M为常数,可以根据实际需要调整M的大小。
在上述实施例中,描述了如何判断终端设备处于数据包阻塞状态。下面将结合图5说明数据包的去重过程。
图5为本申请实施例提供的数据包去重示意图,如图5所示,在第一待传输队列50中包括多个数据包,且这多个数据包均为TCP/IP数据包。
在TCP/IP数据包中,包括包头信息,包头关键信息相同的TCP/IP数据包即为相同的TCP/IP数据包。因此,可以根据TCP/IP协议栈下发的TCP/IP数据包中的包头信息进行遍历检查。如果两个TCP/IP数据包的包头关键信息相同,则认为这两个TCP/IP数据包是相同的TCP/IP数据包。其中,包头信息指IP包头信息和TCP包头信息。
包头关键信息包括:
IP版本、源IP地址、目的IP地址、源端口号、目的端口号、TCP序号SEQ值、包头长度和数据长度。
例如在图5中,数据包51和数据包54的包头关键信息相同,则确定数据包51和数据包54为重复的数据包。同样的,数据包52、数据包53和数据包55的包头关键信息相同,则确定数据包52、数据包53和数据包55也为重复的数据包。
在确定了重复的数据包后,可以根据重复的数据包,对第一待传输队列中的数据包进行去重操作,对每种重复的数据包只保留其中的一个即可。例如在图5中,数据包51和数据包54为重复的数据包,可以只保留数据包51而去除数据包54,也可以只保留数据包54而去除数据包51。数据包52、数据包53和数据包55为重复的数据包,可以只保留数据包52而去除数据包53和数据包55,也可以只保留数据包53而去除数据包52和数据包55,也可以只保留数据包55而去除数据包52和数据包53,等等。
在进行去重操作后,得到第二待传输队列,如图5所示,第二待传输队列中包括数据包51和数据包52,且数据包51和数据包52的包头信息不同,是不同的数据包。
在第一待传输队列中,包括多个TCP/IP数据包,这些TCP/IP数据包中,可能包括普通的TCP/IP数据包,还可能包括TCP/IP协议数据包,TCP/IP协议数据包比普通的TCP/IP数据包优先级高,需要及时发给基站。例如,当需要建立TCP连接时,需要经历三次握手和四次挥手的过程,实现TCP连接的建立,在建立TCP连接后可以进行数据的传输。而建立TCP连接的TCP/IP协议数据包不能阻塞在普通的TCP/IP数据包之后发送。
在上述实施例中,针对第一待传输队列中包括的多个数据包进行了去重操作,但是在信号较差的情况下,基站分配给终端设备的上行调度资源仍然十分有限,因此去重操作之后若包括多个待传输的数据包,则靠后的数据包仍然可能存在不能及时传输的问题。
为了保证有效报文的及时传输,本申请实施例中,对去重操作后的数据包进行优先级的重新排列。
图6为本申请实施例提供的数据包优先级排列示意图,如图6所示,在图5的基础上,进行了数据包的去重操作之后,剩余两个数据包,分别是数据包51和数据包52。
在不进行数据包优先级的重新排列之前,数据包51先于数据包52进入传输队列,因此根据时间先后顺序,应该是先进行数据包51的传输,然后再进行数据包52的传输。
本申请实施例提供一种方案,在进行数据包的包头信息的遍历并进行去重操作时,获取每个数据包的类型,其中数据包的类型包括普通的TCP/IP数据包和TCP/IP协议数据包。
若去重操作后传输队列中还包括TCP/IP协议数据包,则将TCP/IP协议数据包进行前插,排列到普通的TCP/IP数据包的前面,使得TCP/IP协议数据包在第二传输队列中的发送优先级高于普通TCP/IP数据包的发送优先级。
例如,在图6中,若数据包51为普通的TCP/IP数据包,数据包52为TCP/IP协议数据包,则此时需要对数据包52进行前插操作,将数据包52设置于数据包51的前面,使得数据包52具有比数据包51更高的发送优先级,如图6中的第二待传输队列60所示。
通过这样的处理,既能够去除大量重复的数据包的传输,同时能够将包括有效报文的TCP/IP协议数据包进行优先传输,从而保证了包括有效报文的TCP/IP协议数据包不被阻塞,能够及时传输到基站。
在进行去重操作以及TCP/IP协议数据包的前插后,得到第二待传输队列。可选的,可以将第二待传输队列中的数据包进行加密操作后,向网络设备发送第二待传输队列中的数据包。
本申请实施例提供的数据处理方法,应用于终端设备,在终端设备处于数据包阻塞状态时,在第一待传输队列的多个数据包中确定重复的数据包,然后根据重复的数据包,对多个数据包进行去重操作,得到第二待传输队列,且第二待传输队列中的任意两个数据包均不相同。本申请实施例提供的方案,针对终端设备处于数据包阻塞状态时存在大量重复和无效的数据包的情形,对多个数据包进行了去重操作,减小了大量的重复和无效的数据包的重传,从而减小了需要传输的数据包的数量,从而减小了终端设备的数据包的阻塞。同时,针对包括有效报文的TCP/IP协议数据包,还进行了前插操作,将TCP/IP协议数据包的发送优先级设置为高于其他普通的TCP/IP数据包的发送优先级,从而进一步保证包括有效报文的TCP/IP协议数据包不被阻塞住,能够及时有效的传输到网络设备。本申请实施例的方案,TCP/IP协议栈不需要加入(LTE)协议栈的消息机制,维持了TCP/IP协议栈的成熟性和稳定性。
图7为本申请实施例提供的一种数据处理装置的结构示意图,如图7所示,包括确定模块71和处理模块72,其中:
确定模块71用于在终端设备处于数据包阻塞状态时,在第一待传输队列的多个数据包中确定重复的数据包;
处理模块72用于根据所述重复的数据包,对所述多个数据包进行去重操作,得到第二待传输队列,所述第二待传输队列中的任意两个数据包均不相同。
在一种可能的实施方式中,所述数据包为传输控制协/网络议TCP/IP数据包,所述重复的数据包为包头关键信息相同的TCP/IP数据包。
在一种可能的实施方式中,所述第二待传输队列中包括至少一个TCP/IP协议数据包,所述至少一个TCP/IP协议数据包在所述第二待传输队列中的发送优先级高于所述第二待传输队列中除所述至少一个TCP/IP协议数据包外的其他TCP/IP数据包。
在一种可能的实施方式中,所述包头关键信息包括:
IP版本、源IP地址、目的IP地址、源端口号、目的端口号、TCP SEQ值、包头长度和数据长度。
在一种可能的实施方式中,所述数据包阻塞状态为所述第一待传输队列的长度大于或等于预设长度。
在一种可能的实施方式中,所述确定模块71还用于:
根据预设时间间隔获取上行调度资源;
若连续M次获取的上行调度资源值均小于或等于预设值,则根据所述第一待传输队列的长度判断所述终端设备是否处于数据包阻塞状态,所述M为大于1的整数。
在一种可能的实施方式中,所述处理模块72还用于:
向网络设备发送所述第二待传输队列中的数据包。
本申请实施例提供的装置,可用于执行上述方法实施例的技术方案,其实现原理和技术效果类似,此处不再赘述。
图8为本申请实施例提供的数据处理设备的硬件结构示意图,如图8所示,该数据处理设备包括:至少一个处理器81和存储器82。其中,处理器81和存储器82通过总线83连接。
可选地,该模型确定还包括通信部件。例如,通信部件可以包括接收器和/或发送器。
在具体实现过程中,至少一个处理器81执行所述存储器82存储的计算机执行指令,使得至少一个处理器81执行如上的数据处理方法。
处理器81的具体实现过程可参见上述方法实施例,其实现原理和技术效果类似,本实施例此处不再赘述。
在上述图8所示的实施例中,应理解,处理器可以是中央处理单元(英文:CentralProcessing Unit,简称:CPU),还可以是其他通用处理器、数字信号处理器(英文:DigitalSignal Processor,简称:DSP)、专用集成电路(英文:Application Specific IntegratedCircuit,简称:ASIC)等。通用处理器可以是微处理器或者该处理器也可以是任何常规的处理器等。结合申请所公开的方法的步骤可以直接体现为硬件处理器执行完成,或者用处理器中的硬件及软件模块组合执行完成。
存储器可能包含高速RAM存储器,也可能还包括非易失性存储NVM,例如至少一个磁盘存储器。
总线可以是工业标准体系结构(Industry Standard Architecture,ISA)总线、外部设备互连(Peripheral Component,PCI)总线或扩展工业标准体系结构(ExtendedIndustry Standard Architecture,EISA)总线等。总线可以分为地址总线、数据总线、控制总线等。为便于表示,本申请附图中的总线并不限定仅有一根总线或一种类型的总线。
本申请还提供一种计算机可读存储介质,所述计算机可读存储介质中存储有计算机执行指令,当处理器执行所述计算机执行指令时,实现如上所述的数据处理方法。
上述的计算机可读存储介质,上述可读存储介质可以是由任何类型的易失性或非易失性存储设备或者它们的组合实现,如静态随机存取存储器(SRAM),电可擦除可编程只读存储器(EEPROM),可擦除可编程只读存储器(EPROM),可编程只读存储器(PROM),只读存储器(ROM),磁存储器,快闪存储器,磁盘或光盘。可读存储介质可以是通用或专用计算机能够存取的任何可用介质。
一种示例性的可读存储介质耦合至处理器,从而使处理器能够从该可读存储介质读取信息,且可向该可读存储介质写入信息。当然,可读存储介质也可以是处理器的组成部分。处理器和可读存储介质可以位于专用集成电路(Application Specific IntegratedCircuits,简称:ASIC)中。当然,处理器和可读存储介质也可以作为分立组件存在于设备中。
所述单元的划分,仅仅为一种逻辑功能划分,实际实现时可以有另外的划分方式,例如多个单元或组件可以结合或者可以集成到另一个系统,或一些特征可以忽略,或不执行。另一点,所显示或讨论的相互之间的耦合或直接耦合或通信连接可以是通过一些接口,装置或单元的间接耦合或通信连接,可以是电性,机械或其它的形式。
所述作为分离部件说明的单元可以是或者也可以不是物理上分开的,作为单元显示的部件可以是或者也可以不是物理单元,即可以位于一个地方,或者也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部单元来实现本实施例方案的目的。
另外,在本申请各个实施例中的各功能单元可以集成在一个处理单元中,也可以是各个单元单独物理存在,也可以两个或两个以上单元集成在一个单元中。
所述功能如果以软件功能单元的形式实现并作为独立的产品销售或使用时,可以存储在一个计算机可读取存储介质中。基于这样的理解,本申请的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的部分可以以软件产品的形式体现出来,该计算机软件产品存储在一个存储介质中,包括若干指令用以使得一台计算机设备(可以是个人计算机,服务器,或者网络设备等)执行本申请各个实施例所述方法的全部或部分步骤。而前述的存储介质包括:U盘、移动硬盘、只读存储器(ROM,Read-Only Memory)、随机存取存储器(RAM,Random Access Memory)、磁碟或者光盘等各种可以存储程序代码的介质。
本领域普通技术人员可以理解:实现上述各方法实施例的全部或部分步骤可以通过程序指令相关的硬件来完成。前述的程序可以存储于一计算机可读取存储介质中。该程序在执行时,执行包括上述各方法实施例的步骤;而前述的存储介质包括:ROM、RAM、磁碟或者光盘等各种可以存储程序代码的介质。
最后应说明的是:以上各实施例仅用以说明本申请的技术方案,而非对其限制;尽管参照前述各实施例对本申请进行了详细的说明,本领域的普通技术人员应当理解:其依然可以对前述各实施例所记载的技术方案进行修改,或者对其中部分或者全部技术特征进行等同替换;而这些修改或者替换,并不使相应技术方案的本质脱离本申请各实施例技术方案的范围。
Claims (16)
1.一种数据处理方法,其特征在于,应用于终端设备,包括:
在所述终端设备处于数据包阻塞状态时,在第一待传输队列的多个数据包中确定重复的数据包;
根据所述重复的数据包,对所述多个数据包进行去重操作,得到第二待传输队列,所述第二待传输队列中的任意两个数据包均不相同。
2.根据权利要求1所述的方法,其特征在于,所述数据包为传输控制/网络协议TCP/IP数据包,所述重复的数据包为包头关键信息相同的TCP/IP数据包。
3.根据权利要求2所述的方法,其特征在于,所述第二待传输队列中包括至少一个TCP/IP协议数据包,所述至少一个TCP/IP协议数据包在所述第二待传输队列中的发送优先级高于所述第二待传输队列中除所述至少一个TCP/IP协议数据包外的其他TCP/IP数据包。
4.根据权利要求2或3所述的方法,其特征在于,所述包头关键信息包括:
IP版本、源IP地址、目的IP地址、源端口号、目的端口号、TCP序号SEQ值、包头长度和数据长度。
5.根据权利要求1-3任一项所述的方法,其特征在于,所述数据包阻塞状态为所述第一待传输队列的长度大于或等于预设长度。
6.根据权利要求5所述的方法,其特征在于,所述方法还包括:
根据预设时间间隔获取上行调度资源;
若连续M次获取的上行调度资源值均小于或等于预设值,则根据所述第一待传输队列的长度判断所述终端设备是否处于数据包阻塞状态,所述M为大于1的整数。
7.根据权利要求1-3任一项所述的方法,其特征在于,所述方法还包括:
向网络设备发送所述第二待传输队列中的数据包。
8.一种数据处理装置,其特征在于,包括:
确定模块,用于在终端设备处于数据包阻塞状态时,在第一待传输队列的多个数据包中确定重复的数据包;
处理模块,用于根据所述重复的数据包,对所述多个数据包进行去重操作,得到第二待传输队列,所述第二待传输队列中的任意两个数据包均不相同。
9.根据权利要求8所述的装置,其特征在于,所述数据包为传输控制/网络协议TCP/IP数据包,所述重复的数据包为包头关键信息相同的TCP/IP数据包。
10.根据权利要求9所述的装置,其特征在于,所述第二待传输队列中包括至少一个TCP/IP协议数据包,所述至少一个TCP/IP协议数据包在所述第二待传输队列中的发送优先级高于所述第二待传输队列中除所述至少一个TCP/IP协议数据包外的其他TCP/IP数据包。
11.根据权利要求9或10所述的装置,其特征在于,所述包头关键信息包括:
IP版本、源IP地址、目的IP地址、源端口号、目的端口号、TCP SEQ值、包头长度和数据长度。
12.根据权利要求8-10任一项所述的装置,其特征在于,所述数据包阻塞状态为所述第一待传输队列的长度大于或等于预设长度。
13.根据权利要求12所述的装置,其特征在于,所述确定模块还用于:
根据预设时间间隔获取上行调度资源;
若连续M次获取的上行调度资源值均小于或等于预设值,则根据所述第一待传输队列的长度判断所述终端设备是否处于数据包阻塞状态,所述M为大于1的整数。
14.根据权利要求8-10任一项所述的装置,其特征在于,所述处理模块还用于:
向网络设备发送所述第二待传输队列中的数据包。
15.一种数据处理设备,其特征在于,包括:
存储器,用于存储程序;
处理器,用于执行所述存储器存储的所述程序,当所述程序被执行时,所述处理器用于执行如权利要求1至7中任一所述的数据处理方法。
16.一种计算机可读存储介质,其特征在于,包括指令,当其在计算机上运行时,使得计算机执行如权利要求1至7中任一所述的数据处理方法。
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202010302059.1A CN111479293B (zh) | 2020-04-16 | 2020-04-16 | 数据处理方法及装置 |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202010302059.1A CN111479293B (zh) | 2020-04-16 | 2020-04-16 | 数据处理方法及装置 |
Publications (2)
Publication Number | Publication Date |
---|---|
CN111479293A true CN111479293A (zh) | 2020-07-31 |
CN111479293B CN111479293B (zh) | 2023-07-25 |
Family
ID=71755395
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN202010302059.1A Active CN111479293B (zh) | 2020-04-16 | 2020-04-16 | 数据处理方法及装置 |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN111479293B (zh) |
Cited By (1)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
WO2023146756A1 (en) * | 2022-01-25 | 2023-08-03 | Qualcomm Incorporated | Lower analog media access control (mac-a) layer and physical layer (phy-a) functions for analog transmission protocol stack |
Citations (10)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
US20040223452A1 (en) * | 2003-05-06 | 2004-11-11 | Santos Jose Renato | Process for detecting network congestion |
US20070211633A1 (en) * | 2006-03-13 | 2007-09-13 | Microsoft Corporation | Competitive and considerate congestion control |
CN102082674A (zh) * | 2009-12-01 | 2011-06-01 | 中兴通讯股份有限公司 | 数据通道的仿真方法和系统 |
US20110273982A1 (en) * | 2010-05-04 | 2011-11-10 | International Business Machines Corporation | Deduplicated data processing congestion control |
CN102521269A (zh) * | 2011-11-22 | 2012-06-27 | 清华大学 | 一种基于索引的计算机连续数据保护方法 |
US20130170342A1 (en) * | 2011-02-03 | 2013-07-04 | King Saud University | Data communication systems and methods |
CN104754760A (zh) * | 2013-12-27 | 2015-07-01 | 重庆重邮信科通信技术有限公司 | 一种分组业务重建方法和终端 |
WO2017075832A1 (zh) * | 2015-11-06 | 2017-05-11 | 华为技术有限公司 | 一种下行数据包、上行数据包传输方法及设备 |
CN110167084A (zh) * | 2018-08-15 | 2019-08-23 | 腾讯科技(深圳)有限公司 | 多通道数据传输方法及装置 |
CN110798860A (zh) * | 2018-08-01 | 2020-02-14 | 华为技术有限公司 | 数据处理方法、设备及系统 |
-
2020
- 2020-04-16 CN CN202010302059.1A patent/CN111479293B/zh active Active
Patent Citations (10)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
US20040223452A1 (en) * | 2003-05-06 | 2004-11-11 | Santos Jose Renato | Process for detecting network congestion |
US20070211633A1 (en) * | 2006-03-13 | 2007-09-13 | Microsoft Corporation | Competitive and considerate congestion control |
CN102082674A (zh) * | 2009-12-01 | 2011-06-01 | 中兴通讯股份有限公司 | 数据通道的仿真方法和系统 |
US20110273982A1 (en) * | 2010-05-04 | 2011-11-10 | International Business Machines Corporation | Deduplicated data processing congestion control |
US20130170342A1 (en) * | 2011-02-03 | 2013-07-04 | King Saud University | Data communication systems and methods |
CN102521269A (zh) * | 2011-11-22 | 2012-06-27 | 清华大学 | 一种基于索引的计算机连续数据保护方法 |
CN104754760A (zh) * | 2013-12-27 | 2015-07-01 | 重庆重邮信科通信技术有限公司 | 一种分组业务重建方法和终端 |
WO2017075832A1 (zh) * | 2015-11-06 | 2017-05-11 | 华为技术有限公司 | 一种下行数据包、上行数据包传输方法及设备 |
CN110798860A (zh) * | 2018-08-01 | 2020-02-14 | 华为技术有限公司 | 数据处理方法、设备及系统 |
CN110167084A (zh) * | 2018-08-15 | 2019-08-23 | 腾讯科技(深圳)有限公司 | 多通道数据传输方法及装置 |
Non-Patent Citations (1)
Title |
---|
ZTE: "C4-202215 "Packet Forwarding Model for MPTCP"", 《3GPP TSG_CT\WG4_PROTOCOLLARS_EX-CN4》 * |
Cited By (2)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
WO2023146756A1 (en) * | 2022-01-25 | 2023-08-03 | Qualcomm Incorporated | Lower analog media access control (mac-a) layer and physical layer (phy-a) functions for analog transmission protocol stack |
US11997693B2 (en) | 2022-01-25 | 2024-05-28 | Qualcomm Incorporated | Lower analog media access control (MAC-A) layer and physical layer (PHY-A) functions for analog transmission protocol stack |
Also Published As
Publication number | Publication date |
---|---|
CN111479293B (zh) | 2023-07-25 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
US8228911B2 (en) | Enhanced data link communication over iridium | |
CN104683017B (zh) | 一种卫星移动通信rlc层am模式传输方法 | |
KR20110081027A (ko) | 무선 통신 시스템에서 mac 프로토콜 데이터 유닛 처리 방법 | |
CN103795632A (zh) | 一种数据报文传输方法及相关设备、系统 | |
US20210007008A1 (en) | Method and apparatus for data segmentation and reassembly over multiple wireless links | |
EP4220990A1 (en) | Transmission control method and apparatus, device, and storage medium | |
CN114979839A (zh) | 一种传输控制协议代理方法及通信装置 | |
CN111479293A (zh) | 数据处理方法及装置 | |
KR20140069656A (ko) | 위성 통신에서의 랜덤 접속 부하 제어 방법 | |
CN114642060B (zh) | 通信方法、装置及设备 | |
CN109428684A (zh) | 一种数据传输方法、rlc实体及pdcp实体 | |
WO2018232194A1 (en) | System and method of local retransmission of tcp/ip frames | |
CN116963175A (zh) | 数据传输方法、装置及系统 | |
JP2022535346A (ja) | リソースのアクティブ方法、装置、記憶媒体及び電子装置 | |
CN116114299A (zh) | 一种信道传输方法及其装置 | |
CN109547167B (zh) | 一种计数方法及通信装置 | |
CN112218390A (zh) | 数据处理的方法和设备 | |
CN106209733B (zh) | 一种数据处理方法及装置 | |
WO2023108642A1 (zh) | 通信方法、装置、设备、芯片、存储介质、产品及程序 | |
CN112333675B (zh) | 一种数据计数的方法及相关装置 | |
WO2023207365A1 (zh) | 定时提前量报告发送方法及装置 | |
WO2024159342A1 (zh) | Gnss有效期的发送方法、装置、设备和介质 | |
WO2024199031A1 (zh) | 通信方法与通信装置 | |
CN108990168B (zh) | 一种适用于低轨卫星物联网的改进型crdsa协议的实现方法 | |
CN105052223B (zh) | 一种数据发送的方法、装置及系统 |
Legal Events
Date | Code | Title | Description |
---|---|---|---|
PB01 | Publication | ||
PB01 | Publication | ||
SE01 | Entry into force of request for substantive examination | ||
SE01 | Entry into force of request for substantive examination | ||
GR01 | Patent grant | ||
GR01 | Patent grant |