CN109039810A - A kind of message processing method and device - Google Patents
A kind of message processing method and device Download PDFInfo
- Publication number
- CN109039810A CN109039810A CN201810786379.1A CN201810786379A CN109039810A CN 109039810 A CN109039810 A CN 109039810A CN 201810786379 A CN201810786379 A CN 201810786379A CN 109039810 A CN109039810 A CN 109039810A
- Authority
- CN
- China
- Prior art keywords
- message
- processing module
- service processing
- service
- module
- 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.)
- Pending
Links
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L43/00—Arrangements for monitoring or testing data switching networks
- H04L43/50—Testing arrangements
-
- 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/33—Flow control; Congestion control using forward notification
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L49/00—Packet switching elements
- H04L49/90—Buffering arrangements
- H04L49/9005—Buffering arrangements using dynamic buffer space allocation
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Debugging And Monitoring (AREA)
Abstract
The application provides a kind of message processing method and device, this method and can be applied on the detection module of network intermediary device, it may include: receive the message from the receiving module；Whether the service process performance for detecting the Service Processing Module supports the Service Processing Module to handle the message；If it is not, the Service Processing Module is forbidden to handle the message, and the message is sent to sending module, the message is forwarded by sending module.Using method provided by the present application, can solve because of the packet loss problem that the process performance of Service Processing Module is insufficient and generates.
Description
Technical field
This application involves computer communication field more particularly to a kind of message processing methods and device.
Background technique
Network intermediary device can be assignment be placed in it is between sending ending equipment and receiving device, network can be accessed
Equipment.
After the network intermediary device receives the Business Stream of sending ending equipment sending, specified industry can be carried out to the Business Stream
Business is handled, such as the business such as protocol identification, bandwidth limitation, access control, connection number limitation, traffic statistics for carrying out message.?
After the completion of specified services processing, then the Business Stream is sent to receiving device.
Summary of the invention
In view of this, the application provides a kind of message processing method and device, to solve because of Service Processing Module
The packet loss problem that process performance is insufficient and generates.
Specifically, the application is achieved by the following technical solution:
According to a first aspect of the present application, a kind of message processing method is provided, the method is applied to network intermediary device
On detection module, the network intermediary device further includes Service Processing Module, receiving module and sending module, the method packet
It includes:
Receive the message from the receiving module；
Whether the service process performance for detecting the Service Processing Module supports the Service Processing Module to handle the message；
If it is not, the Service Processing Module is forbidden to handle the message, and the message is sent to sending module, by sending
Message described in module forwards.
Optionally, whether the service process performance of the detection Service Processing Module is supported at the Service Processing Module
Manage the message, comprising:
Detect whether the Service Processing Module has available spatial cache；The spatial cache is for caching the business
Processing module outstanding message；
If so, determining that the service process performance of the Service Processing Module supports the Service Processing Module to handle the message；
If it is not, determining that the service process performance of the Service Processing Module does not support the Service Processing Module to handle the report
Text.
Optionally, the Service Processing Module includes several business processing submodules；Each business processing submodule difference
The type of service of corresponding business is different；
Whether the service process performance of the detection Service Processing Module can support that Service Processing Module processing should
Message, comprising:
Detection is to receive time of reception of the message whether to have received any industry in the forward preset duration of starting point
The back-pressure control message that business processing submodule issues；The back-pressure control message is that any business processing submodule is detecting
This business processing submodule, which is not used to cache, to be issued when the spatial cache of outstanding message；
If receiving, it is determined that the service process performance of the Service Processing Module supports that Service Processing Module processing should
Message；
If not receiving, determine that the service process performance for detecting the Service Processing Module does not support the Service Processing Module
Handle the message.
Optionally, the method also includes:
If detecting, the service process performance of the Service Processing Module of this equipment does not support that Service Processing Module processing should
Message then records the message characteristic of the message received, generates the log for the message and shows user.
Optionally, the method also includes:
If detecting, the service process performance of the Service Processing Module of this equipment supports the Service Processing Module to handle the report
The message is then sent to the Service Processing Module by text, carries out business processing to the message by the Service Processing Module.
According to a second aspect of the present application, a kind of message process device is provided, described device is applied to network intermediary device
On detection module, the network intermediary device further includes Service Processing Module, receiving module and sending module, described device packet
It includes:
Receiving unit, for receiving the message from the receiving module；
Whether detection unit, the service process performance for detecting the Service Processing Module support the Service Processing Module
Handle the message；
Transmission unit for if it is not, the Service Processing Module is forbidden to handle the message, and the message is sent to
Module is sent, the message is forwarded by sending module.
Optionally, the detection unit, specifically for detecting whether the Service Processing Module has available spatial cache；
The spatial cache is for caching the Service Processing Module outstanding message；If so, determining the Service Processing Module
Service process performance supports the Service Processing Module to handle the message；If it is not, determining the business processing of the Service Processing Module
Performance does not support the Service Processing Module to handle the message.
Optionally, the Service Processing Module includes several business processing submodules；Each business processing submodule difference
The type of service of corresponding business is different；
The detection unit, specifically for detecting the time of reception to receive the message as the forward preset duration of starting point
Inside whether have received the back-pressure control message that any business processing submodule issues；The back-pressure control message is any industry
Business processing submodule sending when detecting that this business processing submodule is not used to cache the spatial cache of outstanding message
's；If receiving, it is determined that the service process performance of the Service Processing Module supports the Service Processing Module to handle the message；
If not receiving, determine that the service process performance for detecting the Service Processing Module does not support the Service Processing Module to handle the report
Text.
Optionally, described device further include:
Generation unit, if the service process performance of the Service Processing Module for detecting this equipment is not supported at the business
The resume module message is managed, then records the message characteristic of the message received, generates the log for the message and displaying
To user.
Optionally, the transmission unit, if being also used to detect the service process performance of the Service Processing Module of this equipment
It supports the Service Processing Module to handle the message, then the message is sent to the Service Processing Module, by the business
It manages module and business processing is carried out to the message.
The application provides a kind of message processing method, by increasing in the network intermediary device with service processing function
Detection module.After receiving message, whether the service process performance that detection module can detect Service Processing Module is supported to this
Message carries out business processing, when detection module detects that the service process performance of Service Processing Module is not enough to support to receiving
Message carry out business processing when, which can be sent to sending module by detection module, be transmitted to receiving end by sending module
Equipment.
Since Service Processing Module is not enough to support to receiving in the service process performance for detecting Service Processing Module
Message carry out business processing, not by the message be sent to Service Processing Module (Service Processing Module in industry performance deficiency, meeting
By packet loss), but the message is sent to by receiving device by sending module, it is possible to it prevents because of business processing
The packet loss problem that the process performance of module is insufficient and generates.
Detailed description of the invention
Fig. 1 is a kind of schematic diagram of traditional audit equipment shown in one exemplary embodiment of the application；
Fig. 2 is a kind of schematic diagram of audit device shown in one exemplary embodiment of the application；
Fig. 3 is a kind of flow chart of message processing method shown in one exemplary embodiment of the application；
Fig. 4 is a kind of schematic diagram of message processing method shown in one exemplary embodiment of the application；
Fig. 5 is a kind of hardware structure diagram of network intermediary device shown in one exemplary embodiment of the application；
Fig. 6 is a kind of device figure of Message processing shown in one exemplary embodiment of the application.
Specific embodiment
Example embodiments are described in detail here, and the example is illustrated in the accompanying drawings.Following description is related to
When attached drawing, unless otherwise indicated, the same numbers in different drawings indicate the same or similar elements.Following exemplary embodiment
Described in embodiment do not represent all embodiments consistent with the application.On the contrary, they be only with it is such as appended
The example of the consistent device and method of some aspects be described in detail in claims, the application.
It is only to be not intended to be limiting the application merely for for the purpose of describing particular embodiments in term used in this application.
It is also intended in the application and the "an" of singular used in the attached claims, " described " and "the" including majority
Form, unless the context clearly indicates other meaning.It is also understood that term "and/or" used herein refers to and wraps
It may be combined containing one or more associated any or all of project listed.
It will be appreciated that though various information, but this may be described using term first, second, third, etc. in the application
A little information should not necessarily be limited by these terms.These terms are only used to for same type of information being distinguished from each other out.For example, not departing from
In the case where the application range, the first information can also be referred to as the second information, and similarly, the second information can also be referred to as
One information.Depending on context, word as used in this " if " can be construed to " ... when " or " when ...
When " or " in response to determination ".
It should be noted that herein described network intermediary device, can be arranged in sending ending equipment and receiving end is set
The equipment for carrying out specified services processing between standby.Here the audit that network intermediary device can be progress network auditing system is set
It is standby, it is also possible to that other forwarding devices etc. of other business processings can be carried out.Here only to service processing function
Network intermediary device is illustratively illustrated, is not carried out to it specifically defined.
Below by taking network intermediary device is audit device as an example, message processing method provided by the present application is carried out in detail
Illustrate, for other kinds of network intermediary device, message processing method is similar with the audit device, and which is not described herein again.
Audit device, also referred to as transparent forwarding equipment, the mode which E-Packets are using interface pair
Form E-Packet.For example, be pre-configured with interface on audit device to table, the interface is to including several interfaces pair in table
List item, interface is to the corresponding relationship for having recorded incoming interface and outgoing interface in list item.
For example, the interface of audit device is the port A to the incoming interface that list item records, outgoing interface is the corresponding relationship of the port B.
This interface makes after audit device receives message from the port A list item, can send message from the port B.
It is a kind of schematic diagram of traditional audit equipment shown in one exemplary embodiment of the application referring to Fig. 1, Fig. 1.
It generally may include three modules, respectively receiving module 101, business processing in Fig. 1, on usual audit device
Module 102 and sending module 103.The traditional Message processing mode of audit device is: receiving module 101 receives sending ending equipment hair
Then the message sent extracts the characteristic information of the message received.The characteristic information of the message can with the five-tuple of message, connect
Mouth, VLAN mark etc..
Then, the message characteristic information extracted and the message received can be sent to audit device by receiving module 101
Service Processing Module 102.Service Processing Module 102 can the characteristic information based on the message to message carry out business processing.
For example, audit device can the characteristic information based on the message to message carry out protocol identification, bandwidth limitation, access control, company
Connect the business such as number limitation, traffic statistics analysis.After Service Processing Module 102 carries out business processing to message, business processing mould
Message can be sent to the sending module 103 of audit device by block 102, search the incoming interface with the message by sending module 103
The message is sent list item according to the interface searched by the interface matched to the outgoing interface recorded in list item.
But when the service process performance of the Service Processing Module of audit device 102 is not enough to support to carry out the message
When processing, Service Processing Module 102 can be by packet loss.This allows for sending ending equipment and is sent to the message of receiving device by industry
Processing module 102 of being engaged in abandons, so that receiving device can not receive the message, causes packet loss.
In view of this, the application provides a kind of message processing method, by increasing detection module in audit device.It is connecing
After receiving message, whether the service process performance that detection module can detect Service Processing Module is supported to carry out at business the message
Reason, when detection module detects that the service process performance of Service Processing Module is not enough to support to carry out business to the message received
When processing, which can be sent to sending module by detection module, be transmitted to receiving device by sending module.
Since Service Processing Module is not enough to support to receiving in the service process performance for detecting Service Processing Module
Message carry out business processing, not by the message be sent to Service Processing Module (Service Processing Module in industry performance deficiency, meeting
By packet loss), but the message is sent to by receiving device by sending module, it is possible to it prevents because of business processing
The packet loss problem that the process performance of module is insufficient and generates.
Referring to fig. 2, Fig. 2 is a kind of schematic diagram of audit device shown in one exemplary embodiment of the application.This equipment is
Traditional audit device increases detection module, which is specifically used for the service process performance of detection Service Processing Module
The Service Processing Module whether can be supported to handle the message received.
As shown in Fig. 2, the audit device of the application include four modules, respectively receiving module 201, detection module 202,
Service Processing Module 203 and sending module 204.
Wherein, receiving module 201 is mainly used for receiving the message etc. that sending ending equipment is sent.
Whether detection module 202 can be supported at the business mainly for detection of the service process performance of Service Processing Module
The message that reason resume module receives, if so, message is sent to Service Processing Module 203, it is right by Service Processing Module 203
The message carries out business processing and is forwarded the message by the sending module 204 if it is not, message is then sent to sending module 204
To receiving device.
Service Processing Module 203 is mainly used for carrying out the message received business processing, for example carries out agreement to message
The business processings such as identification, bandwidth limitation, access control, connection number limitation, traffic statistics.
Sending module 204 is mainly used for message to be sent being sent to receiving end indicated by the destination address of message
Equipment.
It is a kind of flow chart of message processing method shown in one exemplary embodiment of the application referring to Fig. 3, Fig. 3.The report
Literary processing method can be applicable on the detection module of audit device, it may include step as follows.
Step 301: detection module can receive the message from the receiving module.
The receiving module of audit device can receive the message from sending ending equipment.The receiving module of audit device will connect
The message received is sent to the detection module of audit device.
Step 302: whether the service process performance that detection module can detect the Service Processing Module is supported at the business
Manage the resume module message.
In an optional implementation manner, ordinary business practice module is corresponding with spatial cache, which is mainly used for
Cache outstanding message.After Service Processing Module is received from the message of receiving module, Service Processing Module is not
It is business processing directly to be carried out to the message, but message is stored in the corresponding spatial cache of the Service Processing Module.When
After Service Processing Module has handled currently processed message, industry is carried out in the outstanding message for obtaining caching from spatial cache
Business processing, then discharges the spatial cache for caching the clear text.
Whether supported at the Service Processing Module in the service process performance that detection module detects the Service Processing Module
When managing the message, detection module can detect whether the Service Processing Module has available spatial cache.If the Service Processing Module
There are available spatial caches, it is determined that the service process performance of the Service Processing Module supports that Service Processing Module processing should
Message.If available spatial cache is not present in the Service Processing Module, it is determined that the business processing of the Service Processing Module
The Service Processing Module can not be supported to handle the message.
In another optional implementation, which includes several business processing submodules, if should
A dry business processing submodule respectively corresponds different business.
In order to adapt to the business processing of pipeline system, business processing submodule can be sequentially connected with.When any business processing
When module detects that this business processing submodule is not used to cache the available cache memory space of clear text, at any business
It manages submodule and sends back-pressure control message to previous business processing submodule.The back-pressure control message is used to indicate any business
The service process performance of processing submodule is not enough to that any business processing submodule is supported to handle the message received.
After previous business processing submodule receives the back-pressure control message, previous business processing submodule can be anti-by this
Pressure control message is sent to more preceding business processing submodule, and so on, which is eventually sent to inspection
Survey module.
After detection module is received from the message of receiving module, detection module can be to receive the reception of the message
Moment is that starting point traces forward preset duration, and whether detection has received any business processing submodule in the preset duration sends
Back-pressure control message.
If having received the back-pressure control message that any business processing submodule is sent in the preset duration, it is determined that should
The service process performance of Service Processing Module does not support the Service Processing Module to handle the message.If in the preset duration not
Receive the back-pressure control message that any business processing submodule is sent, it is determined that the service process performance branch of the Service Processing Module
It holds the Service Processing Module and handles the message.
Wherein, preset duration can set the business processing speed of message according to Service Processing Module, be here
Preset duration is illustratively illustrated, the preset duration is not carried out specifically defined.
It is a kind of schematic diagram of message processing method shown in one exemplary embodiment of the application for example, with reference to Fig. 4, Fig. 4.
Assuming that business module include 4 business submodules, respectively business processing submodule 1, business processing submodule 2,
Business processing submodule 3 and business processing submodule 4.Assuming that business processing submodule 1 to business processing submodule 4 respectively corresponds
Business be protocol identification, bandwidth limitation, access control, traffic statistics.
Protocol identification, bandwidth limitation, access control and flow are successively carried out to message since audit device is configured in advance
The business of statistics.So can be by business processing submodule 1, business processing submodule 2, business processing submodule 3 and business processing
Submodule 4 is connected.
When business processing submodule 3 detects the business processing submodule 3 without available spatial cache, business processing
Submodule 3 can send back-pressure control message to business processing submodule 2.Business processing submodule 2 can be by the back-pressure control message
It is sent to business processing submodule 1, which can be sent to detection module by business processing submodule 1.
Detection module is recordable at the time of receive the back-pressure control message, it is assumed that at the time of receiving back-pressure control message
For 12:00:00 (indicating at 12 points 0 minute and 0 second)
Assuming that preset duration is 30 seconds.
Assuming that the time of reception that detection module receives the message from receiving module is that 12:00:03 (indicates 12: 0
Divide 3 seconds), then whether detection module can detecte has received back-pressure control between period [11:59:57-12:00:03]
Message, due to having received back-pressure control message during this period of time, it is determined that the service process performance of the Service Processing Module
It is not enough to that Service Processing Module is supported to handle the message.
Step 303: if the service process performance of Service Processing Module is that the Service Processing Module is not supported to handle the message,
Detection module forbids the Service Processing Module to handle the message, and the message is sent to sending module, by sending module
Forward the message.
If detection module detects that the service process performance of Service Processing Module does not support that Service Processing Module processing should
Message can be then sent to sending module by message, and the destination address that the message is forwarded to the message by sending module is corresponding
Receiving device.
Detection module also can record the message characteristic information of the message, such as the five-tuple information of message, VLAN mark etc.
Deng, and the message characteristic information based on record generates the log for being directed to the message.Then the log can be showed user, to mention
Show that user's audit device has carried out transparent transmission to which message and (do not carried out business processing to message, directly turn to message
Hair).
Step 304: if the service process performance of Service Processing Module is that the Service Processing Module is supported to handle the message, examining
It surveys module and the message is sent to the Service Processing Module, business processing is carried out to the message by the Service Processing Module.
Seen from the above description, by increasing detection module in audit device.After receiving message, detection module can
Whether the service process performance of detection Service Processing Module is supported to carry out business processing to the message, when detection module detects industry
When the service process performance of business processing module is not enough to support to carry out business processing to the message received, detection module can should
Message is sent to sending module, is transmitted to receiving device by sending module.
Since Service Processing Module is not enough to support to receiving in the service process performance for detecting Service Processing Module
Message carry out business processing, not by the message be sent to Service Processing Module (Service Processing Module in industry performance deficiency, meeting
By packet loss), but the message is sent to by receiving device by sending module, it is possible to it prevents because of business processing
The packet loss problem that the process performance of module is insufficient and generates.
Referring to Fig. 5, the disclosure also provides a kind of hardware architecture diagram of network intermediary device with service processing function, should
Network intermediary device includes: communication interface 501, processor 502, memory 503 and bus 504；Wherein, communication interface 501, place
Reason device 502 and memory 503 pass through bus 504 and complete mutual communication.
Wherein, processor 502 can be a CPU, and memory 503 can be nonvolatile memory (non-
Volatile memory), and the logical order of Message processing is stored in memory 5403, processor 502 can be executed and be deposited
The logical order of the Message processing stored in reservoir 503.
Machine readable storage medium 503 referred to herein can be any electronics, magnetism, optics or other physical stores
Device may include or store information, such as executable instruction, data, etc..For example, machine readable storage medium may is that
RAM (Radom Access Memory, random access memory), volatile memory, nonvolatile memory, flash memory, storage are driven
Dynamic device (such as hard disk drive), solid state hard disk, any kind of storage dish (such as CD, dvd) or similar storage are situated between
Matter or their combination.
So far, hardware configuration description shown in fig. 5 is completed.
It is a kind of device figure of Message processing shown in one exemplary embodiment of the application referring to Fig. 6, Fig. 6.The device can
It applies on the detection module of the network intermediary device with service processing function, it may include unit as follows.
Receiving unit 601, for receiving the message from the receiving module；
Whether detection unit 602, the service process performance for detecting the Service Processing Module support the business processing
The resume module message；
Transmission unit 603 for if it is not, the Service Processing Module is forbidden to handle the message, and the message is sent
To sending module, the message is forwarded by sending module.
Optionally, the detection unit 602, specifically for detecting whether the Service Processing Module has available caching empty
Between；The spatial cache is for caching the Service Processing Module outstanding message；If so, determining the Service Processing Module
Service process performance support the Service Processing Module to handle the message；If it is not, determining at the business of the Service Processing Module
Rationality can not support the Service Processing Module to handle the message.
Optionally, the Service Processing Module includes several business processing submodules；Each business processing submodule difference
The type of service of corresponding business is different；
The detection unit 602, it is forward default as starting point specifically for detecting the time of reception to receive the message
Whether back-pressure control message that any business processing submodule issue is had received in duration；The back-pressure control message is this
One business processing submodule is when detecting that this business processing submodule is not used to cache the spatial cache of outstanding message
It issues；If receiving, it is determined that the service process performance of the Service Processing Module supports that Service Processing Module processing should
Message；If not receiving, determine that the service process performance for detecting the Service Processing Module is not supported at the Service Processing Module
Manage the message.
Optionally, described device further include:
Generation unit 604, if the service process performance of the Service Processing Module for detecting this equipment does not support the industry
Business processing module handles the message, then records the message characteristic of the message received, and generation is directed to the log of the message simultaneously
Show user.
Optionally, the transmission unit 603, if being also used to detect the business processing of the Service Processing Module of this equipment
The Service Processing Module can be supported to handle the message, then the message is sent to the Service Processing Module, by the business
Processing module carries out business processing to the message.
The function of each unit and the realization process of effect are specifically detailed in the above method and correspond to step in above-mentioned apparatus
Realization process, details are not described herein.
For device embodiment, since it corresponds essentially to embodiment of the method, so related place is referring to method reality
Apply the part explanation of example.The apparatus embodiments described above are merely exemplary, wherein described be used as separation unit
The unit of explanation may or may not be physically separated, and component shown as a unit can be or can also be with
It is not physical unit, it can it is in one place, or may be distributed over multiple network units.It can be according to actual
The purpose for needing to select some or all of the modules therein to realize application scheme.Those of ordinary skill in the art are not paying
Out in the case where creative work, it can understand and implement.
The foregoing is merely the preferred embodiments of the application, not to limit the application, all essences in the application
Within mind and principle, any modification, equivalent substitution, improvement and etc. done be should be included within the scope of the application protection.
Claims (10)
1. a kind of message processing method, which is characterized in that the method is applied to the detection module on network intermediary device, described
Network intermediary device further includes Service Processing Module, receiving module and sending module, which comprises
Receive the message from the receiving module；
Whether the service process performance for detecting the Service Processing Module supports the Service Processing Module to handle the message；
If it is not, the Service Processing Module is forbidden to handle the message, and the message is sent to sending module, by sending module
Forward the message.
2. the method according to claim 1, wherein the business processing of the detection Service Processing Module
The Service Processing Module whether can be supported to handle the message, comprising:
Detect whether the Service Processing Module has available spatial cache；The spatial cache is for caching the business processing
Module outstanding message；
If so, determining that the service process performance of the Service Processing Module supports the Service Processing Module to handle the message；
If it is not, determining that the service process performance of the Service Processing Module does not support the Service Processing Module to handle the message.
3. the method according to claim 1, wherein the Service Processing Module includes several business processings
Module；The type of service of the corresponding business of each business processing submodule is different；
Whether the service process performance of the detection Service Processing Module can support the Service Processing Module to handle the message,
Include:
Detection is to receive time of reception of the message whether to have received at any business in the forward preset duration of starting point
Manage the back-pressure control message that submodule issues；The back-pressure control message is that any business processing submodule is detecting this industry
Business processing submodule, which is not used to cache, to be issued when the spatial cache of outstanding message；
If receiving, it is determined that the service process performance of the Service Processing Module supports the Service Processing Module to handle the report
Text；
If not receiving, determine that the service process performance for detecting the Service Processing Module does not support the Service Processing Module to handle
The message.
4. the method according to claim 1, wherein the method also includes:
If detecting, the service process performance of the Service Processing Module of this equipment does not support the Service Processing Module to handle the message,
The message characteristic of the message received is then recorded, the log for the message is generated and shows user.
5. the method according to claim 1, wherein the method also includes:
If detecting, the service process performance of the Service Processing Module of this equipment supports the Service Processing Module to handle the message,
The message is sent to the Service Processing Module, business processing is carried out to the message by the Service Processing Module.
6. a kind of message process device, which is characterized in that described device is applied to set among the network with service processing function
Standby upper detection module, the network intermediary device further includes Service Processing Module, receiving module and sending module, described device
Include:
Receiving unit, for receiving the message from the receiving module；
Whether detection unit, the service process performance for detecting the Service Processing Module support the Service Processing Module to handle
The message；
The message for if it is not, the Service Processing Module is forbidden to handle the message, and is sent to transmission mould by transmission unit
Block forwards the message by sending module.
7. device according to claim 6, which is characterized in that the detection unit is specifically used for detecting at the business
Whether reason module has available spatial cache；The spatial cache is for caching the Service Processing Module outstanding message；
If so, determining that the service process performance of the Service Processing Module supports the Service Processing Module to handle the message；If it is not, determining
The service process performance of the Service Processing Module does not support the Service Processing Module to handle the message.
8. device according to claim 6, which is characterized in that the Service Processing Module includes several business processings
Module；The type of service of the corresponding business of each business processing submodule is different；
The detection unit, specifically for detecting the time of reception to receive the message to be in the forward preset duration of starting point
The no back-pressure control message for having received any business processing submodule and issuing；The back-pressure control message is at any business
Reason submodule is issued when detecting that this business processing submodule is not used to cache the spatial cache of outstanding message；If
It receives, it is determined that the service process performance of the Service Processing Module supports the Service Processing Module to handle the message；If not
It receives, determines that the service process performance for detecting the Service Processing Module does not support the Service Processing Module to handle the message.
9. device according to claim 6, which is characterized in that described device further include:
Generation unit, if the service process performance of the Service Processing Module for detecting this equipment does not support the business processing mould
Block handles the message, then records the message characteristic of the message received, generates the log for the message and shows use
Family.
10. device according to claim 6, which is characterized in that the transmission unit, if being also used to detect this equipment
The service process performance of Service Processing Module supports the Service Processing Module to handle the message, then is sent to the message described
Service Processing Module carries out business processing to the message by the Service Processing Module.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201810786379.1A CN109039810A (en) | 2018-07-17 | 2018-07-17 | A kind of message processing method and device |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201810786379.1A CN109039810A (en) | 2018-07-17 | 2018-07-17 | A kind of message processing method and device |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN109039810A true CN109039810A (en) | 2018-12-18 |
Family
ID=64643075
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201810786379.1A Pending CN109039810A (en) | 2018-07-17 | 2018-07-17 | A kind of message processing method and device |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN109039810A (en) |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112995119A (en) * | 2019-12-18 | 2021-06-18 | 北京国双科技有限公司 | Data monitoring method and device |
Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN1859308A (en) * | 2006-03-18 | 2006-11-08 | 华为技术有限公司 | Method for recombining IP message |
| CN101304345A (en) * | 2008-06-26 | 2008-11-12 | 北京邮电大学 | Intrusive measurement node and its measurement method for self-organizing network |
| CN103532848A (en) * | 2013-10-25 | 2014-01-22 | 迈普通信技术股份有限公司 | Virtual private local area network service message processing method and system |
| CN107783721A (en) * | 2016-08-25 | 2018-03-09 | 华为技术有限公司 | The processing method and physical machine of a kind of data |
-
2018
- 2018-07-17 CN CN201810786379.1A patent/CN109039810A/en active Pending
Patent Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN1859308A (en) * | 2006-03-18 | 2006-11-08 | 华为技术有限公司 | Method for recombining IP message |
| CN101304345A (en) * | 2008-06-26 | 2008-11-12 | 北京邮电大学 | Intrusive measurement node and its measurement method for self-organizing network |
| CN103532848A (en) * | 2013-10-25 | 2014-01-22 | 迈普通信技术股份有限公司 | Virtual private local area network service message processing method and system |
| CN107783721A (en) * | 2016-08-25 | 2018-03-09 | 华为技术有限公司 | The processing method and physical machine of a kind of data |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112995119A (en) * | 2019-12-18 | 2021-06-18 | 北京国双科技有限公司 | Data monitoring method and device |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| FR2517442A1 (en) | INTERRUPTION DEVICE FOR MULTITRATING SYSTEM, METHOD FOR CONTROLLING THE SAME, AND SYSTEM FOR IMPLEMENTING SAME | |
| CN107391271A (en) | A kind of delayed tasks triggering method and device based on Message Queuing system | |
| CA2318963A1 (en) | Method and apparatus for media data transmission | |
| CN110532251B (en) | Deduplication method for big data of seismic network based on Bloom filter algorithm | |
| US11442814B2 (en) | Variable number and size of put operations for storage backup | |
| IL191329A (en) | Sending routing data based on times that servers joined a cluster | |
| FR2737029A1 (en) | INTERFACE DEVICE BETWEEN A COMPUTER WITH REDUNDANT ARCHITECTURE AND A COMMUNICATION MEANS | |
| CN110830442A (en) | Message processing method, device and gateway | |
| US20140286339A1 (en) | Hardware Acceleration for Routing Programs | |
| CN113469669A (en) | Method for querying client information across instances, related device and computer storage medium | |
| US10223435B2 (en) | Data transfer between multiple databases | |
| CN109726575A (en) | A kind of data ciphering method and device | |
| CN102129619A (en) | Service data processing method and system based on cloud storage | |
| CN109039810A (en) | A kind of message processing method and device | |
| CN101997774A (en) | Recoding method for forwarding time delay and router | |
| CN101753456B (en) | Method and system for detecting flow of peer-to-peer network | |
| CN106470171B (en) | The delivery method and device of multicast forwarding list item | |
| EP1788760A1 (en) | System and method for static packet data flow routing in an interconnection network | |
| EP0812084A1 (en) | Device for communication between a plurality of functional modules within a local unit and an external ethernet bus | |
| CN110932982B (en) | Maintenance method and device of hardware routing table | |
| CN110086727B (en) | Load sharing method and device between CGN boards | |
| CN110149365B (en) | Service adaptation method, device, system and computer readable medium | |
| JP2005354233A5 (en) | ||
| FR3057127A1 (en) | PROCESSOR ADAPTED FOR ETHERNET NETWORK DETERMINISTIC SWITCH | |
| CN101827068A (en) | Business scenario reduction method and device |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| RJ01 | Rejection of invention patent application after publication |
Application publication date: 20181218 |
|
| RJ01 | Rejection of invention patent application after publication |