CN113923169B - Message filtering method and device, storage medium and electronic device - Google Patents
Message filtering method and device, storage medium and electronic device Download PDFInfo
- Publication number
- CN113923169B CN113923169B CN202111182608.7A CN202111182608A CN113923169B CN 113923169 B CN113923169 B CN 113923169B CN 202111182608 A CN202111182608 A CN 202111182608A CN 113923169 B CN113923169 B CN 113923169B
- Authority
- CN
- China
- Prior art keywords
- message
- target
- filtering
- cache
- tables
- 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
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
- H04L47/24—Traffic characterised by specific attributes, e.g. priority or QoS
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L47/00—Traffic control in data switching networks
- H04L47/10—Flow control; Congestion control
- H04L47/32—Flow control; Congestion control by discarding or delaying data units, e.g. packets or frames
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
The invention discloses a method and a device for filtering messages, a storage medium and an electronic device, wherein the method comprises the following steps: under the condition that the terminal receives the target message, analyzing all filter tables in a filter table queue of the terminal; traversing the filtering table items of all the filtering tables, and determining whether one or more target filtering tables exist in the filtering table items of all the filtering tables, wherein the target message types of the target filtering tables are consistent with the message types of the target messages; and under the condition that one or more target filtering tables exist in the filtering table items of all the filtering tables, determining whether the priority of the first message in the target filtering table is smaller than the message priority of the target message, and discarding the first message under the condition that the priority of the first message is smaller than the message priority of the target message.
Description
Technical Field
The present invention relates to the field of communications, and in particular, to a method and apparatus for filtering a message, a storage medium, and an electronic device.
Background
In a communication network, with the continuous addition of network devices, network messages are caused to increase in a burst mode, and under the condition of limited bandwidth, network congestion or storm is caused frequently. Under the condition of network congestion, the method for selectively receiving the messages, discarding unnecessary messages, controlling the message receiving rate and the like and inhibiting the network message receiving becomes an important means for ensuring the normal operation of the equipment.
In the traditional method for inhibiting network message reception, a counter is started at a device receiving end, the messages to be limited are counted in a certain time window, and if the limit value is exceeded, the messages are buffered or lost. However, after the number of the messages exceeds a limit value, packet loss processing is immediately performed, so that the service which is processing the messages is abnormal, and the normal operation of the equipment is affected.
Aiming at the problems that a terminal receives a large number of messages and exceeds the processing capacity of the terminal, so that the device enters a serious abnormal state and the like in the related art, no effective solution is proposed.
Disclosure of Invention
The embodiment of the invention provides a message filtering method and device, a storage medium and an electronic device, which at least solve the problems that a terminal receives a large number of messages and exceeds the processing capacity of the terminal, so that equipment enters a serious abnormal state and the like in the related technology.
According to one embodiment of the present invention, there is provided a method for filtering a message, including: under the condition that a terminal receives a target message, analyzing all filtering tables in a filtering table queue of the terminal, wherein the filtering tables comprise: filtering table entries, the filtering table entries comprising: message type, message priority; traversing the filtering table items of all the filtering tables, and determining whether one or more target filtering tables exist in the filtering table items of all the filtering tables, wherein the target message types of the target filtering tables are consistent with the message types of the target messages; and under the condition that one or more target filtering tables exist in the filtering table items of all the filtering tables, determining whether the priority of a first message in the target filtering table is smaller than the message priority of the target message, and discarding the first message under the condition that the priority of the first message is smaller than the message priority of the target message.
In an exemplary embodiment, in a case that it is determined that one or more target filtering tables do not exist in the filtering table entries of all the filtering tables, all the buffering tables in the buffering table queue of the terminal are parsed, where the buffering tables include: the cache entry includes: message type, priority; traversing the cache table entries of all the cache tables, and determining whether one or more target cache tables exist in the cache table entries of all the cache tables, wherein the target message types of the target cache tables are consistent with the message types of the target messages; and under the condition that one or more target cache tables exist in the cache table items of all the cache tables, determining a target cache table corresponding to the target message type, and caching the target message into a target message cache region corresponding to the target cache table.
In an exemplary embodiment, caching the target message in a target message cache area corresponding to the target cache table includes: determining whether the capacity of the target message buffer area meets a preset condition; and under the condition that the preset condition is met, caching the target message into a target message cache region corresponding to the target cache table.
In an exemplary embodiment, determining whether the capacity of the target packet buffer meets a preset condition includes: determining whether the number of second messages cached in the target message cache area is equal to a first preset threshold, wherein the first preset threshold is used for indicating the maximum number of messages cached in the target message cache area; and under the condition that the number of the second messages cached in the target message cache area is smaller than the first preset threshold value, determining that the capacity of the target message cache area meets the preset condition.
In an exemplary embodiment, after determining whether the capacity of the target packet buffer meets the preset condition, the method further includes: determining whether the priority of the second messages cached in the target cache database is greater than the priority of the target messages under the condition that the number of the second messages cached in the target cache database is equal to the first preset threshold; and discarding the second message and caching the target message under the condition that the priority of the second message is smaller than that of the target message.
In an exemplary embodiment, before parsing all filter tables in a filter table queue of the terminal in a case that the terminal receives the target message, the method further includes: determining the number of the received monitoring messages; and under the condition that the number of the monitoring messages is larger than the filtering water line, establishing a filtering table corresponding to the monitoring messages, and adding the filtering table corresponding to the monitoring messages into the filtering table queue.
In an exemplary embodiment, after determining the number of received monitoring messages, the method further comprises: when the number of the monitoring messages is smaller than the filtering waterline and the number of the monitoring messages is larger than the buffering waterline, establishing a buffering table corresponding to the monitoring messages, and adding the buffering table corresponding to the monitoring messages into the buffering table queue; and acquiring an alarm notification address in a cache table corresponding to the monitoring message, and sending alarm information to a source terminal corresponding to the alarm notification address, wherein the alarm information is used for indicating the source terminal corresponding to the alarm notification address to send the target message in a preset strategy.
In an exemplary embodiment, after determining the number of received monitoring messages, the method further comprises: determining whether a cache table corresponding to the monitoring message exists in the cache table queue or not under the condition that the number of the monitoring messages is smaller than the cache waterline; determining the delay receiving time of the target cache table under the condition that whether the cache table corresponding to the monitoring message exists in the cache table queue; and writing the target message in the target cache data into a network protocol stack corresponding to the target message according to the delay receiving time.
According to another embodiment of the present invention, there is further provided a filtering apparatus for a packet, and an parsing module, configured to parse all filtering tables in a filtering table queue of a terminal when the terminal receives a target packet, where the filtering tables include: filtering table entries, the filtering table entries comprising: message type, message priority; the determining module is used for traversing the filtering table items of all the filtering tables and determining whether one or more target filtering tables exist in the filtering table items of all the filtering tables, wherein the target message types of the target filtering tables are consistent with the message types of the target messages; and the filtering module is used for determining whether the priority of a first message in the target filtering table is smaller than the message priority of the target message under the condition that one or more target filtering tables exist in the filtering table items of all the filtering tables, and discarding the first message under the condition that the priority of the first message is smaller than the message priority of the target message.
According to a further embodiment of the invention, there is also provided a computer-readable storage medium having stored therein a computer program, wherein the computer program is arranged to perform the steps of any of the method embodiments described above when run.
According to a further embodiment of the invention, there is also provided an electronic device comprising a memory having stored therein a computer program and a processor arranged to run the computer program to perform the steps of any of the method embodiments described above.
The invention provides a method for filtering messages, which comprises the following steps: under the condition that a terminal receives a target message, analyzing all filtering tables in a filtering table queue of the terminal, wherein the filtering tables comprise: filtering table entries, the filtering table entries comprising: message type, message priority; traversing the filtering table items of all the filtering tables, and determining whether the filtering table items of all the filtering tables have the target message type consistent with the message type of the target message; one or more target filtering tables exist in the filtering table items of all the filtering tables, wherein the target message types of the target filtering tables are consistent with the message types of the target messages; determining whether a first message in the target filtering table has a priority smaller than a message priority of a target message under the condition that one or more target filtering tables exist in filtering table items of all the filtering tables, discarding the first message under the condition that the first message has a priority smaller than the message priority of the target message, by adopting the scheme, the problems that in the related technology, the terminal exceeds the processing capacity because a large number of messages are received, so that the equipment enters a serious abnormal state and the like are solved, the packet loss can be prevented when the message flow is sudden, and the impact damage to the terminal can be prevented when the message flow is overlarge.
Drawings
The accompanying drawings, which are included to provide a further understanding of the application and are incorporated in and constitute a part of this specification, illustrate embodiments of the application and together with the description serve to explain the application and do not constitute a limitation on the application. In the drawings:
FIG. 1 is a block diagram of a hardware configuration of a computer terminal of a method for filtering a message according to an embodiment of the present invention;
FIG. 2 is a flow chart of a method of filtering messages according to an embodiment of the present invention;
FIG. 3 is a schematic diagram of a method for filtering messages according to an alternative embodiment of the present invention;
FIG. 4 is a flow chart of counter processing of a method for filtering messages according to an alternative embodiment of the present invention;
fig. 5 is a block diagram of a message filtering apparatus according to an embodiment of the present invention.
Detailed Description
The application will be described in detail hereinafter with reference to the drawings in conjunction with embodiments. It should be noted that, without conflict, the embodiments of the present application and features of the embodiments may be combined with each other.
It should be noted that the terms "history," "second," and the like in the description and the claims of the present invention and the above drawings are used for distinguishing between similar objects and not necessarily for describing a particular sequential or chronological order.
The method embodiments provided by the embodiments of the present application may be executed in a computer terminal, or similar computing device. Taking the operation on a computer terminal as an example, fig. 1 is a block diagram of a hardware structure of a computer terminal of a method for filtering a message according to an embodiment of the present application. As shown in fig. 1, the computer terminal may include one or more (only one is shown in fig. 1) processors 102 (the processor 102 may include, but is not limited to, a microprocessor MCU or a processing device such as a programmable logic device FPGA) and a memory 104 for storing data, and in one exemplary embodiment, may also include a transmission device 106 for communication functions and an input-output device 108. It will be appreciated by those skilled in the art that the configuration shown in fig. 1 is merely illustrative and is not intended to limit the configuration of the computer terminal described above. For example, a computer terminal may also include more or fewer components than shown in FIG. 1, or have a different configuration than the equivalent functions shown in FIG. 1 or more than the functions shown in FIG. 1.
The memory 104 may be used to store a computer program, for example, a software program of application software and a module, such as a computer program corresponding to a method for filtering a message of a computer terminal in an embodiment of the present invention, and the processor 102 executes the computer program stored in the memory 104 to perform various functional applications and data processing, that is, implement the method described above. Memory 104 may include high-speed random access memory, and may also include non-volatile memory, such as one or more magnetic storage devices, flash memory, or other non-volatile solid-state memory. In some examples, the memory 104 may further include memory remotely located relative to the processor 102, which may be connected to the computer terminal 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 transmission means 106 is arranged to receive or transmit data via a network. Specific examples of the network described above may include a wireless network provided by a communication provider of a computer terminal. In one example, the transmission device 106 includes a network adapter (Network Interface Controller, simply referred to as a NIC) that can connect to other network devices through a base station to communicate with the internet. In one example, the transmission device 106 may be a Radio Frequency (RF) module, which is used to communicate with the internet wirelessly.
In this embodiment, a method for filtering a message is provided and applied to the computer terminal, and fig. 2 is a flowchart of a method for filtering a message according to an embodiment of the present invention, where the flowchart includes the following steps:
step S202, under the condition that a terminal receives a target message, analyzing all filtering tables in a filtering table queue of the terminal, wherein the filtering tables comprise: filtering table entries, the filtering table entries comprising: message type, message priority;
It should be noted that the number of the substrates, the filter table includes: the table name, packet loss priority, and the table entry (message type, priority) are filtered.
Step S204, traversing the filtering table items of all the filtering tables, and determining whether one or more target filtering tables exist in the filtering table items of all the filtering tables, wherein the target message types of the target filtering tables are consistent with the message types of the target messages;
Step S206, determining whether the priority of the first message in the target filtering table is smaller than the message priority of the target message if one or more target filtering tables exist in the filtering table entries of all the filtering tables, and discarding the first message if the priority of the first message is smaller than the message priority of the target message.
Through the steps, under the condition that the terminal receives the target message, all the filtering tables in the filtering table queue of the terminal are analyzed, wherein the filtering tables comprise: filtering table entries, the filtering table entries comprising: message type, message priority; traversing the filtering table items of all the filtering tables, and determining whether one or more target filtering tables exist in the filtering table items of all the filtering tables, wherein the target message types of the target filtering tables are consistent with the message types of the target messages; under the condition that one or more target filtering tables exist in the filtering table items of all the filtering tables, determining the target filtering table corresponding to the target message type; the method and the device for determining the priority of the first message in the target filtering table are used for determining whether the priority of the first message is smaller than the message priority of the target message, and discarding the first message under the condition that the priority of the first message is smaller than the message priority of the target message.
In an exemplary embodiment, in a case that it is determined that one or more target filtering tables do not exist in the filtering table entries of all the filtering tables, all the buffering tables in the buffering table queue of the terminal are parsed, where the buffering tables include: the cache entry includes: message type, priority; traversing the cache table entries of all the cache tables, and determining whether one or more target cache tables exist in the cache table entries of all the cache tables, wherein the target message types of the target cache tables are consistent with the message types of the target messages; and under the condition that one or more target cache tables exist in the cache table items of all the cache tables, determining a target cache table corresponding to the target message type, and caching the target message into a target message cache region corresponding to the target cache table.
It should be noted that, determining whether the cache entries of all the cache tables have the target message type consistent with the message type of the target message may be understood as: determining whether the message type of the target message is consistent with the target message type in the target cache table, and caching the target message into a target message cache region corresponding to the target cache table under the condition that the message type of the target message is determined to be consistent with the target message type in the target cache table; and under the condition that the message type of the target message is inconsistent with the target message type in the target cache table, determining whether to cache the target message according to the message priority.
In an exemplary embodiment, caching the target message in a target message cache area corresponding to the target cache table includes: determining whether the capacity of the target message buffer area meets a preset condition; and under the condition that the preset condition is met, caching the target message into a target message cache region corresponding to the target cache table.
That is, the relation between the capacity of the target message buffer area and the preset condition is judged, and the target message is buffered to the target message buffer area corresponding to the target buffer table under the condition that the capacity of the target message buffer area meets the preset condition.
Specifically, determining whether the number of second messages cached in the target message cache area is equal to a first preset threshold, wherein the first preset threshold is used for indicating the maximum number of messages cached in the target message cache area; and under the condition that the number of the second messages cached in the target message cache area is smaller than the first preset threshold value, determining that the capacity of the target message cache area meets the preset condition.
That is, the relationship between the capacity of the target message buffer and the preset condition is determined by: under the condition that the number of second messages cached in the target message cache area is smaller than the first preset threshold value, determining that the capacity of the target message cache area meets a preset condition; and under the condition that the number of the second messages cached in the target message cache area is equal to the first preset threshold value, determining that the capacity of the target message cache area does not meet the preset condition.
In an exemplary embodiment, after determining whether the capacity of the target packet buffer area meets a preset condition, determining whether the priority of the second packet buffered in the target buffer database is greater than the priority of the target packet if the number of second packets buffered in the target buffer database is equal to the first preset threshold; and discarding the second message and caching the target message under the condition that the priority of the second message is smaller than that of the target message. Further, under the condition that the number of second messages cached in the target message cache area is equal to the first preset threshold value, namely, under the condition that the capacity of the target message cache area does not meet the preset condition, determining the priority of the second messages and the priority of the target messages, comparing the magnitude relation between the priority of the second messages and the priority of the target messages, and discarding the target messages under the condition that the magnitude relation indicates that the priority of the second messages is greater than the priority of the target messages; and discarding the second message and caching the target message under the condition that the magnitude relation indicates that the priority of the second message is smaller than that of the target message.
Further, if the message type of the target message is inconsistent with the target message type in the target cache table, and if the message type of the target message is inconsistent with the target message type in the target filter table, the target message is normally processed.
In one exemplary embodiment, the number of received monitoring messages is determined prior to parsing the target filter table in the filter table queue; and under the condition that the number of the monitoring messages is larger than the filtering water line, establishing a filtering table corresponding to the monitoring messages, and adding the filtering table corresponding to the monitoring messages into the filtering table queue.
That is, the number of the received monitoring messages is determined, a filtering table is built for the monitoring messages when the number of the received monitoring messages is larger than a filtering waterline, the filtering table is added into a filtering table queue, the packet loss priority of the filtering table is set to be smaller than the priority of a second preset threshold, if the filtering table exists in the filtering table queue, the packet loss priority of the filtering table is increased by one, and if the priority of the filtering table is larger than a third preset threshold, the messages corresponding to the filtering table are all discarded.
In an exemplary embodiment, when the number of the monitoring messages is smaller than a filtering waterline and the number of the monitoring messages is larger than a buffering waterline, a buffering table corresponding to the monitoring messages is established, and the buffering table corresponding to the monitoring messages is added into the buffering table queue; and acquiring an alarm notification address in a cache table corresponding to the monitoring message, and sending alarm information to a source terminal corresponding to the alarm notification address, wherein the alarm information is used for indicating the source terminal corresponding to the alarm notification address to send the target message in a preset strategy.
Further, when the number of the monitoring messages is smaller than the filtering water line and the number of the monitoring messages is larger than the buffering water line, a buffer table corresponding to the monitoring messages is built, the buffer table corresponding to the monitoring messages is added into the buffer table queue, an alarm notification address in the buffer table corresponding to the monitoring messages is determined, alarm information is sent to a source end corresponding to the alarm notification address through a udp message, after the notified source end receives the alarm information, message flow control is carried out according to the content of the buffer table in the alarm information and a preset strategy, and if the buffer table corresponding to the monitoring messages already exists in the buffer table queue, the alarm information is directly sent to the source end corresponding to the alarm notification address through the udp message.
In an exemplary embodiment, after determining the number of the received monitoring messages, determining whether a cache table corresponding to the monitoring messages exists in the cache table queue under the condition that the number of the monitoring messages is smaller than the cache waterline; determining the delay receiving time of the buffer table corresponding to the monitoring message under the condition that whether the buffer table corresponding to the monitoring message exists in the buffer table queue; and writing the target message in the buffer table corresponding to the monitoring message into a network protocol stack corresponding to the target message according to the delay receiving time.
Namely, reading the delay receiving time of the buffer table corresponding to the monitoring message, starting a delay task processing work queue according to the read delay receiving time, reading the message in the target message buffer area corresponding to the buffer table corresponding to the monitoring message into a network protocol stack, simultaneously setting the buffer state of the buffer table corresponding to the monitoring message to be empty, and removing the buffer table corresponding to the monitoring message from the buffer queue.
Further, under the condition of closing the target filtering table, the packet loss priority of the target filtering table is adjusted to be lower than the priority of the second preset threshold value, and meanwhile, the target filtering table is removed from the filtering table queue. And dynamically adjusting the filtering waterline and the cache waterline according to the utilization rate of the memory or the utilization rate of the central processing unit.
In order to better understand the process of the filtering method of the above-mentioned message, the following describes the flow of the filtering method of the above-mentioned message in combination with the alternative embodiment, but is not used for limiting the technical scheme of the embodiment of the present invention.
The embodiment of the invention provides a message filtering method, which is characterized in that a message receiving processing flow and a message monitoring counter processing flow are used for realizing the caching, alarming notification and discarding of a received message of a central processing unit based on a preset filtering waterline, a preset caching waterline and a corresponding caching table and a preset filtering table. Therefore, the control of message receiving is realized, and the impact of the network message on the equipment can be flexibly controlled according to different application scenes. The detailed procedure is as follows:
Fig. 3 is a schematic diagram of a method for filtering a message according to an alternative embodiment of the present invention, and as shown in fig. 3, the specific steps of the message receiving process flow are as follows:
step S301: counting the received monitoring messages (corresponding to the target messages in the above embodiment);
step S302: reading all the filter tables in the filter table queue, and analyzing all the filter tables;
Step S303: determining whether a filtering table item of a filtering table in the filtering table queue has a target message type consistent with the message type of the monitoring message, and executing step S304 if the target message type is present and meets the filtering condition; if the filtering condition does not exist or is not satisfied, step S305 is performed;
Wherein, the filtering condition is: the priority of the second message of the target filtering table is greater than the message priority of the monitoring message.
Step S304: discarding the monitoring message and terminating the rest message receiving flow;
step S305: reading all cache tables in the cache table queue, and analyzing all cache tables;
Step S306: determining whether the cache table entries of all the cache tables have a target message type consistent with the message type of the monitoring message, and executing step S307 if the target message type exists and meets the cache condition; if the cache condition does not exist or is not satisfied, step S308 is performed;
Wherein, the preset conditions are: the capacity of the target message buffer area corresponding to the target buffer table has surplus or the message priority of the monitoring message is larger than the message priority of the first message in the target message buffer area.
Step S307: caching the monitoring message and terminating the rest message receiving flow;
Step S308: and under the condition that the monitoring message is not matched with the cache table and is not matched with the filtering table, entering a normal receiving flow.
In the above step S305, the target cache table is parsed by:
The notification address (corresponding to the alarm notification address in the above embodiment) stored in the target cache table is read, alarm information is sent to the notification address, the content of the information is the content of the cache table, and after the notified device (corresponding to the source end in the above embodiment) receives the alarm information, the message flow control is performed according to the content of the cache table and a predetermined policy, so that the notified device reduces the sending of the message. Secondly, under the condition that the monitoring message is received, matching the message types of the monitoring message and the target cache table, and caching the matched monitoring message into a cache allocated by the target cache table. And finally, in the process of storing the target message into the cache allocated by the target cache table, firstly reading the number of the cache message stored by the target cache table, and judging whether the number of the caches allocated by the internal cache table reaches the upper limit. If the number of the distributed caches reaches the upper limit, judging the size relation between the priority of the stored message and the priority of the target message, indicating the priority of the target message with the priority smaller than that of the stored message in the size relation, releasing space for the target message, and if the priority of the stored message is greater than that of the target message, discarding the target message.
In the above step S302, the target filter table is parsed by:
According to the priority of the messages in the target filtering table, firstly discarding the messages with the lowest priority, and continuing discarding the messages with the lowest priority in the next period until the stored messages in the target filtering table are discarded.
Fig. 4 is a counter processing flow chart of a method for filtering a message according to an alternative embodiment of the present invention, and as shown in fig. 4, the counter processing flow may be implemented by the following steps:
Step S401: counting the monitoring messages, reading a monitoring message counter, and judging the counting value of the monitoring messages;
Step S402: judging whether the count value of the monitoring message is larger than a filtering waterline or not; executing step S403 when the monitored message count value is greater than the filtering water line, and executing step S404 when the monitored message count value is less than the filtering water line;
Step S403: adding a target filter table corresponding to the monitoring message into a filter table queue, setting the packet loss priority of the filter table to be smaller than the priority of a second preset threshold, adding one to the packet loss priority of the target filter table if the target filter table corresponding to the monitoring message is already in the filter table queue until the packet loss priority of the target filter table is larger than a third preset threshold, and discarding the message corresponding to the target filter table;
Step S404: judging whether the count value of the monitoring message is larger than a cache waterline or not; executing step S405 when the monitored message count value is greater than the cache waterline, and executing step S406 when the monitored message count value is less than the cache waterline;
Step S405: adding a target cache table corresponding to the monitoring message into a cache table queue, sending the alarm information to a source terminal corresponding to the alarm notification address through the udp message, and directly sending the alarm information to the source terminal corresponding to the alarm notification address through the udp message if the target cache table corresponding to the monitoring message is already in the cache table queue;
step S406: if the target cache table corresponding to the monitoring message is already in the cache table queue, taking the target cache table out of the cache table queue, and closing the target cache table;
step S407: if the target filtering table corresponding to the monitoring message is already in the filtering table queue, taking the target filtering table out of the filtering table queue, and closing the target filtering table;
step S408: and resetting the monitoring message counter.
Specifically, the manner of closing the target cache table in step S406 is as follows:
Reading the delay receiving time of the target cache table, starting a delay task processing work queue according to the read delay receiving time, reading the message in the target cache table into a network protocol stack, simultaneously setting the cache state of the target cache table to be empty, and removing the target cache table from the cache table queue.
Specifically, the manner of closing the target filter table in step S407 is as follows:
And adjusting the packet loss priority of the target filter table to be lower than the priority of the second preset threshold value, and simultaneously removing the target filter table from the filter table queue.
Furthermore, the filtering waterline and the cache waterline can be dynamically adjusted according to the utilization rate of the memory or the utilization rate of the central processing unit.
In summary, the timer is started to count the number of the specific messages, when the buffer waterline is exceeded, the message buffer action is triggered, the remote equipment is informed of the inhibition action, and when the buffer waterline is exceeded, the message filtering action is triggered. By using the embodiment of the invention, the packet loss of the message can be prevented when the message flow is sudden, and the impact damage to the equipment can be prevented when the message flow is overlarge.
From the description of the above embodiments, it will be clear to a person skilled in the art that the method according to the above embodiments may be implemented by means of software plus the necessary general hardware platform, but of course also by means of hardware, but in many cases the former is a preferred embodiment. Based on such understanding, the technical solution of the present invention may be embodied essentially or in a part contributing to the prior art in the form of a software product stored in a storage medium (e.g. ROM/RAM, magnetic disk, optical disk) comprising instructions for causing a terminal device (which may be a mobile phone, a computer, a server, or a network device, etc.) to perform the method according to the embodiments of the present invention.
The embodiment also provides a device for filtering a message, which is used for implementing the above embodiment and the preferred implementation manner, and is not described in detail. As used below, the term "module" may be a combination of software and/or hardware that implements a predetermined function. While the means described in the following embodiments are preferably implemented in software, implementation in hardware, or a combination of software and hardware, is also possible and contemplated.
FIG. 5 is a block diagram of a message filtering apparatus according to an embodiment of the present invention; as shown in fig. 5, includes:
The parsing module 52 is configured to parse all filtering tables in a filtering table queue of a terminal when the terminal receives a target packet, where the filtering tables include: filtering table entries, the filtering table entries comprising: message type, message priority;
It should be noted that the target cache table includes: buffer table name, alarm notification address, message buffer size, buffer message delay receiving time, buffer table item (message type, priority).
A determining module 54, configured to traverse all the filtering table entries of the filtering tables, and determine whether one or more target filtering tables exist in the filtering table entries of all the filtering tables, where a target message type of the target filtering table is consistent with a message type of the target message;
It should be noted that the number of the substrates, the filter table includes: filtering table name, packet loss priority, filtering table entry (message type, priority)
And a filtering module 56, configured to determine, if one or more target filtering tables exist in the filtering table entries of all the filtering tables, whether a priority of a first message in the target filtering table is smaller than a message priority of a target message, and discard the first message if the priority of the first message is smaller than the message priority of the target message.
Through the module, under the condition that the terminal receives the target message, all filtering tables in a filtering table queue of the terminal are analyzed, wherein the filtering tables comprise: filtering table entries, the filtering table entries comprising: message type, message priority; traversing the filtering table items of all the filtering tables, and determining whether one or more target filtering tables exist in the filtering table items of all the filtering tables, wherein the target message types of the target filtering tables are consistent with the message types of the target messages; under the condition that one or more target filtering tables exist in the filtering table items of all the filtering tables, determining the target filtering table corresponding to the target message type; the method and the device for determining the priority of the first message in the target filtering table are used for determining whether the priority of the first message is smaller than the message priority of the target message, and discarding the first message under the condition that the priority of the first message is smaller than the message priority of the target message.
In an exemplary embodiment, the above apparatus further includes: the buffer memory module is configured to parse all buffer memory tables in a buffer memory table queue of the terminal, where the buffer memory table includes: the cache entry includes: message type, priority; traversing the cache table entries of all the cache tables, and determining whether one or more target cache tables exist in the cache table entries of all the cache tables, wherein the target message types of the target cache tables are consistent with the message types of the target messages; and under the condition that one or more target cache tables exist in the cache table items of all the cache tables, determining a target cache table corresponding to the target message type, and caching the target message into a target message cache region corresponding to the target cache table.
It should be noted that, determining whether the cache entries of all the cache tables have the target message type consistent with the message type of the target message may be understood as: determining whether the message type of the target message is consistent with the target message type in the target cache table, and caching the target message into a target message cache region corresponding to the target cache table under the condition that the message type of the target message is determined to be consistent with the target message type in the target cache table; and under the condition that the message type of the target message is inconsistent with the target message type in the target cache table, determining whether to cache the target message according to the message priority.
In an exemplary embodiment, the buffer module is further configured to determine whether the capacity of the target packet buffer meets a preset condition; and under the condition that the preset condition is met, caching the target message into a target message cache region corresponding to the target cache table.
That is, the relation between the capacity of the target message buffer area and the preset condition is judged, and the target message is buffered to the target message buffer area corresponding to the target buffer table under the condition that the capacity of the target message buffer area meets the preset condition.
Specifically, the determining module is further configured to determine whether the number of second messages cached in the target message cache area is equal to a first preset threshold, where the first preset threshold is used to indicate a maximum number of messages cached in the target message cache area; and under the condition that the number of the second messages cached in the target message cache area is smaller than the first preset threshold value, determining that the capacity of the target message cache area meets the preset condition.
That is, the relationship between the capacity of the target message buffer and the preset condition is determined by: under the condition that the number of second messages cached in the target message cache area is smaller than the first preset threshold value, determining that the capacity of the target message cache area meets a preset condition; and under the condition that the number of the second messages cached in the target message cache area is equal to the first preset threshold value, determining that the capacity of the target message cache area does not meet the preset condition.
In an exemplary embodiment, the buffer module is further configured to determine, if the number of second packets buffered in the target buffer database is equal to the first preset threshold, whether a priority of the second packets buffered in the target buffer database is greater than a priority of the target packet; and discarding the second message and caching the target message under the condition that the priority of the second message is smaller than that of the target message.
Further, under the condition that the number of second messages cached in the target message cache area is equal to the first preset threshold value, namely, under the condition that the capacity of the target message cache area does not meet the preset condition, determining the priority of the second messages and the priority of the target messages, comparing the magnitude relation between the priority of the second messages and the priority of the target messages, and discarding the target messages under the condition that the magnitude relation indicates that the priority of the second messages is greater than the priority of the target messages; and discarding the second message and caching the target message under the condition that the magnitude relation indicates that the priority of the second message is smaller than that of the target message.
Further, the device further includes a processing module, configured to, when it is determined that the message type of the target message is inconsistent with the target message type in the target cache table, and when the message type of the target message is inconsistent with the target message type in the target filter table, normally process the target message.
In an exemplary embodiment, the apparatus further includes a building module configured to determine a number of received monitoring packets before parsing the target filtering table in the filtering table queue; and under the condition that the number of the monitoring messages is larger than the filtering water line, establishing a filtering table corresponding to the monitoring messages, and adding a target filtering table corresponding to the monitoring messages into the filtering table queue.
That is, the number of the received monitoring messages is determined, a corresponding filtering table is built for the monitoring messages when the number of the received monitoring messages is larger than a filtering waterline, the filtering table corresponding to the monitoring messages is added to a filtering table queue, the packet loss priority of the filtering table corresponding to the monitoring messages is set to be smaller than the priority of a second preset threshold, if the filtering table corresponding to the monitoring messages already exists in the filtering table queue, the packet loss priority of the filtering table corresponding to the monitoring messages is increased by one, and if the priority of the filtering table corresponding to the monitoring messages is larger than a third preset threshold, the messages corresponding to the filtering table corresponding to the monitoring messages are all discarded.
In an exemplary embodiment, the establishing module is further configured to establish a buffer table corresponding to the monitoring packet and add the buffer table corresponding to the monitoring packet to the buffer table queue when the number of the monitoring packets is less than the filtering waterline and the number of the monitoring packets is greater than the buffering waterline; the method comprises the steps of obtaining an alarm notification address in a cache table corresponding to a monitoring message, and sending alarm information to a source terminal corresponding to the alarm notification address, wherein the alarm information is used for indicating the source terminal corresponding to the alarm notification address to send the target message in a preset strategy.
Further, when the number of the monitoring messages is smaller than the filtering water line and the number of the monitoring messages is larger than the buffering water line, a buffer table corresponding to the monitoring messages is built, the buffer table corresponding to the monitoring messages is added into the buffer table queue, an alarm notification address in the buffer table corresponding to the monitoring messages is determined, alarm information is sent to a source end corresponding to the alarm notification address through a udp message, after the notified source end receives the alarm information, message flow control is conducted according to the content of the buffer table in the alarm information and a preset strategy, and if the buffer table corresponding to the monitoring messages already exists in the buffer table queue, the alarm information is directly sent to the source end corresponding to the alarm notification address through the udp message.
In an exemplary embodiment, the processing module is further configured to determine, when the number of the monitoring packets is smaller than the buffer waterline, whether a buffer table corresponding to the monitoring packets exists in the buffer table queue; determining the delay receiving time of the buffer table corresponding to the monitoring message under the condition that whether the buffer table corresponding to the monitoring message exists in the buffer table queue; and writing the target message in the target cache data into a network protocol stack corresponding to the target message according to the delay receiving time.
Namely, the delay receiving time of the target cache table is read, a delay task processing work queue is started according to the read delay receiving time, the message in the target message cache region corresponding to the cache table corresponding to the monitoring message is read into the network protocol stack, the cache state of the cache table corresponding to the monitoring message is set to be empty, and the cache table corresponding to the monitoring message is moved out of the cache queue.
Further, under the condition of closing the target filtering table, the packet loss priority of the filtering table corresponding to the monitoring message is adjusted to be lower than the priority of the second preset threshold value, and meanwhile, the filtering table corresponding to the monitoring message is moved out of the filtering table queue. And dynamically adjusting the filtering waterline and the cache waterline according to the utilization rate of the memory or the utilization rate of the central processing unit.
In order to better understand the process of the filtering method of the above-mentioned message, the following describes the flow of the filtering method of the above-mentioned message in combination with the alternative embodiment, but is not used for limiting the technical scheme of the embodiment of the present invention.
An embodiment of the present invention also provides a storage medium including a stored program, wherein the program executes the method of any one of the above.
In an exemplary embodiment, in the present embodiment, the above-described storage medium may be configured to store a computer program for performing the steps of:
S1, under the condition that a terminal receives a target message, analyzing all filtering tables in a filtering table queue of the terminal, wherein the filtering tables comprise: filtering table entries, the filtering table entries comprising: message type, message priority;
s2, traversing the filtering table items of all the filtering tables, and determining whether one or more target filtering tables exist in the filtering table items of all the filtering tables, wherein the target message types of the target filtering tables are consistent with the message types of the target messages;
s3, under the condition that one or more target filtering tables exist in the filtering table items of all the filtering tables, determining whether the priority of a first message in the target filtering table is smaller than the message priority of the target message, and discarding the first message under the condition that the priority of the first message is smaller than the message priority of the target message.
In an exemplary embodiment, in the present embodiment, the storage medium may include, but is not limited to: a usb disk, a Read-Only Memory (ROM), a random access Memory (Random Access Memory RAM), a removable hard disk, a magnetic disk, or an optical disk, or other various media capable of storing a computer program.
An embodiment of the invention also provides an electronic device comprising a memory having stored therein a computer program and a processor arranged to run the computer program to perform the steps of any of the method embodiments described above.
In an exemplary embodiment, the electronic apparatus may further include a transmission device connected to the processor, and an input/output device connected to the processor.
In an exemplary embodiment, in this embodiment, the above-mentioned processor may be configured to execute the following steps by a computer program:
S1, under the condition that a terminal receives a target message, analyzing all filtering tables in a filtering table queue of the terminal, wherein the filtering tables comprise: filtering table entries, the filtering table entries comprising: message type, message priority;
s2, traversing the filtering table items of all the filtering tables, and determining whether one or more target filtering tables exist in the filtering table items of all the filtering tables, wherein the target message types of the target filtering tables are consistent with the message types of the target messages;
s3, under the condition that one or more target filtering tables exist in the filtering table items of all the filtering tables, determining whether the priority of a first message in the target filtering table is smaller than the message priority of the target message, and discarding the first message under the condition that the priority of the first message is smaller than the message priority of the target message.
In an exemplary embodiment, reference may be made to the examples described in the foregoing embodiments and optional implementations, and this embodiment is not repeated herein.
It will be apparent to those skilled in the art that the modules or steps of the invention described above may be implemented in a general purpose computing device, they may be concentrated on a single computing device, or distributed across a network of computing devices, and in one exemplary embodiment they may be implemented in program code executable by a computing device, so that they may be stored in a memory device for execution by a computing device, and in some cases, the steps shown or described may be performed in a different order than what is shown or described, or they may be separately fabricated into individual integrated circuit modules, or a plurality of modules or steps in them may be fabricated into a single integrated circuit module. Thus, the present invention is not limited to any specific combination of hardware and software.
The above description is only of the preferred embodiments of the present invention and is not intended to limit the present invention, but various modifications and variations can be made to the present invention by those skilled in the art. Any modification, equivalent replacement, improvement, etc. made within the principle of the present invention should be included in the protection scope of the present invention.
Claims (8)
1. A method for filtering a message, comprising:
under the condition that a terminal receives a target message, analyzing all filtering tables in a filtering table queue of the terminal, wherein the filtering tables comprise: filtering table entries, the filtering table entries comprising: message type, message priority;
traversing the filtering table items of all the filtering tables, and determining whether one or more target filtering tables exist in the filtering table items of all the filtering tables, wherein the target message types of the target filtering tables are consistent with the message types of the target messages;
Determining whether the priority of a first message in the target filtering table is smaller than the message priority of the target message under the condition that one or more target filtering tables exist in the filtering table items of all the filtering tables, and discarding the first message under the condition that the priority of the first message is smaller than the message priority of the target message;
Under the condition that the terminal receives the target message, before analyzing all the filter tables in the filter table queue of the terminal, the method further comprises the following steps:
Determining the number of the received monitoring messages;
When the number of the monitoring messages is larger than the filtering water line, establishing a filtering table corresponding to the monitoring messages, and adding the filtering table corresponding to the monitoring messages into the filtering table queue;
wherein, after determining the number of the received monitoring messages, the method further comprises:
When the number of the monitoring messages is smaller than the filtering waterline and the number of the monitoring messages is larger than the buffering waterline, establishing a buffering table corresponding to the monitoring messages, and adding the buffering table corresponding to the monitoring messages into a buffering table queue;
Acquiring an alarm notification address in a cache table corresponding to the monitoring message, and sending alarm information to a source terminal corresponding to the alarm notification address, wherein the alarm information is used for indicating the source terminal corresponding to the alarm notification address to send the target message in a preset strategy;
wherein, after determining the number of the received monitoring messages, the method further comprises:
determining whether a cache table corresponding to the monitoring message exists in the cache table queue or not under the condition that the number of the monitoring messages is smaller than the cache waterline;
Determining the delay receiving time of the buffer table corresponding to the monitoring message under the condition that the buffer table corresponding to the monitoring message exists in the buffer table queue;
and writing the target message in the target message buffer area corresponding to the buffer table corresponding to the monitoring message into the network protocol stack corresponding to the target message according to the delay receiving time.
2. The method for filtering a message according to claim 1, wherein after traversing all the filtering table entries of the filtering tables to determine whether one or more target filtering tables exist in the filtering table entries of all the filtering tables, the method further comprises:
and under the condition that one or more target filtering tables are not existed in the filtering table items of all the filtering tables, analyzing all the caching tables in the caching table queue of the terminal, wherein the caching tables comprise: the cache entry includes: message type, priority;
Traversing all cache table entries of the cache tables, and determining whether one or more target cache tables exist in the cache table entries of all the cache tables, wherein the target message types of the target cache tables are consistent with the message types of the target messages;
And under the condition that one or more target cache tables exist in the cache table entries of all the cache tables, caching the target message into a target message cache region corresponding to the target cache table.
3. The method for filtering a message according to claim 2, wherein caching the target message in a target message cache area corresponding to the target cache table includes:
Determining whether the capacity of the target message buffer area meets a preset condition;
And under the condition that the preset condition is met, caching the target message into the target message cache area.
4. The method for filtering a message according to claim 3, wherein determining whether the capacity of the target message buffer meets a preset condition comprises:
Determining whether the number of second messages cached in the target message cache area is equal to a first preset threshold, wherein the first preset threshold is used for indicating the maximum number of messages cached in the target message cache area;
and under the condition that the second message quantity of the target message buffer area is smaller than the first preset threshold value, determining that the capacity of the target message buffer area meets the preset condition.
5. The method for filtering a message according to claim 4, wherein after determining whether the capacity of the target message buffer meets a preset condition, the method further comprises:
determining whether the priority of the second message cached in the target message cache area is greater than the priority of the target message under the condition that the number of the second messages cached in the target message cache area is equal to the first preset threshold;
and discarding the second message and caching the target message under the condition that the priority of the second message is smaller than that of the target message.
6. A message filtering apparatus, comprising:
the analyzing module is configured to analyze all filtering tables in a filtering table queue of the terminal when the terminal receives the target message, where the filtering table includes: filtering table entries, the filtering table entries comprising: message type, message priority;
The determining module is used for traversing the filtering table items of all the filtering tables and determining whether one or more target filtering tables exist in the filtering table items of all the filtering tables, wherein the target message types of the target filtering tables are consistent with the message types of the target messages;
The filtering module is used for determining whether the priority of a first message in the target filtering table is smaller than the message priority of the target message under the condition that one or more target filtering tables exist in the filtering table items of all the filtering tables, and discarding the first message under the condition that the priority of the first message is smaller than the message priority of the target message;
wherein the apparatus further comprises: the establishing module is used for determining the number of the received monitoring messages before analyzing the target filtering table in the filtering table queue; when the number of the monitoring messages is larger than the filtering water line, establishing a filtering table corresponding to the monitoring messages, and adding a target filtering table corresponding to the monitoring messages into the filtering table queue;
The building module is further configured to build a buffer table corresponding to the monitoring message and add the buffer table corresponding to the monitoring message to the buffer table queue when the number of the monitoring messages is smaller than the filtering waterline and the number of the monitoring messages is larger than the buffering waterline; acquiring an alarm notification address in a cache table corresponding to a monitoring message, and sending alarm information to a source terminal corresponding to the alarm notification address, wherein the alarm information is used for indicating the source terminal corresponding to the alarm notification address to send the target message in a preset strategy;
Wherein the apparatus further comprises: the processing module is further used for determining whether a cache table corresponding to the monitoring message exists in the cache table queue or not under the condition that the number of the monitoring messages is smaller than the cache waterline; determining the delay receiving time of the buffer table corresponding to the monitoring message under the condition that the buffer table corresponding to the monitoring message exists in the buffer table queue; and writing the target message in the target cache data into a network protocol stack corresponding to the target message according to the delay receiving time.
7. A computer readable storage medium, characterized in that the computer readable storage medium comprises a stored program, wherein the program when run performs the method of any of the preceding claims 1 to 5.
8. An electronic device comprising a memory and a processor, characterized in that the memory has stored therein a computer program, the processor being arranged to execute the method according to any of the claims 1 to 5 by means of the computer program.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111182608.7A CN113923169B (en) | 2021-10-11 | 2021-10-11 | Message filtering method and device, storage medium and electronic device |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111182608.7A CN113923169B (en) | 2021-10-11 | 2021-10-11 | Message filtering method and device, storage medium and electronic device |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN113923169A CN113923169A (en) | 2022-01-11 |
| CN113923169B true CN113923169B (en) | 2024-10-01 |
Family
ID=79239156
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202111182608.7A Active CN113923169B (en) | 2021-10-11 | 2021-10-11 | Message filtering method and device, storage medium and electronic device |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN113923169B (en) |
Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN111314240A (en) * | 2018-12-12 | 2020-06-19 | 深圳市中兴微电子技术有限公司 | Congestion control method and device, network device and storage medium |
| CN112468413A (en) * | 2020-11-26 | 2021-03-09 | 迈普通信技术股份有限公司 | Message processing method and device, electronic equipment and storage medium |
| CN112804156A (en) * | 2019-11-13 | 2021-05-14 | 深圳市中兴微电子技术有限公司 | Congestion avoidance method and device and computer readable storage medium |
Family Cites Families (15)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| TWI227080B (en) * | 2001-05-31 | 2005-01-21 | Via Tech Inc | Network switch providing congestion control and method thereof |
| US8203956B1 (en) * | 2008-08-28 | 2012-06-19 | Raytheon Bbn Technologies Corp. | Method and apparatus providing a precedence drop quality of service (PDQoS) |
| US8531961B2 (en) * | 2009-06-12 | 2013-09-10 | Cygnus Broadband, Inc. | Systems and methods for prioritization of data for intelligent discard in a communication network |
| CN101753440A (en) * | 2009-12-18 | 2010-06-23 | 华为技术有限公司 | Method, device and wireless network controller for active queue management |
| CN101800699A (en) * | 2010-02-09 | 2010-08-11 | 上海华为技术有限公司 | Method and device for dropping packets |
| CN102025638A (en) * | 2010-12-21 | 2011-04-20 | 福建星网锐捷网络有限公司 | Data transmission method and device based on priority level as well as network equipment |
| CN103036794A (en) * | 2011-10-10 | 2013-04-10 | 华为技术有限公司 | Learning method, device and system of message |
| CN102594691B (en) * | 2012-02-23 | 2019-02-15 | 中兴通讯股份有限公司 | A method and device for processing messages |
| CN104951373B (en) * | 2015-05-28 | 2018-11-27 | 浙江元亨通信技术股份有限公司 | The message queue processing method of scheduling system |
| CN107454014A (en) * | 2016-05-30 | 2017-12-08 | 中兴通讯股份有限公司 | A kind of method and device of Priority Queuing |
| CN107800643B (en) * | 2016-08-29 | 2022-12-09 | 中兴通讯股份有限公司 | Message forwarding method and device |
| CN110493145B (en) * | 2019-08-01 | 2022-06-24 | 新华三大数据技术有限公司 | Caching method and device |
| CN113037640A (en) * | 2019-12-09 | 2021-06-25 | 华为技术有限公司 | Data forwarding method, data caching device and related equipment |
| CN111555974B (en) * | 2020-03-19 | 2023-05-02 | 视联动力信息技术股份有限公司 | Data packet processing method and device, terminal equipment and storage medium |
| CN113206800B (en) * | 2021-03-15 | 2022-05-27 | 新华三信息安全技术有限公司 | Message caching method and device and network equipment |
-
2021
- 2021-10-11 CN CN202111182608.7A patent/CN113923169B/en active Active
Patent Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN111314240A (en) * | 2018-12-12 | 2020-06-19 | 深圳市中兴微电子技术有限公司 | Congestion control method and device, network device and storage medium |
| CN112804156A (en) * | 2019-11-13 | 2021-05-14 | 深圳市中兴微电子技术有限公司 | Congestion avoidance method and device and computer readable storage medium |
| CN112468413A (en) * | 2020-11-26 | 2021-03-09 | 迈普通信技术股份有限公司 | Message processing method and device, electronic equipment and storage medium |
Also Published As
| Publication number | Publication date |
|---|---|
| CN113923169A (en) | 2022-01-11 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN110138678B (en) | Data transmission control method and device, network transmission equipment and storage medium | |
| US9736872B2 (en) | Data transmission method, apparatus, and system | |
| EP1471695A1 (en) | Method for flow control in a communication system | |
| JPH07135512A (en) | Router equipment | |
| CN113438169A (en) | Data scheduling method, electronic equipment and storage medium | |
| EP3952233B1 (en) | Tcp congestion control method, apparatus, terminal, and readable storage medium | |
| CN117579611A (en) | Data transmission method and device, storage medium and electronic device | |
| EP4181479A1 (en) | Method for identifying flow, and apparatus | |
| US12052607B2 (en) | Communication apparatus, communication method, and program | |
| CN113923169B (en) | Message filtering method and device, storage medium and electronic device | |
| CN106792905B (en) | Message processing method and base station | |
| CN106850714B (en) | Cache sharing method and device | |
| CN101577845A (en) | Method and device for processing switching control command | |
| CN110661722B (en) | Flow control method and device | |
| CN112367265B (en) | Reliable data transmission method and device suitable for narrow-band weak connection network | |
| CN103747484B (en) | A kind of RIM flow systems information processing method and service node device | |
| JP6466279B2 (en) | Communication device | |
| CN115604197B (en) | Time-sensitive network message scheduling method, device, equipment and storage medium | |
| CN114268934B (en) | Flow control method, device and storage medium based on BLE GATT | |
| CN115883466A (en) | Switch control method and device, storage medium and electronic device | |
| CN111177196B (en) | Time window aggregation calculation method and device | |
| US20170331754A1 (en) | Control method and network structure | |
| WO2024152699A1 (en) | Cache management method for switching device and switching device | |
| CN108512769B (en) | Method and related equipment for sending and receiving flow table items in software defined network | |
| WO2023072082A1 (en) | Event monitoring method and apparatus, chip, and computer storage 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 |