CN112491871A - TCP (Transmission control protocol) recombination method and device, electronic equipment and storage medium - Google Patents
TCP (Transmission control protocol) recombination method and device, electronic equipment and storage medium Download PDFInfo
- Publication number
- CN112491871A CN112491871A CN202011337249.3A CN202011337249A CN112491871A CN 112491871 A CN112491871 A CN 112491871A CN 202011337249 A CN202011337249 A CN 202011337249A CN 112491871 A CN112491871 A CN 112491871A
- Authority
- CN
- China
- Prior art keywords
- linked list
- tcp
- packet
- tcp packet
- cache linked
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Granted
Links
Images
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- 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/16—Implementation or adaptation of Internet protocol [IP], of transmission control protocol [TCP] or of user datagram protocol [UDP]
- H04L69/163—In-band adaptation of TCP data exchange; In-band control procedures
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/50—Network services
- H04L67/56—Provisioning of proxy services
- H04L67/565—Conversion or adaptation of application format or content
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/50—Network services
- H04L67/56—Provisioning of proxy services
- H04L67/568—Storing data temporarily at an intermediate stage, e.g. caching
-
- 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/22—Parsing or analysis of headers
-
- Y—GENERAL TAGGING OF NEW TECHNOLOGICAL DEVELOPMENTS; GENERAL TAGGING OF CROSS-SECTIONAL TECHNOLOGIES SPANNING OVER SEVERAL SECTIONS OF THE IPC; TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
- Y02—TECHNOLOGIES OR APPLICATIONS FOR MITIGATION OR ADAPTATION AGAINST CLIMATE CHANGE
- Y02D—CLIMATE CHANGE MITIGATION TECHNOLOGIES IN INFORMATION AND COMMUNICATION TECHNOLOGIES [ICT], I.E. INFORMATION AND COMMUNICATION TECHNOLOGIES AIMING AT THE REDUCTION OF THEIR OWN ENERGY USE
- Y02D30/00—Reducing energy consumption in communication networks
- Y02D30/50—Reducing energy consumption in communication networks in wire-line communication networks, e.g. low power modes or reduced link rate
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Computer Security & Cryptography (AREA)
- Memory System Of A Hierarchy Structure (AREA)
- Computer And Data Communications (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
The invention provides a TCP (transmission control protocol) recombination method, a device, electronic equipment and a storage medium, wherein the method comprises the following steps: under the condition that the sequence of the current TCP packet does not meet the expectation, storing the current TCP packet into a cache linked list according to the sequence order of the current TCP packet; under the condition that the number of the cached TCP packets in the cache linked list exceeds the preset number, sending a packet loss event to a service layer, and extracting a first TCP packet in the cache linked list as a target TCP packet; and sending the target TCP packet to a service layer for processing. And when the current TCP packets which do not meet the expectation are stored in the cache linked list, detecting the total number stored in the cache linked list every time, sending a packet loss event to a service layer under the condition that the number of the TCP packets cached in the cache linked list exceeds the preset number, and determining whether to discard the data currently processed by the service layer, so that the influence range of the packet loss on the service processing can be reduced as much as possible.
Description
Technical Field
The present invention relates to the field of information processing technologies, and in particular, to a TCP reassembly method and apparatus, an electronic device, and a storage medium.
Background
The development of the internet is not independent of network communication, and the most widely used is the TCP/IP protocol at present. The IP layer is mainly responsible for sending data to the correct place, but it cannot guarantee that these data will be sent certainly, nor can it guarantee to control the transmission rate of the data and the order of arrival of the data. TCP, which mainly solves the above problems, is a connection-oriented, reliable transport layer communication protocol based on byte streams. TCP controls the transmission rate of flow through a sliding window protocol, and guarantees data order through overtime retransmission and sequence number piggybacking.
Usually, the service index is monitored, and a statistical function needs to be added in the implementation of the service, so that the coupling degree is too high, especially in a scenario where the statistical items are more and more complicated. In order to decouple the service function from the monitoring service index, one method is to use the data mirroring function of the switch, copy one copy of the network traffic, and forward the copied copy to the specified monitoring service for analysis.
The conventional TCP packet loss processing flow: and judging whether the received TCP packet seq is matched or not, and if not, caching. After a period of time, the expected TCP packet has not been received, the opposite party is required to retransmit the packet. And processing the TCP packets according to the seq sequence after receiving the retransmitted TCP packets.
After the conventional TCP packet is lost, the packet lost by retransmission can be directly required to be sent to ensure the communication quality. However, data packet loss generated in the mirroring process cannot be the same as that of conventional TCP transmission, and a sender may be required to retransmit the data packet after the data packet loss, so that the conventional TCP packet is not suitable for such a scenario.
Therefore, how to solve the problem of TCP packet loss in the mirror mode has become an urgent problem to be solved in the industry.
Disclosure of Invention
The invention provides a TCP (transmission control protocol) reassembly method, a device, electronic equipment and a storage medium, which are used for solving the defect that the problem of TCP packet loss occurring in a mirror image mode cannot be processed in the prior art and realizing the TCP reassembly method.
The invention provides a TCP recombination method, which comprises the following steps:
under the condition that the sequence of the current TCP packet does not meet the expectation, storing the current TCP packet into a cache linked list according to the sequence order of the current TCP packet;
under the condition that the number of the cached TCP packets in the cache linked list exceeds the preset number, sending a packet loss event to a service layer, and extracting a first TCP packet in the cache linked list as a target TCP packet;
and sending the target TCP packet to a service layer for processing.
According to a TCP reassembly method provided by the present invention, the method further comprises:
under the condition that the sequence of the current TCP packet meets an expected sequence, the current TCP packet is sent to a service layer for processing, and an expectation is updated;
detecting whether the sequence of the first TCP packet in the cache linked list meets the updated expectation;
and when the sequence of the first TCP packet in the cache linked list meets the updated expectation, sending the first TCP packet in the cache linked list as a target TCP packet to a service layer for processing.
According to the TCP reassembly method provided by the present invention, after the step of detecting whether the sequence of the first TCP packet in the cache chain table meets the updated expectation, the method further comprises:
when the first TCP packet in the cache linked list does not meet the updated expectation, detecting whether the number of the TCP packets in the cache linked list exceeds a preset number;
under the condition that the number of the cached TCP packets in the cache linked list exceeds the preset number, sending a packet loss event to a service layer, and extracting a first TCP packet in the cache linked list to be used as a target TCP packet;
and sending the target TCP packet to a service layer for processing.
According to a TCP reassembly method provided by the present invention, the method further comprises:
triggering timing detection at intervals of a preset time interval to obtain a cache linked list at the current moment;
traversing the cache linked list at the current moment, and detecting whether a first TCP packet in the connected cache linked list is overtime or not when the cache linked list at the current moment has an unretraversed connection;
if the first TCP packet in the connected cache linked list is overtime, a packet loss event is sent to a service layer;
and sending the first TCP packet in the connected cache linked list to a service layer for processing.
According to a TCP reassembly method provided by the present invention, after the step of sending a packet loss event to the service layer, the method further comprises:
deleting the first TCP packet in the connected cache linked list to obtain an updated cache linked list;
calculating the next expectation of the current expectation to obtain an updated expectation;
and when the first TCP packet in the updated cache linked list does not accord with the updated expectation, continuously traversing the cache linked list at the current moment.
According to a TCP reassembly method provided by the present invention, after the step of calculating a next expectation of a current expectation to obtain an updated expectation, the method further comprises:
when the first TCP packet in the updated cache linked list conforms to the updated expectation, the first TCP packet in the updated cache linked list is sent to a service layer for processing;
and deleting the first TCP packet in the updated cache linked list to obtain a target cache linked list, and continuously updating the updated expectation to obtain the target expectation.
The present invention also provides a TCP reassembling apparatus, comprising:
the buffer module is used for storing the current TCP packet into a buffer linked list according to the sequence order of the current TCP packet under the condition that the sequence of the current TCP packet does not meet the expectation;
the processing module is used for sending a packet loss event to a service layer under the condition that the number of the cached TCP packets in the cache linked list exceeds the preset number, and extracting a first TCP packet in the cache linked list to be used as a target TCP packet;
and the sending module is used for sending the target TCP packet to a service layer for processing.
According to a TCP reassembly device provided by the present invention, the device further comprises:
the updating module is used for sending the current TCP packet to a service layer for processing and updating the expectation under the condition that the sequence of the current TCP packet meets the expectation sequence;
the detection module is used for detecting whether the sequence of the first TCP packet in the cache linked list meets the updated expectation;
and the calculation module is used for sending the first TCP packet in the cache linked list as a target TCP packet to a service layer for processing when the sequence of the first TCP packet in the cache linked list meets the updated expectation.
The present invention also provides an electronic device, which includes a memory, a processor, and a computer program stored in the memory and executable on the processor, wherein the processor implements the steps of any of the above TCP reassembly methods when executing the program.
The present invention also provides a non-transitory computer readable storage medium having stored thereon a computer program which, when executed by a processor, performs the steps of the TCP reassembly method as described in any of the above.
The invention provides a TCP (transmission control protocol) recombination method, a device, electronic equipment and a storage medium, wherein current TCP packets which do not meet expectations are stored in a cache linked list, the total number stored in the cache linked list is detected every time, under the condition that the number of the TCP packets cached in the cache linked list exceeds the preset number, the TCP packets cannot be cached continuously, a packet loss event is sent to a service layer, whether currently processed data is discarded or not is determined by the service layer, and the first TCP packet in the cache linked list is continuously extracted and sent to the service layer for processing, so that the range of influence of packet loss on service processing can be reduced as much as possible.
Drawings
In order to more clearly illustrate the technical solutions of the present invention or the prior art, the drawings needed for the description of the embodiments or the prior art will be briefly described below, and it is obvious that the drawings in the following description are some embodiments of the present invention, and those skilled in the art can also obtain other drawings according to the drawings without creative efforts.
FIG. 1 is a schematic flow chart of a TCP reassembly method according to the present invention;
FIG. 2 is a flow chart corresponding to TCP packet reassembly provided by the present invention;
FIG. 3 is a schematic diagram of a timing detection process provided by the present invention;
FIG. 4 is a schematic diagram of a TCP reassembly device according to the present invention;
fig. 5 is a schematic physical structure diagram of an electronic device provided in the present invention.
Detailed Description
In order to make the objects, technical solutions and advantages of the present invention clearer, the technical solutions of the present invention will be clearly and completely described below with reference to the accompanying drawings, and it is obvious that the described embodiments are some, but not all embodiments of the present invention. All other embodiments, which can be derived by a person skilled in the art from the embodiments given herein without making any creative effort, shall fall within the protection scope of the present invention.
The TCP reassembly method of the present invention is described below in conjunction with fig. 1-3.
Fig. 1 is a schematic flow diagram of a TCP reassembly method provided in the present invention, as shown in fig. 1, including:
step S1, under the condition that the sequence of the current TCP packet does not meet the expectation, storing the current TCP packet into a cache linked list according to the sequence order of the current TCP packet;
specifically, the current TCP packet described in the present invention specifically refers to a TCP packet generated in the mirroring process, that is, a TCP packet of network mirrored data.
When a new TCP packet is received, the packet is taken as the TCP packet which is currently processed, the source address and the destination address of the TCP packet which is currently processed are sequenced and then are simply hashed to obtain the unique identifier of the connection, the unique identifier of the connection is used for searching the service processing object of the connection, the flow direction of the current TCP packet is calculated, and the corresponding cache linked list and the expected seq are obtained.
Assuming that the two addresses of the interaction are A, B, the processing object of each service has a- > B cache TCP packet linked list, B- > a cache TCP packet linked list, and the respective expected seq.
When the sequence of the current TCP packet does not meet the expected seq, the condition of packet loss is shown, and in order to avoid the current packet loss from influencing the processing of subsequent data, the sequence of the TCP packet is firstly stored into the cache linked list in sequence, so that after the problem of packet loss is solved, the TCP packet stored in the cache linked list is sent to the service layer for processing continuously, and the service blocking is effectively avoided.
Step S2, when the number of the TCP packets cached in the cache linked list exceeds the preset number, a packet loss event is sent to a service layer, and the first TCP packet in the cache linked list is extracted as a target TCP packet;
in the invention, after the TCP packets are stored in the cache linked list each time, whether the storage quantity of the TCP packets stored in the cache linked list exceeds the preset quantity or not is detected, so that the condition that a large amount of service data is lost because the cache linked list cannot be continuously cached after being fully stored is avoided.
When the invention detects that the number of the cached TCP packets in the cache linked list exceeds the preset number, the cache linked list is not suitable for continuously storing the TCP packets, and a packet loss event can be sent to the service layer under the condition that the packet loss event is still not solved, so that the service layer judges whether the data needs to be discarded or not.
Meanwhile, after a packet loss event is sent by the service layer, if the problem that the sequence of the initial current TCP packet does not meet the expected packet loss event is solved, the first TCP packet in the cache linked list is extracted and used as the target TCP packet, that is, the data in the cache linked list is processed, so that the service congestion is effectively avoided.
And step S3, sending the target TCP packet to a service layer for processing.
In the invention, a first TCP packet in the cache linked list is extracted as a target TCP packet; and sending the target TCP packet to a service layer for processing, wherein the purpose is to continuously perform service processing after solving the problem of TCP packet loss, so that continuous service blocking caused by TCP packet loss is avoided.
The invention stores the current TCP packets which do not meet the expectation into the cache linked list, detects the total number stored in the cache linked list every time, under the condition that the number of the TCP packets cached in the cache linked list exceeds the preset number, the TCP packets can not be cached continuously at the moment, sends a packet loss event to the service layer at the moment, determines whether to discard the data currently processed by the service layer, continuously extracts the first TCP packet in the cache linked list, and sends the first TCP packet to the service layer for processing, thereby reducing the range of influence of the packet loss on the service processing as much as possible.
In another embodiment, the method further comprises:
under the condition that the sequence of the current TCP packet meets the expectation, the current TCP packet is sent to a service layer for processing, and the expectation is updated;
detecting whether the sequence of the first TCP packet in the cache linked list meets the updated expectation;
and when the sequence of the first TCP packet in the cache linked list meets the updated expectation, sending the first TCP packet in the cache linked list as a target TCP packet to a service layer for processing.
Specifically, when the sequence of the current TCP packet meets the expectation, that is, when the packet loss does not occur, the next processing is continued.
Updating expectations as described in the present invention specifically refers to the current seq + data length. If the syn flag is set, an additional 1 is required.
After the expectation is updated every time, whether the sequence of the first TCP packet in the cache linked list meets the new expectation or not is detected, the TCP packet in the cache linked list can be effectively ensured to be omitted, and the normal operation of the service is ensured.
In the invention, a first TCP packet in the cache linked list is extracted as a target TCP packet; and sending the target TCP packet to a service layer for processing, wherein the purpose is to continuously perform service processing after solving the problem of TCP packet loss, so that continuous service blocking caused by TCP packet loss is avoided.
The invention detects the sequence of the first TCP packet in the cache linked list after updating the expectation, and whether the updated expectation is met, thereby ensuring the TCP packet in the cache linked list, and being capable of normally issuing after solving the problem of packet loss, thereby ensuring the normal operation of the service.
In another embodiment, after the step of detecting whether the sequence of the first TCP packet in the cache chain table satisfies the updated expectation, the method further comprises:
when the first TCP packet in the cache linked list does not meet the updated expectation, detecting whether the number of the TCP packets in the cache linked list exceeds a preset number;
under the condition that the number of the cached TCP packets in the cache linked list exceeds the preset number, sending a packet loss event to a service layer, and extracting a first TCP packet in the cache linked list to be used as a target TCP packet;
and sending the target TCP packet to a service layer for processing.
Specifically, when the first TCP packet in the cache linked list does not meet the updated expectation, it indicates that the TCP packet in the cache linked list still cannot be issued at this time, and then it is detected whether the number of TCP packets in the cache linked list exceeds a preset number.
In the invention, when the condition that the cached TCP packets in the cache linked list exceed the preset number is detected, the cache linked list is not suitable for continuously storing the TCP packets, and a packet loss event can be sent like a service layer under the condition that the packet loss event is still not solved, so that the service layer judges whether the data needs to be discarded or not.
In another embodiment, the method further comprises:
triggering timing detection at intervals of a preset time interval to obtain a cache linked list at the current moment;
traversing the cache linked list at the current moment, and detecting whether a first TCP packet in the connected cache linked list is overtime or not when the cache linked list at the current moment has an unretraversed connection;
if the first TCP packet in the connected cache linked list is overtime, a packet loss event is sent to a service layer;
and sending the first TCP packet in the connected cache linked list to a service layer for processing.
Specifically, the preset time interval in the present invention may be preset as required, for example, 10s or 15s triggers a timing monitoring.
The timing monitoring in the invention means that the following detection process is automatically carried out for each preset time.
The buffer linked list at the current time described in the present invention may specifically refer to a buffer linked list that triggers a timing detection time.
The invention detects whether the first TCP packet in the connected cache linked list is overtime, detects whether the time stored by the TCP packet exceeds the preset time under the condition of keeping the connection, if the cached TCP packet exceeds the preset time and is not sent to a service layer for processing, the occurrence of packet loss is judged, and the condition that the service is blocked because the TCP packet which can not be subpackaged for a long time can be effectively avoided.
Traversing the cache linked list at the current time described in the present invention means performing the above analysis on each connection in the cache linked list according to the above steps.
The invention carries out timing detection through each preset time, and judges whether the first TCP packet in each connected cache linked list is overtime, thereby avoiding the condition that when the connection is accidentally disconnected or the disconnected packet is lost, the part of the cached memory can not be released forever, and the memory is leaked.
In another embodiment, after the step of sending a packet loss event to the service layer, the method further includes:
deleting the first TCP packet in the connected cache linked list to obtain an updated cache linked list;
calculating the next expectation of the current expectation to obtain an updated expectation;
and when the first TCP packet in the updated cache linked list does not accord with the updated expectation, continuously traversing the cache linked list at the current moment.
The first TCP packet in the connected cache linked list is deleted in the invention because the first TCP packet is already issued to the service layer before, and the related data in the cache linked list should be deleted at this time, thereby realizing the updating of the first TCP packet in the cache linked list.
Similarly, since the first TCP packet is already delivered to the service layer, the expectation also needs to be updated accordingly, so as to obtain the updated expectation.
When the first TCP packet in the updated buffer linked list does not meet the updated expectation, it indicates that the TCP packet in the buffer linked list still cannot be issued at this time, and the buffer linked list at the current time is continuously traversed.
When the first TCP packet in the updated cache linked list conforms to the updated expectation, the first TCP packet in the updated cache linked list is sent to a service layer for processing;
and deleting the first TCP packet in the updated cache linked list to obtain a target cache linked list, and continuously updating the updated expectation to obtain the target expectation.
The invention stores the current TCP packets which do not meet the expectation into the cache linked list, detects the total number stored in the cache linked list every time, under the condition that the number of the TCP packets cached in the cache linked list exceeds the preset number, the TCP packets can not be cached continuously at the moment, sends a packet loss event to the service layer at the moment, determines whether to discard the data currently processed by the service layer, continuously extracts the first TCP packet in the cache linked list, and sends the first TCP packet to the service layer for processing, thereby reducing the range of influence of the packet loss on the service processing as much as possible.
In the above embodiment, the timeout time of TCP reassembly and the buffer packet size of each TCP connection may be extracted as configurations, and when any one of the timeout time and the buffer packet size satisfies a condition, a packet loss event is triggered. Thus, a reasonable value can be configured according to the physical machine configuration (mainly the size of the memory) actually deployed and the business requirement.
If the packet is lost, the memory may be burst due to too fast transmission speed if the packet is only limited by the timeout time. If only the size of the cache packet is limited, when the connection is unexpectedly disconnected or the disconnected packet (the packet containing the fin mark) is lost, the part of the cache memory can never be released, and the memory leak is caused.
When the seq of a received TCP packet is not expected, it is buffered in a doubly linked list. And judging whether the TCP packet just received is behind the packet in the linked list from the tail part of the linked list to the front part. Since TCP packets are sequential in most cases, most of them need to be compared only once. The problem of seq wrap around needs to be considered when comparing the order of two TCP packets.
If seq2 is after seq1, then the right condition (c code) is satisfied: (s32) ((u32) seq2- (u32) seq1) >0
Why a simple line can be used to judge whether the wool is good. The following scenario was analyzed:
1. no wrap-around occurs, and if seq1 is 0x01, seq2 is 0x80000000, seq2-seq1 is 0x7 fffffffff, the final result turns strong to be 32-bit signed, the result is a positive value, the condition is satisfied, and the sequence is seq1- > seq2, which is consistent with reality.
2. If the wrap-around does not occur, seq1 is 0x01, seq2 is 0x80000001, seq2-seq1 is 0x80000000, and the final result turns to be strong 32 bits with signs, and the highest bit is set to 1, and the result is that the condition of negative value is not established, so the sequence is seq2- > seq1, which is not consistent in reality.
3. Wrap around occurs, assuming seq 1-0 xFFFFFFFF and seq 2-0 x 01. since the calculation results in overflow and the final condition is satisfied, seq2-seq1 is 2, the sequence is seq1- > seq2, and is consistent with reality.
4. Wrap around occurs, assuming seq 1-0 xFFFFFFFF, seq 2-0 x 80000000. The sequence seq2-seq1 is 0x80000001, the final result turns to 32 bits with signs, the highest bit is set to 1, and the negative condition is not satisfied, so the sequence seq2- > seq1 is inconsistent with the reality.
From the above scenario analysis, the premise for using the above judgment is that the increment after wrapping is less than 2^ (32-1) -1, so that the wrapping of data close to 2G can be supported, but the buffer size of the actual single connection cannot be set to be so large, so that the use requirement can be met.
In another embodiment, fig. 2 is a flowchart corresponding to TCP packet reassembly provided by the present invention, as shown in fig. 2, first, a new TCP packet is received, and this packet is taken as the currently processed TCP packet. And sequencing the source address and the destination address of the TCP packet currently processed, then performing simple hash to obtain the unique identifier of the connection, namely taking the network quadruple as a key, searching the service processing object of the connection by using the unique identifier of the connection, calculating the flow direction of the current TCP packet to obtain a corresponding cache linked list and an expected seq, and if not, establishing the cache linked list and the expected seq, and initializing the expected seq to be 0. Assuming that the two addresses of the interaction are A, B, the processing object of each service has a- > B cache TCP packet linked list, B- > a cache TCP packet linked list, and the respective expected seq.
It is then determined whether the currently processed TCP packet is the expected seq. The judging method comprises the following steps: and calculating the seq of the current TCP packet, and judging whether the current seq is equal to the next expected seq or the next expected seq is 0. Since the packets on the network are directly mirrored, and it is likely that the access data packet is started halfway, the first TCP packet is directly used as the first packet.
And if the expected seq packet is the current TCP packet, transmitting the current TCP packet to a service layer for processing, and calculating the seq of the next expected TCP packet. The next expected seq is calculated as current seq + data length. If the syn flag is set, an additional 1 is needed; the currently processed TCP packets are stored in the linked list in the order expected by the seq. When sorting, seq wrap-around scenarios need to be considered. And checking whether the first TCP packet seq in the cache linked list corresponding to the connection is expected or not.
And if the first TCP packet seq in the cache linked list corresponding to the connection is expected, taking the first TCP packet in the cache linked list as the currently processed packet, and removing the first TCP packet from the cache linked list.
If the first TCP packet seq in the cache linked list corresponding to the connection is not expected, judging whether the size of the current cached packet exceeds the limit, if so, returning to the step of taking the first TCP packet in the cache linked list as the current processed packet and removing the first TCP packet from the cache linked list, and if not, ending the flow.
If the first TCP packet seq in the cache linked list corresponding to the connection is not expected, storing the packets in the linked list according to the expected sequence of the seq, continuously monitoring whether the size of the currently cached packet exceeds the limit, if so, returning to the step of taking the first TCP packet in the cache linked list as the currently processed packet, and removing the first TCP packet from the cache linked list, and if not, ending the flow.
Fig. 3 is a schematic diagram of a timing detection process provided by the present invention, as shown in fig. 3, including: triggering timing detection, then detecting whether a connection which is not traversed exists, and if the connection which is not traversed does not exist, ending the process; if the connection which is not traversed exists, removing the current connection, then detecting whether the first TCP packet cached in the current connection is overtime, and if the first TCP packet cached in the current connection is not overtime, returning to the operation of detecting whether the connection which is not traversed exists;
if the first TCP packet connected with the current cache is detected to be overtime, a packet loss message is sent to a service layer, the first TCP packet of the cache is deleted and sent to the service layer, the next expected seq is calculated, then whether the first TCP packet of the cache chain table is matched with the expected seq is detected, if the first TCP packet of the cache chain table is matched with the expected seq, the first TCP packet of the cache chain table is returned to the service layer, the first TCP packet of the cache is deleted and sent to the service layer, and the next expected seq is calculated;
and if the first TCP packet of the cache linked list does not match the expected seq, returning to the operation of detecting whether the non-traversal connection exists.
In another embodiment, all packets are assumed to be in the correct order 1, 2, 3, 4, 5 … …
Example 1
Assume that the data packets coming from a TCP connection are 1, 3, 4, and 2 in sequence.
After receiving the packet number 1, the connection finds that the connection receives the packet for the first time, and immediately sends the packet to the service layer, at this time, the buffer chain table is empty, and the number of the next expected packet is 2.
After receiving the packet number 3, if the packet number is found not matched with the expected packet number 2, the packet is cached, and at this time, the cache chain table is 3.
After receiving the number 4 packet, if the number is not matched with the expected packet 2, the packet is cached, and the cache chain table is 3 and 4 at the moment.
After receiving the number 2 packet, if the number 2 packet is matched with the expected packet 2, the number 2 packet is immediately sent to a service layer, and the next expected packet is calculated. The number is 3, then the first packet 3 of the cache linked list is matched, the packet 3 is immediately sent to the service layer, the first packet (number 3) of the cache linked list is deleted, the next expected packet is calculated to be 4, then the first packet 4 of the cache linked list is matched, the packet 4 is immediately sent to the service layer, the first packet (number 4) of the cache linked list is deleted, the next expected packet 5 is calculated, and the cache is empty at this moment, and the method is finished.
Example 2
Assume that the data packets coming from a TCP connection are 3, 5, 6, 7 … … 100000 in sequence.
After receiving the packet No. 3, it finds that the connection receives the packet for the first time, and immediately sends the packet to the service layer, at this time, the buffer chain table is empty, and the next expected packet number is 4.
After receiving the number 5 packet, if the number is not matched with the expected packet 4, the packet is cached, and the cache chain table is 5 at the moment.
After receiving the number 6 packet, if the number 6 packet is not matched with the expected packet 4, the packet is cached, and the cache chain table is 5 and 6 at the moment.
……
After receiving the 999 number packet, the 999 number packet is found not to be matched with the expected packet 4, the total size of the cache packet at the moment is judged to exceed the threshold value, a packet loss message is sent to the service layer firstly, then the first packet (No. 5) in the cache is sent forcibly, then the loop calculation is carried out, whether the packet in the chain table meets the expectation or not is judged, and finally all the packets are sent to the service layer.
Example 3
Suppose that the data packets coming from a TCP connection are 5, 7, and 8 in sequence, which remain connected and no more packets are sent.
After receiving the 5 number packet, it is found that the connection receives the packet for the first time, and immediately sends the packet to the service layer, at this time, the buffer chain table is empty, and the next expected packet number is 6.
After receiving the packet number 7, if the packet number is found not to be matched with the expected packet 6, the packet is cached, and the cache chain table is 7 at this moment.
After receiving the number 8 packet, if the number 8 packet is found not to be matched with the expected packet 6, the packet is cached, and the cache chain table is 7 and 8 at the moment.
……
After a period of time, triggering overtime, sending a packet loss message to a service layer, then forcibly sending a first packet (No. 7) in the cache, and then circularly calculating and judging whether the packet in the linked list is in accordance with the expectation and sending.
This example requires to keep the connection all the time, because if the connection is broken, it will trigger the fin flag to issue, and after receiving the fin packet, it will need to trigger the packet loss message judgment immediately and force to issue all the packets in the buffer.
The TCP reassembly device provided by the present invention is described below, and the TCP reassembly device described below and the TCP reassembly method described above may be referred to in correspondence.
Fig. 4 is a schematic diagram of a TCP reassembly device provided in the present invention, as shown in fig. 4, including: a caching module 410, a processing module 420 and a sending module 430; the cache module 410 is configured to store the current TCP packet into a cache linked list according to a sequence order of the current TCP packet when the sequence of the current TCP packet does not meet an expectation; the processing module 420 is configured to send a packet loss event to the service layer when the number of the TCP packets cached in the cache linked list exceeds a preset number, and extract a first TCP packet in the cache linked list as a target TCP packet; the sending module 430 is configured to send the target TCP packet to a service layer for processing.
The device further comprises: the updating module is used for sending the current TCP packet to a service layer for processing and updating the expectation under the condition that the sequence of the current TCP packet meets the expectation sequence; the detection module is used for detecting whether the sequence of the first TCP packet in the cache linked list meets the updated expectation; and the calculation module is used for sending the first TCP packet in the cache linked list as a target TCP packet to a service layer for processing when the sequence of the first TCP packet in the cache linked list meets the updated expectation.
The detection module is further configured to: when the first TCP packet in the cache linked list does not meet the updated expectation, detecting whether the number of the TCP packets in the cache linked list exceeds a preset number; under the condition that the number of the cached TCP packets in the cache linked list exceeds the preset number, sending a packet loss event to a service layer, and extracting a first TCP packet in the cache linked list to be used as a target TCP packet; and sending the target TCP packet to a service layer for processing.
The device also comprises a timing monitoring module, wherein the timing monitoring module is used for triggering timing detection at intervals of preset time to acquire the cache linked list at the current moment;
traversing the cache linked list at the current moment, and detecting whether a first TCP packet in the connected cache linked list is overtime or not when the cache linked list at the current moment has an unretraversed connection;
if the first TCP packet in the connected cache linked list is overtime, a packet loss event is sent to a service layer;
and sending the first TCP packet in the connected cache linked list to a service layer for processing.
The timing monitoring module is also used for calculating the next expected expectation to obtain an updated expectation;
and when the first TCP packet in the updated cache linked list does not accord with the updated expectation, continuously traversing the cache linked list at the current moment.
When the first TCP packet in the updated cache linked list conforms to the updated expectation, the first TCP packet in the updated cache linked list is sent to a service layer for processing;
and deleting the first TCP packet in the updated cache linked list to obtain a target cache linked list, and continuously updating the updated expectation to obtain the target expectation.
The invention stores the current TCP packets which do not meet the expectation into the cache linked list, detects the total number stored in the cache linked list every time, under the condition that the number of the TCP packets cached in the cache linked list exceeds the preset number, the TCP packets can not be cached continuously at the moment, sends a packet loss event to the service layer at the moment, determines whether to discard the data currently processed by the service layer, continuously extracts the first TCP packet in the cache linked list, and sends the first TCP packet to the service layer for processing, thereby reducing the range of influence of the packet loss on the service processing as much as possible.
Fig. 5 is a schematic physical structure diagram of an electronic device provided in the present invention, and as shown in fig. 5, the electronic device may include: a processor (processor)510, a communication Interface (Communications Interface)520, a memory (memory)530 and a communication bus 540, wherein the processor 510, the communication Interface 520 and the memory 530 communicate with each other via the communication bus 540. Processor 510 may invoke logic instructions in memory 530 to perform a TCP reassembly method comprising: under the condition that the sequence of the current TCP packet does not meet the expectation, storing the current TCP packet into a cache linked list according to the sequence order of the current TCP packet; under the condition that the number of the cached TCP packets in the cache linked list exceeds the preset number, sending a packet loss event to a service layer, and extracting a first TCP packet in the cache linked list as a target TCP packet; and sending the target TCP packet to a service layer for processing.
Furthermore, the logic instructions in the memory 530 may be implemented in the form of software functional units and stored in a computer readable storage medium when the software functional units are sold or used as independent products. Based on such understanding, the technical solution of the present invention may be embodied in the form of a software product, which is stored in a storage medium and includes instructions for causing a computer device (which may be a personal computer, a server, or a network device) to execute all or part of the steps of the method according to the embodiments of the present invention. And the aforementioned storage medium includes: a U-disk, a removable hard disk, a Read-Only Memory (ROM), a Random Access Memory (RAM), a magnetic disk or an optical disk, and other various media capable of storing program codes.
In another aspect, the present invention also provides a computer program product comprising a computer program stored on a non-transitory computer-readable storage medium, the computer program comprising program instructions, which when executed by a computer, enable the computer to perform the TCP reassembly method provided by the above methods, the method comprising: under the condition that the sequence of the current TCP packet does not meet the expectation, storing the current TCP packet into a cache linked list according to the sequence order of the current TCP packet; under the condition that the number of the cached TCP packets in the cache linked list exceeds the preset number, sending a packet loss event to a service layer, and extracting a first TCP packet in the cache linked list as a target TCP packet; and sending the target TCP packet to a service layer for processing.
In yet another aspect, the present invention also provides a non-transitory computer-readable storage medium, on which a computer program is stored, the computer program being implemented by a processor to execute the TCP reassembly method provided in the above embodiments, the method including: under the condition that the sequence of the current TCP packet does not meet the expectation, storing the current TCP packet into a cache linked list according to the sequence order of the current TCP packet; under the condition that the number of the cached TCP packets in the cache linked list exceeds the preset number, sending a packet loss event to a service layer, and extracting a first TCP packet in the cache linked list as a target TCP packet; and sending the target TCP packet to a service layer for processing.
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 may be selected according to actual needs to achieve the purpose of the solution of the present embodiment. One of ordinary skill in the art can understand and implement it without inventive effort.
Through the above description of the embodiments, those skilled in the art will clearly understand that each embodiment can be implemented by software plus a necessary general hardware platform, and certainly can also be implemented by hardware. With this understanding in mind, the above-described technical solutions may be embodied in the form of a software product, which can be stored in a computer-readable storage medium such as ROM/RAM, magnetic disk, optical disk, etc., and includes instructions for causing a computer device (which may be a personal computer, a server, or a network device, etc.) to execute the methods described in the embodiments or some parts of the embodiments.
Finally, it should be noted that: the above examples are only intended to illustrate the technical solution of the present invention, but not to limit it; although the present invention has been described in detail with reference to the foregoing embodiments, it will be understood by those of ordinary skill in the art that: the technical solutions described in the foregoing embodiments may still be modified, or some technical features may be equivalently replaced; and such modifications or substitutions do not depart from the spirit and scope of the corresponding technical solutions of the embodiments of the present invention.
Claims (10)
1. A TCP reassembly method, comprising:
under the condition that the sequence of the current TCP packet does not meet the expectation, storing the current TCP packet into a cache linked list according to the sequence order of the current TCP packet;
under the condition that the number of the cached TCP packets in the cache linked list exceeds the preset number, sending a packet loss event to a service layer, and extracting a first TCP packet in the cache linked list as a target TCP packet;
and sending the target TCP packet to a service layer for processing.
2. The TCP reassembly method of claim 1, further comprising:
under the condition that the sequence of the current TCP packet meets the expectation, the current TCP packet is sent to a service layer for processing, and the expectation is updated;
detecting whether the sequence of the first TCP packet in the cache linked list meets the updated expectation;
and when the sequence of the first TCP packet in the cache linked list meets the updated expectation, sending the first TCP packet in the cache linked list as a target TCP packet to a service layer for processing.
3. The TCP reassembly method of claim 2, wherein after said step of detecting whether a sequence of a first TCP packet in said buffer chain table satisfies said updated expectation, said method further comprises:
when the first TCP packet in the cache linked list does not meet the updated expectation, detecting whether the number of the TCP packets in the cache linked list exceeds a preset number;
under the condition that the number of the cached TCP packets in the cache linked list exceeds the preset number, sending a packet loss event to a service layer, and extracting a first TCP packet in the cache linked list to be used as a target TCP packet;
and sending the target TCP packet to a service layer for processing.
4. The TCP reassembly method of claim 1, further comprising:
triggering timing detection at intervals of a preset time interval to obtain a cache linked list at the current moment;
traversing the cache linked list at the current moment, and detecting whether a first TCP packet in the connected cache linked list is overtime or not when the cache linked list at the current moment has an unretraversed connection;
if the first TCP packet in the connected cache linked list is overtime, a packet loss event is sent to a service layer;
and sending the first TCP packet in the connected cache linked list to a service layer for processing.
5. The TCP reassembly method according to claim 4, wherein after said step of sending a packet loss event to a traffic layer, said method further comprises:
deleting the first TCP packet in the connected cache linked list to obtain an updated cache linked list;
calculating the next expectation of the current expectation to obtain an updated expectation;
and when the first TCP packet in the updated cache linked list does not accord with the updated expectation, continuously traversing the cache linked list at the current moment.
6. The TCP reassembly method according to claim 5, wherein after said step of calculating a next expected current expectation, resulting in an updated expectation, said method further comprises:
when the first TCP packet in the updated cache linked list conforms to the updated expectation, the first TCP packet in the updated cache linked list is sent to a service layer for processing;
and deleting the first TCP packet in the updated cache linked list to obtain a target cache linked list, and continuously updating the updated expectation to obtain the target expectation.
7. A TCP reassembly device, comprising:
the buffer module is used for storing the current TCP packet into a buffer linked list according to the sequence order of the current TCP packet under the condition that the sequence of the current TCP packet does not meet the expectation;
the processing module is used for sending a packet loss event to a service layer under the condition that the number of the cached TCP packets in the cache linked list exceeds the preset number, and extracting a first TCP packet in the cache linked list to be used as a target TCP packet;
and the sending module is used for sending the target TCP packet to a service layer for processing.
8. The TCP reassembly device of claim 7, further comprising:
the updating module is used for sending the current TCP packet to a service layer for processing and updating the expectation under the condition that the sequence of the current TCP packet meets the expectation sequence;
the detection module is used for detecting whether the sequence of the first TCP packet in the cache linked list meets the updated expectation;
and the calculation module is used for sending the first TCP packet in the cache linked list as a target TCP packet to a service layer for processing when the sequence of the first TCP packet in the cache linked list meets the updated expectation.
9. An electronic device comprising a memory, a processor and a computer program stored on the memory and executable on the processor, wherein the steps of the TCP reassembly method as claimed in any one of claims 1 to 6 are implemented when the processor executes said program.
10. A non-transitory computer readable storage medium having stored thereon a computer program, wherein the computer program, when executed by a processor, implements the steps of the TCP reassembly method as recited in any one of claims 1 to 6.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202011337249.3A CN112491871B (en) | 2020-11-25 | 2020-11-25 | TCP reorganization method, TCP reorganization device, electronic equipment and storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202011337249.3A CN112491871B (en) | 2020-11-25 | 2020-11-25 | TCP reorganization method, TCP reorganization device, electronic equipment and storage medium |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN112491871A true CN112491871A (en) | 2021-03-12 |
| CN112491871B CN112491871B (en) | 2023-07-28 |
Family
ID=74934569
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202011337249.3A Active CN112491871B (en) | 2020-11-25 | 2020-11-25 | TCP reorganization method, TCP reorganization device, electronic equipment and storage medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN112491871B (en) |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN113364862A (en) * | 2021-06-03 | 2021-09-07 | 上海天旦网络科技发展有限公司 | Packet decoding system and method |
Citations (22)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20050160293A1 (en) * | 2004-01-16 | 2005-07-21 | Anantha Ramaiah | Preventing network data injection attacks using duplicate-ACK and reassembly gap approaches |
| US20050180327A1 (en) * | 2004-02-12 | 2005-08-18 | International Business Machines Corporation | Method and apparatus for handling reordered data packets |
| CN101123580A (en) * | 2007-09-11 | 2008-02-13 | 华为技术有限公司 | Packet transmission method and base station device |
| CN101369877A (en) * | 2007-12-27 | 2009-02-18 | 华为技术有限公司 | Wireless transmission control protocol processing method and equipment |
| CN101547473A (en) * | 2009-03-24 | 2009-09-30 | 中兴通讯股份有限公司 | Method for discarding service data unit (SDU) of link layer in TD-SCDMA system |
| JP2012186780A (en) * | 2011-02-17 | 2012-09-27 | Nippon Telegr & Teleph Corp <Ntt> | Packet loss rate estimation device and method and program |
| CN102823207A (en) * | 2012-05-18 | 2012-12-12 | 华为技术有限公司 | Method and device for forwarding data packet |
| CN103166912A (en) * | 2011-12-09 | 2013-06-19 | 华为技术有限公司 | Data package transmission method and system |
| CN103179039A (en) * | 2012-10-25 | 2013-06-26 | 四川省电力公司信息通信公司 | Method for effectively filtering normal network data package |
| JP2013179486A (en) * | 2012-02-28 | 2013-09-09 | Nippon Telegr & Teleph Corp <Ntt> | Packet monitoring device, packet monitoring method, and packet monitoring system |
| CN105045723A (en) * | 2015-06-26 | 2015-11-11 | 深圳市腾讯计算机系统有限公司 | Processing method, apparatus and system for cached data |
| CN105337892A (en) * | 2014-08-15 | 2016-02-17 | 深圳市中兴微电子技术有限公司 | Data processing method and data processing device |
| US20170289872A1 (en) * | 2014-12-19 | 2017-10-05 | Huawei Technologies Co., Ltd. | Apparatus, system, and method for preventing tcp connection interruption |
| WO2018041043A1 (en) * | 2016-08-29 | 2018-03-08 | 烽火通信科技股份有限公司 | Streaming media-based system and method for second retransmission of lost packet |
| CN107786472A (en) * | 2017-10-31 | 2018-03-09 | 北京亚鸿世纪科技发展有限公司 | A kind of efficient tcp session reconstruction units |
| CN108174008A (en) * | 2017-12-22 | 2018-06-15 | 天津七二通信广播股份有限公司 | A kind of voice packet storage method for communication speech Transmission system |
| CN108206787A (en) * | 2016-12-17 | 2018-06-26 | 北京华为数字技术有限公司 | A kind of congestion-preventing approach and device |
| WO2018171806A1 (en) * | 2017-03-24 | 2018-09-27 | 中兴通讯股份有限公司 | Control packet transmission method, electronic device and computer storage medium |
| CN108667755A (en) * | 2017-03-27 | 2018-10-16 | 中兴通讯股份有限公司 | A kind of method and apparatus message fragment storage and recombinated |
| CN109818884A (en) * | 2019-02-01 | 2019-05-28 | 深圳市比速智网技术有限公司 | Multilink data transmission method, sending device, reception device and storage medium |
| CN111385068A (en) * | 2018-12-29 | 2020-07-07 | 阿里巴巴集团控股有限公司 | Data transmission method and device, electronic equipment and communication system |
| CN111930740A (en) * | 2020-06-28 | 2020-11-13 | 腾讯科技(成都)有限公司 | Game data processing method and device, server and storage medium |
-
2020
- 2020-11-25 CN CN202011337249.3A patent/CN112491871B/en active Active
Patent Citations (23)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20050160293A1 (en) * | 2004-01-16 | 2005-07-21 | Anantha Ramaiah | Preventing network data injection attacks using duplicate-ACK and reassembly gap approaches |
| US20050180327A1 (en) * | 2004-02-12 | 2005-08-18 | International Business Machines Corporation | Method and apparatus for handling reordered data packets |
| CN101123580A (en) * | 2007-09-11 | 2008-02-13 | 华为技术有限公司 | Packet transmission method and base station device |
| CN101369877A (en) * | 2007-12-27 | 2009-02-18 | 华为技术有限公司 | Wireless transmission control protocol processing method and equipment |
| CN101547473A (en) * | 2009-03-24 | 2009-09-30 | 中兴通讯股份有限公司 | Method for discarding service data unit (SDU) of link layer in TD-SCDMA system |
| JP2012186780A (en) * | 2011-02-17 | 2012-09-27 | Nippon Telegr & Teleph Corp <Ntt> | Packet loss rate estimation device and method and program |
| CN103166912A (en) * | 2011-12-09 | 2013-06-19 | 华为技术有限公司 | Data package transmission method and system |
| JP2013179486A (en) * | 2012-02-28 | 2013-09-09 | Nippon Telegr & Teleph Corp <Ntt> | Packet monitoring device, packet monitoring method, and packet monitoring system |
| CN102823207A (en) * | 2012-05-18 | 2012-12-12 | 华为技术有限公司 | Method and device for forwarding data packet |
| CN103179039A (en) * | 2012-10-25 | 2013-06-26 | 四川省电力公司信息通信公司 | Method for effectively filtering normal network data package |
| CN105337892A (en) * | 2014-08-15 | 2016-02-17 | 深圳市中兴微电子技术有限公司 | Data processing method and data processing device |
| US20170289872A1 (en) * | 2014-12-19 | 2017-10-05 | Huawei Technologies Co., Ltd. | Apparatus, system, and method for preventing tcp connection interruption |
| CN105045723A (en) * | 2015-06-26 | 2015-11-11 | 深圳市腾讯计算机系统有限公司 | Processing method, apparatus and system for cached data |
| WO2018041043A1 (en) * | 2016-08-29 | 2018-03-08 | 烽火通信科技股份有限公司 | Streaming media-based system and method for second retransmission of lost packet |
| CN108206787A (en) * | 2016-12-17 | 2018-06-26 | 北京华为数字技术有限公司 | A kind of congestion-preventing approach and device |
| WO2018171806A1 (en) * | 2017-03-24 | 2018-09-27 | 中兴通讯股份有限公司 | Control packet transmission method, electronic device and computer storage medium |
| CN108632177A (en) * | 2017-03-24 | 2018-10-09 | 中兴通讯股份有限公司 | A kind of transmission method and electronic equipment of control packet |
| CN108667755A (en) * | 2017-03-27 | 2018-10-16 | 中兴通讯股份有限公司 | A kind of method and apparatus message fragment storage and recombinated |
| CN107786472A (en) * | 2017-10-31 | 2018-03-09 | 北京亚鸿世纪科技发展有限公司 | A kind of efficient tcp session reconstruction units |
| CN108174008A (en) * | 2017-12-22 | 2018-06-15 | 天津七二通信广播股份有限公司 | A kind of voice packet storage method for communication speech Transmission system |
| CN111385068A (en) * | 2018-12-29 | 2020-07-07 | 阿里巴巴集团控股有限公司 | Data transmission method and device, electronic equipment and communication system |
| CN109818884A (en) * | 2019-02-01 | 2019-05-28 | 深圳市比速智网技术有限公司 | Multilink data transmission method, sending device, reception device and storage medium |
| CN111930740A (en) * | 2020-06-28 | 2020-11-13 | 腾讯科技(成都)有限公司 | Game data processing method and device, server and storage medium |
Non-Patent Citations (1)
| Title |
|---|
| UYLESS BLACK, vol. 1, 北京：机械工业出版社, pages: 124 - 127 * |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN113364862A (en) * | 2021-06-03 | 2021-09-07 | 上海天旦网络科技发展有限公司 | Packet decoding system and method |
Also Published As
| Publication number | Publication date |
|---|---|
| CN112491871B (en) | 2023-07-28 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN111314358B (en) | Attack protection method, device, system, computer storage medium and electronic equipment | |
| CN108234087B (en) | Data transmission method and sending end | |
| CN113765626B (en) | Data transmission method and device of mobile communication system | |
| US9332092B2 (en) | Method and system for processing data record packet | |
| EP1706955B1 (en) | Method and apparatus for preventing network data injection attacks | |
| US20170294991A1 (en) | Low latency packet recovery | |
| CN104486243A (en) | Data transmission method, equipment and system | |
| EP1716488B1 (en) | Preventing network data injection attacks using duplicate ACK and re-assembly gap approaches | |
| US8243736B2 (en) | Packet capturing device | |
| CN112187793A (en) | Protection method and device for ACK Flood attack | |
| CN111107182B (en) | MAC address synchronization method, device, system, equipment and medium | |
| CN112491871A (en) | TCP (Transmission control protocol) recombination method and device, electronic equipment and storage medium | |
| CN110233856B (en) | Message processing method and device and computer readable storage medium | |
| CN110417707B (en) | Data transmission protection method, device, system and computer readable storage medium | |
| RU2358395C2 (en) | Method of reducing transmission time of run file through test point | |
| US10110350B2 (en) | Method and system for flow control | |
| CN108667682B (en) | Connection synchronization method, device and medium based on secure gateway deep packet detection | |
| CN114244785B (en) | 5G data flow out-of-order processing method and device | |
| CN116155826A (en) | Message receiving and transmitting method, network equipment, system and storage medium | |
| KR20000040467A (en) | Method for controlling data communication of network | |
| CN109547389B (en) | Code stream file recombination method and device | |
| CN114257456B (en) | Control method and system for breakpoint continuous file transfer based on FTP protocol | |
| CN115001630B (en) | Data transmission method, device, equipment and storage medium | |
| EP0597030B1 (en) | Automatically deactivated no-owner frame removal mechanism for token ring networks | |
| CN117857066A (en) | Virus transmission interception method and device based on session, electronic equipment and medium |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |