CN112565088B - Message processing method, system, apparatus and network device - Google Patents

Abstract

The embodiment of the invention relates to the field of communication, and discloses a message processing method, a system, a device and network equipment. The message processing method comprises the following steps: receiving a message packaged according to a predefined structure, wherein the message packaged according to the predefined structure comprises an identification frame, a service frame, a blank frame and a content frame; checking whether the message contains a routing frame or not, and determining a corresponding routing strategy according to a checking result so as to process the message; the identification frame comprises a service type which can be processed by the source node and a distinguishing code of the source node, and is used for representing the identity source of the message; the service frame comprises a service type and is used for representing the service requested by the message; the content frame includes the message content. The method is applied to the message transmission process, and the purpose of improving the message timeliness is achieved.

Description

Message processing method, system, apparatus and network device

technical field

Embodiments of the present invention relate to the field of communications, and in particular, to a message processing method, system, apparatus, and network device.

Background technique

As an important part of communication middleware, message service provides information synchronization and transmission guarantee for application server. Most of the current message services use IP addresses as network connection and processing identifiers. The client establishes network connections with different services according to different business requirements. After the message service receives the message, it forwards to the business service layer by layer according to the IP address. And then deal with the business.

However, the existing communication scenarios are becoming more and more complex, and the microservices make the functions carried by each service more and more single, resulting in a sharp increase in the number of services. After the message service receives the message, it can reach the business service only after it is forwarded layer by layer, which increases the delivery path and reduces the timeliness of the message.

SUMMARY OF THE INVENTION

The purpose of the embodiments of the present invention is to provide a message processing method, system, apparatus and network device, which can improve the timeliness of message transmission.

In order to solve the above technical problem, an embodiment of the present invention provides a message processing method, comprising: receiving a message encapsulated according to a predefined structure, wherein the message encapsulated according to the predefined structure includes an identification frame, a service frame, Blank frame, content frame; check whether the message contains a routing frame, and determine a corresponding routing strategy according to the inspection result to process the message; wherein, the identification frame includes the service type that the source node can handle and the source node's distinguishing code , which is used to represent the identity source of the message; the service frame contains the service type, which is used to represent the service requested by the message; the content frame contains the content of the message.

Embodiments of the present invention also provide a message processing system, including:

a sending node, configured to send a message encapsulated according to a predefined structure to a receiving node, wherein the message encapsulated according to the predefined structure includes an identification frame, a service frame, a blank frame, and a content frame;

a receiving node, configured to receive a message encapsulated according to a predefined structure, check whether the message contains a routing frame, and determine a corresponding routing policy according to the inspection result to process the message;

Wherein, the sending node and the receiving node each carry an identification frame, and the identification frame includes the service type that the sending node or the receiving node can handle and the distinguishing code of the sending node or the receiving node.

Embodiments of the present invention also provide a message processing device, including:

The message layer is used to encapsulate the message according to the predefined structure, including the message address, message separation and message content;

The packaging layer is used to shield the differences between different communication mechanisms;

The transport layer is used to transmit messages encapsulated in a predefined structure, including intra-process communication and inter-process communication.

Embodiments of the present invention also provide a network device, including:

at least one processor; and,

a memory communicatively coupled to the at least one processor; wherein,

The memory stores instructions executable by the at least one processor, the instructions being executed by the at least one processor to enable the at least one processor to perform the message processing method described above.

Compared with the prior art, the embodiment of the present invention encapsulates a message according to a predefined structure, so that the message contains an identification frame, a service frame, a blank frame and a content frame, and the current node determines the corresponding route according to whether the message contains enough routing frames. The strategy is to complete the processing of the message, reduce the transmission path of the message, and improve the timeliness of the message.

In addition, in the message processing method provided by the embodiment of the present invention, the checking whether the message contains a routing frame, and determining a corresponding routing policy to process the message according to the checking result, includes: checking whether there is a routing frame in the message; If there is no routing frame in the message, the blind routing rule is used to process the message; if there is a routing frame in the message, the message is processed using the directional routing rule, wherein the routing frame has the same content as the identification frame. The routing frame in the message is a non-essential frame. According to whether the message contains a routing frame, it is determined whether to use the blind routing rule to process the message or the directional routing rule to process the message, which realizes message directional transmission and non-directional transmission, and improves the timeliness of message transmission.

