CN111600811A - Message processing method and device - Google Patents
Message processing method and device Download PDFInfo
- Publication number
- CN111600811A CN111600811A CN202010290982.8A CN202010290982A CN111600811A CN 111600811 A CN111600811 A CN 111600811A CN 202010290982 A CN202010290982 A CN 202010290982A CN 111600811 A CN111600811 A CN 111600811A
- Authority
- CN
- China
- Prior art keywords
- message
- service
- service message
- copying
- packet
- 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.)
- Withdrawn
Links
- 238000003672 processing method Methods 0.000 title claims abstract description 17
- 238000000034 method Methods 0.000 claims abstract description 40
- 230000009471 action Effects 0.000 claims description 30
- 230000008569 process Effects 0.000 claims description 15
- 230000010076 replication Effects 0.000 claims description 2
- 230000003362 replicative effect Effects 0.000 claims description 2
- 230000000694 effects Effects 0.000 abstract description 6
- 230000005540 biological transmission Effects 0.000 description 9
- 238000004891 communication Methods 0.000 description 9
- 238000010586 diagram Methods 0.000 description 4
- 230000006870 function Effects 0.000 description 3
- 230000009286 beneficial effect Effects 0.000 description 1
- 230000015556 catabolic process Effects 0.000 description 1
- 238000004590 computer program Methods 0.000 description 1
- 238000005516 engineering process Methods 0.000 description 1
- 230000006872 improvement Effects 0.000 description 1
- 230000010365 information processing Effects 0.000 description 1
- 230000003993 interaction Effects 0.000 description 1
- 230000007246 mechanism Effects 0.000 description 1
- 230000004048 modification Effects 0.000 description 1
- 238000012986 modification Methods 0.000 description 1
- 230000002265 prevention Effects 0.000 description 1
- 230000004044 response Effects 0.000 description 1
Images
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L49/00—Packet switching elements
- H04L49/20—Support for services
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L49/00—Packet switching elements
- H04L49/30—Peripheral units, e.g. input or output ports
- H04L49/3009—Header conversion, routing tables or routing tags
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L69/00—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass
- H04L69/06—Notations for structuring of protocol data, e.g. abstract syntax notation one [ASN.1]
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Computer Security & Cryptography (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
The application provides a message processing method and a device, which are applied to network equipment using an OpenFlow protocol, and the method comprises the following steps: acquiring a service message, and judging whether a flow table item matched with the service message exists or not; if yes, judging whether a copy ratio exists in the flow table item matched with the service message; if yes, copying the service message according to the copying ratio; and sending the service message and a copy message of the service message. By adopting the method, the service message is copied, so that the receiving end can more possibly receive the service message, the packet loss rate of the service message is reduced, and the service processing effect is further improved.
Description
Technical Field
The present application relates to the field of information processing technologies, and in particular, to a method and an apparatus for processing a packet.
Background
The delay problem and the packet loss problem of wide area network access are important problems of service transmission, and especially for low-delay services (such as audio and video transmission), the packet loss can cause low-quality user experience such as screen blooming, blurring and mosaic; therefore, there is a need for a scheme for packet loss resistance and disorder resistance in service transmission to improve the transmission effect of services such as audio and video.
Therefore, how to reduce the packet loss rate in the service transmission process is one of the considerable problems.
Disclosure of Invention
In view of this, the present application provides a method and an apparatus for processing a packet, so as to reduce a packet loss rate in a service transmission process.
Specifically, the method is realized through the following technical scheme:
according to a first aspect of the present application, a message processing method is provided, which is applied to a network device using an OpenFlow protocol, and the method includes:
acquiring a service message, and judging whether a flow table item matched with the service message exists or not;
if yes, judging whether a copy ratio exists in the flow table item matched with the service message;
if yes, copying the service message according to the copying ratio;
and sending the service message and a copy message of the service message.
Optionally, if the flow entry matching the service packet further includes a timestamp field, before sending the service packet and the duplicate packet of the service packet, the method further includes:
and adding timestamps in the service message and the duplicate message of the service message so that a receiving end processes the received service message based on the timestamps.
Optionally, the replicating the service packet according to the replication ratio includes:
determining the message processing quantity of accumulated processing service messages after the last execution of the service message copying;
and when the message processing quantity meets a message copying condition, copying the service message according to the copying ratio.
Optionally, the determining whether a copy ratio exists in the flow table entry matched with the service packet includes:
and judging whether the action set of the flow table item matched with the service message has a copy rate or not.
Optionally, if there is no duplication ratio in the flow table entry matched with the service packet, processing the service packet according to the action set in the flow table entry; and sending the processed service message.
According to a second aspect of the present application, there is provided a packet processing apparatus, which is applied to a network device using an OpenFlow protocol, and the apparatus includes:
the acquisition module is used for acquiring the service message;
the first judging module is used for judging whether a flow table item matched with the service message exists or not;
a second judging module, configured to judge whether a duplication ratio exists in a flow table entry matched with the service packet if the judgment result of the first judging module is yes;
the message copying module is used for copying the service message according to the copying ratio if the judgment result of the second judgment module is that the service message exists;
and the sending module is used for sending the service message and the copy message of the service message.
Optionally, if the flow entry matched with the service packet further includes a timestamp field, the apparatus further includes:
and the adding module is used for adding timestamps in the service message and the duplicate message of the service message before the sending module sends the service message and the duplicate message of the service message so that a receiving end processes the received service message based on the timestamps.
Optionally, the message copying module is specifically configured to determine a message processing number of the accumulated processing service messages after the last service message copying is performed; and when the message processing quantity meets a message copying condition, copying the service message according to the copying ratio.
Optionally, the first determining module is specifically configured to determine whether a copy ratio exists in an action set of a flow entry matched with the service packet.
Optionally, the message processing apparatus provided in the present application further includes:
a message processing module, configured to process the service message according to the action set in the flow table entry if the determination result of the first determination module indicates that there is no duplication rate in the flow table entry matching the service message; and sending the processed service message.
According to a third aspect of the present application, there is provided a network device comprising a processor and a machine-readable storage medium storing machine-executable instructions capable of being executed by the processor, the processor being caused by the machine-executable instructions to perform the method provided in the first aspect of the embodiments of the present application.
According to a fourth aspect of the present application, there is provided a machine-readable storage medium storing machine-executable instructions that, when invoked and executed by a processor, cause the processor to perform the method as provided by the first aspect of the embodiments of the present application.
The beneficial effects of the embodiment of the application are as follows:
according to the message processing method and device provided by the embodiment of the application, after the network equipment acquires the service message, whether a flow table item matched with the service message exists or not is judged; if yes, judging whether a copy ratio exists in the flow table item matched with the service message; if yes, copying the service message according to the copying ratio; then, the service message and the copy message of the service message are sent. Due to the fact that the service message is copied, the receiving end can receive the service message more possibly, the packet loss rate of the service message is reduced, and the service processing effect is improved.
Drawings
Fig. 1 is a schematic structural diagram of a network device according to an exemplary embodiment of the present application;
fig. 2 is a flowchart illustrating a message processing method according to an exemplary embodiment of the present application;
fig. 3 is a flowchart illustrating another message processing method according to an exemplary embodiment of the present application;
fig. 4 is a block diagram of a message processing apparatus according to an exemplary embodiment of the present application.
Detailed Description
Reference will now be made in detail to the exemplary embodiments, examples of which are illustrated in the accompanying drawings. When the following description refers to the accompanying drawings, like numbers in different drawings represent the same or similar elements unless otherwise indicated. The embodiments described in the following exemplary embodiments do not represent all embodiments consistent with the present application. Rather, they are merely examples of apparatus and methods consistent with certain aspects of the present application, as detailed in the appended claims.
The terminology used herein is for the purpose of describing particular embodiments only and is not intended to be limiting of the application. As used in this application and the appended claims, the singular forms "a", "an", and "the" are intended to include the plural forms as well, unless the context clearly indicates otherwise. It should also be understood that the term "and/or" as used herein refers to and encompasses any and all possible combinations of one or more of the corresponding listed items.
It is to be understood that although the terms first, second, third, etc. may be used herein to describe various information, such information should not be limited to these terms. These terms are only used to distinguish one type of information from another. For example, first information may also be referred to as second information, and similarly, second information may also be referred to as first information, without departing from the scope of the present application. The word "if" as used herein may be interpreted as "at … …" or "when … …" or "in response to a determination", depending on the context.
The inventor finds that the network device based on the OpenFlow protocol at present cannot well realize the packet loss prevention function, and when processing a service requiring low delay, the service processing effect is still poor due to the problem of packet loss.
In view of this, the present application provides a message processing method, which is applied to a Network device using an OpenFlow protocol, where the OpenFlow protocol is a communication interface standard between a control layer and a forwarding layer Defined in a Software Defined Network (SDN) architecture, and a core idea of the SDN Network is to separate the control layer from the forwarding layer and implement virtualization of bottom layer hardware. After acquiring a service message, the network device judges whether a flow table item matched with the service message exists; if yes, judging whether a copy ratio exists in the flow table item matched with the service message; if yes, copying the service message according to the copying ratio; then, the service message and the copy message of the service message are sent. Due to the fact that the service message is copied, the receiving end can receive the service message more possibly, the packet loss rate of the service message is reduced, and the service processing effect is improved.
Fig. 1 is a block diagram of a network device 100 using an OpenFlow protocol according to an embodiment of the present disclosure. The network device 100 includes a memory 110, a processor 120, and a communication module 130. The memory 110, the processor 120, and the communication module 130 are electrically connected to each other directly or indirectly to enable data transmission or interaction. For example, the components may be electrically connected to each other via one or more communication buses or signal lines.
The memory 110 is used to store programs or data. The Memory 110 may be, but is not limited to, a Random Access Memory (RAM), a Read Only Memory (ROM), a Programmable Read-Only Memory (PROM), an erasable Read-Only Memory (EPROM), an electrically erasable Read-Only Memory (EEPROM), and the like.
The processor 120 is used to read/write data or programs stored in the memory 110 and perform corresponding functions. For example, when the computer program stored in the memory 110 is executed by the processor 120, the message processing method disclosed in the embodiments of the present application can be implemented.
The communication module 130 is used for establishing a communication connection between the network device 100 and another communication terminal through a network, and for transceiving data through the network. For example, the network device 100 may obtain the service packet from other communication terminals through the communication module 130.
It should be understood that the configuration shown in fig. 1 is merely a schematic diagram of the configuration of network device 100, and that network device 100 may include more or fewer components than shown in fig. 1, or have a different configuration than shown in fig. 1. The components shown in fig. 1 may be implemented in hardware, software, or a combination thereof. Optionally, the network device 100 in this embodiment may be a device such as an OpenFlow switch, or may be other devices, which is determined according to an actual situation. The OpenFlow switch is a network device supporting an OpenFlow protocol, and the OpenFlow switch may be a physical device or a virtual device.
The following describes the message processing method provided in the present application in detail.
Referring to fig. 2, fig. 2 is a flowchart of a message processing method shown in the present application. The network device implementing the method may include the following steps:
s201, acquiring a service message, and judging whether a flow table entry matched with the service message exists or not; if yes, go to step S202; if not, go to step S205.
Specifically, in order to ensure smooth processing of some services, such as audio/video services, services that have requirements on transmission delay and transmission speed are provided. In order to ensure that the audio/video services do not suffer from the situations of deadlock and the like, the network device may process flow entries for processing the services, that is, start the OpenFlow protocol, and then add the copy rate to the flow entries for processing the services by using the OpenFlow protocol. Thus, after the network device obtains a service message of a certain service, it can be determined whether a flow table entry matching the service message exists in all flow table entries in the current network device, and if not, the service message can be processed according to the existing service message processing method; and when the flow table item matched with the service message exists, processing according to the relevant processing flow of the flow table item.
Specifically, a control layer of the SDN network sends a flow table for processing various types of services to a network device, where the flow table is composed of flow table entries, one flow table may include multiple flow table entries, and each flow table entry includes a matching condition of a packet and an action for processing the packet.
When determining whether a flow table entry matched with the service message exists, extracting information to be matched from the service message; and then determining whether the information to be matched is matched with the matching condition of the message in each flow table entry, and if so, determining that the flow table entry matched with the service message exists. For example, if a certain matching condition is a packet type that can be processed by a flow entry, the information to be matched extracted from the service packet may include the packet type of the service packet, and then it is determined whether the packet type is consistent with the packet types of the flow entries, if so, it is determined that a flow entry matching the service packet exists, and if not, it is determined that a flow entry matching the service packet does not exist. Of course, other matching conditions may be included, which may be determined according to actual situations.
S202, judging whether a copy ratio exists in a flow table item matched with the service message; if yes, go to step S203; otherwise, step S206 is executed.
In specific implementation, not all services have strict requirements on the packet loss problem, and accordingly, it is not necessary to add a duplication rate field to all flow table entries, based on this principle, after determining a flow table entry matched with a service packet, it may be determined whether a duplication rate exists in the flow table entry, and when the duplication rate exists in the flow table entry, it indicates that the service packet needs to be duplicated, specifically please refer to the description in step S203. And when the copy ratio does not exist in the flow table entry, indicating that the packet loss has little influence on the service corresponding to the service packet, the processing is performed only according to the normal processing flow of the flow table entry.
Specifically, the flow entry includes an action set, and a duplication ratio is added to the action set of the flow entry corresponding to the service with strict control over packet loss, and on this basis, when determining whether the duplication ratio exists in the flow entry, the following procedure may be implemented: and judging whether the action set of the flow table entry comprises a copy rate field, if so, copying the service message except executing other actions in the action set.
And S203, copying the service message according to the copying ratio.
Specifically, the service packet may be copied according to the following procedure and copy ratio: determining the message processing quantity of accumulated processing service messages after the last execution of the service message copying; and when the message processing quantity meets a message copying condition, copying the service message according to the copying ratio.
In specific implementation, when the service packet is copied, if all the service packets matched based on the flow table entry are copied, huge processing pressure or even breakdown is brought to the network device, and therefore, in order to avoid the problem, the service packet is flexibly copied by configuring the copy ratio. Specifically, after the flow table entry is matched, the message processing number of the service message which is accumulated after the copy operation is executed last time can be determined, and then the copy operation is performed on the service message when the message processing number meets the message copy condition, otherwise, the copy operation is not performed, so that the processing pressure of the network equipment can be relieved. The duplication ratio can be dynamically adjusted, the specific value of the duplication ratio can be determined according to the quality of the current link, the link with poor link quality can be configured with the duplication ratio with a higher value, and the link with good link quality can be appropriately configured with the duplication ratio with a lower value, which is determined according to the actual link condition.
Specifically, the flow entry includes a count statistics count, and the count statistics value is modified to obtain the number of message processes accumulatively processed. For example, a threshold value is set according to the duplication ratio, so that, for any flow entry, when a service message is successfully matched with the flow entry, the count value in the flow entry is added by 1, so as to obtain the message processing number of accumulated processing, and thus, the count value in the flow entry is the message processing number of accumulated processing service messages after the last service message duplication operation is performed. At this time, the set message copying conditions may be: when the message processing quantity reaches the threshold value, determining that the message processing quantity meets the message copying condition, then copying the currently acquired service message, then resetting the counting value, and counting again to update the message processing quantity.
Optionally, the count statistic in the flow table entry may not be zero-cleared, and the packet processing number may be determined according to the duplication ratio and the count statistic, for example, a remainder of a ratio between the technical statistic and a denominator of the duplication ratio is determined, and the remainder is determined as the packet processing number after the last service packet duplication processing is performed. For example, taking an example that the duplication ratio is M/N, when the remainder of the ratio of COUNTS to N is K, K is used as the packet processing number, and then it is determined whether the packet processing number reaches the threshold value, and when the packet processing number reaches the threshold value, the packet processing is performed on the currently acquired service packet.
When the message processing quantity reaches the message copying condition, when the message copying is carried out, the message copying is also described by taking the copying ratio as M/N as an example, and M copied messages are copied from the service message. For example, the copy ratio is set to 1%, and every time 99 messages are processed cumulatively, a copy operation needs to be performed on the 100 th message, that is, when the number of processed messages accumulated after the last service message copy operation is performed reaches 100, one copy of the current service message is copied to obtain a copy message of the service message.
It should be noted that the action set of the flow table entry generally includes other actions to be performed besides the copy rate field, and after the copy operation is performed, a series of other actions in the action set also needs to be performed, which is not described in detail herein.
And S204, sending the service message and the copy message of the service message.
Specifically, by performing the copy operation on the service packet and then sending both the service packet and the copy packet to the receiving end, it can be ensured that the receiving end can successfully receive the service packet, thereby effectively reducing the packet loss rate of the service packet.
In addition, after receiving the service message, the receiving end compares the service message and discards the same service message.
And S205, processing the service message according to the common processing flow and sending the processed service message.
Specifically, an entry with the lowest priority is defaulted in the OpenFlow protocol, and the matching domain of the Table-Miss entry can match all service packets. On this basis, when there is no flow Table entry matching the service packet, the flow Table entry may be matched with the Table-Miss Table entry, and then the service packet is processed according to the action set included in the Table-Miss Table entry.
S206, processing the service message according to the original mode of the flow table entry, and sending the processed service message.
In specific implementation, when there is no duplication ratio in the flow entry, it indicates that the service corresponding to the service packet belongs to a service that does not have a high requirement for packet loss, and does not need to perform duplication operation, and the service packet is processed according to the action set included in the flow entry, for example, the TTL of the IP address of the service packet is modified, and then the processed packet is sent to the receiving end.
By adopting the flow shown in fig. 2, a duplication rate field is added to flow entries of a service with a higher requirement on packet loss rate, then a duplication operation is performed on service packets matched with the flow entries, and then the service packets and the duplicated packets of the service packets are sent to a receiving end, so that the success rate of receiving the service packets by the receiving end is improved, and the packet loss rate of the packets is reduced.
Optionally, the flow entry matched with the service packet may further include a timestamp field, before implementing step S204, the packet processing method provided in this application further includes the following steps, please refer to fig. 3, and the description process of other steps in fig. 3 refers to the related description in fig. 2, which is not described in detail here, and then the implementation process of the scheme provided in this embodiment is:
s301, adding a time stamp in the service message and the duplicate message of the service message, so that the receiving end processes the received service message based on the time stamp.
Specifically, since the action set of the flow entry includes the timestamp field, a timestamp may be added to the service packet according to the action set, and specifically, the time when the flow entry is written, or the current processing time, may be added to the timestamp option of the option field of the packet header of the service packet and the duplicate packet of the service packet, and then the service packet and the duplicate packet to which the timestamp is added are sent to the receiving end. The receiving end starts the anti-packet loss mechanism, and deletes the same service message according to the timestamp carried by the received service message, that is, the redundant backup message is discarded. On the other hand, the receiving end can also sort the real sequence of the received service messages by extracting the timestamps of the service messages, so as to reduce the disorder rate of the service messages, for example, taking the audio and video services as an example, the playing sequence of the service messages is ensured by comparing the timestamps of the received service messages, so that the playing effect of the audio and video services is ensured.
Specifically, when step S301 is executed, it may be determined whether a timestamp field exists in the flow entry, and when a timestamp option exists, a timestamp may be added to the service packet and the duplicate packet of the service packet. Specifically, it may be determined whether a timestamp field exists in the action set of the flow entry, and if so, execute a timestamp adding action, that is, add time when the service packet is written in the flow entry, or add current processing time, in the service packet and the duplicate packet of the service packet. When the action set of the flow table item does not have the timestamp field, processing the service message according to the action set in the flow table item; and sending the processed service message.
By adopting the flow of fig. 3, the duplication rate field and the timestamp field are added in the action set of the flow entry, so that the service packet matched with the flow entry is duplicated and the timestamp is added, thereby not only reducing the packet loss rate of the service packet, but also reducing the disorder rate of the service packet.
Based on the same inventive concept, the application also provides a message processing device corresponding to the message processing method. The implementation of the message processing apparatus may refer to the above description of the message processing method, and is not discussed here one by one.
Referring to fig. 4, fig. 4 is a message processing apparatus according to an exemplary embodiment of the present application, which is applied to a network device using an OpenFlow protocol, and the message processing apparatus includes:
an obtaining module 401, configured to obtain a service packet;
a first determining module 402, configured to determine whether a flow entry matching the service packet exists;
a second determining module 403, configured to determine whether a duplication ratio exists in a flow entry matched with the service packet if the determination result of the first determining module 402 is yes;
a message copying module 404, configured to copy the service message according to the copy ratio if the determination result of the second determining module 403 indicates that the service message exists;
a sending module 405, configured to send the service packet and a duplicate packet of the service packet.
Optionally, if the flow entry matched with the service packet further includes a timestamp field, the packet processing apparatus provided in the present application further includes: add modules, please also refer to fig. 4, wherein:
an adding module 406, configured to add a timestamp to the service packet and the duplicate packet of the service packet before the sending module 405 sends the service packet and the duplicate packet of the service packet, so that a receiving end processes the received service packet based on the timestamp.
Optionally, the message copying module 404 is specifically configured to determine the message processing number of the accumulated processed service messages after the last service message copying is executed; and when the message processing quantity meets a message copying condition, copying the service message according to the copying ratio.
Optionally, the first determining module 402 is specifically configured to determine whether a copy ratio exists in an action set of a flow entry matched with the service packet.
Optionally, the message processing apparatus provided in the present application further includes:
a message processing module 407, configured to process the service message according to the action set in the flow table entry if the determination result of the first determining module 402 is that there is no duplication rate in the flow table entry matched with the service message; and sending the processed service message.
In addition, the embodiment of the present application provides a machine-readable storage medium, which stores machine-executable instructions, and when the machine-readable storage medium is called and executed by a processor, the machine-executable instructions cause the processor to execute the message processing method provided in any embodiment of the present application.
As for the embodiments of the network device and the machine-readable storage medium, since the contents of the related methods are substantially similar to those of the foregoing embodiments of the methods, the description is relatively simple, and for the relevant points, reference may be made to the partial description of the embodiments of the methods.
The implementation process of the functions and actions of each unit in the above device is specifically described in the implementation process of the corresponding step in the above method, and is not described herein again.
For the device embodiments, since they substantially correspond to the method embodiments, reference may be made to the partial description of the method embodiments for relevant points. The above-described embodiments of the apparatus are merely illustrative, and the units described as separate parts may or may not be physically separate, and parts displayed as units may or may not be physical units, may be located in one place, or may be distributed on a plurality of network units. Some or all of the modules can be selected according to actual needs to achieve the purpose of the scheme of the application. One of ordinary skill in the art can understand and implement it without inventive effort.
The above description is only exemplary of the present application and should not be taken as limiting the present application, as any modification, equivalent replacement, or improvement made within the spirit and principle of the present application should be included in the scope of protection of the present application.
Claims (10)
1. A message processing method is applied to a network device using an OpenFlow protocol, and the method comprises the following steps:
acquiring a service message, and judging whether a flow table item matched with the service message exists or not;
if yes, judging whether a copy ratio exists in the flow table item matched with the service message;
if yes, copying the service message according to the copying ratio;
and sending the service message and a copy message of the service message.
2. The method of claim 1, wherein the flow entry matching the service packet further comprises a timestamp field, and wherein before sending the service packet and the duplicate packet of the service packet, the method further comprises:
and adding timestamps in the service message and the duplicate message of the service message so that a receiving end processes the received service message based on the timestamps.
3. The method of claim 1, wherein replicating the service packet according to the replication ratio comprises:
determining the message processing quantity of accumulated processing service messages after the last execution of the service message copying;
and when the message processing quantity meets a message copying condition, copying the service message according to the copying ratio.
4. The method of claim 1, wherein determining whether a duplication ratio exists in the flow table entry matching the service packet comprises:
and judging whether the action set of the flow table item matched with the service message has a copy rate or not.
5. The method according to claim 4, wherein if there is no duplication ratio in the flow table entry matching the service packet, the service packet is processed according to the action set in the flow table entry; and sending the processed service message.
6. A message processing apparatus, which is applied to a network device using an OpenFlow protocol, and the apparatus includes:
the acquisition module is used for acquiring the service message;
the first judging module is used for judging whether a flow table item matched with the service message exists or not;
a second judging module, configured to judge whether a duplication ratio exists in a flow table entry matched with the service packet if the judgment result of the first judging module is yes;
the message copying module is used for copying the service message according to the copying ratio if the judgment result of the second judgment module is that the service message exists;
and the sending module is used for sending the service message and the copy message of the service message.
7. The apparatus of claim 6, wherein the flow entry matching the service packet further comprises a timestamp field, the apparatus further comprising:
and the adding module is used for adding timestamps in the service message and the duplicate message of the service message before the sending module sends the service message and the duplicate message of the service message so that a receiving end processes the received service message based on the timestamps.
8. The apparatus of claim 6,
the message copying module is specifically used for determining the message processing quantity of the accumulated processing service messages after the last service message copying is executed; and when the message processing quantity meets a message copying condition, copying the service message according to the copying ratio.
9. The apparatus of claim 6,
the first determining module is specifically configured to determine whether a duplication rate exists in an action set of a flow entry matched with the service packet.
10. The apparatus of claim 9, further comprising:
a message processing module, configured to process the service message according to the action set in the flow table entry if the determination result of the first determination module indicates that there is no duplication rate in the flow table entry matching the service message; and sending the processed service message.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010290982.8A CN111600811A (en) | 2020-04-14 | 2020-04-14 | Message processing method and device |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010290982.8A CN111600811A (en) | 2020-04-14 | 2020-04-14 | Message processing method and device |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN111600811A true CN111600811A (en) | 2020-08-28 |
Family
ID=72192165
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202010290982.8A Withdrawn CN111600811A (en) | 2020-04-14 | 2020-04-14 | Message processing method and device |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN111600811A (en) |
Citations (12)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20070030803A1 (en) * | 2005-08-05 | 2007-02-08 | Mark Gooch | Prioritization of network traffic sent to a processor by using packet importance |
| CN103081418A (en) * | 2010-09-09 | 2013-05-01 | 日本电气株式会社 | Computer system and communication method in computer system |
| CN104580222A (en) * | 2015-01-12 | 2015-04-29 | 山东大学 | DDoS attack distributed detection and response system and method based on information entropy |
| CN104618194A (en) * | 2015-02-15 | 2015-05-13 | 杭州华三通信技术有限公司 | Software definition network message monitoring method, SDN controller and switching devices |
| CN104702536A (en) * | 2015-03-26 | 2015-06-10 | 清华大学 | Message processing method of OpenFlow switch for wireless communication |
| WO2016082367A1 (en) * | 2014-11-25 | 2016-06-02 | 中兴通讯股份有限公司 | Method and device for realizing hardware table traversal based on network processor |
| CN108810183A (en) * | 2018-05-04 | 2018-11-13 | 新华三技术有限公司 | Processing method, device and the machine readable storage medium of conflict MAC Address |
| CN109547288A (en) * | 2018-11-29 | 2019-03-29 | 中国科学院信息工程研究所 | A kind of unrelated forwarding Network Programmable flow measuring method of agreement |
| CN109600318A (en) * | 2018-11-29 | 2019-04-09 | 新华三技术有限公司合肥分公司 | A kind of method and SDN controller monitoring application program in SDN |
| CN109981409A (en) * | 2019-03-26 | 2019-07-05 | 新华三技术有限公司 | Message forwarding method, device and forwarding device |
| CN110071853A (en) * | 2019-04-30 | 2019-07-30 | 新华三技术有限公司 | A kind of message statistical method and the network equipment |
| CN110290100A (en) * | 2019-03-06 | 2019-09-27 | 广东电网有限责任公司信息中心 | A SDN-based mimic Web server and user request processing method |
-
2020
- 2020-04-14 CN CN202010290982.8A patent/CN111600811A/en not_active Withdrawn
Patent Citations (12)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20070030803A1 (en) * | 2005-08-05 | 2007-02-08 | Mark Gooch | Prioritization of network traffic sent to a processor by using packet importance |
| CN103081418A (en) * | 2010-09-09 | 2013-05-01 | 日本电气株式会社 | Computer system and communication method in computer system |
| WO2016082367A1 (en) * | 2014-11-25 | 2016-06-02 | 中兴通讯股份有限公司 | Method and device for realizing hardware table traversal based on network processor |
| CN104580222A (en) * | 2015-01-12 | 2015-04-29 | 山东大学 | DDoS attack distributed detection and response system and method based on information entropy |
| CN104618194A (en) * | 2015-02-15 | 2015-05-13 | 杭州华三通信技术有限公司 | Software definition network message monitoring method, SDN controller and switching devices |
| CN104702536A (en) * | 2015-03-26 | 2015-06-10 | 清华大学 | Message processing method of OpenFlow switch for wireless communication |
| CN108810183A (en) * | 2018-05-04 | 2018-11-13 | 新华三技术有限公司 | Processing method, device and the machine readable storage medium of conflict MAC Address |
| CN109547288A (en) * | 2018-11-29 | 2019-03-29 | 中国科学院信息工程研究所 | A kind of unrelated forwarding Network Programmable flow measuring method of agreement |
| CN109600318A (en) * | 2018-11-29 | 2019-04-09 | 新华三技术有限公司合肥分公司 | A kind of method and SDN controller monitoring application program in SDN |
| CN110290100A (en) * | 2019-03-06 | 2019-09-27 | 广东电网有限责任公司信息中心 | A SDN-based mimic Web server and user request processing method |
| CN109981409A (en) * | 2019-03-26 | 2019-07-05 | 新华三技术有限公司 | Message forwarding method, device and forwarding device |
| CN110071853A (en) * | 2019-04-30 | 2019-07-30 | 新华三技术有限公司 | A kind of message statistical method and the network equipment |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US8531960B2 (en) | Method and system of using counters to monitor a system port buffer | |
| EP1603272B1 (en) | Communication network event logging systems and methods | |
| CN111478850B (en) | Gateway adjusting method and device | |
| US9600355B2 (en) | Redundant encoding | |
| CN111314179B (en) | Network quality detection method, device, equipment and storage medium | |
| US8213325B2 (en) | Packet analysis method, packet analysis apparatus, recording medium storing packet analysis program | |
| CN111262792A (en) | Message forwarding method, device, network equipment and storage medium | |
| CN117221091A (en) | Isolation method and device for sub-health nodes in storage cluster and electronic equipment | |
| CN112751833A (en) | RTP message identification method and device, electronic equipment and readable storage medium | |
| CN115087025B (en) | Private network data collection method, device and storage medium | |
| CN112769639A (en) | Method and device for parallel issuing configuration information | |
| JP5728617B2 (en) | Network elements that automatically and automatically suspend | |
| CN111262782B (en) | Message processing method, device and equipment | |
| CN112104564A (en) | Load sharing method and equipment | |
| CN113518046B (en) | Message forwarding method and frame type switching equipment | |
| CN111600811A (en) | Message processing method and device | |
| CN114765585B (en) | Service quality detection method, message processing method and device | |
| JP7105838B2 (en) | Video quality evaluation method and device | |
| US7502447B2 (en) | Call failure recording | |
| US8132089B1 (en) | Error checking at the re-sequencing stage | |
| US8774013B2 (en) | Field deployable message compromiser | |
| CN117240941A (en) | A method and device for processing in-band network telemetry messages | |
| CN113904787B (en) | Flow auditing method, device, equipment and computer readable storage medium | |
| US20220173959A1 (en) | Inserting replay events in network production flows | |
| CN110336759B (en) | RDMA (remote direct memory Access) -based protocol message forwarding method and device |
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 | ||
| WW01 | Invention patent application withdrawn after publication | ||
| WW01 | Invention patent application withdrawn after publication |
Application publication date: 20200828 |