[go: up one dir, main page]

CN105656804B - 一种报文处理方法及装置 - Google Patents

一种报文处理方法及装置 Download PDF

Info

Publication number
CN105656804B
CN105656804B CN201410667895.4A CN201410667895A CN105656804B CN 105656804 B CN105656804 B CN 105656804B CN 201410667895 A CN201410667895 A CN 201410667895A CN 105656804 B CN105656804 B CN 105656804B
Authority
CN
China
Prior art keywords
message
channel
messages
module
identifiers
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.)
Active
Application number
CN201410667895.4A
Other languages
English (en)
Other versions
CN105656804A (zh
Inventor
李良峰
杨金梅
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
ZTE Corp
Original Assignee
ZTE Corp
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by ZTE Corp filed Critical ZTE Corp
Priority to CN201410667895.4A priority Critical patent/CN105656804B/zh
Priority to EP15860389.4A priority patent/EP3223478A4/en
Priority to JP2017525886A priority patent/JP2017536042A/ja
Priority to PCT/CN2015/071131 priority patent/WO2016078212A1/zh
Publication of CN105656804A publication Critical patent/CN105656804A/zh
Application granted granted Critical
Publication of CN105656804B publication Critical patent/CN105656804B/zh
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Classifications

    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L49/00—Packet switching elements
    • H04L49/25—Routing or path finding in a switch fabric
    • H04L49/252—Store and forward routing
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L47/00—Traffic control in data switching networks
    • H04L47/10—Flow control; Congestion control
    • H04L47/34—Flow control; Congestion control ensuring sequence integrity, e.g. using sequence numbers
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L47/00—Traffic control in data switching networks
    • H04L47/10—Flow control; Congestion control
    • H04L47/36—Flow control; Congestion control by determining packet size, e.g. maximum transfer unit [MTU]
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L47/00—Traffic control in data switching networks
    • H04L47/50—Queue scheduling
    • H04L47/62—Queue scheduling characterised by scheduling criteria
    • H04L47/622—Queue service order
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L49/00—Packet switching elements
    • H04L49/90—Buffering arrangements
    • H04L49/9005—Buffering arrangements using dynamic buffer space allocation
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L49/00—Packet switching elements
    • H04L49/90—Buffering arrangements
    • H04L49/901—Buffering arrangements using storage descriptor, e.g. read or write pointers
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L49/00—Packet switching elements
    • H04L49/90—Buffering arrangements
    • H04L49/9047—Buffering arrangements including multiple buffers, e.g. buffer pools
    • H04L49/9052—Buffering arrangements including multiple buffers, e.g. buffer pools with buffers of different sizes

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Computer Security & Cryptography (AREA)
  • Data Exchanges In Wide-Area Networks (AREA)
  • Information Transfer Between Computers (AREA)

Abstract

本发明公开了一种报文处理方法，包括：接收报文，将所述报文分发至有效的通道，记录所述通道的通道标识并存储；对分发的报文进行处理并存储；按照存储通道标识的顺序读取通道标识，每读取一个通道标识，发送读取的通道标识对应的通道内的报文，直至所有报文发送结束。本发明还同时公开了一种报文处理装置。

Description

一种报文处理方法及装置
技术领域
本发明涉及通信技术领域，尤其涉及一种报文处理方法及装置。
背景技术
随着高速数据通信网络的快速发展，交换机端口的线速已经达到几百Gbit/S，因此，要求网络设备具有强大的报文处理效率；为了提高网络设备处理报文的效率，通常对报文采用分布式处理，即：报文后，从入端口进入的报文分配至多个通道，各个通道并行处理报文，然后再将报文按照进入入端口的顺序经出端口发出。
但是，分布式处理报文会存在报文乱序的问题，即：将报文分配至多个通道后，报文会经过若干中间节点，在出口端处报文未按照报文的进入顺序发出，严重影响网络设备的性能；如：在1588V2精确时钟同步协议中，报文乱序会导致报文携带的时间戳不准确，从而无法实现网络设备的同步；因此，如何在分布式处理报文的情况下，防止报文丢失和报文乱序是亟待解决的问题。
发明内容
有鉴于此，本发明实施例期望提供一种报文处理方法及装置，不仅能够提高处理报文的效率，而且能够保证报文的发出顺序与报文的接收顺序一致。
本发明实施例的技术方案是这样实现的：
本发明实施例提供一种报文处理方法，所述方法包括：接收报文，将所述报文分发至有效的通道，记录所述通道的通道标识并存储；对分发的报文进行处理并存储；按照存储通道标识的顺序读取通道标识，每读取一个通道标识，发送读取的通道标识对应的通道内的报文，直至所有报文发送结束。
上述实现方案中，所述将所述报文分发至有效的通道，包括：分别计算接收的报文流量和通道能够处理的报文流量，在接收的报文流量小于所述通道能够处理的报文流量时，将接收的报文分发至所述通道。
上述实现方案中，所述对分发的报文进行处理，包括：修改分发的报文的字段内容，和/或标识分发的报文的优先级。
上述实现方案中，所述发送读取的通道标识对应的通道内的报文，包括：发送读取的通道标识对应的通道内当前存储的报文中最先存储的报文。
上述实现方案中，所述按照存储通道标识的顺序读取通道标识之后，所述方法还包括：删除已经读取的通道标识。
本发明实施例还提供一种报文处理装置，所述装置包括：报文接收模块、通道标识模块、报文处理模块、存储模块和报文发送模块；其中，
所述报文接收模块，用于接收报文，将所述报文分发至有效的通道；
所述通道标识模块，用于记录所述通道的通道标识；
所述报文处理模块，用于对分发的报文进行处理；
所述存储模块，用于存储通道标识及处理后的报文；
所述报文发送模块，用于按照存储通道标识的顺序读取通道标识，每读取一个通道标识，发送读取的通道标识对应的通道内的报文，直至所有报文发送结束。
上述实现方案中，所述报文接收模块，具体用于分别计算接收的报文流量和通道能够处理的报文流量，在接收的报文流量小于所述通道能够处理的报文流量时，将接收的报文分发至所述通道。
上述实现方案中，所述报文处理模块，具体用于修改分发的报文的字段内容，和/或标识分发的报文的优先级。
上述实现方案中，所述报文发送模块，具体用于送读取的通道标识对应的通道内当前存储的报文中最先存储的报文。
上述实现方案中，所述报文发送模块，还用于在按照存储通道标识的顺序读取通道标识之后，删除已经读取的通道标识。
本发明实施例所提供的报文处理方法及装置，接收报文，将所述报文分发至有效的通道，记录所述通道的通道标识并存储；对分发的报文进行处理并存储；按照存储通道标识的顺序读取通道标识，每读取一个通道标识，发送读取的通道标识对应的通道内的报文，直至所有报文发送结束。如此，在将报文分发至多个通道的情况下，通过记录接收报文的通道的通道标识来识别报文的接收顺序，依据报文的接收顺序依次发送报文，能够避免报文发送过程中产生的报文丢失和报文乱序问题。
附图说明
图1为本发明实施例报文处理方法的基本处理流程示意图；
图2为本发明实施例报文处理方法的详细处理流程示意图；
图3为本发明实施例报文处理装置的组成结构示意图。
具体实施方式
本发明实施例中，接收报文，将所述报文分发至有效的通道，记录所述通道的通道标识并存储；对分发的报文进行处理并存储；按照存储通道标识的顺序读取通道标识，每读取一个通道标识，发送读取的通道标识对应的通道内的报文，直至所有报文发送结束。
本发明实施例报文处理方法的基本处理流程，如图1所示，包括以下步骤：
步骤101，接收报文，将所述报文分发至有效的通道，记录所述通道的通道标识并存储；
具体地，报文接收模块接收报文，计算接收的报文流量和通道能够处理的报文流量，在接收的报文流量大于所述通道能够处理的报文流量时，不向所述通道分发报文；在接收的报文流量小于所述通道能够处理的报文流量时，将接受的报文分发至所述通道，通道标识模块记录分发报文的通道的通道标识，存储模块存储记录的通道标识。
步骤102，对分发的报文进行处理并存储；
具体地，报文处理模块处理报文根据实际需求修改分发的报文的字段内容，和/或标识分发的报文的优先级，存储模块存储处理后的报文。
步骤103，按照存储通道标识的顺序读取通道标识，每读取一个通道标识，发送读取的通道标识对应的通道内的报文，直至所有报文发送结束；
具体地，按照存储通道标识的顺序读取通道标识，并删除已经读取的通道标识，每读取一个通道标识，便发送读取的通道标识对应的通道内当前存储的报文中最先存储的报文，直至所有报文发送结束。
本发明实施例中，所述报文处理方法可以应用与计算机网络，也可以应用于任何需要对报文进行分通道高速处理、对报文进行流量控制和通道合并的场景。
以三个通道同时对报文进行处理为例，本发明实施例报文处理方法的详细处理流程，如图2所示，包括以下步骤：
步骤201，接收第一报文，将所述报文分发至有效的通道，记录所述通道的通道标识并存储；
具体地，报文接收计算第一报文的流量为10Mbit，第一通道的流量为15Mbit，第一报文流量小于第一通道能够处理的报文流量，因此，将第一报文分发至第一通道；报文标识模块记录第一通道的通道标识为“1”，存储模块存储通道标识“1”。
步骤202，对第一报文进行处理并存储；
具体地，报文处理模块修改第一报文的字段内容，存储模块存储修改后的第一报文。
步骤203，接收第二报文，将所述报文分发至有效的通道，记录所述通道的通道标识并存储；
具体地，报文接收计算第二报文的流量为15Mbit，第二通道的流量为50Mbit，第二报文流量小于第二通道能够处理的报文流量，因此，将第二报文分发至第二通道；报文标识模块记录第二通道的通道标识为“2”，存储模块存储通道标识“2”。
步骤204，对第二报文进行处理并存储；
具体地，报文处理模块标识第二报文的优先级，存储模块存储修改后的第二报文。
步骤205，接收第三报文，将所述报文分发至有效的通道，记录所述通道的通道标识并存储；
具体地，报文接收计算第三报文的流量为10Mbit，第三通道的流量为100Mbit，第三报文流量小于第三通道能够处理的报文流量，因此，将第三报文分发至第三通道；报文标识模块记录第三通道的通道标识为“3”，存储模块存储通道标识“3”。
步骤206，对第三报文进行处理并存储；
具体地，报文处理模块标识第三报文的优先级，存储模块存储修改后的第三报文。
步骤207，接收第四报文，将所述报文分发至有效的通道，记录所述通道的通道标识并存储；
具体地，报文接收计算第四报文的流量为10Mbit，第一通道的流量为5Mbit，第四报文的流量小于第一通道能够处理的报文流量，因此，不向第一通道分发第四报文；第二通道的流量为35Mbit，第四报文流量小于第二通道能够处理的报文流量，因此，将第四报文分发至第二通道；报文标识模块记录第二通道的通道标识为“2”，存储模块存储通道标识“2”。
步骤208，对第四报文进行处理并存储；
具体地，报文处理模块标识第四报文的优先级，存储模块存储修改后的第四报文。
步骤209，按照存储通道标识的顺序读取通道标识，每读取一个通道标识，发送读取的通道标识对应的通道内的报文，直至所有报文发送结束。
具体地，此时存储模块内存储的通道标识的顺序为“1-2-3-2”，报文发送模块按照存储通道标识的顺序读取通道标识时，第一次读取的通道标识为“1”，发送通道标识“1”对应的第一通道内的报文；
报文发送模块第二次读取通道标识为“2”，发送通道标识“2”对应的第二通道内的报文；这里，第二通道内有两份报文，应发送最先存储的一份报文；
报文发送模块第三次读取通道标识为“3”，发送通道标识“3”对应的第三通道内的报文；
报文发送模块第四次读取通道标识为“2”发送通道标识“2”对应的第二通道内的报文；此时，第二通道内仅有一份报文，则发送该报文。
为实现上述报文处理方法，本发明实施例还提供一种报文处理装置，所述装置的组成结构如图3所示，包括：报文接收模块11、通道标识模块12、报文处理模块13、存储模块14和报文发送模块15；其中，
所述报文接收模块11，用于接收报文，将所述报文分发至有效的通道；
所述通道标识模块12，用于记录所述通道的通道标识；
所述报文处理模块13，用于对分发的报文进行处理；
所述存储模块14，用于存储通道标识及处理后的报文；
所述报文发送模块15，用于按照存储通道标识的顺序读取通道标识，每读取一个通道标识，发送读取的通道标识对应的通道内的报文，直至所有报文发送结束。
上述实现方案中，所述报文接收模块11，具体用于分别计算接收的报文流量和通道能够处理的报文流量，在接收的报文流量小于所述通道能够处理的报文流量时，将接收的报文分发至所述通道。
上述实现方案中，报文处理模块13，具体用于修改分发的报文的字段内容，和/或标识分发的报文的优先级。
上述实现方案中，所述报文发送15模块，具体用于送读取的通道标识对应的通道内当前存储的报文中最先存储的报文。
上述实现方案中，所述报文发送模块15，还用于在按照存储通道标识的顺序读取通道标识之后，删除已经读取的通道标识。
本发明实施例中，所述终端设备可以为：手机、平板电脑等移动终端，可以为电视遥控器等电子设备。
需要说明的是，在实际应用中，所述报文接收模块11、通道标识模块12、报文处理模块13、存储模块14和报文发送模块15的功能可由位于报文处理装置上的中央处理器(CPU)、或微处理器(MPU)、或数字信号处理器(DSP)、或可编程门阵列(FPGA)实现。
以上所述仅为本发明的较佳实施例而已，并非用于限定本发明的保护范围。

Claims (10)

1.一种报文处理方法，其特征在于，所述方法包括：
接收报文，将所述报文分发至有效的通道，记录所述通道的通道标识并存储；其中，所述有效的通道具体为通道流量大于接收的所述报文流量的通道；
对分发的报文进行处理并存储；
按照存储通道标识的顺序读取通道标识，每读取一个通道标识，发送读取的通道标识对应的通道内的报文，直至所有报文发送结束。
2.根据权利要求1所述报文处理方法，其特征在于，所述将所述报文分发至有效的通道，包括：
分别计算接收的报文流量和通道能够处理的报文流量，在接收的报文流量小于所述通道能够处理的报文流量时，将接收的报文分发至所述通道。
3.根据权利要求1所述报文处理方法，其特征在于，所述对分发的报文进行处理，包括：
修改分发的报文的字段内容，和/或标识分发的报文的优先级。
4.根据权利要求1所述报文处理方法，其特征在于，所述发送读取的通道标识对应的通道内的报文，包括：
发送读取的通道标识对应的通道内当前存储的报文中最先存储的报文。
5.根据权利要求1所述报文处理方法，其特征在于，所述按照存储通道标识的顺序读取通道标识之后，所述方法还包括：
删除已经读取的通道标识。
6.一种报文处理装置，其特征在于，所述装置包括：报文接收模块、通道标识模块、报文处理模块、存储模块和报文发送模块；其中，
所述报文接收模块，用于接收报文，将所述报文分发至有效的通道；其中，所述有效的通道具体为通道流量大于接收的所述报文流量的通道；
所述通道标识模块，用于记录所述通道的通道标识；
所述报文处理模块，用于对分发的报文进行处理；
所述存储模块，用于存储通道标识及处理后的报文；
所述报文发送模块，用于按照存储通道标识的顺序读取通道标识，每读取一个通道标识，发送读取的通道标识对应的通道内的报文，直至所有报文发送结束。
7.根据权利要求6所述报文处理装置，其特征在于，所述报文接收模块，具体用于分别计算接收的报文流量和通道能够处理的报文流量，在接收的报文流量小于所述通道能够处理的报文流量时，将接收的报文分发至所述通道。
8.根据权利要求6所述报文处理装置，其特征在于，所述报文处理模块，具体用于修改分发的报文的字段内容，和/或标识分发的报文的优先级。
9.根据权利要求6所述报文处理装置，其特征在于，所述报文发送模块，具体用于送读取的通道标识对应的通道内当前存储的报文中最先存储的报文。
10.根据权利要求6所述报文处理装置，其特征在于，所述报文发送模块，还用于在按照存储通道标识的顺序读取通道标识之后，删除已经读取的通道标识。
CN201410667895.4A 2014-11-20 2014-11-20 一种报文处理方法及装置 Active CN105656804B (zh)

Priority Applications (4)

Application Number Priority Date Filing Date Title
CN201410667895.4A CN105656804B (zh) 2014-11-20 2014-11-20 一种报文处理方法及装置
EP15860389.4A EP3223478A4 (en) 2014-11-20 2015-01-20 Packet processing method and device, and storage medium
JP2017525886A JP2017536042A (ja) 2014-11-20 2015-01-20 メッセージ処理方法、装置、プログラム及び記録媒体
PCT/CN2015/071131 WO2016078212A1 (zh) 2014-11-20 2015-01-20 一种报文处理方法、装置及存储介质

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN201410667895.4A CN105656804B (zh) 2014-11-20 2014-11-20 一种报文处理方法及装置

Publications (2)

Publication Number Publication Date
CN105656804A CN105656804A (zh) 2016-06-08
CN105656804B true CN105656804B (zh) 2019-12-24

Family

ID=56013136

Family Applications (1)

Application Number Title Priority Date Filing Date
CN201410667895.4A Active CN105656804B (zh) 2014-11-20 2014-11-20 一种报文处理方法及装置

Country Status (4)

Country Link
EP (1) EP3223478A4 (zh)
JP (1) JP2017536042A (zh)
CN (1) CN105656804B (zh)
WO (1) WO2016078212A1 (zh)

Families Citing this family (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN108462652B (zh) 2017-07-31 2019-11-12 新华三技术有限公司 一种报文处理方法、装置和网络设备
CN114124854B (zh) * 2021-11-29 2024-02-09 天融信雄安网络安全技术有限公司 报文处理方法、装置、电子设备及可读存储介质

Family Cites Families (7)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JPH1132055A (ja) * 1997-07-14 1999-02-02 Fujitsu Ltd バッファ制御装置及びバッファ制御方法
KR100273641B1 (ko) * 1998-11-11 2000-12-15 윤종용 공통 메모리 스위치에서 셀 그룹 처리장치 및 그 처리방법
US6862282B1 (en) * 2000-08-29 2005-03-01 Nortel Networks Limited Method and apparatus for packet ordering in a data processing system
US8478811B2 (en) * 2002-10-08 2013-07-02 Netlogic Microsystems, Inc. Advanced processor with credit based scheme for optimal packet flow in a multi-processor system on a chip
CN101834791B (zh) * 2010-04-21 2011-12-21 瑞斯康达科技发展股份有限公司 一种组播报文转发方法
CN102204183A (zh) * 2011-05-09 2011-09-28 华为技术有限公司 报文保序处理方法、保序协处理器和网络设备
CN102638589B (zh) * 2012-04-12 2015-01-21 北京星网锐捷网络技术有限公司 一种通道的对应连接关系的确定方法及相关连接端和系统

Also Published As

Publication number Publication date
EP3223478A1 (en) 2017-09-27
CN105656804A (zh) 2016-06-08
JP2017536042A (ja) 2017-11-30
WO2016078212A1 (zh) 2016-05-26
EP3223478A4 (en) 2017-12-06

Similar Documents

Publication Publication Date Title
US12075106B2 (en) Message sending method and device, readable medium and electronic device
CN109412964B (zh) 报文控制方法及网络装置
US8914662B2 (en) Implementing transparent clock by correcting time information carried in data using residence time information
EP3068087B1 (en) Method and system for transmitting data parallelly on wireless link and wired link
WO2014041547A1 (en) Live video broadcasting from a mobile device
US7583735B2 (en) Methods and systems for handling underflow and overflow in a software defined radio
US20170310720A1 (en) Non-DSG Mechanisms for Aligning Client Devices with Their Multicast Data Flows in a DOCSIS Network Environment
CN105656800A (zh) 一种传输报文的方法及装置
CN105656804B (zh) 一种报文处理方法及装置
CN112787873B (zh) 一种ioam时延测量性能排序方法及系统
CN114422589B (zh) 数据传输方法、装置、设备及存储介质
CN104219157A (zh) 一种统计时间间隔的确定方法和设备
WO2016131323A1 (zh) 一种控制双连接x2状态报告发送的方法、装置及辅基站
CN103457793A (zh) 一种组播时延测量方法、设备及系统
US9130827B2 (en) Sampling from distributed streams of data
EP4207687A1 (en) Traffic shaping method and device
CN104159323A (zh) 用户终端数据传输方法及多路传输用户终端
KR101958374B1 (ko) 네트워크 내의 지연을 정확하게 추정하는 서비스들, 시스템들 및 방법들
CN107276620B (zh) 耳机数据传输的方法、终端设备及计算机可读存储介质
CN107547323B (zh) 报文传输方法、装置、相关电子设备及可读存储介质
EP2699028A2 (en) Method and apparatus for sending messages
CN111327923B (zh) 一种音频流切换方法及装置
CN103051383A (zh) 处理信息的方法和设备
US9674569B2 (en) Clock recovery in transponder-bonded systems using BCRs and marker packets at a set-top box
CN109413485B (zh) 数据缓存方法及装置

Legal Events

Date Code Title Description
C06 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