In addition, in the message processing method provided by the embodiment of the present invention, the processing of the message using a blind routing rule includes: saving the identification frame in the message, and updating the identification frame in the message to the identification frame preset by the current node. The current node checks whether the service type of the service frame in the message is consistent with the service type of the identification frame preset by the node; if consistent, the current node obtains the message content in the message content frame to process the service, A routing frame is added to the message, and the original identification frame of the message is set in the routing frame as the address of the next node, the result of the processing service is written into the message content frame, and sent to the next node After receiving the message, the current node judges whether the service can be processed according to the service type. If it cannot be processed, the default routing node is selected for forwarding, which reduces the transmission path of the message and improves the processing efficiency of the message.

In addition, in the message processing method provided by the embodiment of the present invention, the processing of the message using a directional routing rule includes: saving the identification frame in the message, and updating the identification frame in the message to the identification frame preset by the current node. ; The current node obtains a routing frame in the message according to the reverse order of the encapsulated routing frame order; Check whether the service type in the routing frame is consistent with the service type of the identification frame preset by the current node, wherein, if are consistent, the current node obtains the message content in the message content frame to process the service, adds a new routing frame to the message, and sets the original identification frame of the message in the new routing frame as the address of the next node , write the result of processing the service into the message content frame, and send it to the next node; if inconsistent, check whether there is a next routing frame in the message. The transmission processing of the message is realized according to the routing paths specified by all the routing frames in the message, which improves the transmission efficiency and timeliness of the message.

In addition, the message processing system provided by the embodiment of the present invention includes: the node records the node that establishes the channel with itself; the node extracts the service type of the self-identification frame and the service type of the identification frame of the node that establishes the channel with itself; The above node classifies all nodes according to business types and saves them as business and node relationship records. All nodes in the message processing system will record the nodes that establish a channel with the current node, and classify and save each node and the business types it can handle, which is convenient for message routing and the addition of new nodes.

In addition, the message processing system provided by the embodiment of the present invention includes: when a new node accesses, the new node actively sends a registration message to the current node, wherein the registration message is encapsulated according to a predefined structure and includes an identification frame; The current node acquires the identification frame of the new node registration message, and updates service and node relationship records. After the new node is connected to the message processing system, the current node can route messages to the new node. The current node is equivalent to having the business processing capability of the new node, thus realizing the self-discovery of services and expanding the business of the current node. ability.

Description of drawings

One or more embodiments are exemplified by the pictures in the corresponding drawings, and these exemplifications do not constitute limitations of the embodiments, and elements with the same reference numerals in the drawings are denoted as similar elements, Unless otherwise stated, the figures in the accompanying drawings do not constitute a scale limitation.

1 is a flowchart of a message processing method provided by a first embodiment of the present invention;

2 is a flowchart of a message processing method provided by a second embodiment of the present invention;

3 is a flowchart of step 202 in the message processing method provided by the second embodiment of the present invention shown in FIG. 2;

FIG. 4 is a flowchart of step 203 in the message processing method provided by the second embodiment of the present invention shown in FIG. 2;

5 is a flowchart of a message processing system provided by a third embodiment of the present invention;

6 is a flowchart of a message processing apparatus provided by a fourth embodiment of the present invention;

FIG. 7 is a schematic structural diagram of a network device provided by a seventh embodiment of the present invention.

Detailed ways

In order to make the objectives, technical solutions and advantages of the embodiments of the present invention clearer, the various embodiments of the present invention will be described in detail below with reference to the accompanying drawings. However, those of ordinary skill in the art can appreciate that, in the various embodiments of the present invention, many technical details are set forth in order for the reader to better understand the present application. However, even without these technical details and various changes and modifications based on the following embodiments, the technical solutions claimed in the present application can be realized. The following divisions of the various embodiments are for the convenience of description, and should not constitute any limitation on the specific implementation of the present invention, and the various embodiments may be combined with each other and referred to each other on the premise of not contradicting each other.

