CN109729021A - 一种报文处理方法及电子设备 - Google Patents
一种报文处理方法及电子设备 Download PDFInfo
- Publication number
- CN109729021A CN109729021A CN201811609755.6A CN201811609755A CN109729021A CN 109729021 A CN109729021 A CN 109729021A CN 201811609755 A CN201811609755 A CN 201811609755A CN 109729021 A CN109729021 A CN 109729021A
- Authority
- CN
- China
- Prior art keywords
- message
- processor
- queue
- class
- processing
- 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.)
- Pending
Links
- 238000003672 processing method Methods 0.000 title claims abstract description 10
- 238000012545 processing Methods 0.000 claims abstract description 89
- 238000000034 method Methods 0.000 claims abstract description 20
- 230000005540 biological transmission Effects 0.000 claims description 10
- 230000008569 process Effects 0.000 abstract description 9
- 238000004891 communication Methods 0.000 description 13
- 230000006870 function Effects 0.000 description 9
- 238000004458 analytical method Methods 0.000 description 6
- 230000004048 modification Effects 0.000 description 4
- 238000012986 modification Methods 0.000 description 4
- 239000000284 extract Substances 0.000 description 3
- 230000005574 cross-species transmission Effects 0.000 description 2
- 238000010586 diagram Methods 0.000 description 2
- 230000005611 electricity Effects 0.000 description 2
- 238000003780 insertion Methods 0.000 description 2
- 230000037431 insertion Effects 0.000 description 2
- 230000003993 interaction Effects 0.000 description 2
- 239000000203 mixture Substances 0.000 description 2
- 230000003068 static effect Effects 0.000 description 2
- 239000002699 waste material Substances 0.000 description 2
- 230000009471 action Effects 0.000 description 1
- 230000009286 beneficial effect Effects 0.000 description 1
- 230000008901 benefit Effects 0.000 description 1
- 238000010276 construction Methods 0.000 description 1
- 238000001514 detection method Methods 0.000 description 1
Landscapes
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
本发明公开了一种报文处理方法及电子设备,该方法应用于电子设备,所述电子设备具有至少一个处理器,所述方法包括:接收多个报文,并对所述报文进行分类处理,以将所述报文至少区分为第一类报文和第二类报文,其中,所述第一类报文和所述第二类报文具有不同的权重;基于所述报文的类型将所述报文分别排列在多个不同队列中,并使同一所述队列中仅排列有相同类型的所述报文,其中,所述队列对应有所述处理器,或者对应有所述处理器的核心;利用所述处理器处理与其相对应的所述队列中的所述报文。该方法能够在报文的处理过程中,将权重较高的控制信息报文区别于权重较低的业务报文,保证了控制信息报文在处理器过程中不被丢失。
Description
技术领域
本发明涉及与网络通信相关的数据处理领域,特别涉及一种报文处理方法及电子设备。
背景技术
目前网络成了社会中必不可少的工具,面对日益复杂的业务场景,越来越多的电子设备被加入到网络中。很多情况下,大量的电子设备都是采用通信线路串联的形式分布在网络中,如两个电子设备之间仅通过一对通信接口进行连接。在这样的配置环境中,不仅业务流量需要在两个系统之间处理,同时两个系统之间还需要处理或同步一些重要的控制信息(需对相应的控制信息报文进行处理)。通常电子设备的处理器对业务报文的检测和处理需要消耗较长时间,如果业务报文的传输速率很快,两个系统之间的通信接口的收包队列会被填满而发生丢包的情况,这时重要的控制信息报文也会发生丢包等现象,影响了对重要的控制信息报文的获取和处理。
发明内容
本发明实施例的目的在于提供一种报文处理方法及电子设备,该方法能够在报文的处理过程中,将权重较高的控制信息报文区别于权重较低的业务报文,保证了控制信息报文在处理器过程中不被丢失。
为了解决上述技术问题,本申请的实施例采用了如下技术方案:一种报文处理方法,应用于电子设备,所述电子设备具有至少一个处理器,所述方法包括:
接收多个报文,并对所述报文进行分类处理,以将所述报文至少区分为第一类报文和第二类报文,其中,所述第一类报文和所述第二类报文具有不同的权重;
基于所述报文的类型将所述报文分别排列在多个不同队列中,并使同一所述队列中仅排列有相同类型的所述报文,其中,所述队列对应有所述处理器,或者对应有所述处理器的核心;
利用所述处理器处理与其相对应的所述队列中的所述报文。
作为优选,所述的接收多个报文,并对所述报文进行分类处理包括:
分析所述报文的头数据和数据本体,以获取预设标记字段;
根据所述预设标记字段确定所述报文的类型。
作为优选,所述的接收多个报文,并对所述报文进行分类处理包括:
利用现场可编程门阵列,并根据所述报文的源地址和目的地址确定所述报文的类型,或者,
利用现场可编程门阵列,并根据所述报文的自定义字段确定所述报文的类型,其中所述报文包括基于IP地址传送的报文。
作为优选,所述电子设备至少具有第一处理器和第二处理器,所述的利用所述处理器处理与其相对应的所述队列中的所述报文包括:
将第一类报文分配给第一处理器处理;
将第二类报文分配给第一处理器和/或第二处理器处理,其中所述第一类报文的权重高于所述第二类报文的权重。
作为优选,所述的基于所述报文的类型将所述报文分别排列在多个不同队列中,并使同一所述队列中仅排列有相同类型的所述报文包括:
将所述第一类报文排列在第一队列中,将所述第二类报文分别排列在所述第二队列中和第三队列中,以使所述第一处理器处理所述第一类报文和部分所述第二类报文,所述第二处理器处理部分所述第二类报文,其中,所述第一队列具有与所述第一类报文的流量相对应的预设长度。
本发明实施例还提供了一种电子设备,具有至少一个处理器,所述电子设备包括:
接收模块,所述接收模块配置为:接收多个报文,并对所述报文进行分类处理,以将所述报文至少区分为第一类报文和第二类报文,其中,所述第一类报文和所述第二类报文具有不同的权重;
处理模块,所述处理模块配置为:基于所述报文的类型将所述报文分别排列在多个不同队列中,并使同一所述队列中仅排列有相同类型的所述报文,其中,所述队列对应有所述处理器,或者对应有所述处理器的核心;利用所述处理器处理与其相对应的所述队列中的所述报文。
作为优选,所述接收模块进一步配置为:
分析所述报文的头数据和数据本体,以获取预设标记字段;
根据所述预设标记字段确定所述报文的类型。
作为优选,所述接收模块进一步配置为:
利用现场可编程门阵列,并根据所述报文的源地址和目的地址确定所述报文的类型,或者,
利用现场可编程门阵列,并根据所述报文的自定义字段确定所述报文的类型,其中所述报文包括基于IP地址传送的报文。
作为优选,所述电子设备至少具有第一处理器和第二处理器,所述处理模块进一步配置为:
将第一类报文分配给第一处理器处理;
将第二类报文分配给第一处理器和/或第二处理器处理,其中所述第一类报文的权重高于所述第二类报文的权重。
作为优选,所述处理模块进一步配置为:
将所述第一类报文排列在第一队列中,将所述第二类报文分别排列在所述第二队列中和第三队列中,以使所述第一处理器处理所述第一类报文和部分所述第二类报文,所述第二处理器处理部分所述第二类报文,其中,所述第一队列具有与所述第一类报文的流量相对应的预设长度。
本发明实施例的有益效果在于:该方法能够在报文的处理过程中,将权重较高的控制信息报文区别于权重较低的业务报文,保证了控制信息报文在处理器过程中不被丢失。
附图说明
图1为本发明实施例的报文处理方法的流程图;
图2为本发明实施例的图1中步骤S1的流程图;
图3为本发明实施例的图1中步骤S3的流程图;
图4为本发明实施例的报文处理方法的一个具体实施例的报文流转示意图;
图5为本发明实施例的电子设备的结构示意图。
具体实施方式
此处参考附图描述本发明的各种方案以及特征。
应理解的是,可以对此处发明的实施例做出各种修改。因此,上述说明书不应该视为限制,而仅是作为实施例的范例。本领域的技术人员将想到在本发明的范围和精神内的其他修改。
包含在说明书中并构成说明书的一部分的附图示出了本发明的实施例,并且与上面给出的对本发明的大致描述以及下面给出的对实施例的详细描述一起用于解释本发明的原理。
通过下面参照附图对给定为非限制性实例的实施例的优选形式的描述,本发明的这些和其它特性将会变得显而易见。
还应当理解,尽管已经参照一些具体实例对本发明进行了描述,但本领域技术人员能够确定地实现本发明的很多其它等效形式,它们具有如权利要求所述的特征并因此都位于借此所限定的保护范围内。
当结合附图时,鉴于以下详细说明,本发明的上述和其他方面、特征和优势将变得更为显而易见。
此后参照附图描述本发明的具体实施例;然而,应当理解,所发明的实施例仅仅是本发明的实例,其可采用多种方式实施。熟知和/或重复的功能和结构并未详细描述以避免不必要或多余的细节使得本发明模糊不清。因此,本文所发明的具体的结构性和功能性细节并非意在限定,而是仅仅作为权利要求的基础和代表性基础用于教导本领域技术人员以实质上任意合适的详细结构多样地使用本发明。
本说明书可使用词组“在一种实施例中”、“在另一个实施例中”、“在又一实施例中”或“在其他实施例中”,其均可指代根据本发明的相同或不同实施例中的一个或多个。
本发明实施例的一种报文处理方法,应用于计算机等电子设备,该电子设备与其他的设备通过通信线路与其他设备通信连接,能够与其他设备进行数据交互,如该电子设备为第一电子设备,其通过通信接口与第二电子设备通信连接。该电子设备具有至少一个处理器,如可以具有多个处理器,处理器相互协调来处理任务,如图1所示,该处理方法包括以下步骤:
S1,接收多个报文,并对报文进行分类处理,以将报文至少区分为第一类报文和第二类报文,其中,第一类报文和第二类报文具有不同的权重。电子设备可以通过通信接口来接收其他设备发送的报文,接收后需要对该报文进行分类处理。本实施例中可以根据报文的实际组成情况将报文进行分类,至少分为第一类报文和第二类报文,这使得能够根据权重来对不同类型的报文进行处理,这包括对权重较高的报文单独处理,提高电子设备的处理器的处理效率。
S2,基于报文的类型将报文分别排列在多个不同队列中,并使同一队列中仅排列有相同类型的报文,其中,队列对应有处理器,或者对应有处理器的核心。
S3,利用处理器处理与其相对应的队列中的报文。
队列是数据结构中一种线性表,它允许在表的前端(front)进行删除操作,而在表的后端(rear)进行插入操作,队列的长度解决了其存储空间的大小,即存储报文的数量,当处理器的处理速度不能满足需要时,报文的数量超过队列的长度后会发生溢出现象,从而造成报文丢失,本实施中,由于根据类型将不同的报文排列在各自对应的队列中,使得处理器在处理一个队列中的一类报文时处理频率平稳,不会发生大的波动,并且能够有效提高处理器的处理效率,此外重要的是,由于具有较高权重的一类报文是排列在一个队列中,而且该队列可以根据这类报文而设置,因此可以避免这类具有较高权重的报文在处理过程中发生丢失现象。例如,控制信息报文具有较高权重,将所有的控制信息报文排列在同一个队列中,而该队列对应有一个处理器,使得处理器能够使用与其相适配的处理方式处理控制信息报文,提高处理效率,同时保证不会在接收报文的过程中丢失该控制信息报文。在另一个实施例中,处理器可以具有多个核心,各个队列也可以与核心对应,如一个队列对应一个核心或者多个队列对应一个核心,使得核心的处理方式与上述处理器处理报文的方式相似。
此外,在处理器处理与其相对应的队列中的报文的过程中,对于具有较高权重的报文来说,往往其本身流量较少,如具有较高权重的控制信息报文流量较少,不会在短时间内将相对应的队列占满,因此进一步能够保证相应的处理器能够满足处理要求,保证该具有较高权重的控制信息报文在接收过程中没有丢包现象发生。在一个实施例中,还可以将队列的长度或容量依据实际使用情况来预先设置,例如可以根据接收报文的流量,或者根据接收与该队列相对应类型的报文的流量来预先设置,从而进一步避免了报文丢失现象发生。
在本发明的一个实施例中,如图2所示,所述的接收多个报文,并对报文进行分类处理的步骤包括以下步骤:
S11,分析报文的头数据和数据本体,以获取预设标记字段;
S12,根据预设标记字段确定报文的类型。
具体来说,报文具有头数据和数据本体,可以将预设标记字段预先放置在报文中,例如可以放置在头数据之中或数据本体之中,当然也可以放置在头数据与数据本体之间,由于头数据和数据本体均具有显著的特征,因此容易分辨,进而容易从中获取到预设标记字段。例如在以太网中,报文都是固定以MAC头(头数据)开始,可以在MAC头部与数据之间预先封装几个字节的预设标记字段,用这些预设标记字段来标识报文是是哪个类型的报文,如用第一标记来表示控制信息报文。当电子设备在接收到报文时,通过分析报文中的有预设标记字段便能够快读的确定该报文的类型,进而决定将该类报文存放到那个队列当中。
在本发明的一个实施例中,所述的接收多个报文,并对报文进行分类处理的步骤包括以下步骤:
利用现场可编程门阵列,并根据报文的源地址和目的地址确定报文的类型,或者,利用现场可编程门阵列,并根据报文的自定义字段确定报文的类型,其中报文包括基于IP地址传送的报文。
具体来说,现场可编程门阵列(FPGA,Field programmable gate array)是可编程器件,与传统逻辑电路和门阵列(如PAL,GAL及CPLD器件)相比,现场可编程门阵列具有不同的结构。现场可编程门阵列利用小型查找表来实现组合逻辑,既可实现组合逻辑功能又可实现时序逻辑功能的基本逻辑单元模块。现场可编程门阵列的逻辑是通过向内部静态存储单元加载编程数据来实现的,存储在存储器单元中的值决定了逻辑单元的逻辑功能以及各模块之间或模块与I/O间的联接方式,并最终决定了现场可编程门阵列所能实现的功能,现场可编程门阵列允许无限次的编程。因此本实施例中可以对现场可编程门阵列进行编程以使其适用于接收和分析该报文,具有较大的灵活性和可扩展性。本实施例中,报文是基于IP地址传送的,可以用现场可编程门阵列来模拟电子设备的通信接口及相关硬件,如模拟电子设备的网卡来接收报文,现场可编程门阵列可以根据报文的源地址和目的地址确定报文的类型,即根据报文的源头和目的地的相关信息来确定报文的类型。在另一个实施例中,现场可编程门阵列可以根据报文的自定义字段确定报文的类型,特别是对于一些较为特殊的报文来说,可以根据该报文的具体内容在报文中预先设置自定义字段,这样现场可编程门阵列在接收报文后并对该报文分析时,可以根据自定义字段来判断报文的类型。
在本发明的一个实施例中,如图3所示,电子设备至少具有第一处理器和第二处理器,第一处理器和第二处理器可以相互配合工作,例如分别执行不同的任务或者同时执行相同的任务,所述的利用处理器处理与其相对应的队列中的报文的步骤包括以下步骤:
S31,将第一类报文分配给第一处理器处理;
S32,将第二类报文分配给第一处理器和/或第二处理器处理,其中第一类报文的权重高于第二类报文的权重。
具体来说,第一处理器可以对应处理权重较高的第一类报文,如控制信息报文,第一处理器在处理控制信息报文时可以平稳的来处理,不会对第一处理器的工作频率造成太大的波动,保证了处理速度,使得该控制信息报文不会发生丢失现象。本实施例中,将使用第一处理器和/或第二处理器处理第二类报文,例如处理权重较低的业务报文,该业务报文的数量较大,为了保证尽可能的提高处理效率可以将处理该业务报文的任务分配给第二处理器,或者同时分配给第一处理器和第二处理器,由于在处理的过程中均是针对同样的业务报文,也能够最大限度的避免业务报文的丢失,而且由于第一处理器在处理控制信息报文时仅需使用较少资源,因此还有剩余处理能力来处理业务报文,避免了处理资源浪费。
在本发明的一个实施例中,所述的基于报文的类型将报文分别排列在多个不同队列中,并使同一队列中仅排列有相同类型的报文包括以下步骤:将第一类报文排列在第一队列中,将第二类报文分别排列在第二队列中和第三队列中,以使第一处理器处理第一类报文和部分第二类报文,第二处理器处理部分第二类报文,其中,第一队列具有与第一类报文的流量相对应的预设长度。
结合图4具体来说,第一类报文可以是控制信息报文等接收数量较小的报文,第二类报文可以是接收数量较大的业务报文,因此可以将控制信息报文仅仅排列(存储)在第一队列中,由第一处理器处理;而将业务报文排列在第二队列中和第三队列中,甚至还将其排列在其他的队列中(根据实际需要来确定),由第一处理器处理第二队列,并由第二处理器处理第三队列,保证处理效率。此外在处理过程中,可以先基于排列在队列中的报文形成相应的逻辑关系,再根据该逻辑关系由处理器处理,如将设置在硬件中的第一队列的第一类报文提取出来,并在内存中加载相应程序以使其与第一处理器相关联;将设置在硬件中的第二队列的第二类报文以及第三队列的第二类报文提取出来,并在内存中加载相应程序以使其与第二处理器相关联,从而保证各个处理器能够正确的寻找到相对应的报文,并正确的处理相对应的报文。当然本实施例中还可以设置更多的队列以及分出更多的类型的报文,处理方式与上述过程类似,在此不再赘述。
本发明还提供了一种电子设备,该电子设备与其他的设备通过通信线路与其他设备通信连接,能够与其他设备进行数据交互,如该电子设备为第一电子设备,其通过通信接口与第二电子设备通信连接。该电子设备具有至少一个处理器,如可以具有多个处理器,处理器相互协调来处理任务,如图5所示,该电子设备包括:
接收模块,接收模块配置为:接收多个报文,并对报文进行分类处理,以将报文至少区分为第一类报文和第二类报文,其中,第一类报文和第二类报文具有不同的权重。接收模块可以通过通信接口来接收其他设备发送的报文,接收后需要对该报文进行分类处理。本实施例中接收模块可以根据报文的实际组成情况将报文进行分类,至少分为第一类报文和第二类报文,这使得能够根据权重来对不同类型的报文进行处理,这包括对权重较高的报文单独处理,提高电子设备的处理器的处理效率。
处理模块,处理模块配置为:基于报文的类型将报文分别排列在多个不同队列中,并使同一队列中仅排列有相同类型的报文,其中,队列对应有处理器,或者对应有处理器的核心;利用处理器处理与其相对应的队列中的报文。
队列是数据结构中一种线性表,它允许在表的前端(front)进行删除操作,而在表的后端(rear)进行插入操作,队列的长度解决了其存储空间的大小,即存储报文的数量,当处理器的处理速度不能满足需要时,报文的数量超过队列的长度后会发生溢出现象,从而造成报文丢失,本实施中,由于处理模块根据类型将不同的报文排列在各自对应的队列中,使得处理器在处理一个队列中的一类报文时处理频率平稳,不会发生大的波动,并且能够有效提高处理器的处理效率,此外重要的是,由于具有较高权重的一类报文是排列在一个队列中,而且该队列可以根据这类报文而设置,因此可以避免这类具有较高权重的报文在处理过程中发生丢失现象。例如,控制信息报文具有较高权重,将所有的控制信息报文排列在同一个队列中,而该队列对应有一个处理器,使得处理器能够使用与其相适配的处理方式处理控制信息报文,提高处理效率,同时保证不会在接收报文的过程中丢失该控制信息报文。在另一个实施例中,处理器可以具有多个核心,各个队列也可以与核心对应,如一个队列对应一个核心或者多个队列对应一个核心,使得核心的处理方式与上述处理器处理报文的方式相似。
此外,在处理器处理与其相对应的队列中的报文的过程中,对于具有较高权重的报文来说,往往其本身流量较少,如具有较高权重的控制信息报文流量较少,不会在短时间内将相对应的队列占满,因此进一步能够保证相应的处理器能够满足处理要求,保证该具有较高权重的控制信息报文在接收过程中没有丢包现象发生。在一个实施例中,处理模块还可以将队列的长度或容量依据实际使用情况来预先设置,例如可以根据接收报文的流量,或者根据接收与该队列相对应类型的报文的流量来预先设置,从而进一步避免了报文丢失现象发生。
在本发明的一个实施例中,接收模块进一步配置为:分析报文的头数据和数据本体,以获取预设标记字段;根据预设标记字段确定报文的类型。
具体来说,报文具有头数据和数据本体,可以将预设标记字段预先放置在报文中,例如可以放置在头数据之中或数据本体之中,当然也可以放置在头数据与数据本体之间,由于头数据和数据本体均具有显著的特征,因此容易分辨,进而接收模块容易从中获取到预设标记字段。例如在以太网中,报文都是固定以MAC头(头数据)开始,可以在MAC头部与数据之间预先封装几个字节的预设标记字段,用这些预设标记字段来标识报文是是哪个类型的报文,如用第一标记来表示控制信息报文。当接收模块在接收到报文时,通过分析报文中的有预设标记字段便能够快读的确定该报文的类型,进而决定将该类报文存放到那个队列当中。
在本发明的一个实施例中,接收模块进一步配置为:利用现场可编程门阵列,并根据报文的源地址和目的地址确定报文的类型,或者,利用现场可编程门阵列,并根据报文的自定义字段确定报文的类型,其中报文包括基于IP地址传送的报文。
具体来说,现场可编程门阵列(FPGA,Field programmable gate array)是可编程器件,与传统逻辑电路和门阵列(如PAL,GAL及CPLD器件)相比,现场可编程门阵列具有不同的结构。现场可编程门阵列利用小型查找表来实现组合逻辑,既可实现组合逻辑功能又可实现时序逻辑功能的基本逻辑单元模块。现场可编程门阵列的逻辑是通过向内部静态存储单元加载编程数据来实现的,存储在存储器单元中的值决定了逻辑单元的逻辑功能以及各模块之间或模块与I/O间的联接方式,并最终决定了现场可编程门阵列所能实现的功能,现场可编程门阵列允许无限次的编程。因此本实施例中可以对现场可编程门阵列进行编程以使其适用于接收和分析该报文,具有较大的灵活性和可扩展性。本实施例中,报文是基于IP地址传送的,接收模块可以用现场可编程门阵列来模拟电子设备的通信接口及相关硬件,如模拟电子设备的网卡来接收报文,现场可编程门阵列可以根据报文的源地址和目的地址确定报文的类型,即根据报文的源头和目的地的相关信息来确定报文的类型。在另一个实施例中,接收模块利用现场可编程门阵列可以根据报文的自定义字段确定报文的类型,特别是对于一些较为特殊的报文来说,可以根据该报文的具体内容在报文中预先设置自定义字段,这样现场可编程门阵列在接收报文后并对该报文分析时,可以根据自定义字段来判断报文的类型。
在本发明的一个实施例中,电子设备至少具有第一处理器和第二处理器,处理模块进一步配置为:
将第一类报文分配给第一处理器处理;
将第二类报文分配给第一处理器和/或第二处理器处理,其中第一类报文的权重高于第二类报文的权重。
具体来说,第一处理器可以对应处理权重较高的第一类报文,如控制信息报文,第一处理器在处理控制信息报文时可以平稳的来处理,不会对第一处理器的工作频率造成太大的波动,保证了处理速度,使得该控制信息报文不会发生丢失现象。本实施例中,将使用第一处理器和/或第二处理器处理第二类报文,例如处理权重较低的业务报文,该业务报文的数量较大,为了保证尽可能的提高处理效率处理模块可以将处理该业务报文的任务分配给第二处理器,或者同时分配给第一处理器和第二处理器,由于在处理的过程中均是针对同样的业务报文,也能够最大限度的避免业务报文的丢失,而且由于第一处理器在处理控制信息报文时仅需使用较少资源,因此还有剩余处理能力来处理业务报文,避免了处理资源浪费。
在本发明的一个实施例中,处理模块进一步配置为:将第一类报文排列在第一队列中,将第二类报文分别排列在第二队列中和第三队列中,以使第一处理器处理第一类报文和部分第二类报文,第二处理器处理部分第二类报文,其中,第一队列具有与第一类报文的流量相对应的预设长度。
结合图4具体来说,第一类报文可以是控制信息报文等接收数量较小的报文,第二类报文可以是接收数量较大的业务报文,因此处理模块可以将控制信息报文仅仅排列(存储)在第一队列中,由第一处理器处理;而将业务报文排列在第二队列中和第三队列中,甚至还将其排列在其他的队列中(根据实际需要来确定),由第一处理器处理第二队列,并由第二处理器处理第三队列,保证处理效率。此外在处理过程中,处理模块可以先基于排列在队列中的报文形成相应的逻辑关系,再根据该逻辑关系由处理器处理,如将设置在硬件中的第一队列的第一类报文提取出来,并在内存中加载相应程序以使其与第一处理器相关联;将设置在硬件中的第二队列的第二类报文以及第三队列的第二类报文提取出来,并在内存中加载相应程序以使其与第二处理器相关联,从而保证各个处理器能够正确的寻找到相对应的报文,并正确的处理相对应的报文。当然本实施例中还可以设置更多的队列以及分出更多的类型的报文,处理方式与上述过程类似,在此不再赘述。
以上实施例仅为本发明的示例性实施例,不用于限制本发明,本发明的保护范围由权利要求书限定。本领域技术人员可以在本发明的实质和保护范围内,对本发明做出各种修改或等同替换,这种修改或等同替换也应视为落在本发明的保护范围内。
Claims (10)
1.一种报文处理方法,其特征在于,应用于电子设备,所述电子设备具有至少一个处理器,所述方法包括:
接收多个报文,并对所述报文进行分类处理,以将所述报文至少区分为第一类报文和第二类报文,其中,所述第一类报文和所述第二类报文具有不同的权重;
基于所述报文的类型将所述报文分别排列在多个不同队列中,并使同一所述队列中仅排列有相同类型的所述报文,其中,所述队列对应有所述处理器,或者对应有所述处理器的核心;
利用所述处理器处理与其相对应的所述队列中的所述报文。
2.根据权利要求1所述的方法,其特征在于,所述的接收多个报文,并对所述报文进行分类处理包括:
分析所述报文的头数据和数据本体,以获取预设标记字段;
根据所述预设标记字段确定所述报文的类型。
3.根据权利要求1所述的方法,其特征在于,所述的接收多个报文,并对所述报文进行分类处理包括:
利用现场可编程门阵列,并根据所述报文的源地址和目的地址确定所述报文的类型,或者,
利用现场可编程门阵列,并根据所述报文的自定义字段确定所述报文的类型,其中所述报文包括基于IP地址传送的报文。
4.根据权利要求1所述的方法,其特征在于,所述电子设备至少具有第一处理器和第二处理器,所述的利用所述处理器处理与其相对应的所述队列中的所述报文包括:
将第一类报文分配给第一处理器处理;
将第二类报文分配给第一处理器和/或第二处理器处理,其中所述第一类报文的权重高于所述第二类报文的权重。
5.根据权利要求4所述的方法,其特征在于,所述的基于所述报文的类型将所述报文分别排列在多个不同队列中,并使同一所述队列中仅排列有相同类型的所述报文包括:
将所述第一类报文排列在第一队列中,将所述第二类报文分别排列在所述第二队列中和第三队列中,以使所述第一处理器处理所述第一类报文和部分所述第二类报文,所述第二处理器处理部分所述第二类报文,其中,所述第一队列具有与所述第一类报文的流量相对应的预设长度。
6.一种电子设备,其特征在于,具有至少一个处理器,所述电子设备包括:
接收模块,所述接收模块配置为:接收多个报文,并对所述报文进行分类处理,以将所述报文至少区分为第一类报文和第二类报文,其中,所述第一类报文和所述第二类报文具有不同的权重;
处理模块,所述处理模块配置为:基于所述报文的类型将所述报文分别排列在多个不同队列中,并使同一所述队列中仅排列有相同类型的所述报文,其中,所述队列对应有所述处理器,或者对应有所述处理器的核心;利用所述处理器处理与其相对应的所述队列中的所述报文。
7.根据权利要求6所述的电子设备,其特征在于,所述接收模块进一步配置为:
分析所述报文的头数据和数据本体,以获取预设标记字段;
根据所述预设标记字段确定所述报文的类型。
8.根据权利要求6所述的电子设备,其特征在于,所述接收模块进一步配置为:
利用现场可编程门阵列,并根据所述报文的源地址和目的地址确定所述报文的类型,或者,
利用现场可编程门阵列,并根据所述报文的自定义字段确定所述报文的类型,其中所述报文包括基于IP地址传送的报文。
9.根据权利要求6所述的电子设备,其特征在于,所述电子设备至少具有第一处理器和第二处理器,所述处理模块进一步配置为:
将第一类报文分配给第一处理器处理;
将第二类报文分配给第一处理器和/或第二处理器处理,其中所述第一类报文的权重高于所述第二类报文的权重。
10.根据权利要求9所述的电子设备,其特征在于,所述处理模块进一步配置为:
将所述第一类报文排列在第一队列中,将所述第二类报文分别排列在所述第二队列中和第三队列中,以使所述第一处理器处理所述第一类报文和部分所述第二类报文,所述第二处理器处理部分所述第二类报文,其中,所述第一队列具有与所述第一类报文的流量相对应的预设长度。
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201811609755.6A CN109729021A (zh) | 2018-12-27 | 2018-12-27 | 一种报文处理方法及电子设备 |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201811609755.6A CN109729021A (zh) | 2018-12-27 | 2018-12-27 | 一种报文处理方法及电子设备 |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN109729021A true CN109729021A (zh) | 2019-05-07 |
Family
ID=66297363
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201811609755.6A Pending CN109729021A (zh) | 2018-12-27 | 2018-12-27 | 一种报文处理方法及电子设备 |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN109729021A (zh) |
Cited By (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN110943941A (zh) * | 2019-12-06 | 2020-03-31 | 北京天融信网络安全技术有限公司 | 一种报文接收方法、发送方法、网卡及电子设备 |
| CN112799840A (zh) * | 2021-01-29 | 2021-05-14 | 北京百度网讯科技有限公司 | 用于传输数据的方法、装置、设备以及存储介质 |
| CN113630318A (zh) * | 2020-05-06 | 2021-11-09 | 华为技术有限公司 | 报文传输的方法和框式通信设备 |
| WO2024011854A1 (zh) * | 2022-07-14 | 2024-01-18 | 天翼云科技有限公司 | 一种报文传输方法及装置 |
| WO2024244799A1 (zh) * | 2023-05-31 | 2024-12-05 | 深圳市中兴微电子技术有限公司 | 负载调度方法、负载调度装置及可读介质 |
| CN119583686A (zh) * | 2024-11-29 | 2025-03-07 | 天翼云科技有限公司 | 报文处理方法、装置、计算机设备、可读存储介质和程序产品 |
Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20030081615A1 (en) * | 2001-10-22 | 2003-05-01 | Sun Microsystems, Inc. | Method and apparatus for a packet classifier |
| CN104579962A (zh) * | 2015-01-23 | 2015-04-29 | 盛科网络(苏州)有限公司 | 一种区分不同报文的QoS策略的方法及装置 |
| CN105511954A (zh) * | 2014-09-23 | 2016-04-20 | 华为技术有限公司 | 一种报文处理方法及装置 |
| CN106713185A (zh) * | 2016-12-06 | 2017-05-24 | 瑞斯康达科技发展股份有限公司 | 一种多核cpu的负载均衡方法及装置 |
| CN106789152A (zh) * | 2016-11-17 | 2017-05-31 | 东软集团股份有限公司 | 基于多队列网卡的处理器扩展方法及装置 |
| CN107659515A (zh) * | 2017-09-29 | 2018-02-02 | 曙光信息产业(北京)有限公司 | 报文处理方法、装置、报文处理芯片及服务器 |
-
2018
- 2018-12-27 CN CN201811609755.6A patent/CN109729021A/zh active Pending
Patent Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20030081615A1 (en) * | 2001-10-22 | 2003-05-01 | Sun Microsystems, Inc. | Method and apparatus for a packet classifier |
| CN105511954A (zh) * | 2014-09-23 | 2016-04-20 | 华为技术有限公司 | 一种报文处理方法及装置 |
| CN104579962A (zh) * | 2015-01-23 | 2015-04-29 | 盛科网络(苏州)有限公司 | 一种区分不同报文的QoS策略的方法及装置 |
| CN106789152A (zh) * | 2016-11-17 | 2017-05-31 | 东软集团股份有限公司 | 基于多队列网卡的处理器扩展方法及装置 |
| CN106713185A (zh) * | 2016-12-06 | 2017-05-24 | 瑞斯康达科技发展股份有限公司 | 一种多核cpu的负载均衡方法及装置 |
| CN107659515A (zh) * | 2017-09-29 | 2018-02-02 | 曙光信息产业(北京)有限公司 | 报文处理方法、装置、报文处理芯片及服务器 |
Cited By (9)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN110943941A (zh) * | 2019-12-06 | 2020-03-31 | 北京天融信网络安全技术有限公司 | 一种报文接收方法、发送方法、网卡及电子设备 |
| CN110943941B (zh) * | 2019-12-06 | 2022-03-11 | 北京天融信网络安全技术有限公司 | 一种报文接收方法、网卡及电子设备 |
| CN113630318A (zh) * | 2020-05-06 | 2021-11-09 | 华为技术有限公司 | 报文传输的方法和框式通信设备 |
| EP4135276A4 (en) * | 2020-05-06 | 2023-10-04 | Huawei Technologies Co., Ltd. | MESSAGE TRANSMISSION METHOD AND FRAMEWORK COMMUNICATION DEVICE |
| CN112799840A (zh) * | 2021-01-29 | 2021-05-14 | 北京百度网讯科技有限公司 | 用于传输数据的方法、装置、设备以及存储介质 |
| CN112799840B (zh) * | 2021-01-29 | 2024-07-05 | 北京百度网讯科技有限公司 | 用于传输数据的方法、装置、设备以及存储介质 |
| WO2024011854A1 (zh) * | 2022-07-14 | 2024-01-18 | 天翼云科技有限公司 | 一种报文传输方法及装置 |
| WO2024244799A1 (zh) * | 2023-05-31 | 2024-12-05 | 深圳市中兴微电子技术有限公司 | 负载调度方法、负载调度装置及可读介质 |
| CN119583686A (zh) * | 2024-11-29 | 2025-03-07 | 天翼云科技有限公司 | 报文处理方法、装置、计算机设备、可读存储介质和程序产品 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN109729021A (zh) | 一种报文处理方法及电子设备 | |
| DE69129851T2 (de) | Konfigurierbare gigabit/s Vermittlunganpassungseinrichtung | |
| US6226267B1 (en) | System and process for application-level flow connection of data processing networks | |
| EP2507951B1 (en) | An apparatus and a method of receiving and storing data packets controlled by a central controller | |
| CN101217467B (zh) | 核间负载分发装置及方法 | |
| EP2317702A2 (en) | Methods and apparatus related to a distributed switch fabric | |
| US9106593B2 (en) | Multicast flow reordering scheme | |
| CN105975433B (zh) | 一种报文处理方法及装置 | |
| CN110505161B (zh) | 一种报文处理方法及设备 | |
| WO2009139805A2 (en) | System and method for offloading packet protocol encapsulation from software | |
| CN108121608A (zh) | 一种队列调度方法以及节点设备 | |
| CN103873550A (zh) | 用于ecu和/或测量设备之间的数据传输的方法 | |
| EP2680536A1 (en) | Methods and apparatus for providing services in a distributed switch | |
| CN108347477A (zh) | 数据发送方法、装置以及服务器 | |
| CN104022896B (zh) | 一种配置管理方法、装置及网络设备 | |
| CN104135548A (zh) | 基于fpga的静态nat实现方法及装置 | |
| CN110166857B (zh) | 一种光纤通道交换机动态配置的实现方法 | |
| CN104052679B (zh) | 网络流量的负载均衡方法和装置 | |
| US20160285737A1 (en) | Network control device, network control method, and storage medium | |
| US20100008372A1 (en) | Network component, method for the operation of such a network component, and automation system with such a network component | |
| CN114006927A (zh) | 业务报文的处理方法及其处理装置、电子设备、存储介质 | |
| CN106713010B (zh) | 一种航电网络系统的通信方法及系统 | |
| EP3101843A2 (en) | Capturing network data to provide to a data analyser | |
| CN109800074A (zh) | 任务数据并发执行方法、装置以及电子设备 | |
| CN105357148A (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 | ||
| RJ01 | Rejection of invention patent application after publication |
Application publication date: 20190507 |
|
| RJ01 | Rejection of invention patent application after publication |