CN113489652B - Data stream amplifying method and device, converging shunt and storage medium - Google Patents
Data stream amplifying method and device, converging shunt and storage medium Download PDFInfo
- Publication number
- CN113489652B CN113489652B CN202110771446.4A CN202110771446A CN113489652B CN 113489652 B CN113489652 B CN 113489652B CN 202110771446 A CN202110771446 A CN 202110771446A CN 113489652 B CN113489652 B CN 113489652B
- Authority
- CN
- China
- Prior art keywords
- message
- data
- data message
- identification information
- multicast tree
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
- 238000000034 method Methods 0.000 title claims abstract description 38
- 238000003860 storage Methods 0.000 title claims abstract description 22
- 230000009471 action Effects 0.000 claims abstract description 20
- 230000003321 amplification Effects 0.000 claims abstract description 9
- 238000003199 nucleic acid amplification method Methods 0.000 claims abstract description 9
- 238000012545 processing Methods 0.000 claims description 8
- 238000009825 accumulation Methods 0.000 claims description 7
- 238000004458 analytical method Methods 0.000 claims description 6
- 230000006798 recombination Effects 0.000 claims description 6
- 238000005215 recombination Methods 0.000 claims description 6
- 238000004590 computer program Methods 0.000 claims description 4
- 238000012360 testing method Methods 0.000 abstract description 13
- 230000005540 biological transmission Effects 0.000 description 7
- 230000006870 function Effects 0.000 description 6
- 230000002776 aggregation Effects 0.000 description 4
- 238000004220 aggregation Methods 0.000 description 4
- 238000010586 diagram Methods 0.000 description 4
- 238000001914 filtration Methods 0.000 description 4
- 230000003287 optical effect Effects 0.000 description 3
- 230000008569 process Effects 0.000 description 3
- 230000008859 change Effects 0.000 description 2
- 238000011161 development Methods 0.000 description 2
- 230000000694 effects Effects 0.000 description 2
- 239000013307 optical fiber Substances 0.000 description 2
- 230000000644 propagated effect Effects 0.000 description 2
- 230000009286 beneficial effect Effects 0.000 description 1
- 238000013461 design Methods 0.000 description 1
- 238000005516 engineering process Methods 0.000 description 1
- 238000004519 manufacturing process Methods 0.000 description 1
- 230000007246 mechanism Effects 0.000 description 1
- 238000010295 mobile communication Methods 0.000 description 1
- 230000008707 rearrangement Effects 0.000 description 1
- 230000008521 reorganization Effects 0.000 description 1
- 230000010076 replication Effects 0.000 description 1
- 230000000717 retained effect Effects 0.000 description 1
- 239000004065 semiconductor Substances 0.000 description 1
- 239000007787 solid Substances 0.000 description 1
- 238000006467 substitution reaction Methods 0.000 description 1
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L47/00—Traffic control in data switching networks
- H04L47/10—Flow control; Congestion control
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
The embodiment of the invention discloses a data stream amplifying method, a data stream amplifying device, a converging splitter and a storage medium. The method comprises the following steps: acquiring at least one data message to be amplified; acquiring a multicast tree which is respectively matched with the amplifying actions of each data message, wherein the added target ports of at least two nodes in the multicast tree are the same; and copying the matched data message through the multicast tree, and sending the data message and the copied message to the target port so as to amplify the flow of the data message. The method can realize the amplification of the data message flow, meets the requirement of the doubled packet sending quantity under the condition of not increasing the cost, and realizes the test of the high-speed network.
Description
Technical Field
The embodiment of the invention relates to the technical field of Ethernet, in particular to a data stream amplifying method, a device, a converging shunt and a storage medium.
Background
With the development of ethernet technology, network transmission speeds are becoming faster and faster. After the ethernet standard ieee802.3ba is determined, the development of the high-speed transmission network device is paid more attention, and the testing capability of the network device needs to be synchronously improved.
For example, when the original 10G transmission speed is increased to 40G or 100G transmission speed, the data flow to be sent by the packet sending device corresponding to the network device needs to be increased by multiple times, for example, the number of packets to be sent needs to be increased by multiple times, so as to meet the test requirement of the high-speed transmission network device. The number of the packages of the package sending device is limited, and the requirement of the number of the packages which are multiplied cannot be met. By increasing the number of the contracting devices or buying a larger contracting device, the increasing the contracting number increases the additional cost.
Disclosure of Invention
The embodiment of the invention provides a data stream amplifying method, a data stream amplifying device, a converging shunt and a storage medium, which can realize the multiple increase of the number of sending packets and meet the test requirement of a high-speed Ethernet.
In a first aspect, an embodiment of the present invention provides a data stream amplifying method, including:
acquiring at least one data message to be amplified;
Acquiring a multicast tree which is respectively matched with the amplifying actions of the data messages, wherein the added target ports of at least two nodes in the multicast tree are the same;
and copying the matched data message through the multicast tree, and sending the data message and the copied message to a target port so as to amplify the flow of the data message.
Optionally, copying the matched data message through the multicast tree, and sending the data message and the copied message to a target port, including:
acquiring identification information used for distinguishing data streams in each data message;
copying the matched data messages through the multicast tree, accumulating the identification information of the copied messages through a register, and generating multiple copies of the data messages;
And sending the data message and the copy message to a target port through the multicast tree.
Optionally, accumulating the identification information for the copied message through a register, including:
Judging whether the accumulated value of the register exceeds a preset range or not;
If yes, carrying out zero clearing processing on the accumulator of the register, and then carrying out accumulation on the identification information on the copied message through the register.
Optionally, before acquiring the data packet to be amplified, the method further includes:
Acquiring an input port corresponding to each data message to be amplified and at least one output port corresponding to each amplified data message flow;
and setting target ports added by nodes of the multicast tree according to the input ports and the output ports corresponding to the input ports respectively to obtain the multicast tree which is matched with the amplifying action of the data messages respectively.
Optionally, before obtaining the multicast tree respectively matched with the amplifying actions of the data packets, the method further includes:
Carrying out message analysis on the data message and judging whether the data message has identification information for distinguishing data streams or not;
if yes, carrying out message recombination on the data message;
if not, discarding the data message.
Optionally, accumulating the identification information of the copied message through a register to generate multiple copies of the data message, including:
accumulating the identification information through a register;
and recombining the accumulated identification information with the rest information in the data message to generate multiple copies of the data message.
In a second aspect, an embodiment of the present invention further provides a data stream amplifying apparatus, including:
The data message acquisition module is used for acquiring at least one data message to be amplified;
the multicast tree acquisition module is used for acquiring multicast trees which are respectively matched with the amplifying actions of the data messages, wherein the target ports added by at least two nodes in the multicast tree are the same;
And the message sending module is used for copying the matched data message through the multicast tree, and sending the data message and the copied message to a target port so as to amplify the flow of the data message.
Optionally, the message sending module includes:
the identification information acquisition unit is used for acquiring identification information used for distinguishing data streams in each data message;
the duplicate message generating unit is used for duplicating the matched data message through the multicast tree, accumulating the identification information of the duplicated message through a register, and generating multiple duplicate messages of the data message;
and the message sending unit is used for sending the data message and the copy message to a target port through the multicast tree.
In a third aspect, an embodiment of the present invention further provides a converging splitter, including:
One or more processors;
Storage means for storing one or more programs,
The one or more programs, when executed by the one or more processors, cause the one or more processors to implement a data stream amplification method as described in any embodiment of the present invention.
In a fourth aspect, embodiments of the present invention further provide a computer readable storage medium having stored thereon a computer program which, when executed by a processor, implements a data stream amplifying method according to any embodiment of the present invention.
The technical scheme of the embodiment of the invention comprises the steps of obtaining at least one data message to be amplified; acquiring a multicast tree which is respectively matched with the amplifying actions of each data message, wherein the added target ports of at least two nodes in the multicast tree are the same; the matched data messages are copied through the multicast tree, and the data messages and the copied messages are sent to the target port so as to amplify the flow of the data messages, thereby solving the problem of high-speed Ethernet test, amplifying the flow of the data messages without increasing the cost and meeting the effect of the high-speed Ethernet test.
Drawings
FIG. 1a is a flow chart of a data stream amplifying method according to a first embodiment of the present invention;
Fig. 1b is a flowchart of multicast tree establishment according to a first embodiment of the present invention;
FIG. 1c is a flow chart of a method for amplifying a data stream according to a first embodiment of the present invention;
Fig. 2 is a schematic structural diagram of a data stream amplifying device according to a second embodiment of the present invention;
Fig. 3 is a schematic structural diagram of a converging diverter according to a third embodiment of the present invention.
Detailed Description
The invention is described in further detail below with reference to the drawings and examples. It is to be understood that the specific embodiments described herein are merely illustrative of the invention and are not limiting thereof. It should be further noted that, for convenience of description, only some, but not all of the structures related to the present invention are shown in the drawings.
Example 1
Fig. 1a is a flowchart of a data flow amplifying method according to an embodiment of the present invention, where the method may be applicable to amplifying data packet traffic during high-speed ethernet testing, and the method may be performed by a data flow amplifying device, where the device may be implemented by software and/or hardware, and the device may be integrated in a convergence splitter, as shown in fig. 1a, and the method specifically includes:
step 110, at least one data message to be amplified is obtained.
The data message may be a message that needs to be amplified in the high-speed ethernet test. By amplifying the data messages, the processing capacity of the network equipment to a large number of data messages can be tested, so that the high-speed Ethernet can be tested.
Specifically, the data message may be input from an input port of the aggregation splitter. The convergence splitter can analyze each field of the data message and store the analysis result in metadata (matedate). matedate may be modified by an editable exchange chip or the like. The aggregation splitter can be used for collecting the data streams of a plurality of data message production devices and forwarding the data streams to other network devices for using the data messages.
In an optional implementation manner of the embodiment of the present invention, before acquiring the data packet to be amplified, the method further includes: acquiring an input port corresponding to each data message to be amplified and at least one output port corresponding to each amplified data message; and setting target ports added by each node of the multicast tree according to each input port and each corresponding output port to obtain the multicast tree respectively matched with the amplifying action of each data message.
The input port may be an input end of the converging splitter, and the output port may be a target port to which the output end of the converging splitter is connected. Specifically, the destination port may be an input of the network device. The target ports may be embodied individually or by means of a load balancing group. The load balancing group comprises a plurality of physical ports (such as target ports), and the data messages in the aggregation shunt can be forwarded to a certain physical port of the load balancing group according to a certain load balancing algorithm.
The load balancing algorithm may determine a hash value of the data packet according to a preset algorithm, and modulo-divide all physical ports in the load balancing group according to the hash value, so as to obtain a final output port. The hash values calculated by different data messages are different, so that load balancing output can be realized.
In an embodiment of the present invention, the multicast tree may be a mechanism for traffic replication in a programmable chip, such as tofino chips. Multiple nodes may be connected under the multicast tree, multiple physical ports such as destination ports may be connected under each node, or a load balancing group may be connected. The aggregation shunt can copy the data message to each node through the multicast tree, and if the node is connected with an Internet of things port, the data message can be copied to each port connected with each node; if the nodes are connected with the load balancing group, the data message can be copied and transmitted to the connected load balancing group.
Fig. 1b is a flowchart of multicast tree establishment according to a first embodiment of the present invention. As shown in fig. 1b, a command may be generated according to the correspondence between the input port and the output port, issued through a command line, and the legitimacy of the command is verified. One input port may correspond to one or more output ports, i.e., the same data packet may be sent to one or more output ports. The destination ports in the multicast tree may be set according to the output ports. The output ports may be the same or different. That is, each destination port in the multicast tree may be the same or may be different, that is, when a data packet is forwarded through the multicast tree, the data packet may be replicated into multiple packets, and all packets are forwarded to the same destination port. The multicast tree generated may be different for different input ports or data messages, and different multicast trees may have different identification information.
And 120, acquiring a multicast tree which is respectively matched with the amplifying actions of the data messages, wherein the added target ports of at least two nodes in the multicast tree are the same.
The acquisition of the multicast tree matched with the data message can have various implementation modes. For example, the multicast tree corresponding to the identifier may be determined according to the input port of the data packet; or the multicast tree corresponding to the identification can be determined according to the identification information of the data message; or the data message may have output port information therein, and a corresponding multicast tree may be generated according to the output port information.
In the embodiment of the invention, when the target ports added by a plurality of nodes exist in the multicast tree and are the same, the same data message can be copied into a plurality of copies and forwarded to the target ports, the receiving quantity of the data message by the target ports can be increased, and the high-flow test of the network equipment is realized, thereby meeting the Ethernet test requirement.
In an optional implementation manner of the embodiment of the present invention, before acquiring the multicast tree respectively matched with the amplifying actions of each data packet, the method further includes: carrying out message analysis on the data message, and judging whether identification information for distinguishing data streams exists in the data message; if yes, the data message is recombined; if not, discarding the data message.
The message parsing may be to obtain and store information of each field in the data message. The network device can distinguish different data messages according to the identification information for distinguishing the data streams; that is, when the identification information for distinguishing the data flows in each data packet is different, the network device may determine that the data packet is a different data flow. In the embodiment of the invention, the data flow of the data message is amplified specifically by changing the identification information for distinguishing the data flow, so that the network equipment can identify more different data messages.
Specifically, the identification information for distinguishing the data flows may be an internet protocol (Internet Protocol, IP) Address or a media access Control (MEDIA ACCESS Control Address) MAC Address in the data packet.
In embodiments of the present invention, access control list (Access Control Lists, ACL) filtering may be performed on the data messages. Specifically, each field in the parsed data message can be matched with the key value in the ACL table, and if the matching fails, the data message can be discarded.
For example, ACL filtering may be performed on the data packet by whether identification information for distinguishing the data flow exists in the data packet. If the identification information for distinguishing the data streams does not exist in the data message, the message can be discarded. If the identification information for distinguishing the data flow exists in the data message, the fields in the data message can be recombined according to a preset format, so that the network equipment can normally receive and identify the message.
And 130, copying the matched data message through the multicast tree, and sending the data message and the copied message to a target port so as to amplify the flow of the data message.
When the destination ports connected with the nodes in the multicast tree are the same, a large number of copies of the data message can be realized, and the data stream is amplified. Illustratively, each node in the multicast tree may be connected to the same destination port, so as to implement the same network device to receive a large number of data packets, and perform a high-speed ethernet test.
In an optional implementation manner of the embodiment of the present invention, copying the matched data packet through the multicast tree, and sending the data packet and the copied packet to the target port, including: acquiring identification information used for distinguishing data streams in each data message; copying the matched data messages through a multicast tree, and accumulating identification information of the copied messages through a register to generate multiple copies of the data messages; and sending the data message and the copy message to the target port through the multicast tree.
After ACL filtering, the data packet may enter the stage of the input decoding flow (INGRESSDPARSER) of the convergence splitter. At stage INGRESSDPARSER, the data packet may be reassembled, and identification information, such as an IP address, for distinguishing the data stream may be extracted to determine that the data packet needs to be amplified. The amplifying of the data packet by the multicast tree may be connecting the nodes of the multicast tree to the same destination port, for example, the destination ports to which each node is connected are the same, so that the data packet may be output from the same port. Thereafter, an output encoding process (EGRESS DEPARSER) phase may be entered. At stage EGRESS DEPARSER, a data packet magnification table may be added, for example, an IP address change may be made. For example, the register may accumulate the IP addresses according to a preset step size, and change the IP addresses in each copied message. In EGRESS DEPARSER stage, message recombination can be performed on the message with the modified IP address to realize the update of the IP address, and a copy message is generated. The IP address in the above procedure may be replaced with other identification information for distinguishing the data flow.
In an optional implementation manner of the embodiment of the present invention, the accumulating of the identification information of the copied message through the register includes: judging whether the accumulated value of the register exceeds a preset range or not; if yes, carrying out zero clearing processing on an accumulator of the register, and then carrying out accumulation of identification information on the copied message through the register.
When the accumulated value of the register exceeds the preset range, data overflow is easy, for example, the IP address does not meet the preset specification. Therefore, when the accumulated value of the register exceeds the preset range, the register can be cleared, so that the identification information accumulation of the next data message is facilitated.
In an optional implementation manner of the embodiment of the present invention, the accumulating of the identification information is performed on the duplicated messages through the register, so as to generate multiple duplicated messages of the data message, including: accumulating the identification information of the copied message through a register; and recombining the accumulated identification information and the rest information in the data message to generate multiple copies of the data message.
In EGRESS DEPARSER stage, message reorganization can be performed on the message modified with the identification information to update the identification information, so as to generate a copy message.
The embodiment of the invention can realize data stream amplification through the converging current divider. The converging current divider can be designed through a programmable switching chip such as tofino chip, so that the problem that hardware forwarding logic of a non-programmable switching chip cannot be changed after the design is finished can be avoided, and the problem that a data message can only be adjusted through software parameters when the data message is modified can also be avoided. When the data flow is amplified by the software, only the data message can be modified, the processing sequence can not be adjusted, the setting range of the software is limited, and the flexibility is poor. The technical scheme of the embodiment of the invention can avoid the problems, realize the data stream amplification in a hardware mode and improve the flexibility of the data stream amplification.
Fig. 1c is a flowchart of a data stream amplifying method according to an embodiment of the present invention, as shown in fig. 1c, a tofino chip may use P4 voice to perform custom programming on a switch chip resource, a data stream sequence, etc. And defining IP protocol stack analysis through P4 language, modifying and repackaging the analyzed message, copying a plurality of copies and forwarding, and realizing the flow amplifying function of the converging current divider. Specifically, as shown in fig. 1c, a use process of the embodiment of the present invention may be:
And in the input decoding flow, acquiring the data message, and determining the corresponding input port and output port. Multiple multicast trees may be created according to the correspondence of input ports to output ports. For example, when the data packet a is sent to the target port B and the data flow is amplified, all ports connected to each node in the multicast tree corresponding to the data packet a may be set as the target port B. After the multicast tree is established, the amplifying action of the corresponding data message can be configured. For example, ACL filtering may be performed on the data packet, the data packet that needs to be amplified is retained, and identification information, such as an IP address, in the data packet is extracted. And carrying out message recombination on the received data message and determining whether the received data message has identification information such as an IP address. When it is determined that the reassembled data packet does not have an IP address, other flows may be performed. Other processes may be adding, deleting or modifying the content of the data message. When the identification information exists in the recombined message, judging whether to start the stream amplifying function. For example, whether the identification location of the stream amplification function is located. When it is determined that the flow amplifying function is turned off, other flows may be performed. When the stream amplifying function is determined to be started, the data message can be copied through the corresponding multicast tree, and the register is accumulated. When the accumulated value of the register does not exceed the preset range, the identification information in the message, such as an IP address, can be extracted, and the identification information is accumulated. When the accumulated value of the register exceeds the preset range, the register can be cleared, then the identification information in the message, such as an IP address, is extracted, and the identification information is accumulated. After the identification information is accumulated, the data messages can be recombined, so that the identification information is updated, and the data messages are output from the target ports corresponding to the multicast tree, so that the amplification of the data stream is realized.
According to the technical scheme, at least one data message to be amplified is obtained; acquiring a multicast tree which is respectively matched with the amplifying actions of each data message, wherein the added target ports of at least two nodes in the multicast tree are the same; the matched data messages are copied through the multicast tree, and the data messages and the copied messages are sent to the target port so as to amplify the flow of the data messages, thereby solving the problem that large data flow is required in high-speed Ethernet test, amplifying the flow of the data messages under the condition of not increasing the cost, and meeting the effect of high-speed Ethernet test of network equipment.
Example two
Fig. 2 is a schematic structural diagram of a data stream amplifying device according to a second embodiment of the present invention. With reference to fig. 2, the apparatus comprises: a data message acquisition module 210, a multicast tree acquisition module 220 and a message transmission module 230. Wherein:
A data message obtaining module 210, configured to obtain at least one data message to be amplified;
a multicast tree obtaining module 220, configured to obtain a multicast tree that is respectively matched with the amplifying actions of each data packet, where the target ports added by at least two nodes in the multicast tree are the same;
the message sending module 230 is configured to copy the matched data message through the multicast tree, and send the data message and the copied message to the destination port, so as to amplify the traffic of the data message
Optionally, the message sending module 230 includes:
The identification information acquisition unit is used for acquiring identification information used for distinguishing data streams in each data message;
The duplicate message generating unit is used for duplicating the matched data message through the multicast tree, accumulating the identification information of the duplicated message through the register, and generating multiple duplicate messages of the data message;
and the message sending unit is used for sending the data message and the copy message to the target port through the multicast tree.
Optionally, the duplicate message generating unit includes:
An accumulated value judging subunit, configured to judge whether the accumulated value of the register exceeds a preset range; if yes, carrying out zero clearing processing on an accumulator of the register, and then carrying out accumulation of identification information on the copied message through the register.
Optionally, the device further includes:
the port acquisition module is used for acquiring an input port corresponding to each data message to be amplified and at least one output port corresponding to each data message after the data message flow is amplified before acquiring the data message to be amplified;
and the multicast tree building module is used for setting a target port added by each node of the multicast tree according to each input port and each corresponding output port to obtain the multicast tree respectively matched with the amplifying action of each data message.
Optionally, the device further includes:
The identification information judging module is used for carrying out message analysis on the data messages before acquiring the multicast tree respectively matched with the amplifying actions of the data messages, and judging whether the identification information for distinguishing the data streams exists in the data messages or not; if yes, the data message is recombined; if not, discarding the data message.
Optionally, the duplicate message generating unit includes:
the identification information accumulation subunit is used for accumulating the identification information of the copied message through the register;
and the duplicate message Wen Shengcheng subunit is used for recombining the accumulated identification information and the rest information in the data message to generate multiple duplicate messages of the data message.
The data stream amplifying device provided by the embodiment of the invention can execute the data stream amplifying method provided by any embodiment of the invention, and has the corresponding functional modules and beneficial effects of the executing method.
Example III
Fig. 3 is a schematic structural diagram of a converging splitter according to a third embodiment of the present invention, and as shown in fig. 3, the converging splitter includes:
One or more processors 310, one processor 310 being illustrated in FIG. 3;
A memory 320;
the apparatus may further include: an input device 330 and an output device 340.
The processor 310, memory 320, input 330 and output 340 of the device may be connected by a bus or other means, for example in fig. 3.
The memory 320 is a non-transitory computer readable storage medium, and may be used to store a software program, a computer executable program, and modules, such as program instructions/modules (e.g., the data packet acquisition module 210, the multicast tree acquisition module 220, and the packet transmission module 230 shown in fig. 2) corresponding to a data stream amplifying method in an embodiment of the present invention. The processor 310 executes various functional applications of the computer device and data processing by running software programs, instructions and modules stored in the memory 320, i.e. implements a data stream amplifying method of the above method embodiment, namely:
acquiring at least one data message to be amplified;
Acquiring a multicast tree which is respectively matched with the amplifying actions of the data messages, wherein the added target ports of at least two nodes in the multicast tree are the same;
and copying the matched data message through the multicast tree, and sending the data message and the copied message to a target port so as to amplify the flow of the data message.
Memory 320 may include a storage program area that may store an operating system, at least one application program required for functionality, and a storage data area; the storage data area may store data created according to the use of the computer device, etc. In addition, memory 320 may include high-speed random access memory, and may also include non-transitory memory, such as at least one magnetic disk storage device, flash memory device, or other non-transitory solid state storage device. In some embodiments, memory 320 may optionally include memory located remotely from processor 310, which may be connected to the terminal device via a network. Examples of such networks include, but are not limited to, the internet, intranets, local area networks, mobile communication networks, and combinations thereof.
The input device 330 may be used to receive input numeric or character information and to generate key signal inputs related to user settings and function control of the computer device. The output device 340 may include a display device such as a display screen.
Example IV
A fourth embodiment of the present invention provides a computer readable storage medium having stored thereon a computer program which, when executed by a processor, implements a data stream amplifying method as provided by the embodiments of the present invention:
acquiring at least one data message to be amplified;
Acquiring a multicast tree which is respectively matched with the amplifying actions of the data messages, wherein the added target ports of at least two nodes in the multicast tree are the same;
and copying the matched data message through the multicast tree, and sending the data message and the copied message to a target port so as to amplify the flow of the data message.
Any combination of one or more computer readable media may be employed. The computer readable medium may be a computer readable signal medium or a computer readable storage medium. The computer readable storage medium can be, for example, but not limited to, an electronic, magnetic, optical, electromagnetic, infrared, or semiconductor system, apparatus, or device, or a combination of any of the foregoing. More specific examples (a non-exhaustive list) of the computer-readable storage medium would include the following: an electrical connection having one or more wires, a portable computer diskette, a hard disk, a Random Access Memory (RAM), a read-only memory (ROM), an erasable programmable read-only memory (EPROM or flash memory), an optical fiber, a portable compact disc read-only memory (CD-ROM), an optical storage device, a magnetic storage device, or any suitable combination of the foregoing. In this document, a computer readable storage medium may be any tangible medium that can contain, or store a program for use by or in connection with an instruction execution system, apparatus, or device.
The computer readable signal medium may include a propagated data signal with computer readable program code embodied therein, either in baseband or as part of a carrier wave. Such a propagated data signal may take any of a variety of forms, including, but not limited to, electro-magnetic, optical, or any suitable combination of the foregoing. A computer readable signal medium may also be any computer readable medium that is not a computer readable storage medium and that can communicate, propagate, or transport a program for use by or in connection with an instruction execution system, apparatus, or device.
Program code embodied on a computer readable medium may be transmitted using any appropriate medium, including but not limited to wireless, wireline, optical fiber cable, RF, etc., or any suitable combination of the foregoing.
Computer program code for carrying out operations of the present invention may be written in any combination of one or more programming languages, including an object oriented programming language such as Java, smalltalk, C ++ and conventional procedural programming languages, such as the "C" programming language or similar programming languages. The program code may execute entirely on the user's computer, partly on the user's computer, as a stand-alone software package, partly on the user's computer and partly on a remote computer or entirely on the remote computer or server. In the case of a remote computer, the remote computer may be connected to the user's computer through any kind of network, including a Local Area Network (LAN) or a Wide Area Network (WAN), or may be connected to an external computer (for example, through the Internet using an Internet service provider).
Note that the above is only a preferred embodiment of the present invention and the technical principle applied. It will be understood by those skilled in the art that the present invention is not limited to the particular embodiments described herein, but is capable of various obvious changes, rearrangements and substitutions as will now become apparent to those skilled in the art without departing from the scope of the invention. Therefore, while the invention has been described in connection with the above embodiments, the invention is not limited to the embodiments, but may be embodied in many other equivalent forms without departing from the spirit or scope of the invention, which is set forth in the following claims.
Claims (7)
1. A method of data stream amplification, the method comprising:
acquiring at least one data message to be amplified;
Acquiring a multicast tree which is respectively matched with the amplifying actions of the data messages, wherein the added target ports of at least two nodes in the multicast tree are the same;
copying the matched data message through the multicast tree, and sending the data message and the copied message to a target port so as to amplify the flow of the data message;
the step of copying the matched data message through the multicast tree and sending the data message and the copied message to a target port comprises the following steps:
acquiring identification information used for distinguishing data streams in each data message;
copying the matched data messages through the multicast tree, accumulating the identification information of the copied messages through a register, and generating multiple copies of the data messages;
Transmitting the data message and the copy message to a target port through the multicast tree; the nodes of the multicast tree are connected with the same target port, the identification information is accumulated according to a preset step length, the identification information in each copied message is changed, the message of the modified identification information is subjected to message recombination to update the identification information, and a copied message is generated;
The step of accumulating the identification information for the copied message through the register comprises the following steps:
Judging whether the accumulated value of the register exceeds a preset range or not;
If yes, carrying out zero clearing processing on the accumulator of the register, and then carrying out accumulation on the identification information on the copied message through the register.
2. The method of claim 1, further comprising, prior to acquiring the data message to be amplified:
Acquiring an input port corresponding to each data message to be amplified and at least one output port corresponding to each amplified data message flow;
and setting target ports added by nodes of the multicast tree according to the input ports and the output ports corresponding to the input ports respectively to obtain the multicast tree which is matched with the amplifying action of the data messages respectively.
3. The method of claim 1, further comprising, prior to obtaining a multicast tree that matches each of the data message's amplification actions, respectively:
Carrying out message analysis on the data message and judging whether the data message has identification information for distinguishing data streams or not;
if yes, carrying out message recombination on the data message;
if not, discarding the data message.
4. The method of claim 1, wherein accumulating the identification information for the replicated messages via a register to generate multiple replicated messages for the data message comprises:
accumulating the identification information through a register;
and recombining the accumulated identification information with the rest information in the data message to generate multiple copies of the data message.
5. A data stream amplifying device is characterized in that,
The data message acquisition module is used for acquiring at least one data message to be amplified;
the multicast tree acquisition module is used for acquiring multicast trees which are respectively matched with the amplifying actions of the data messages, wherein the target ports added by at least two nodes in the multicast tree are the same;
The message sending module is used for copying the matched data message through the multicast tree, and sending the data message and the copied message to a target port so as to amplify the flow of the data message;
The message sending module comprises:
the identification information acquisition unit is used for acquiring identification information used for distinguishing data streams in each data message;
the duplicate message generating unit is used for duplicating the matched data message through the multicast tree, accumulating the identification information of the duplicated message through a register, and generating multiple duplicate messages of the data message;
A message sending unit, configured to send the data message and the duplicate message to a destination port through the multicast tree; the nodes of the multicast tree are connected with the same target port, the identification information is accumulated according to a preset step length, the identification information in each copied message is changed, the message of the modified identification information is subjected to message recombination to update the identification information, and a copied message is generated;
the duplicate message generating unit includes:
an accumulated value judging subunit, configured to judge whether an accumulated value of the register exceeds a preset range;
If yes, carrying out zero clearing processing on the accumulator of the register, and then carrying out accumulation on the identification information on the copied message through the register.
6. A converging splitter, comprising:
One or more processors; wherein the processor adopts a programmable logic chip;
Storage means for storing one or more programs,
The one or more programs, when executed by the one or more processors, cause the one or more processors to implement the method of any of claims 1-4.
7. A computer readable storage medium, on which a computer program is stored, characterized in that the program, when being executed by a processor, implements the method according to any of claims 1-4.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110771446.4A CN113489652B (en) | 2021-07-08 | 2021-07-08 | Data stream amplifying method and device, converging shunt and storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110771446.4A CN113489652B (en) | 2021-07-08 | 2021-07-08 | Data stream amplifying method and device, converging shunt and storage medium |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN113489652A CN113489652A (en) | 2021-10-08 |
| CN113489652B true CN113489652B (en) | 2024-08-02 |
Family
ID=77937919
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202110771446.4A Active CN113489652B (en) | 2021-07-08 | 2021-07-08 | Data stream amplifying method and device, converging shunt and storage medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN113489652B (en) |
Families Citing this family (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN114039880B (en) * | 2021-11-08 | 2023-09-05 | 上海天融信网络安全技术有限公司 | Performance test method, device and system for connectionless service |
| CN114465924B (en) * | 2021-12-24 | 2023-12-22 | 阿里巴巴（中国）有限公司 | Network equipment testing method, data packet generating method and switching chip |
| CN115174676A (en) * | 2022-07-04 | 2022-10-11 | 深圳星云智联科技有限公司 | Convergence and shunt method and related equipment thereof |
| CN116996527B (en) * | 2023-09-25 | 2023-12-12 | 北京中科网芯科技有限公司 | Method for synchronizing data of converging current divider and storage medium |
Citations (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN111404964A (en) * | 2020-03-30 | 2020-07-10 | 恒安嘉新（北京）科技股份公司 | Method, device, equipment and medium for converging and shunting IP datagram |
Family Cites Families (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US9374294B1 (en) * | 2013-11-05 | 2016-06-21 | Cisco Technology, Inc. | On-demand learning in overlay networks |
| CN106550291A (en) * | 2015-09-23 | 2017-03-29 | 中兴通讯股份有限公司 | The transmission of resource allocation information, data distributing method and device |
| CN106453154B (en) * | 2016-09-14 | 2019-08-09 | 盛科网络（苏州）有限公司 | Real-time adjustment method and debugging system based on multicast copy packet |
| CN108055211B (en) * | 2017-12-22 | 2020-10-30 | 盛科网络（苏州）有限公司 | Multicast replication method, equipment and storage medium |
| US11012251B2 (en) * | 2018-10-02 | 2021-05-18 | Cisco Technology, Inc. | Multicast flow scheduling in a data center |
| US11601295B2 (en) * | 2019-09-23 | 2023-03-07 | Juniper Networks, Inc. | Content delivery with reliable multicast using a redundant unicast overlay network |
| CN112202674B (en) * | 2020-09-27 | 2022-10-28 | 北京物芯科技有限责任公司 | A method, device, device and storage medium for forwarding and processing multicast messages |
| CN112866002B (en) * | 2020-11-10 | 2023-04-07 | 网络通信与安全紫金山实验室 | Multicast traffic oriented in-band telemetry method, switching device node and computer readable storage medium |
-
2021
- 2021-07-08 CN CN202110771446.4A patent/CN113489652B/en active Active
Patent Citations (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN111404964A (en) * | 2020-03-30 | 2020-07-10 | 恒安嘉新（北京）科技股份公司 | Method, device, equipment and medium for converging and shunting IP datagram |
Also Published As
| Publication number | Publication date |
|---|---|
| CN113489652A (en) | 2021-10-08 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN113489652B (en) | Data stream amplifying method and device, converging shunt and storage medium | |
| US10938748B2 (en) | Packet processing method, computing device, and packet processing apparatus | |
| US8451717B2 (en) | Method and apparatus for rapid switchover from primary to standby multicast trees | |
| US9900238B2 (en) | Overlay network-based original packet flow mapping apparatus and method therefor | |
| CN104106244A (en) | Control device, communication system, communication method and program | |
| JPWO2011162215A1 (en) | COMMUNICATION SYSTEM, CONTROL DEVICE, NODE CONTROL METHOD, AND PROGRAM | |
| CN104468384A (en) | System and method for achieving multi-service priorities | |
| US11522795B1 (en) | End to end application identification and analytics of tunnel encapsulated traffic in the underlay | |
| US20130198830A1 (en) | Access relay method and access gateway device | |
| CN106357542B (en) | Method for providing multicast service and software-defined network controller | |
| KR101477012B1 (en) | Method, apparatus, system and computer-readable recording medium for sdn switching | |
| JP5534033B2 (en) | Communication system, node, packet transfer method and program | |
| US20180262355A1 (en) | Method for multicast packet transmission in software defined networks | |
| CN109756412B (en) | Data message forwarding method and equipment | |
| US20240283740A1 (en) | Recursive bitstring structure addressing | |
| JP2016523062A (en) | Method and apparatus for generating input parameters | |
| CN108282404B (en) | Route generation method, device and system | |
| KR102485180B1 (en) | Software defined networking switch and method for multicasting thereof | |
| CN105025029A (en) | OLT device dynamic access control list generation method and data packet processing method | |
| CN116455837A (en) | Message processing method and device, equipment and storage medium | |
| CN110324247B (en) | Multicast forwarding method, device and storage medium in three-layer multicast network | |
| WO2024078018A1 (en) | Data transmission method, apparatus and system | |
| CN113852572B (en) | Message processing method and device | |
| CN115314447B (en) | Packet-in message processing method and system in SDN environment | |
| CN116016391B (en) | Message forwarding method and system based on NAT gateway |
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 |