The first embodiment of the present invention relates to a message processing method, and the specific process is shown in FIG. 1 , including:

Step 101: Receive a message encapsulated according to a predefined structure, wherein the message encapsulated according to the predefined structure includes an identification frame, a service frame, a blank frame, and a content frame.

In this embodiment, the identification frame is a necessary frame, which is the first frame of the message, and includes the service type that the source node can handle and the discrimination code of the source node, which is used to indicate the identity source of the message, and the identification frame is represented as IDCode=s. Service type. Distinguishing code; the service frame is a required frame, which is the second frame of the message, including the service type, which is used to indicate the service to be requested by the message, and the service frame is expressed as BizCode=s. Service type; the content frame is a required frame, including The message content can be processed in any encoding format accepted by both the sending and receiving nodes, such as plain text, json, etc. Of course, the above are only specific examples, and the encoding format can be used in actual use. Any existing encoding method is used to perform operations, which will not be repeated here.

Step 102 , check whether the message contains a routing frame, and determine a corresponding routing policy according to the check result to process the message.

Specifically, the routing frame is a non-essential frame, indicating the routing path specified by the message, and the content of the frame is the same as the content of the identification frame. There may be no routing frame in a message, or there may be one or more routing frames. If the third frame is not a blank frame, it is a routing frame, and routing will continue until the end of a blank frame. The blank frame is used to separate the message address and the message content. Above the blank frame is the routing frame, and below the blank frame is the content frame.

Compared with the prior art, the embodiment of the present invention encapsulates a message according to a predefined structure, so that the message contains an identification frame, a service frame, a blank frame and a content frame, and the current node determines the corresponding route according to whether the message contains enough routing frames. The strategy is to complete the processing of the message, reduce the transmission path of the message, and improve the timeliness of the message.

The second embodiment of the present invention relates to a message processing method, which is basically the same as the message processing method provided in the first embodiment, except that, as shown in FIG. 2 , step 102 includes:

Step 201, check whether the message contains a routing frame.

Specifically, if there is no routing frame in the message, step 202 is executed; if there is a routing frame in the message, step 203 is executed.

Step 202, using blind routing rules to process messages.

Specifically, as shown in FIG. 3, step 202 includes:

In step 301, the identification frame in the message is saved, and the identification frame in the update message is the identification frame preset by the current node.

In this embodiment, the identification frame preset by the current node is when the node is deployed in the network, and the identification frame is set for the node according to the service type that the node can handle.

Step 302, the current node checks whether the service type of the service frame in the message is consistent with the service type of the identification frame preset by the node.

Specifically, if the service type of the service frame in the message is consistent with the service type of the identification frame preset by the node, steps 303, 304 and 305 are executed.

Step 303, the current node obtains the message content in the message content frame to process the service.

Step 304, adding a routing frame to the message, and setting the original identification frame of the message as the address of the next node in the routing frame.

Step 305: Write the result of processing the service into the message content frame, and send it to the next node.

If the service type of the service frame in the message is inconsistent with the service type of the identification frame preset by the node, step 306 is executed.

Step 306, adding a routing frame to the message, and setting the default routing node as the next node in the routing frame.

Specifically, each node has a default route, which is pre-specified.

Step 203, using the directional routing rule to process the message.

Specifically, as shown in Figure 4, step 203 includes:

In step 401, the identification frame in the message is saved, and the identification frame in the update message is the identification frame preset by the current node.

In this embodiment, the identification frame preset by the current node is when the node is deployed in the network, and the identification frame is set for the node according to the service type that the node can handle.

Step 402, the current node obtains a routing frame in the message in the reverse order of the encapsulation routing frame.

Step 403: Check whether the service type in the routing frame is consistent with the service type of the identification frame preset by the current node.

Specifically, if the service type in the routing frame is consistent with the service type of the identification frame preset by the current node, steps 404, 405 and 406 are executed.

Step 404, the current node obtains the message content in the message content frame to process the service.

Step 405: Add a new routing frame to the message, and set the original identification frame of the message as the address of the next node in the new routing frame.

