CN104219102A - 一种网络数据压缩统计的方法、装置和系统 - Google Patents
一种网络数据压缩统计的方法、装置和系统 Download PDFInfo
- Publication number
- CN104219102A CN104219102A CN201310207427.4A CN201310207427A CN104219102A CN 104219102 A CN104219102 A CN 104219102A CN 201310207427 A CN201310207427 A CN 201310207427A CN 104219102 A CN104219102 A CN 104219102A
- Authority
- CN
- China
- Prior art keywords
- data packet
- count value
- flow identifier
- length
- flow
- 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
Landscapes
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
本发明的实施例提供一种网络数据压缩统计的方法、装置和系统,能够提升网络数据压缩统计的速度和计算精度。该方法包括:接收第一数据包;将第一数据包的流标识和上一数据包的流标识比较;若流标识不同,获取上一数据包的流标识对应的压缩后的第一计数值;将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值;清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存第一数据包的长度;清除上一数据包的流标识,并缓存第一数据包的流标识;将第一计数值和第二计数值累加,获取第三计数值并缓存;若流标识相同,将第一数据包的长度和第四计数值进行累加并缓存累加结果。本发明适用于计算机领域。
Description
技术领域
本发明涉及计算机领域,尤其涉及一种网络数据压缩统计的方法、装置和系统。
背景技术
对业务流进行测量和监控是实施网络管理的必要步骤之一,统计测量得出的参数对网络的短期监控(如网络安全实时监测)和网络的长期规划(如网络容量规划、网络计费)都具有十分重要的意义。
但是,随着网络规模和业务的不断发展,一个业务流包含的I P数据包的数目和字节数可能非常大,而且链路的业务流总数或者需要统计的某一业务流集合所包含的不同业务流的数目也可能非常大。此外,骨干网速率越来越高,业务流建立的时间和IP数据包到达的时间间隔越来越短,导致对网络数据处理速度的要求越来越高。针对上述特征,当前,如何对业务流进行测量和监控面临巨大挑战。
现有技术中,提出一种DISCO(Discounting Counter,压缩统计)方法,如图1所示,该方法在接收到一个Packet(数据包或分组)后,进行提取数据包或分组流标识的操作,然后将获取的数据包或分组流标识与计数器存储队列中的流标识依次进行比较,若存在相同的流标识,将接收到的数据包或分组的长度压缩后累加到所述流标识对应的计数器存储队列的计数器中;若不存在相同的流标识,创建所述流标识对应的计数器存储队列,并将该数据包的长度压缩后存储到所述计数器存储队列的计数器中。该方法的核心思想是经过压缩,调整计数器的值小于真实需要更新的数值,其大小是真实长度的压缩值,对于长度为1字节的数据包,计数器的大小实际增加了一个小于1的数值。
举例来说,如图2所示,若接收到流标识相同的4个数据包,长度分别为691、142、1420、81,利用全尺寸统计方法最终计数结果为2344,而利用DISCO方法各自压缩后的结果分别为33.4、9.3、220.7、59.2,因为存放所述计数器存储队列的SRAM(Static random accessmemory,静态随机存储器)没有足够的存储单元来存储小数,则所述流标识对应的计数器存储队列中计数器的计数结果则顺次更新为+33、+9、+220、+59,最终计数结果为321。
该方法虽然可以对网络数据进行统计,但是因为要对接收到的每一个数据包依次进行压缩,降低了统计速度;并且因为存放所述计数器存储队列的SRAM没有足够的存储单元来存放小数,只能存放整数,因此计算精度也受到影响,需要进一步改进。
发明内容
本发明的实施例提供一种网络数据压缩统计的方法、装置和系统,能够提升网络数据压缩统计的速度和计算精度。
为达到上述目的,本发明的实施例采用如下技术方案:
第一方面,提供一种网络数据压缩统计的方法,所述方法包括:
接收第一数据包,其中,所述第一数据包携带该数据包的流标识和长度;
将所述第一数据包的流标识和上一数据包的流标识比较;
若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值;
将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值;
清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度;
清除所述上一数据包的流标识,并缓存所述第一数据包的流标识;
将所述第一计数值和所述第二计数值累加,获取第三计数值并缓存所述第三计数值;
若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
在第一种可能的实现方式中,根据第一方面,所述将所述第一数据包的流标识和上一数据包的流标识比较具体包括:
将所述第一数据包的流标识和寄存器中缓存的上一数据包的流标识比较;
所述若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值具体包括:
从静态随机存储器SRAM中获取缓存的所述上一数据包的流标识对应的压缩后的第一计数值;
所述将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值具体包括:
从缓冲计数器获取当前已缓存的上一数据包的流标识对应的数据包长度累加值;
对所述从缓冲计数器获取的当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值;
所述清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度具体包括:
发送第一指示消息给所述缓冲计数器,指示所述缓冲计数器清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度;
所述清除所述上一数据包的流标识,并缓存所述第一数据包的流标识具体包括:
发送第二指示消息给所述寄存器,所述第二指示消息携带所述第一数据包的流标识,指示所述寄存器缓存所述第一数据包的流标识,并清除所述上一数据包的流标识;
所述将所述第一计数值和所述第二计数值累加,获取第三计数值,并缓存所述第三计数值具体包括:
将所述第一计数值和第二计数值累加,获取第三计数值;
发送第三指示消息给所述SRAM,所述第三指示消息携带所述上一数据包的流标识和所述第三计数值,指示所述SRAM根据所述上一数据包的流标识缓存所述第三计数值;
所述若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值具体包括:
若流标识相同,发送第四指示消息给所述缓冲计数器,所述第四指示消息携带所述第一数据包的长度,指示所述缓冲计数器将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
在第二种可能的实现方式中,根据第一方面或第一种可能的实现方式,所述将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值具体包括:
根据压缩算法,将所述当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获取第一结果;
若所述第一结果为小数,将所述第一结果向上取整后减1,获取第二结果;
根据所述第一计数值、所述第二结果和预设的反向估计函数,获取更新概率;
若随机数生成器生成的随机数小于所述更新概率,将所述第二结果作为所述第二计数值;
若随机数生成器生成的随机数大于所述更新概率,将所述第二结果加1,获取第三结果;
将所述第三结果作为所述第二计数值。
在第三种可能的实现方式中,根据第一方面或第一种可能的实现方式或第二种可能的实现方式,所述方法还包括:
接收第五指示消息,所述第五指示消息指示计算所述第三计数值对应的数据包的真实长度;
根据预设的反向估计函数和所述第三计数值,计算所述第三计数值对应的数据包的真实长度。
第二方面,提供一种网络数据压缩统计的装置,所述装置包括接收单元,用于接收第一数据包,其中,所述第一数据包携带该数据包的流标识和长度;
比较单元,用于将所述第一数据包的流标识和上一数据包的流标识比较;
获取单元,用于若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值;
压缩单元,用于将当前已缓存的上一数据包的流标识对应的数据包长度累计值进行压缩,获得第二计数值;
第一更新单元,用于清除当前已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度;
第二更新单元,用于清除所述上一数据包的流标识,并缓存所述第一数据包的流标识;
第三更新单元,用于将所述第一计数值和所述第二计数值累加,获取第三计数值并缓存所述第三计数值;
第四更新单元,用于若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
在第一种可能的实现方式中,根据第二方面,所述比较单元,用于将所述第一数据包的流标识和上一数据包的流标识比较具体包括:
将所述第一数据包的流标识和寄存器中缓存的上一数据包的流标识比较;
所述获取单元,用于若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值具体包括:
从静态随机存储器SRAM中获取缓存的所述上一数据包的流标识对应的压缩后的第一计数值;
所述压缩单元,用于将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值具体包括:
从缓冲计数器获取当前已缓存的上一数据包的流标识对应的数据包长度累加值;
对所述从缓冲计数器获取的当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值;
所述第一更新单元,用于清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度具体包括:
发送第一指示消息给所述缓冲计数器,指示所述缓冲计数器清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度,以使得所述缓冲寄存器清除当前已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度;
所述第二更新单元,用于清除所述上一数据包的流标识,并缓存所述第一数据包的流标识具体包括:
发送第二指示消息给所述寄存器,所述第二指示消息携带所述第一数据包的流标识,指示所述寄存器缓存所述第一数据包的流标识,并清除上一数据包的流标识,以使得所述寄存器缓存所述第一数据包的流标识,并清除所述上一数据包的流标识;
第三更新单元,用于将所述第一计数值和所述第二计数值累加,获取第三计数值并缓存所述第三计数值具体包括:
将所述第一计数值和所述第二计数值累加,获取第三计数值;
发送第三指示消息给所述SRAM,所述第三指示消息携带所述上一数据包的流标识和所述第三计数值,指示所述SRAM根据所述上一数据包的流标识缓存所述第三计数值;
所述第四更新单元,用于若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值具体包括:
若流标识相同,发送第四指示消息给所述缓冲计数器,所述第四指示消息携带所述第一数据包的长度,指示所述缓冲计数器将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
在第二种可能的实现方式中,根据第二方面或第一种可能的实现方式,所述压缩单元将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值具体包括:
根据压缩算法,将所述当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获取第一结果;
若所述第一结果为小数,将所述第一结果向上取整后减1,获取第二结果;
根据所述第一计数值、所述第二结果和预设的反向估计函数,获取更新概率;
若随机数生成器生成的随机数小于所述更新概率,将所述第二结果作为所述第二计数值;
若随机数生成器生成的随机数大于所述更新概率,将所述第二结果加1,获取第三结果;
将所述第三结果作为所述第二计数值。
在第三种可能的实现方式中,根据第二方面或第一种可能的实现方式或第二种可能的实现方式,所述装置还包括计算单元;
所述接收单元,还用于接收第五指示消息,所述第五指示消息指示计算所述第三计数值对应的数据包的真实长度;
所述计算单元,用于根据预设的反向估计函数和所述第三计数值,计算所述第三计数值对应的数据包的真实长度。
第三方面,提供一种网络数据压缩统计的装置,所述装置包括接收器、处理器;
所述接收器,用于接收第一数据包,其中,所述第一数据包携带该数据包的流标识和长度;
所述处理器,用于将所述第一数据包的流标识和上一数据包的流标识比较;
所述处理器,还用于若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值;
所述处理器,还用于将当前已缓存的上一数据包的流标识对应的数据包长度累计值进行压缩,获得第二计数值;
所述处理器,还用于清除已缓存的上一数据包的流标识对应的数据包长度累加值,并存储所述第一数据包的长度;
所述处理器,还用于清除所述上一数据包的流标识,并缓存所述第一数据包的流标识;
所述处理器,还用于将所述第一计数值和所述第二计数值累加,获取第三计数值并缓存所述第三计数值;
所述处理器,还用于若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
在第一种可能的实现方式中,根据第三方面,所述处理器,用于将所述第一数据包的流标识和上一数据包的流标识比较具体包括:
将所述第一数据包的流标识和寄存器中缓存的上一数据包的流标识比较;
所述处理器,用于若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值具体包括:
从静态随机存储器SRAM中缓存的所述上一数据包的流标识对应的压缩后的第一计数值;
所述处理器,用于将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值具体包括:
从缓冲计数器获取当前已缓存的上一数据包的流标识对应的数据包长度累加值;
对所述从缓冲计数器获取的当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值;
所述处理器,用于清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度具体包括:
发送第一指示消息给所述缓冲计数器,指示所述缓冲计数器清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度,以使得所述缓冲寄存器清除当前已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度;
所述处理器,用于清除所述上一数据包的流标识,并缓存所述第一数据包的流标识具体包括:
发送第二指示消息给所述寄存器,所述第二指示消息携带所述第一数据包的流标识,指示所述寄存器缓存所述第一数据包的流标识,并清除上一数据包的流标识,以使得所述寄存器缓存所述第一数据包的流标识,并清除所述上一数据包的流标识;
所述处理器,用于将所述第一计数值和所述第二计数值累加,获取第三计数值并缓存所述第三计数值具体包括:
将所述第一计数值和所述第二计数值累加,获取第三计数值;
发送第三指示消息给所述SRAM,所述第三指示消息携带所述上一数据包的流标识和所述第三计数值,指示所述SRAM根据所述上一数据包的流标识缓存所述第三计数值;
所述处理器,用于若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值具体包括:
若流标识相同,发送第四指示消息给所述缓冲计数器,所述第四指示消息携带所述第一数据包的长度,指示所述缓冲计数器将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
在第二种可能的实现方式中,根据第三方面或第一种可能的实现方式,所述处理器将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值具体包括:
根据压缩算法,将所述当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获取第一结果;
若所述第一结果为小数,将所述第一结果向上取整后减1,获取第二结果;
根据所述第一计数值、所述第二结果和预设的反向估计函数,获取更新概率;
若随机数生成器生成的随机数小于所述更新概率,将所述第二结果作为所述第二计数值;
若随机数生成器生成的随机数大于所述更新概率,将所述第二结果加1,获取第三结果;
将所述第三结果作为所述第二计数值。
在第三种可能的实现方式中,根据第三方面或第一种可能的实现方式或第二种可能的实现方式,所述接收器,还用于接收第五指示消息,所述第五指示消息指示计算所述第三计数值对应的数据包的真实长度;
所述处理器,还用于根据预设的反向估计函数和所述第三计数值,计算所述第三计数值对应的数据包的真实长度。
第四方面,提供一种网络数据压缩统计的系统,所述系统包括寄存器、缓冲计数器、静态随机存储器SRAM以及如第三方面中第一种可能的实现方式所述的一种网络数据压缩统计的装置。
本发明实施例提供一种网络数据压缩统计的方法、装置和系统,所述方法包括:接收第一数据包,其中,所述第一数据包携带该数据包的流标识和长度;将所述第一数据包的流标识和上一数据包的流标识比较;若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值;将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值;清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度;清除所述上一数据包的流标识,并缓存所述第一数据包的流标识;将所述第一计数值和所述第二计数值累加,获取第三计数值并缓存所述第三计数值;若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
基于上述本发明实施例的描述,因为本发明对接收到的流标识相同的数据包的长度进行累加,当流标识不同时,触发压缩更新,而非对接收到的数据包依次压缩后再进行累加,因此能够提升网络数据压缩统计的速度,并且在存放所述计数器存储队列的SRAM没有足够的存储单元存储小数,只能存放整数时,利用本发明实施例所述的方法能够提高计算精度。
附图说明
图1为现有技术提供的一种压缩统计的方法示意图;
图2为一种数据包长度全尺寸统计与压缩统计的结果对比图;
图3为本发明实施例提供的一种网络数据压缩统计的方法;
图4为本发明实施例提供的一种网络数据压缩统计的系统;
图5为本发明实施例提供的一种网络数据压缩统计的方法;
图6为本发明实施例提供的一种网络数据压缩统计的装置;
图7为本发明实施例提供的另一种网络数据压缩统计的装置;
图8为本发明实施例提供的又一种网络数据压缩统计的装置。
具体实施方式
下面将结合本发明实施例中的附图,对本发明实施例中的技术方案进行清楚、完整地描述,显然,所描述的实施例仅仅是本发明一部分实施例,而不是全部的实施例。基于本发明中的实施例,本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例,都属于本发明保护的范围。
实施例一、
本发明实施例提供一种网络数据压缩统计的方法,具体如图3所示,所述方法包括:
301、接收第一数据包,其中,所述第一数据包携带该数据包的流标识和长度。
具体的,在进行网络数据压缩统计时,网络数据压缩统计的装置首先接收第一数据包,其中,所述第一数据包携带该数据包的流标识和长度,以使得所述装置提取所述第一数据包的流标识后,将所述第一数据包的流标识与上一数据包的流标识进行比较。
需要说明的是,所述第一数据包中的“第一”没有任何特殊的含义,仅是为了区别于上一数据包,表示当前接收到的数据包。
302、将所述第一数据包的流标识和上一数据包的流标识比较。
具体的,在接收所述第一数据包后,将所述第一数据包的流标识和上一数据包的流标识进行比较。其中,所述上一数据包的流标识可能存储在所述装置的内存中,也可能存储在与所述装置相连接的寄存器中,本发明实施例对此不作具体限定,仅说明所述装置在接收到第一数据包后,还将所述第一数据包的流标识和上一数据包的流标识比较。
若流标识不同,执行步骤303;
若流标识相同,执行步骤308。
303、若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值。
具体的,所述第一计数值可能存储在所述装置的某一存储模块中,也可能存储在与所述装置相连接的某一存储装置中,比如静态随机存储器SRAM(Static random access memory,静态随机存储器),本发明实施例对此不作具体限定,仅说明若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值。
需要说明的是,数据包的流标识与压缩后的计数值对应存储,可以根据所述上一数据包的流标识,获取已存储的上一数据包的流标识对应的压缩后的第一计数值,当然,在上述存储空间中可能没有所述上一数据包的流标识的记录,此时认为所述第一计数值为0。
304、将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值。
具体的,因为数据包的字节数可能非常大,为了节省存储空间,可以采用压缩算法对数据包的长度进行压缩。本发明实施例在流标识相同时,执行步骤308中的数据包长度累加的动作,仅在流标识不同时,将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值,这样减少了压缩次数,提升了压缩统计的速度,并且由于压缩后的数值有可能是小数,在某些存储单元不支持小数存储时,由于数据包长度累加后再压缩,因此可以减小最终的统计误差,提高计算精度。
具体的,当存储单元有足够的存储空间存储小数时,可以直接根据压缩算法对当前已存储的上一数据包的长度累加值进行压缩,压缩结果即可作为第二计数值,但是,一般情况下,存储单元没有足够的存储空间存储小数,比如静态随机存储器SRAM,此种情况下,所述将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值的方法具体包括:
根据压缩算法,将所述当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获取第一结果;
若所述第一结果为小数,将所述第一结果向上取整后减1,获取第二结果;
根据所述第一计数值、所述第二结果和预设的反向估计函数,获取更新概率;
若随机数生成器生成的随机数小于所述更新概率,将所述第二结果作为所述第二计数值;
若随机数生成器生成的随机数大于所述更新概率,将所述第二结果加1,获取第三结果;
将所述第三结果作为所述第二计数值。
当然,在存储单元没有足够的存储空间存储小数时,也可以有其它的方法将当前已缓存的上一数据包的长度累加值进行压缩,获得第二计数值,本发明实施例对此不作具体限定。
305、清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度。
具体的,因为当前接收到的所述第一数据包与存储的上一数据包的流标识不同,在将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值后,应及时更新存储空间,即清除当前已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度。
306、清除所述上一数据包的流标识,并缓存所述第一数据包的流标识。
具体的,因为当前接收到的所述第一数据包与当前缓存的上一数据包的流标识不同,为了保证后续接收到第一数据包,将所述第一数据包的流标识和缓存的上一数据包的流标识比较时不出错,应清除所述上一数据包的流标识,并缓存所述第一数据包的流标识。
307、将所述第一计数值和所述第二计数值累加,获取第三计数值并缓存所述第三计数值。
具体的,若所述第一计数值不为0,所述第三计数值与所述第一计数值的存储空间保持一致,此时该存储空间的内容由第一计数值更新为第三计数值;若所述第一计数值为0,应对应存储所述上一数据包的流标识与所述第三计数值。
308、若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
具体的,若流标识相同,直接将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,而不是对接收到的数据包的长度进行压缩,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
本发明实施例提供一种网络数据压缩统计的方法,所述方法包括:接收第一数据包,其中,所述第一数据包携带该数据包的流标识和长度;将所述第一数据包的流标识和上一数据包的流标识比较;若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值;将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值;清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度;清除所述上一数据包的流标识,并缓存所述第一数据包的流标识;将所述第一计数值和所述第二计数值累加,获取第三计数值并缓存所述第三计数值;若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
基于本发明上述实施例的描述,因为本发明对接收到的流标识相同的数据包的长度进行累加,当流标识不同时,触发压缩更新,而不是对接收到的数据包依次压缩后再进行累加,因此能够提升网络数据压缩统计的速度,并且在存放所述计数器存储队列的SRAM没有足够的存储单元存储小数,只能存放整数时,利用本发明实施例所述的方法能够提高计算精度。
实施例二、
本发明实施例提供一种网络数据压缩统计的方法,该方法具体在如图4所示的网络数据压缩统计的系统400下进行说明,所述系统400包括:网络数据压缩统计的装置401、寄存器402、缓冲计数器403、静态随机存储器SRAM404,其中,所述网络数据压缩统计的装置401分别与存储器402、缓冲计数器403、静态随机存储器404进行交互,最终完成网络数据的压缩统计,所述方法应用于网络数据压缩统计的装置,具体如图5所示,所述方法包括:
501、接收第一数据包,其中,所述第一数据包携带该数据包的流标识和长度。
具体的,在进行网络数据压缩统计时,网络数据压缩统计的装置首先接收第一数据包,其中,所述第一数据包携带该数据包的流标识和长度,以使得所述装置提取所述第一数据包的流标识后,将所述第一数据包的流标识与上一数据包的流标识进行比较。
需要说明的是,所述第一数据包中的“第一”没有任何特殊的含义,仅是为了区别于上一数据包,表示当前接收到的数据包。
502、将所述第一数据包的流标识和寄存器中缓存的上一数据包的流标识比较。
具体的,与所述网络数据压缩统计的装置相连的寄存器中存储了所述上一数据包的流标识,在接收所述第一数据包后,将所述第一数据包的流标识和寄存器中缓存的上一数据包的流标识比较。
若流标识不同,执行步骤503;
若流标识相同,执行步骤510。
503、若流标识不同,从静态随机存储器SRAM中获取缓存的所述上一数据包的流标识对应的压缩后的第一计数值。
具体的,本发明实施例中采用与所述网络数据压缩统计的装置相连接的静态随机存储器SRAM保存压缩统计结果,故若流标识不同,从静态随机存储器SRAM中获取缓存的所述上一数据包的流标识对应的压缩后的第一计数值。
需要说明的是,数据包的流标识与压缩后的计数值对应存储在所述SRAM中,可以根据所述上一数据包的流标识,通过在所述SRAM中进行查找,获取已缓存的上一数据包的流标识对应的压缩后的第一计数值,当然,若在所述SRAM中没有查找到所述上一数据包的流标识的记录,此时认为所述第一计数值为0。
504、从缓冲计数器获取当前已缓存的上一数据包的流标识对应的数据包长度累加值。
具体的,所述上一数据包的流标识对应的数据包长度累加值存储在与所述数据压缩统计的装置相连接的缓冲计数器中,所以若流标识不同,还从缓冲计数器获取当前已缓存的上一数据包的流标识对应的数据包长度累加值。
505、将所述从缓冲计数器获取的当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值。
具体的,因为数据包的字节数可能非常大,为了节省存储空间,可以采用压缩算法对数据包的长度进行压缩。本发明实施例在流标识相同时,执行步骤510中的数据包长度累加的动作,仅在流标识不同时,将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值,这样减少了压缩次数,提升了压缩统计的速度,并且由于压缩后的数值有可能是小数,而此时保存统计结果的所述SRAM中没有足够的存储单元来存储小数,利用本发明实施例的方法,由于数据包长度累加后再压缩,因此可以减小最终的统计误差,提高计算精度。
具体的,在此时所述SRAM没有足够的存储空间存储小数的情况下,将所述从缓冲计数器获取的当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值具体可以包括:
根据压缩算法,将所述当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获取第一结果;
若所述第一结果为小数,将所述第一结果向上取整后减1,获取第二结果;
根据所述第一计数值、所述第二结果和预设的反向估计函数,获取更新概率;
若随机数生成器生成的随机数小于所述更新概率,将所述第二结果作为所述第二计数值;
若随机数生成器生成的随机数大于所述更新概率,将所述第二结果加1,获取第三结果;
将所述第三结果作为所述第二计数值。
当然,在存储单元没有足够的存储空间存储小数时,也可以有其它的方法将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值,本发明实施例对此不作具体限定。这里根据上述获取第二计数值的方法,给出一种实例说明如下:
具体的,可以通过公式(1)控制所述SRAM中计数器的更新,其中,f(c)表示数据包的真实长度,c表示第一计数值,b是一个预设参数,其中b>1。
假设第一结果为Δ(c,l),当前已缓存的上一数据包的流标识对应的数据包长度累加值为1,则Δ(c,l)=f-1(l+f(c))-c,其中,f-1(□)是f(□)的反函数;
假设第二结果为δ(c,l),则
假设更新概率为pd(c,l),则如公式(2)所示:
根据公式(2)可以获取更新概率。
若随机数生成器生成的随机数大于所述更新概率,将所述第二结果加1,获取第三结果作为第二计数值;
若随机数生成器生成的随机数小于所述更新概率,将所述第二结果作为所述第二计数值
需要说明的是,本发明实施例仅示例性的提供一种通过压缩获取第二计数值的方法,对所述压缩算法不作具体限定。
506、发送第一指示消息给所述缓冲计数器,指示所述缓冲计数器清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度。
具体的,因为当前接收到的所述第一数据包与当前缓存的上一数据包的流标识不同,在将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值后,应及时更新存储空间,即发送第一指示消息给所述缓冲计数器,指示所述缓冲计数器清除当前已缓存的上一数据包流标识对应的数据包长度累加值,并缓存所述第一数据包的长度。
507、发送第二指示消息给所述寄存器,所述第二指示消息携带所述第一数据包的流标识,指示所述寄存器缓存所述第一数据包的流标识,并清除上一数据包的流标识。
具体的,因为当前接收到的所述第一数据包与当前缓存的上一数据包的流标识不同,为了保证后续接收到第一数据包,将所述第一数据包的流标识和缓存的上一数据包的流标识比较时不出错,应清除所述上一数据包的流标识,并缓存所述第一数据包的流标识。
因为步骤502中所述上一数据包的流标识存储在所述寄存器中,故此时发送第二指示消息给所述寄存器,所述第二指示消息携带所述第一数据包的流标识,指示所述寄存器存储所述第一数据包的流标识,并清除上一数据包的流标识。
508、将所述第一计数值和第二计数值累加,获取第三计数值。
509、发送第三指示消息给所述SRAM,所述第三指示消息携带所述上一数据包的流标识和所述第三计数值,指示所述SRAM根据所述上一数据包的流标识缓存所述第三计数值。
具体的,若步骤503中获取的所述第一计数值不为0,则所述第三计数值与所述第一计数值的存储空间保持一致,此时所述SRAM中所述上一数据包的流标识对应的计数器的内容由第一计数值更新为第三计数值;
若步骤503中获取的所述第一计数值为0,则在所述SRAM中对应存储所述上一数据包的流标识与所述第三计数值。
510、若流标识相同,发送第四指示消息给所述缓冲计数器,所述第四指示消息携带所述第一数据包的长度,指示所述缓冲计数器将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
具体的,若流标识相同,直接将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,而不是对接收到的数据包的长度进行压缩,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
因为本发明实施例中,所述数据包的长度累加值存储在于所述缓冲计数器中,所以此时发送第四指示消息给所述缓冲计数器,所述第四指示消息携带所述第一数据包的长度,指示所述缓冲计数器将所述第一数据包的长度和第四计数值进行累加并缓存累加结果。
进一步的,所述方法还包括:
接收第五指示消息,所述第五指示消息指示计算所述第三计数值对应的数据包的真实长度。
根据预设的反向估计函数和所述第三计数值,计算所述第三计数值对应的数据包的真实长度。
具体的,若步骤504中利用公式(1)控制SRAM中计数器的更新,则在接收第五指示消息后,令公式(1)中的
c=第三计数值,
即可获取所述第三计数值对应的数据包的真实长度。
需要说明的是,利用本发明实施例的方法也可统计接收到的数据包的个数,仅需令数据包的长度=1,最后获得的统计结果即为所述接收到的数据包的个数。
本发明实施例提供一种网络数据压缩统计的方法,所述方法包括:接收第一数据包,其中,所述第一数据包携带该数据包的流标识和长度;将所述第一数据包的流标识和上一数据包的流标识比较;若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值;将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值;清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度;清除所述上一数据包的流标识,并缓存所述第一数据包的流标识;将所述第一计数值和所述第二计数值累加,获取第三计数值并缓存所述第三计数值;若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
基于本发明上述实施例的描述,因为本发明对接收到的流标识相同的数据包的长度进行累加,当流标识不同时,触发压缩更新,而不是对接收到的数据包依次压缩后再进行累加,因此能够提升网络数据压缩统计的速度,并且在存放所述计数器存储队列的SRAM没有足够的存储单元存储小数,只能存放整数时,利用本发明实施例所述的方法能够提高计算精度。
实施例三、
本发明实施例提供一种网络数据压缩统计的装置600,具体如图6所示,所述装置600包括接收单元601、比较单元602、获取单元603、压缩单元604、第一更新单元605、第二更新单元606、第三更新单元607、第四更新单元608。
所述接收单元601,用于接收第一数据包,其中,所述第一数据包携带该数据包的流标识和长度。
具体的,在进行网络数据压缩统计时,所述接收单元601首先接收第一数据包,其中,所述第一数据包携带该数据包的流标识和长度,以使得所述装置600提取所述第一数据包的流标识后,将所述第一数据包的流标识与上一数据包的流标识进行比较。
需要说明的是,所述第一数据包中的“第一”没有任何特殊的含义,仅是为了区别于上一数据包,表示当前接收到的数据包。
所述比较单元602,用于将所述第一数据包的流标识和上一数据包的流标识比较。
具体的,在所述接收单元601接收所述第一数据包后,所述比较单元602将所述第一数据包的流标识和上一数据包的流标识进行比较。其中,所述上一数据包的流标识可能存储在所述装置600的内存中,也可能存储在与所述装置600相连接的寄存器中,本发明实施例对此不作具体限定,仅说明所述装置600在接收到第一数据包后,将所述第一数据包的流标识和上一数据包的流标识比较。
所述获取单元603,用于若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值。
具体的,所述第一计数值可能存储在所述装置600的某一存储模块中,也可能存储在与所述装置600相连接的某一存储装置中,比如静态随机存储器SRAM,本发明实施例对此不作具体限定,仅说明若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值。
需要说明的是,数据包的流标识与压缩后的计数值对应存储,可以根据所述上一数据包的流标识,获取已存储的上一数据包的流标识对应的压缩后的第一计数值,当然,在上述存储空间中可能没有所述上一数据包的流标识的记录,此时认为所述第一计数值为0。
所述压缩单元604,用于将当前已缓存的上一数据包的流标识对应的数据包长度累计值进行压缩,获得第二计数值。
具体的,因为数据包的字节数可能非常大,为了节省存储空间,可以采用压缩算法对数据包的长度进行压缩。本发明实施例中所述装置600在流标识相同时,将数据包的长度进行累加,仅在流标识不同时,将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值,这样减少了压缩次数,提升了压缩统计的速度,并且由于压缩后的数值有可能是小数,在某些存储单元不支持小数存储时,由于数据包长度累加后再压缩,因此可以减小最终的统计误差,提高计算精度。
具体的,当存储单元有足够的存储空间存储小数时,可以直接根据压缩算法对当前已存储的上一数据包的长度累加值进行压缩,压缩结果即可作为第二计数值,但是,一般情况下,存储单元没有足够的存储空间存储小数,比如静态随机存储器SRAM,此种情况下,所述压缩单元604将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值的方法具体可以包括:
根据压缩算法,将所述当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获取第一结果;
若所述第一结果为小数,将所述第一结果向上取整后减1,获取第二结果;
根据所述第一计数值、所述第二结果和预设的反向估计函数,获取更新概率;
若随机数生成器生成的随机数小于所述更新概率,将所述第二结果作为所述第二计数值;
若随机数生成器生成的随机数大于所述更新概率,将所述第二结果加1,获取第三结果;
将所述第三结果作为所述第二计数值。
当然,在存储单元没有足够的存储空间存储小数时,也可以有其它的方法将当前已缓存的上一数据包的长度累加值进行压缩,获得第二计数值,本发明实施例对此不作具体限定。
所述第一更新单元605,用于清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度。
具体的,因为当前接收到的所述第一数据包与存储的上一数据包的流标识不同,在所述压缩单元604将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值后,应及时更新存储空间,即清除当前已缓存的上一数据包的流标识对应的数据包长度累加值,并存储所述第一数据包的长度。
所述第二更新单元606,用于清除所述上一数据包的流标识,并缓存所述第一数据包的流标识。
具体的,因为当前接收到的所述第一数据包与当前缓存的上一数据包的流标识不同,为了保证后续接收到第一数据包,将所述第一数据包的流标识和缓存的上一数据包的流标识比较时不出错,所述第二更新单元606清除所述上一数据包的流标识,并缓存所述第一数据包的流标识。
所述第三更新单元607,用于将所述第一计数值和所述第二计数值累加,获取第三计数值并缓存所述第三计数值。
具体的,若所述第一计数值不为0,所述第三计数值与所述第一计数值的存储空间保持一致,此时该存储空间的内容由第一计数值更新为第三计数值;若所述第一计数值为0,应对应存储所述上一数据包的流标识与所述第三计数值。
所述第四更新单元608,用于若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
具体的,若流标识相同,所述第四更新单元608直接将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,而不是对接收到的数据包的长度进行压缩,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
进一步的,所述比较单元602,用于将所述第一数据包的流标识和上一数据包的流标识比较具体包括:
将所述第一数据包的流标识和寄存器中缓存的上一数据包的流标识比较。
所述获取单元603,用于若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值具体包括:
从静态随机存储器SRAM中获取缓存的所述上一数据包的流标识对应的压缩后的第一计数值。
所述压缩单元604,用于将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值具体包括:
从缓冲计数器获取当前已缓存的上一数据包的流标识对应的数据包长度累加值;
对所述从缓冲计数器获取的当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值。
所述第一更新单元605,用于清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度具体包括:
发送第一指示消息给所述缓冲计数器,指示所述缓冲计数器清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存存储所述第一数据包的长度,以使得所述缓冲寄存器清除当前已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度。
所述第二更新单元606,用于清除上一数据包的流标识,并缓存所述第一数据包的流标识具体包括:
发送第二指示消息给所述寄存器,所述第二指示消息携带所述第一数据包的流标识,指示所述寄存器缓存所述第一数据包的流标识,并清除上一数据包的流标识,以使得所述寄存器缓存所述第一数据包的流标识,并清除所述上一数据包的流标识。
第三更新单元607,用于将所述第一计数值和所述第二计数值累加,获取第三计数值并缓存所述第三计数值具体包括:
将所述第一计数值和所述第二计数值累加,获取第三计数值;
发送第三指示消息给所述SRAM,所述第三指示消息携带所述上一数据包的流标识和所述第三计数值,指示所述SRAM根据所述上一数据包的流标识缓存所述第三计数值。
所述第四更新单元608,用于若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值具体包括:
若流标识相同,发送第四指示消息给所述缓冲计数器,所述第四指示消息携带所述第一数据包的长度,指示所述缓冲计数器将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
进一步的,所述压缩单元604将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值具体包括:
根据压缩算法,将所述当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获取第一结果。
若所述第一结果为小数,将所述第一结果向上取整后减1,获取第二结果。
根据所述第一计数值、所述第二结果和预设的反向估计函数,获取更新概率。
若随机数生成器生成的随机数小于所述更新概率,将所述第二结果作为所述第二计数值。
若随机数生成器生成的随机数大于所述更新概率,将所述第二结果加1,获取第三结果;
将所述第三结果作为所述第二计数值。
进一步的,如图7所示,所述装置600还包括计算单元609。
所述接收单元601,还用于接收第五指示消息,所述第五指示消息指示计算所述第三计数值对应的数据包的真实长度。
所述计算单元609,用于根据预设的反向估计函数和所述第三计数值,计算所述第三计数值对应的数据包的真实长度。
具体的,利用所述网络数据压缩统计的装置进行网络数据压缩统计的方法可参考实施例一和实施例二的描述,本发明实施例对此不再赘述。
本发明实施例提供一种网络数据压缩统计的装置,所述装置的接收单元用于接收第一数据包;比较单元用于将所述第一数据包的流标识和上一数据包的流标识比较;获取单元用于若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值;压缩单元用于将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值;第一更新单元用于清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度;第二更新单元用于清除所述上一数据包的流标识,并缓存所述第一数据包的流标识;第三更新单元用于将所述第一计数值和所述第二计数值累加,获得第三计数值并缓存所述第三计数值;第四更新单元,用于若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
基于上述实施例的描述,因为所述网络数据压缩统计的装置对接收到的流标识相同的数据包的长度进行累加,当流标识不同时,触发压缩更新,而非对接收到的数据包依次压缩后再进行累加,因此能够提升网络数据压缩统计的速度,并且在存放所述计数器存储队列的SRAM没有足够的存储单元存储小数,只能存放整数时,利用所述网络数据压缩统计的装置能够提高计算精度。
实施例四、
本发明实施例提供一种网络数据压缩统计的装置401,具体如图8所示,所述装置401包括接收器801、处理器802。
所述接收器801,用于接收第一数据包,其中,所述第一数据包携带该数据包的流标识和长度。
所述处理器802,用于将所述第一数据包的流标识和上一数据包的流标识比较。
所述处理器802,还用于若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值。
所述处理器802,还用于将当前已缓存的上一数据包的流标识对应的数据包长度累计值进行压缩,获得第二计数值。
所述处理器802,还用于清除已缓存的上一数据包的流标识对应的数据包长度累加值,并存储所述第一数据包的长度。
所述处理器802,还用于清除所述上一数据包的流标识,并缓存所述第一数据包的流标识。
所述处理器802,还用于将所述第一计数值和所述第二计数值累加,获取第三计数值并缓存所述第三计数值。
所述处理器802,还用于若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
进一步的,所述处理器802,用于将所述第一数据包的流标识和上一数据包的流标识比较具体包括:
将所述第一数据包的流标识和寄存器中缓存的上一数据包的流标识比较。
所述处理器802,用于若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值具体包括:
从静态随机存储器SRAM中获取缓存的所述上一数据包的流标识对应的压缩后的第一计数值。
所述处理器802,用于将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值具体包括:
从缓冲计数器获取当前已存储的上一数据包的长度累加值;
对所述从缓冲计数器获取的当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值。
所述处理器802,用于清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度具体包括:
发送第一指示消息给所述缓冲计数器,指示所述缓冲计数器清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度,以使得所述缓冲寄存器清除当前已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度。
所述处理器802,用于清除所述上一数据包的流标识,并缓存所述第一数据包的流标识具体包括:
发送第二指示消息给所述寄存器,所述第二指示消息携带所述第一数据包的流标识,指示所述寄存器缓存所述第一数据包的流标识,并清除上一数据包的流标识,以使得所述寄存器缓存存储所述第一数据包的流标识,并清除所述上一数据包的流标识。
所述处理器802,用于将所述第一计数值和所述第二计数值累加,获取第三计数值并缓存所述第三计数值具体包括:
将所述第一计数值和所述第二计数值累加,获取第三计数值;
发送第三指示消息给所述SRAM,所述第三指示消息携带所述上一数据包的流标识和所述第三计数值,指示所述SRAM根据所述上一数据包的流标识缓存所述第三计数值。
所述处理器802,用于若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值具体包括:
若流标识相同,发送第四指示消息给所述缓冲计数器,所述第四指示消息携带所述第一数据包的长度,指示所述缓冲计数器将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
进一步的,所述处理器802将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值具体包括:
根据压缩算法,将所述当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获取第一结果。
若所述第一结果为小数,将所述第一结果向上取整后减1,获取第二结果。
根据所述第一计数值、所述第二结果和预设的反向估计函数,获取更新概率。
若随机数生成器生成的随机数小于所述更新概率,将所述第二结果作为所述第二计数值。
若随机数生成器生成的随机数大于所述更新概率,将所述第二结果加1,获取第三结果。
将所述第三结果作为所述第二计数值。
进一步的,所述接收器801,还用于接收第五指示消息,所述第五指示消息指示计算所述第三计数值对应的数据包的真实长度。
所述处理器802,还用于根据预设的反向估计函数和所述第三计数值,计算所述第三计数值对应的数据包的真实长度。
具体的,利用所述网络数据压缩统计的装置进行网络数据压缩统计的方法可参考实施例一和实施例二的描述,本发明实施例对此不再赘述。
本发明实施例提供一种网络数据压缩统计的装置,所述装置的接收器用于接收第一数据包;处理器用于将所述第一数据包的流标识和上一数据包的流标识比较;若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值;将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值;清除当前已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度;清除所述上一数据包的流标识,并缓存所述第一数据包的流标识;将所述第一计数值和所述第二计数值累加,获得第三计数值并缓存所述第三计数值;所述处理器还用于若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
基于上述实施例的描述,因为所述网络数据压缩统计的装置对接收到的流标识相同的数据包的长度进行累加,当流标识不同时,触发压缩更新,而非对接收到的数据包依次压缩后再进行累加,因此能够提升网络数据压缩统计的速度,并且在存放所述计数器存储队列的SRAM没有足够的存储单元存储小数,只能存放整数时,利用所述网络数据压缩统计的装置能够提高计算精度。
实施例五、
本发明实施例提供一种网络数据压缩统计的系统400,具体如图4所示,所述系统400包括网络数据压缩统计的装置401、寄存器402、缓冲计数器403、静态随机存储器SRAM404。
其中,所述网络数据压缩统计的装置401与所述寄存器402、所述缓冲计数器403、静态随机存储器SRAM404相连接,用于:接收第一数据包,其中,所述第一数据包携带该数据包的流标识和长度;将所述第一数据包的流标识和寄存器中缓存的上一数据包的流标识比较;若流标识不同,从静态随机存储器SRAM中获取缓存的所述上一数据包的流标识对应的压缩后的第一计数值;从缓冲计数器获取当前已缓存的上一数据包的流标识对应的数据包长度累加值,并对所述从缓冲计数器获取的当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值;发送第一指示消息给所述缓冲计数器,指示所述缓冲计数器清除已缓存的上一数据包的长度累加值,并缓存所述第一数据包的长度;发送第二指示消息给所述寄存器,所述第二指示消息携带所述第一数据包的流标识,指示所述寄存器清除所述上一数据包的流标识,并缓存所述第一数据包的流标识;将所述第一计数值和所述第二计数值累加,获取第三计数值;发送第三指示消息给所述SRAM,所述第三指示消息携带所述上一数据包的流标识和所述第三计数值,指示所述SRAM根据所述上一数据包的流标识缓存所述第三计数值;若流标识相同,发送第四指示消息给所述缓冲计数器,所述第四指示消息携带所述第一数据包的长度,指示所述缓冲计数器将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
其中,所述将当前已缓存的上一数据包的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值具体包括:
根据压缩算法,将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获取第一结果;
若所述第一结果为小数,将所述第一结果向上取整后减1,获取第二结果;
根据所述第一计数值、所述第二结果和预设的反向估计函数,获取更新概率;
若随机数生成器生成的随机数小于所述更新概率,将所述第二结果作为所述第二计数值;
若随机数生成器生成的随机数大于所述更新概率,将所述第二结果加1,获取第三结果;
将所述第三结果作为所述第二计数值。
进一步的,所述网络数据压缩统计的装置401还用于:
接收第五指示消息,所述第五指示消息指示计算所述第三计数值对应的数据包的真实长度;
根据预设的反向估计函数和所述第三计数值,计算所述第三计数值对应的数据包的真实长度。
具体的,利用所述网络数据压缩统计的系统进行网络数据压缩统计的方法可参考实施例二的描述,本发明实施例对此不再赘述。
基于上述实施例的描述,因为所述网络数据压缩统计的系统能够对接收到的流标识相同的数据包的长度进行累加,当流标识不同时,触发压缩更新,而非对接收到的数据包依次压缩后再进行累加,因此能够提升网络数据压缩统计的速度,并且在存放所述计数器存储队列的SRAM没有足够的存储单元存储小数,只能存放整数时,利用所述网络数据压缩统计的系统能够提高计算精度。
需说明的是,以上所描述的装置实施例仅仅是示意性的,其中所述作为分离部件说明的单元可以是或者也可以不是物理上分开的,作为单元显示的部件可以是或者也可以不是物理单元,即可以位于一个地方,或者也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部模块来实现本实施例方案的目的。另外,本发明提供的装置实施例附图中,模块之间的连接关系表示它们之间具有通信连接,具体可以实现为一条或多条通信总线或信号线。本领域普通技术人员在不付出创造性劳动的情况下,即可以理解并实施。
通过以上的实施方式的描述,所属领域的技术人员可以清楚地了解到本发明可借助软件加必需的通用硬件的方式来实现,当然也可以通过专用硬件包括专用集成电路、专用CPU、专用存储器、专用元器件等来实现。一般情况下,凡由计算机程序完成的功能都可以很容易地用相应的硬件来实现,而且,用来实现同一功能的具体硬件结构也可以是多种多样的,例如模拟电路、数字电路或专用电路等。但是,对本发明而言更多情况下软件程序实现是更佳的实施方式。基于这样的理解,本发明的技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来,该计算机软件产品存储在可读取的存储介质中,如计算机的软盘,U盘、移动硬盘、只读存储器(ROM,Read-Only Memory)、随机存取存储器(RAM,Random Access Memory)、磁碟或者光盘等,包括若干指令用以使得一台计算机设备(可以是个人计算机,服务器,或者网络设备等)执行本发明各个实施例所述的方法。
以上所述,仅为本发明的具体实施方式,但本发明的保护范围并不局限于此,任何熟悉本技术领域的技术人员在本发明揭露的技术范围内,可轻易想到变化或替换,都应涵盖在本发明的保护范围之内。因此,本发明的保护范围应所述以权利要求的保护范围为准。
Claims (13)
1.一种网络数据压缩统计的方法,其特征在于,所述方法包括:
接收第一数据包,其中,所述第一数据包携带该数据包的流标识和长度;
将所述第一数据包的流标识和上一数据包的流标识比较;
若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值;
将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值;
清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度;
清除所述上一数据包的流标识,并缓存所述第一数据包的流标识;
将所述第一计数值和所述第二计数值累加,获取第三计数值并缓存所述第三计数值;
若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
2.根据权利要求1所述的方法,其特征在于,所述将所述第一数据包的流标识和上一数据包的流标识比较具体包括:
将所述第一数据包的流标识和寄存器中缓存的上一数据包的流标识比较;
所述若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值具体包括:
从静态随机存储器SRAM中获取缓存的所述上一数据包的流标识对应的压缩后的第一计数值;
所述将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值具体包括:
从缓冲计数器获取当前已缓存的上一数据包的流标识对应的数据包长度累加值;
对所述从缓冲计数器获取的当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值;
所述清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度具体包括:
发送第一指示消息给所述缓冲计数器,指示所述缓冲计数器清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度;
所述清除所述上一数据包的流标识,并缓存所述第一数据包的流标识具体包括:
发送第二指示消息给所述寄存器,所述第二指示消息携带所述第一数据包的流标识,指示所述寄存器缓存所述第一数据包的流标识,并清除所述上一数据包的流标识;
所述将所述第一计数值和所述第二计数值累加,获取第三计数值,并缓存所述第三计数值具体包括:
将所述第一计数值和第二计数值累加,获取第三计数值;
发送第三指示消息给所述SRAM,所述第三指示消息携带所述上一数据包的流标识和所述第三计数值,指示所述SRAM根据所述上一数据包的流标识缓存所述第三计数值;
所述若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值具体包括:
若流标识相同,发送第四指示消息给所述缓冲计数器,所述第四指示消息携带所述第一数据包的长度,指示所述缓冲计数器将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
3.根据权利要求1或2所述的方法,其特征在于,所述将当前已缓存的上一数据包的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值具体包括:
根据压缩算法,将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获取第一结果;
若所述第一结果为小数,将所述第一结果向上取整后减1,获取第二结果;
根据所述第一计数值、所述第二结果和预设的反向估计函数,获取更新概率;
若随机数生成器生成的随机数小于所述更新概率,将所述第二结果作为所述第二计数值;
若随机数生成器生成的随机数大于所述更新概率,将所述第二结果加1,获取第三结果;
将所述第三结果作为所述第二计数值。
4.根据权利要求1-3任一项所述的方法,其特征在于,所述方法还包括:
接收第五指示消息,所述第五指示消息指示计算所述第三计数值对应的数据包的真实长度;
根据预设的反向估计函数和所述第三计数值,计算所述第三计数值对应的数据包的真实长度。
5.一种网络数据压缩统计的装置,其特征在于,所述装置包括:
接收单元,用于接收第一数据包,其中,所述第一数据包携带该数据包的流标识和长度;
比较单元,用于将所述第一数据包的流标识和上一数据包的流标识比较;
获取单元,用于若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值;
压缩单元,用于将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值;
第一更新单元,用于清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度;
第二更新单元,用于清除所述上一数据包的流标识,并缓存所述第一数据包的流标识;
第三更新单元,用于将所述第一计数值和所述第二计数值累加,获取第三计数值并缓存所述第三计数值;
第四更新单元,用于若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
6.根据权利要求5所述的装置,其特征在于,所述比较单元,用于将所述第一数据包的流标识和上一数据包的流标识比较具体包括:
将所述第一数据包的流标识和寄存器中缓存的上一数据包的流标识比较;
所述获取单元,用于若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值具体包括:
从静态随机存储器SRAM中获取缓存的所述上一数据包的流标识对应的压缩后的第一计数值;
所述压缩单元,用于将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值具体包括:
从缓冲计数器获取当前已缓存的上一数据包的流标识对应的数据包长度累加值;
对所述从缓冲计数器获取的当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值;
所述第一更新单元,用于清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度具体包括:
发送第一指示消息给所述缓冲计数器,指示所述缓冲计数器清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度,以使得所述缓冲寄存器清除当前已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度;
所述第二更新单元,用于清除所述上一数据包的流标识,并缓存所述第一数据包的流标识具体包括:
发送第二指示消息给所述寄存器,所述第二指示消息携带所述第一数据包的流标识,指示所述寄存器缓存所述第一数据包的流标识,并清除上一数据包的流标识,以使得所述寄存器缓存所述第一数据包的流标识,并清除所述上一数据包的流标识;
第三更新单元,用于将所述第一计数值和所述第二计数值累加,获取第三计数值并缓存所述第三计数值具体包括:
将所述第一计数值和所述第二计数值累加,获取第三计数值;
发送第三指示消息给所述SRAM,所述第三指示消息携带所述上一数据包的流标识和所述第三计数值,指示所述SRAM根据所述上一数据包的流标识缓存所述第三计数值;
所述第四更新单元,用于若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值具体包括:
若流标识相同,发送第四指示消息给所述缓冲计数器,所述第四指示消息携带所述第一数据包的长度,指示所述缓冲计数器将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
7.根据权利要求5或6所述的装置,其特征在于,所述压缩单元将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值具体包括:
根据压缩算法,将所述当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获取第一结果;
若所述第一结果为小数,将所述第一结果向上取整后减1,获取第二结果;
根据所述第一计数值、所述第二结果和预设的反向估计函数,获取更新概率;
若随机数生成器生成的随机数小于所述更新概率,将所述第二结果作为所述第二计数值;
若随机数生成器生成的随机数大于所述更新概率,将所述第二结果加1,获取第三结果;
将所述第三结果作为所述第二计数值。
8.根据权利要求5-7任一项所述的装置,其特征在于,所述装置还包括计算单元;
所述接收单元,还用于接收第五指示消息,所述第五指示消息指示计算所述第三计数值对应的数据包的真实长度;
所述计算单元,用于根据预设的反向估计函数和所述第三计数值,计算所述第三计数值对应的数据包的真实长度。
9.一种网络数据压缩统计的装置,其特征在于,所述装置包括接收器、处理器;
所述接收器,用于接收第一数据包,其中,所述第一数据包携带该数据包的流标识和长度;
所述处理器,用于将所述第一数据包的流标识和上一数据包的流标识比较;
所述处理器,还用于若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值;
所述处理器,还用于将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值;
所述处理器,还用于清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度;
所述处理器,还用于清除所述上一数据包的流标识,并缓存所述第一数据包的流标识;
所述处理器,还用于将所述第一计数值和所述第二计数值累加,获取第三计数值并缓存所述第三计数值;
所述处理器,还用于若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
10.根据权利要求9所述的装置,其特征在于,所述处理器,用于将所述第一数据包的流标识和上一数据包的流标识比较具体包括:
将所述第一数据包的流标识和寄存器中缓存的上一数据包的流标识比较;
所述处理器,用于若流标识不同,获取所述上一数据包的流标识对应的压缩后的第一计数值具体包括:
从静态随机存储器SRAM中获取缓存的所述上一数据包的流标识对应的压缩后的第一计数值;
所述处理器,用于将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值具体包括:
从缓冲计数器获取当前已缓存的上一数据包的流标识对应的数据包长度累加值;
对所述从缓冲计数器获取的当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值;
所述处理器,用于清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度具体包括:
发送第一指示消息给所述缓冲计数器,指示所述缓冲计数器清除已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度,以使得所述缓冲寄存器清除当前已缓存的上一数据包的流标识对应的数据包长度累加值,并缓存所述第一数据包的长度;
所述处理器,用于清除所述上一数据包的流标识,并缓存所述第一数据包的流标识具体包括:
发送第二指示消息给所述寄存器,所述第二指示消息携带所述第一数据包的流标识,指示所述寄存器缓存所述第一数据包的流标识,并清除上一数据包的流标识,以使得所述寄存器缓存所述第一数据包的流标识,并清除所述上一数据包的流标识;
所述处理器,用于将所述第一计数值和所述第二计数值累加,获取第三计数值并缓存所述第三计数值具体包括:
将所述第一计数值和所述第二计数值累加,获取第三计数值;
发送第三指示消息给所述SRAM,所述第三指示消息携带所述上一数据包的流标识和所述第三计数值,指示所述SRAM根据所述上一数据包的流标识缓存所述第三计数值;
所述处理器,用于若流标识相同,将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值具体包括:
若流标识相同,发送第四指示消息给所述缓冲计数器,所述第四指示消息携带所述第一数据包的长度,指示所述缓冲计数器将所述第一数据包的长度和第四计数值进行累加并缓存累加结果,其中,所述第四计数值为当前已缓存的与所述第一数据包的流标识相同的数据包的长度累加值。
11.根据权利要求9或10所述的装置,其特征在于,所述处理器将当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获得第二计数值具体包括:
根据压缩算法,将所述当前已缓存的上一数据包的流标识对应的数据包长度累加值进行压缩,获取第一结果;
若所述第一结果为小数,将所述第一结果向上取整后减1,获取第二结果;
根据所述第一计数值、所述第二结果和预设的反向估计函数,获取更新概率;
若随机数生成器生成的随机数小于所述更新概率,将所述第二结果作为所述第二计数值;
若随机数生成器生成的随机数大于所述更新概率,将所述第二结果加1,获取第三结果;
将所述第三结果作为所述第二计数值。
12.根据权利要求9-11任一项所述的装置,其特征在于,
所述接收器,还用于接收第五指示消息,所述第五指示消息指示计算所述第三计数值对应的数据包的真实长度;
所述处理器,还用于根据预设的反向估计函数和所述第三计数值,计算所述第三计数值对应的数据包的真实长度。
13.一种网络数据压缩统计的系统,其特征在于,所述系统包括寄存器、缓冲计数器、静态随机存储器SRAM以及如权利要求10所述的一种网络数据压缩统计的装置。
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201310207427.4A CN104219102B (zh) | 2013-05-29 | 2013-05-29 | 一种网络数据压缩统计的方法、装置和系统 |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201310207427.4A CN104219102B (zh) | 2013-05-29 | 2013-05-29 | 一种网络数据压缩统计的方法、装置和系统 |
Publications (2)
Publication Number | Publication Date |
---|---|
CN104219102A true CN104219102A (zh) | 2014-12-17 |
CN104219102B CN104219102B (zh) | 2018-10-30 |
Family
ID=52100259
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN201310207427.4A Active CN104219102B (zh) | 2013-05-29 | 2013-05-29 | 一种网络数据压缩统计的方法、装置和系统 |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN104219102B (zh) |
Cited By (3)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN107085576A (zh) * | 2016-02-15 | 2017-08-22 | 阿里巴巴集团控股有限公司 | 一种流式数据统计算法及装置 |
CN107431691A (zh) * | 2015-08-25 | 2017-12-01 | 华为技术有限公司 | 一种数据包传输方法、装置、节点设备以及系统 |
CN107534661A (zh) * | 2015-04-20 | 2018-01-02 | 高通股份有限公司 | 用于数据压缩的增强型压缩格式 |
Citations (3)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN101170487A (zh) * | 2006-10-25 | 2008-04-30 | 华为技术有限公司 | 数据流复用中的压缩方法和压缩系统以及压缩设备 |
US20090077252A1 (en) * | 2007-09-14 | 2009-03-19 | Microsoft Corporation | Optimized Data Stream Compression Using Data-Dependent Chunking |
CN101690079A (zh) * | 2007-03-12 | 2010-03-31 | 思杰系统有限公司 | 用于使用压缩历史来改进网络性能的系统和方法 |
-
2013
- 2013-05-29 CN CN201310207427.4A patent/CN104219102B/zh active Active
Patent Citations (3)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN101170487A (zh) * | 2006-10-25 | 2008-04-30 | 华为技术有限公司 | 数据流复用中的压缩方法和压缩系统以及压缩设备 |
CN101690079A (zh) * | 2007-03-12 | 2010-03-31 | 思杰系统有限公司 | 用于使用压缩历史来改进网络性能的系统和方法 |
US20090077252A1 (en) * | 2007-09-14 | 2009-03-19 | Microsoft Corporation | Optimized Data Stream Compression Using Data-Dependent Chunking |
Non-Patent Citations (1)
Title |
---|
CHENGCHEN HU等: "DISCO:Memory Efficient and Accurate Flow Statistics for Network Measurement", 《2010 INTERNATIONAL CONFERENCE ON DISTRIBUTED COMPUTING SYSTEMS》 * |
Cited By (4)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN107534661A (zh) * | 2015-04-20 | 2018-01-02 | 高通股份有限公司 | 用于数据压缩的增强型压缩格式 |
CN107534661B (zh) * | 2015-04-20 | 2020-06-16 | 高通股份有限公司 | 用于数据压缩的增强型压缩格式 |
CN107431691A (zh) * | 2015-08-25 | 2017-12-01 | 华为技术有限公司 | 一种数据包传输方法、装置、节点设备以及系统 |
CN107085576A (zh) * | 2016-02-15 | 2017-08-22 | 阿里巴巴集团控股有限公司 | 一种流式数据统计算法及装置 |
Also Published As
Publication number | Publication date |
---|---|
CN104219102B (zh) | 2018-10-30 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
CN103200046B (zh) | 监控网元设备性能的方法及系统 | |
US20170300595A1 (en) | Data packet extraction method and apparatus | |
CN111277848B (zh) | 直播间互动消息的处理方法、装置、电子设备及存储介质 | |
CN108880934A (zh) | 一种基于区块链的数据流量统计方法和装置 | |
WO2014177023A1 (zh) | 业务类型确定方法和装置 | |
CN107454120A (zh) | 网络攻击防御系统和防御网络攻击的方法 | |
CN110191024B (zh) | 网络流量监控方法和装置 | |
CN104219102B (zh) | 一种网络数据压缩统计的方法、装置和系统 | |
JP7046073B2 (ja) | リアルタイムデータ処理方法及び装置 | |
CN105516321A (zh) | 一种数据采集方法和装置 | |
CN112702219A (zh) | 物联网网络监测方法、装置、设备及存储介质 | |
CN110636283B (zh) | 视频传输测试方法、装置及终端设备 | |
CN112688837A (zh) | 基于时间滑动窗口的网络测量方法与装置 | |
CN108462590B (zh) | 网络流量的监控方法及装置、计算机终端 | |
CN110245051B (zh) | 数据埋点方法、装置、设备和存储介质 | |
US9485166B2 (en) | Network abnormality detection system, measurement apparatus, and analysis apparatus | |
CN108494635A (zh) | 一种基于云计算的网络流量探测系统 | |
CN113760989A (zh) | 一种无界流数据处理方法、装置、设备及存储介质 | |
CN106599005B (zh) | 一种数据归档方法及装置 | |
CN115357813B (zh) | 采样方法、装置及电子设备 | |
EP3480696A1 (en) | Adaptive event aggregation | |
CN113840157B (zh) | 访问检测方法、系统及装置 | |
CN113485893B (zh) | 一种数据采集方法、装置、系统及电子设备 | |
CN112685271A (zh) | 压测数据处理方法、装置、电子设备及可读存储介质 | |
CN108401165A (zh) | 一种视频资源推送的方法、装置及设备 |
Legal Events
Date | Code | Title | Description |
---|---|---|---|
C06 | Publication | ||
PB01 | Publication | ||
C10 | Entry into substantive examination | ||
SE01 | Entry into force of request for substantive examination | ||
GR01 | Patent grant | ||
GR01 | Patent grant |