Step 406, the result of processing the service is written into the message content frame, and sent to the next node.

If the service type in the routing frame is inconsistent with the service type of the identification frame preset by the current node, step 407 is executed.

Step 407, check whether there is a next routing frame in the message.

Specifically, if there is a next routing frame in the message, steps 408 and 409 are executed.

Step 408, the current node obtains the routing frame.

Step 409 , check whether a channel is established between the current node and the node corresponding to the routing frame.

Specifically, if a channel is established between the current node and the node corresponding to the routing frame, step 409 is executed; if no channel is established, step 410 is executed.

Step 409: Send the message to the node corresponding to the routing frame.

Step 410, adding a new routing frame to the message, and setting the default routing node as the next node in the new routing frame.

If there is no next routing frame in the message, steps 411 and 412 are executed.

Step 411, update the message content frame to an error state.

Step 412: Add a new routing frame to the message, and set the original identification frame of the message in the new routing frame as the address of the next node and send it to the next node.

Compared with the prior art, the embodiments of the present invention, based on the beneficial effects brought by the first embodiment, determine whether to use blind routing rules or directional routing rules to process messages according to whether a routing frame is included in the message. The non-directional transmission and directional transmission improve the transmission efficiency and timeliness of the message.

The third embodiment of the present invention relates to a message processing system, as shown in FIG. 5 , including:

a sending node, configured to send a message encapsulated according to a predefined structure to a receiving node, wherein the message encapsulated according to the predefined structure includes an identification frame, a service frame, a blank frame, and a content frame;

a receiving node, configured to receive a message encapsulated according to a predefined structure, check whether the message contains a routing frame, and determine a corresponding routing policy according to the inspection result to process the message;

Wherein, the sending node and the receiving node each carry an identification frame, and the identification frame includes the service type that the sending node or the receiving node can handle and the distinguishing code of the sending node or the receiving node.

The fourth embodiment of the present invention relates to a message processing apparatus, as shown in FIG. 6 , including:

The message layer 601 is used to encapsulate the message according to a predefined structure, including message address, message separation and message content;

The packaging layer 602 is used to shield the difference of different communication mechanisms;

The transport layer 603 is used to transmit messages encapsulated according to a predefined structure, including intra-process communication and inter-process communication.

The fifth embodiment of the present invention relates to a network device, as shown in FIG. 7 , including:

at least one processor 701; and,

a memory 702 in communication with the at least one processor 701; wherein,

The memory 702 stores instructions executable by the at least one processor, and the instructions are executed by the at least one processor 701 to enable the at least one processor 701 to execute the first to fifth embodiments of the present invention The abnormal behavior detection method described in the method.

The memory and the processor are connected by a bus, and the bus may include any number of interconnected buses and bridges, and the bus connects one or more processors and various circuits of the memory. The bus may also connect together various other circuits, such as peripherals, voltage regulators, and power management circuits, which are well known in the art and therefore will not be described further herein. The bus interface provides the interface between the bus and the transceiver. A transceiver may be a single element or multiple elements, such as multiple receivers and transmitters, providing a means for communicating with various other devices over a transmission medium. The data processed by the processor is transmitted on the wireless medium through the antenna, and further, the antenna also receives the data and transmits the data to the processor.

The processor is responsible for managing the bus and general processing, and can also provide various functions, including timing, peripheral interface, voltage regulation, power management, and other control functions. Instead, memory may be used to store data used by the processor in performing operations.

Those skilled in the art can understand that the above-mentioned embodiments are specific examples for realizing the present invention, and in practical applications, various changes in form and details can be made without departing from the spirit and the spirit of the present invention. scope.

Claims (8)

1. A message processing method, comprising:

receiving a message packaged according to a predefined structure, wherein the message packaged according to the predefined structure comprises an identification frame, a service frame, a blank frame and a content frame;

checking whether the message contains a routing frame or not, and determining a corresponding routing strategy according to a checking result so as to process the message;

the identification frame comprises a service type which can be processed by the source node and a distinguishing code of the source node, and is used for representing the identity source of the message; the service frame comprises a service type and is used for representing the service requested by the message; the content frame contains the message content;

wherein, the checking whether the message contains the routing frame or not, and determining the corresponding routing strategy according to the checking result to process the message includes:

checking whether the message contains a routing frame;

if the message has no routing frame, processing the message in a non-directional transmission mode by adopting a blind routing rule;

and if the message has a routing frame, processing the message in a directional transmission mode by adopting a directional routing rule, wherein the routing frame is the same as the identification frame.

2. The message processing method according to claim 1, wherein the processing the message in a non-directional transmission manner using the blind routing rule comprises:

storing the identification frame in the message, and updating the identification frame in the message to be the identification frame preset by the current node;

the current node checks whether the service type of the service frame in the message is consistent with the service type of the identification frame preset by the node;

if the message content is consistent with the next node address, the current node acquires the message content in the message content frame to process the service, adds a routing frame in the message, sets an original identification frame of the message in the routing frame as the next node address, writes the result of processing the service into the message content frame, and sends the result to the next node;

and if not, adding a routing frame in the message, and setting a default routing node as a next node in the routing frame.

3. The message processing method according to claim 1, wherein the processing the message in a directional transmission manner by using a directional routing rule comprises:

storing the identification frame in the message, and updating the identification frame in the message to be the identification frame preset by the current node;

the current node acquires a routing frame in the message according to the sequence opposite to the sequence of the encapsulated routing frame;

checking whether the service type in the routing frame is consistent with the service type of an identification frame preset by the current node, wherein if so, the current node acquires the message content in the message content frame to process the service, adds a new routing frame in the message, sets the original identification frame of the message in the new routing frame as the address of the next node, writes the result of processing the service into the message content frame, and sends the result to the next node;

if not, checking whether the message has the next routing frame.

4. The message processing method of claim 3, wherein said checking whether there is a next routing frame in the message comprises:

if the message has a next routing frame, the current node acquires the routing frame, and checks whether the current node and a node corresponding to the routing frame establish a channel, wherein if the channel is established, the message is sent to the node corresponding to the routing frame, if the channel is not established, a new routing frame is added into the message, and a default routing node is set in the new routing frame as the next node;

and if the message has no next routing frame, updating the message content frame to be in an error state, adding a new routing frame into the message, setting an original identification frame of the message in the new routing frame as a next node address, and sending the next node address to the next node.

5. A message processing system, comprising:

the system comprises a sending node and a receiving node, wherein the sending node is used for sending a message packaged according to a predefined structure to the receiving node, and the message packaged according to the predefined structure comprises an identification frame, a service frame, a blank frame and a content frame;

the receiving node is used for receiving the message encapsulated according to the predefined structure, checking whether the message contains a routing frame or not, and determining a corresponding routing strategy according to the checking result so as to process the message;

the sending node and the receiving node respectively carry an identification frame, and the identification frame comprises service types which can be processed by the sending node or the receiving node and distinguishing codes of the sending node or the receiving node;

wherein, the checking whether the message contains the routing frame, and determining the corresponding routing strategy according to the checking result to process the message includes:

checking whether the message contains a routing frame;

if the message has no routing frame, processing the message in a non-directional transmission mode by adopting a blind routing rule;

and if the message has a routing frame, processing the message in a directional transmission mode by adopting a directional routing rule, wherein the routing frame is the same as the identification frame.

6. Message processing system according to claim 5, characterized in that it comprises:

the node records a node establishing a channel with the node;

the node extracts the service type of the self identification frame and the service type of the identification frame of the node establishing a channel with the node;

and classifying all the nodes according to the service types by the nodes, and storing the nodes as service and node relation records.

7. Message processing system according to claim 5, characterized in that it comprises:

when a new node is accessed, the new node actively sends a registration message to the current node, wherein the registration message is encapsulated according to a predefined structure and comprises an identification frame;

and the current node acquires the identification frame of the new node registration message and updates the service and node relation record.

8. A network device, comprising:

at least one processor; and (c) a second step of,

a memory communicatively coupled to the at least one processor; wherein,

the memory stores instructions executable by the at least one processor to enable the at least one processor to perform the message processing method of any one of claims 1 to 4.

Images