CN112134763B - Method, system, equipment and medium for transmitting layered messages among cluster nodes - Google Patents
Method, system, equipment and medium for transmitting layered messages among cluster nodes Download PDFInfo
- Publication number
- CN112134763B CN112134763B CN202011023255.1A CN202011023255A CN112134763B CN 112134763 B CN112134763 B CN 112134763B CN 202011023255 A CN202011023255 A CN 202011023255A CN 112134763 B CN112134763 B CN 112134763B
- Authority
- CN
- China
- Prior art keywords
- transmission
- target
- cluster
- transmission path
- information
- 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
Images
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/10—Active monitoring, e.g. heartbeat, ping or trace-route
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L45/00—Routing or path finding of packets in data switching networks
- H04L45/12—Shortest path evaluation
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L45/00—Routing or path finding of packets in data switching networks
- H04L45/14—Routing performance; Theoretical aspects
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Health & Medical Sciences (AREA)
- Cardiology (AREA)
- General Health & Medical Sciences (AREA)
- Computer And Data Communications (AREA)
Abstract
The application discloses a method, a system, equipment and a medium for transmitting layered messages among cluster nodes, which are applied to a cluster sending node to acquire target data to be sent; determining an information transmission path between the cluster receiving node and the information transmission path; determining a target transmission path satisfying the transmission condition in the information transmission path based on the transmission performance of the information transmission path; determining the credit degree of an information transmission link in a target transmission path; transmitting target data to a cluster receiving node through a target transmission path based on a heartbeat mechanism and credit; wherein, the credit degree comprises information characterizing the transmission performance of the information transmission link. In the application, because the target transmission path meets the transmission condition, the credit degree of the transmission link is information representing the transmission performance of the information transmission link, and the heartbeat mechanism has the keep-alive capability, the cluster sending node can be ensured to transmit data to the cluster receiving node efficiently and stably, and the performance of the hierarchical message transmission of the cluster nodes is improved.
Description
Technical Field
The present application relates to the field of information transmission technologies, and in particular, to a method, a system, a device, and a medium for transmitting hierarchical messages between cluster nodes.
Background
In storage systems, cluster (cluster) technology is a relatively new technology by which relatively high gains in performance, reliability, flexibility can be achieved at relatively low cost. And the hierarchical message transmission mechanism among the cluster nodes realizes multi-IO high-concurrency communication, however, the cluster nodes have the problems of low transmission efficiency, poor system performance and the like in the hierarchical message transmission process, and the hierarchical message transmission performance of the cluster nodes is influenced.
In summary, how to improve the performance of hierarchical message transmission of cluster nodes is a problem to be solved by those skilled in the art.
Disclosure of Invention
The application aims to provide a method for transmitting layered messages among cluster nodes, which can solve the technical problem of improving the performance of the transmission of the layered messages among the cluster nodes to a certain extent. The application also provides a hierarchical message transmission system, equipment and a computer readable storage medium among cluster nodes.
In order to achieve the above purpose, the present application provides the following technical solutions:
a method for transmitting layered messages among cluster nodes is applied to a cluster sending node and comprises the following steps:
acquiring target data to be sent;
determining an information transmission path between the cluster receiving node and the information transmission path;
determining a target transmission path which meets transmission conditions in the information transmission path based on the transmission performance of the information transmission path;
determining the credit degree of an information transmission link in the target transmission path;
transmitting the target data to the cluster receiving node through the target transmission path based on a heartbeat mechanism and the credit degree;
wherein the credit comprises information characterizing the transmission performance of the information transmission link.
Preferably, the determining, based on the transmission performance of the information transmission path, a target transmission path that satisfies a transmission condition in the information transmission path includes:
acquiring preference values of the information transmission path, wherein the preference values comprise values representing the transmission performance of the information transmission path;
determining the target transmission path meeting the transmission condition in the information transmission path with the maximum preference value;
wherein the transmission condition includes that the sum of the preference values of the target transmission paths is greater than a preset value.
Preferably, the transmitting the target data to the cluster receiving node through the target transmission path based on the heartbeat mechanism and the credit includes:
determining a target transmission link based on the credit degree and the target transmission path;
determining the data transmission quantity of each target transmission link;
and transmitting the target data to the cluster receiving node through the target transmission link based on the heartbeat mechanism and the data transmission quantity.
Preferably, the process of transmitting the target data to the cluster receiving node through the target transmission link based on the heartbeat mechanism and the data transmission amount includes:
and judging whether the frame loss rate of the target transmission link is greater than a preset frame loss value or not based on the heartbeat mechanism, and if so, generating first notification information representing poor reliability of the cluster receiving node.
Preferably, the process of transmitting the target data to the cluster receiving node through the target transmission link based on the heartbeat mechanism and the data transmission amount includes:
and judging whether the idle time of the sending queue of the target data exceeds a first preset time based on the heartbeat mechanism, if so, sending a heartbeat message and a response serial number to the cluster receiving node so as to maintain the target transmission link in a survival state.
Preferably, the process of transmitting the target data to the cluster receiving node through the target transmission link based on the heartbeat mechanism and the data transmission amount includes:
determining a number of blocked links in the target transmission link based on the heartbeat mechanism;
judging whether the number of the blocked links is larger than a preset blocking value or not, and the cluster receiving node and the cluster sending node do not belong to the same cluster; and if so, generating second notification information representing the poor reliability of the cluster receiving node.
Preferably, the determining the number of blocked links in the target transmission link based on the heartbeat mechanism includes:
judging whether a transmitted but unresponsive transmission link to be judged exists in the target transmission link based on the heartbeat mechanism;
if the target transmission link is judged to have the transmitted transmission link to be judged without responding based on the heartbeat mechanism, judging whether the blocking times of the transmission link to be judged are more than or equal to 2;
if the blocking times of the transmission link to be judged is more than or equal to 2, updating the number of the blocked links;
if the blocking times of the transmission link to be judged is less than 2, judging whether the maximum blocking time of the transmission link to be judged is greater than the blocking time;
and if the maximum blocking duration of the transmission link to be judged is greater than the blocking duration, updating the number of the blocked links.
A hierarchical message transmission system among cluster nodes is applied to a cluster sending node and comprises the following components:
the first acquisition module is used for acquiring target data to be sent;
the first determining module is used for determining an information transmission path between the first determining module and the cluster receiving node;
a second determining module, configured to determine, based on transmission performance of the information transmission path, a target transmission path that meets a transmission condition in the information transmission path;
the third determining module is used for determining the credit degree of an information transmission link in the target transmission path;
the first transmission module is used for transmitting the target data to the cluster receiving node through the target transmission path based on a heartbeat mechanism and the credit degree;
wherein the credit comprises information characterizing the transmission performance of the information transmission link.
An inter-cluster-node layered message transport apparatus comprising:
a memory for storing a computer program;
a processor, configured to implement the steps of any of the above-described methods for transmitting layered messages between cluster nodes when executing the computer program.
A computer-readable storage medium, in which a computer program is stored which, when being executed by a processor, carries out the steps of the method for hierarchical message transmission between cluster nodes as set forth in any one of the preceding claims.
The application provides a hierarchical message transmission method among cluster nodes, which is applied to a cluster sending node and used for acquiring target data to be sent; determining an information transmission path between the cluster receiving node and the information transmission path; determining a target transmission path satisfying the transmission condition in the information transmission path based on the transmission performance of the information transmission path; determining the credit degree of an information transmission link in a target transmission path; transmitting target data to a cluster receiving node through a target transmission path based on a heartbeat mechanism and credit; wherein, the credit degree comprises information characterizing the transmission performance of the information transmission link. In the application, because the target transmission path meets the transmission condition, the credit degree of the transmission link is information representing the transmission performance of the information transmission link, and the heartbeat mechanism has the keep-alive capability, the heartbeat mechanism and the credit degree transmit the target data to the cluster receiving nodes through the target transmission path, so that the cluster sending nodes can be ensured to transmit the data to the cluster receiving nodes efficiently and stably, and the performance of the hierarchical message transmission of the cluster nodes is improved. The cluster node layered message transmission system, the cluster node layered message transmission equipment and the computer readable storage medium solve the corresponding technical problems.
Drawings
In order to more clearly illustrate the embodiments of the present application or the technical solutions in the prior art, the drawings needed to be used in the description of the embodiments or the prior art will be briefly introduced below, it is obvious that the drawings in the following description are only embodiments of the present application, and for those skilled in the art, other drawings can be obtained according to the provided drawings without creative efforts.
Fig. 1 is a flowchart of a method for transmitting layered messages between cluster nodes according to an embodiment of the present application;
fig. 2 is a schematic structural diagram of a hierarchical message transmission system between cluster nodes according to an embodiment of the present application;
fig. 3 is a schematic structural diagram of a hierarchical message transmission device between cluster nodes according to an embodiment of the present application;
fig. 4 is another schematic structural diagram of a hierarchical message transmission device between cluster nodes according to an embodiment of the present application.
Detailed Description
The technical solutions in the embodiments of the present application will be clearly and completely described below with reference to the drawings in the embodiments of the present application, and it is obvious that the described embodiments are only a part of the embodiments of the present application, and not all of the embodiments. All other embodiments, which can be derived by a person skilled in the art from the embodiments given herein without making any creative effort, shall fall within the protection scope of the present application.
Referring to fig. 1, fig. 1 is a flowchart of a method for transmitting a layered message between cluster nodes according to an embodiment of the present disclosure.
The method for transmitting the layered messages among the cluster nodes provided by the embodiment of the application is applied to the cluster sending node and comprises the following steps:
step S101: and acquiring target data to be sent.
In practical application, the cluster sending node may obtain the target data to be sent first, and the type and content of the target data may be determined according to actual needs, which is not specifically limited herein.
Step S102: and determining an information transmission path between the cluster receiving node and the information transmission path.
In practical applications, after acquiring target data, the cluster sending node may determine an information transmission path with the cluster receiving node, so as to select a desired target transmission path in the information transmission path subsequently, where the type of the information transmission path may be determined according to actual needs, for example, the information transmission path may be an NTB (Non-Transparent Bridge protocol) path, an FC (fiber Channel, fiber protocol) path, or the like.
Step S103: and determining a target transmission path which meets the transmission condition in the information transmission path based on the transmission performance of the information transmission path.
In practical application, after determining the information transmission path, the cluster sending node may determine, based on the transmission performance of the information transmission path, a target transmission path that meets the transmission condition in the information transmission path to obtain the target transmission path that meets the transmission condition, so that the transmission of the target data meets the transmission condition, and the type of the transmission condition may be determined according to actual needs, which is not specifically limited herein.
It should be noted that, in a specific application scenario, an information transmission path may be determined by a Communication Layer (CL) in a cluster sending node, and a target transmission path that satisfies a transmission condition may be determined in the information transmission path based on the transmission performance of the information transmission path.
Step S104: and determining the credit degree of the information transmission link in the target transmission path, wherein the credit degree comprises information for characterizing the transmission performance of the information transmission link.
In practical application, because the multi-thread parallel computing technology is developed in the current computer technology, the communication field also adopts multi-channel parallel processing to maximize the communication efficiency, so that in order to maximize the parallel transmission performance between the cluster sending node and the cluster receiving node, the cluster sending node can determine the credit degree of the information transmission link in the target transmission path, i.e. the information marking the transmission performance of the information transmission link, so as to transmit the target data according to the transmission performance of the information transmission link in the following process, and the transmission process of the target data is adapted to the parallel transmission performance between the cluster sending node and the cluster receiving node.
In a specific application scenario, the cluster sending node may determine the credit degree of the information transmission link through relevant settings of the cluster receiving node, such as the type and the number of the information transmission link, and the definition of the maximum credit degree; and the cluster receiving node may set a credit flag via a fixed field in the message, with the credit flag transmitting the credit to the cluster sending node, etc.
Step S105: and transmitting the target data to the cluster receiving node through the target transmission path based on the heartbeat mechanism and the credit degree.
In practical application, in the process of sending target data to a cluster receiving node by a cluster sending node, the situation that a target transmission path is unavailable or an information transmission link is unavailable may occur, so that the target data transmission between the cluster sending node and the cluster receiving node fails.
It should be noted that in a specific application scenario, a Window Layer (WL) in the cluster sending node may be responsible for a heartbeat mechanism, etc.
The application provides a hierarchical message transmission method among cluster nodes, which is applied to a cluster sending node and used for acquiring target data to be sent; determining an information transmission path between the cluster receiving node and the information transmission path; determining a target transmission path satisfying the transmission condition in the information transmission path based on the transmission performance of the information transmission path; determining the credit degree of an information transmission link in a target transmission path; transmitting target data to a cluster receiving node through a target transmission path based on a heartbeat mechanism and credit; wherein, the credit degree comprises information characterizing the transmission performance of the information transmission link. In the application, because the target transmission path meets the transmission condition, the credit degree of the transmission link is information representing the transmission performance of the information transmission link, and the heartbeat mechanism has the keep-alive capability, the heartbeat mechanism and the credit degree transmit the target data to the cluster receiving nodes through the target transmission path, so that the cluster sending nodes can be ensured to transmit the data to the cluster receiving nodes efficiently and stably, and the performance of the hierarchical message transmission of the cluster nodes is improved.
In the method for transmitting layered messages between cluster nodes provided by the embodiment of the application, a cluster sending node can acquire a preference value of an information transmission path in the process of determining a target transmission path meeting transmission conditions in the information transmission path based on the transmission performance of the information transmission path, wherein the preference value comprises a value representing the transmission performance of the information transmission path; determining a target transmission path meeting the transmission condition in the information transmission path with the maximum preference value; wherein the transmission condition includes that the sum of the preference values of the target transmission paths is greater than a preset value.
In this embodiment, since the preference value can reflect the transmission performance of the information transmission path, if the target transmission path satisfying the transmission condition is determined in the information transmission path with the largest preference value, it is equivalent to determining the target transmission path satisfying the transmission condition only in the information transmission path with the best transmission performance, so that the best transmission performance of the target transmission path can be ensured.
For convenience of understanding, it is assumed that the types of the information transmission paths are an NTB path and an FC path, the preference value of the NTB path is 30, the preference value of the FC path is 8, and the transmission condition is that the sum of the preference values of the target transmission paths is greater than 16, then in the case of an NTB path, only one NTB path is needed as a target transmission path to satisfy the transmission condition, and in the case of only an FC path, at least two FC paths are needed as target transmission paths to satisfy the transmission condition.
It should be noted that, in a specific application scenario, in order to facilitate determining a target transmission Path, in the communication link establishment, exit and heartbeat processes, the preference values of all paths may be recalculated as appropriate, the maximum value therein is recorded, and the Path whose preference value is equal to the maximum value is set as a Preferred Path (Preferred Path), and the other paths are set as non-Preferred paths, and in the communication link exit process, the cluster sending node checks whether a Preferred Path still exists in the paths leading to the cluster receiving node, if not, sets all paths as Preferred paths, and if yes, selects only the target transmission Path in the Preferred paths.
In the method for transmitting layered messages between cluster nodes provided in the embodiment of the present application, a cluster sending node may execute the following steps in a process of transmitting target data to a cluster receiving node through a target transmission path based on a heartbeat mechanism and a credit degree: determining a target transmission link based on the credit degree and the target transmission path; determining the data transmission quantity of each target transmission link; and transmitting the target data to the cluster receiving node through the target transmission link based on the heartbeat mechanism and the data transmission quantity.
That is, in this embodiment, the cluster sending node may determine the target transmission link based on the credit and the target transmission path, and determine the data transmission amount of each target transmission link, so as to allocate the target data transmission requirement to the target transmission link, and quickly transmit the target data by using the target transmission link; in this process, when the cluster sending node determines the target transmission link based on the credit and the target transmission path, an information transmission link may be newly added to obtain the target transmission link, or an existing information transmission link may be reduced to obtain the target transmission link, and the like.
In the method for transmitting layered messages between cluster nodes provided in the embodiment of the present application, a cluster sending node may determine, based on a heartbeat mechanism and a data transmission amount, whether a frame loss rate of a target transmission link is greater than a preset frame loss value in a process of transmitting target data to a cluster receiving node through a target transmission link, and if so, generate first notification information representing poor reliability of the cluster receiving node.
That is, in this embodiment, in the process of transmitting the target data to the cluster receiving node, a frame loss condition may exist, and at this time, a success rate of transmitting the layered message between the cluster nodes may be affected. The preset frame loss value can be determined according to actual needs, for example, the preset frame loss value can be 10%, and the like. In a specific application scenario, under the condition that the number of the first notification messages is large, exception handling and the like can be performed on the process of transmitting the target data between the cluster sending node and the cluster receiving node.
In practical application, in the process that the cluster sending node transmits the target data to the cluster receiving node through the target transmission link based on the heartbeat mechanism and the data transmission quantity, whether the idle time of the sending queue of the target data exceeds a first preset time can be judged based on the heartbeat mechanism, and if yes, a heartbeat message and a response serial number are sent to the cluster receiving node to maintain the target transmission link in a survival state.
That is, in this embodiment, under the condition that the idle duration of the sending queue of the target data is long, the target transmission link may be maintained in the storage state through the heartbeat mechanism and the response sequence number, so that when the target data needs to be transmitted, the target transmission link may be directly applied to transmit, and the response sequence number is also a sequence number between the cluster sending node and the cluster receiving node, which corresponds to the target transmission link. The first preset time period may be determined according to actual needs, for example, the first preset time period may be 800 ms.
In practical application, in order to further judge whether the target data is successfully transmitted, the cluster sending node can determine the number of blocked links in the target transmission link based on the heartbeat mechanism in the process of transmitting the target data to the cluster receiving node through the target transmission link based on the heartbeat mechanism and the data transmission quantity; judging whether the number of the blocked links is larger than a preset blocking value or not, wherein the cluster receiving nodes and the cluster sending nodes do not belong to the same cluster; and if so, generating second notification information representing poor reliability of the cluster receiving node.
In a specific application scenario, in the process that a cluster sending node determines the number of blocked links in a target transmission link based on a heartbeat mechanism, whether a sent but unresponsed transmission link to be determined exists in the target transmission link can be determined based on the heartbeat mechanism; if the target transmission link is judged to have the transmitted transmission link to be judged without responding based on the heartbeat mechanism, judging whether the blocking frequency of the transmission link to be judged is more than or equal to 2; if the blocking times of the transmission link to be judged are more than or equal to 2, updating the number of the blocked links; if the blocking times of the transmission link to be judged is less than 2, judging whether the maximum blocking time of the transmission link to be judged is greater than the blocking time; and if the maximum blocking duration of the transmission link to be judged is greater than the blocking duration, updating the number of the blocked links. In the process, when judging whether a to-be-judged transmission link which is sent but not responded exists in the target transmission link, whether response information is received within the time period of 400ms and the like after the target transmission link sends data can be judged, and if not, the target transmission link can be judged to be the to-be-judged transmission link; when judging whether the blocking times of the transmission link to be judged is more than or equal to 2, judging whether the serial number of the transmission link to be judged is consistent with the serial number of the historical transmission link to be judged, if so, judging that the blocking times of the transmission link is more than or equal to 2.
It should be noted that, in practical application, the heartbeat mechanism may also be used to refresh the credit, refresh the port state, refresh the preference value, refresh the statistical data, detect the last time when the cluster sending node sends and receives the message, detect the last time when the cluster receiving node sends and receives the message, and the like, and the function of the heartbeat mechanism is not limited in this application.
Referring to fig. 2, fig. 2 is a schematic structural diagram of a hierarchical message transmission system between cluster nodes according to an embodiment of the present disclosure.
The hierarchical message transmission system between cluster nodes provided in the embodiment of the present application is applied to a cluster sending node, and may include:
a first obtaining module 101, configured to obtain target data to be sent;
a first determining module 102, configured to determine an information transmission path between the cluster receiving node and the first determining module;
a second determining module 103, configured to determine, based on the transmission performance of the information transmission path, a target transmission path that meets the transmission condition among the information transmission paths;
a third determining module 104, configured to determine the credit of the information transmission link in the target transmission path;
a first transmission module 105, configured to transmit target data to a cluster receiving node through a target transmission path based on a heartbeat mechanism and a credit;
wherein, the credit degree comprises information characterizing the transmission performance of the information transmission link.
The embodiment of the present application provides a hierarchical message transmission system between cluster nodes, which is applied to a cluster sending node, where the second determining module may include:
a first acquisition unit configured to acquire a preference value of the information transmission path, the preference value including a value representing a transmission performance of the information transmission path;
a first determining unit configured to determine a target transmission path that satisfies a transmission condition among information transmission paths having a maximum preference value;
wherein the transmission condition includes that the sum of the preference values of the target transmission paths is greater than a preset value.
The embodiment of the present application provides a hierarchical message transmission system between cluster nodes, which is applied to a cluster sending node, where a first transmission module may include:
the first determining submodule is used for determining a target transmission link based on the credit degree and the target transmission path;
the second determining submodule is used for determining the data transmission quantity of each target transmission link;
and the first transmission submodule is used for transmitting the target data to the cluster receiving node through the target transmission link based on the heartbeat mechanism and the data transmission quantity.
The embodiment of the application provides a hierarchical message transmission system between cluster nodes, which is applied to a cluster sending node, and a first transmission sub-module may include:
and the first judging unit is used for judging whether the frame loss rate of the target transmission link is greater than a preset frame loss value or not based on the heartbeat mechanism, and if so, generating first notification information representing poor reliability of the cluster receiving node.
The embodiment of the application provides a hierarchical message transmission system between cluster nodes, which is applied to a cluster sending node, and a first transmission sub-module may include:
and the second judging unit is used for judging whether the idle time of the sending queue of the target data exceeds the first preset time based on the heartbeat mechanism, and if so, sending a heartbeat message and a response serial number to the cluster receiving node so as to maintain the target transmission link in a survival state.
The embodiment of the application provides a hierarchical message transmission system between cluster nodes, which is applied to a cluster sending node, and a first transmission sub-module may include:
the second determining unit is used for determining the number of the blocked links in the target transmission link based on the heartbeat mechanism;
the third judging unit is used for judging whether the number of the blocked links is greater than a preset blocking value or not and the cluster receiving node and the cluster sending node do not belong to the same cluster; and if so, generating second notification information representing poor reliability of the cluster receiving node.
The embodiment of the present application provides a hierarchical message transmission system between cluster nodes, which is applied to a cluster sending node, where the second determining unit may include:
the fourth judging unit is used for judging whether a to-be-judged transmission link which is sent but not responded exists in the target transmission link based on the heartbeat mechanism; if the target transmission link is judged to have the transmitted transmission link to be judged without responding based on the heartbeat mechanism, judging whether the blocking frequency of the transmission link to be judged is more than or equal to 2; if the blocking times of the transmission link to be judged are more than or equal to 2, updating the number of the blocked links; if the blocking times of the transmission link to be judged is less than 2, judging whether the maximum blocking time of the transmission link to be judged is greater than the blocking time; and if the maximum blocking duration of the transmission link to be judged is greater than the blocking duration, updating the number of the blocked links.
The application also provides a device and a computer readable storage medium for transmitting the layered messages between the cluster nodes, which both have the corresponding effects of the method for transmitting the layered messages between the cluster nodes provided by the embodiment of the application. Referring to fig. 3, fig. 3 is a schematic structural diagram of a hierarchical message transmission device between cluster nodes according to an embodiment of the present application.
The hierarchical message transmission device between cluster nodes provided by the embodiment of the application includes a memory 201 and a processor 202, wherein the memory 201 stores a computer program, and the processor 202 implements the following steps when executing the computer program:
acquiring target data to be sent;
determining an information transmission path between the cluster receiving node and the information transmission path;
determining a target transmission path satisfying the transmission condition in the information transmission path based on the transmission performance of the information transmission path;
determining the credit degree of an information transmission link in a target transmission path;
transmitting target data to a cluster receiving node through a target transmission path based on a heartbeat mechanism and credit;
wherein, the credit degree comprises information characterizing the transmission performance of the information transmission link.
The hierarchical message transmission device between cluster nodes provided by the embodiment of the application includes a memory 201 and a processor 202, wherein the memory 201 stores a computer program, and the processor 202 implements the following steps when executing the computer program: acquiring a preference value of the information transmission path, wherein the preference value comprises a value representing the transmission performance of the information transmission path; determining a target transmission path meeting the transmission condition in the information transmission path with the maximum preference value; wherein the transmission condition includes that the sum of the preference values of the target transmission paths is greater than a preset value.
The hierarchical message transmission device between cluster nodes provided by the embodiment of the application includes a memory 201 and a processor 202, wherein the memory 201 stores a computer program, and the processor 202 implements the following steps when executing the computer program: determining a target transmission link based on the credit degree and the target transmission path; determining the data transmission quantity of each target transmission link; and transmitting the target data to the cluster receiving node through the target transmission link based on the heartbeat mechanism and the data transmission quantity.
The device for transmitting layered messages between cluster nodes provided in the embodiment of the present application includes a memory 201 and a processor 202, where the memory 201 stores a computer program, and the processor 202 implements the following steps when executing the computer program: and judging whether the frame loss rate of the target transmission link is greater than a preset frame loss value or not based on a heartbeat mechanism, and if so, generating first notification information representing poor reliability of the cluster receiving node.
The hierarchical message transmission device between cluster nodes provided by the embodiment of the application includes a memory 201 and a processor 202, wherein the memory 201 stores a computer program, and the processor 202 implements the following steps when executing the computer program: and judging whether the idle time of the sending queue of the target data exceeds a first preset time based on a heartbeat mechanism, if so, sending a heartbeat message and a response serial number to the cluster receiving node so as to maintain the target transmission link in a survival state.
The hierarchical message transmission device between cluster nodes provided by the embodiment of the application includes a memory 201 and a processor 202, wherein the memory 201 stores a computer program, and the processor 202 implements the following steps when executing the computer program: determining the number of blocked links in a target transmission link based on a heartbeat mechanism; judging whether the number of the blocked links is larger than a preset blocking value or not, wherein the cluster receiving nodes and the cluster sending nodes do not belong to the same cluster; and if so, generating second notification information representing poor reliability of the cluster receiving node.
The hierarchical message transmission device between cluster nodes provided by the embodiment of the application includes a memory 201 and a processor 202, wherein the memory 201 stores a computer program, and the processor 202 implements the following steps when executing the computer program: judging whether a transmitted but unresponsive transmission link to be judged exists in the target transmission link based on a heartbeat mechanism; if the target transmission link is judged to have the transmitted transmission link to be judged without responding based on the heartbeat mechanism, judging whether the blocking frequency of the transmission link to be judged is more than or equal to 2; if the blocking times of the transmission link to be judged are more than or equal to 2, updating the number of the blocked links; if the blocking times of the transmission link to be judged is less than 2, judging whether the maximum blocking time of the transmission link to be judged is greater than the blocking time; and if the maximum blocking duration of the transmission link to be judged is greater than the blocking duration, updating the number of the blocked links.
Referring to fig. 4, another hierarchical message transmission device between cluster nodes according to the embodiment of the present application may further include: an input port 203 connected to the processor 202, for transmitting externally input commands to the processor 202; a display unit 204 connected to the processor 202, for displaying the processing result of the processor 202 to the outside; and the communication module 205 is connected with the processor 202 and is used for realizing communication between the hierarchical message transmission device among the cluster nodes and the outside world. The display unit 204 may be a display panel, a laser scanning display, or the like; the communication method adopted by the communication module 205 includes, but is not limited to, mobile high definition link technology (HML), Universal Serial Bus (USB), High Definition Multimedia Interface (HDMI), and wireless connection: wireless fidelity technology (WiFi), bluetooth communication technology, bluetooth low energy communication technology, ieee802.11s based communication technology.
A computer-readable storage medium is provided in an embodiment of the present application, in which a computer program is stored, and when the computer program is executed by a processor, the computer program implements the following steps:
acquiring target data to be sent;
determining an information transmission path between the cluster receiving node and the information transmission path;
determining a target transmission path satisfying the transmission condition in the information transmission path based on the transmission performance of the information transmission path;
determining the credit degree of an information transmission link in a target transmission path;
transmitting target data to a cluster receiving node through a target transmission path based on a heartbeat mechanism and credit;
wherein, the credit degree comprises information characterizing the transmission performance of the information transmission link.
A computer-readable storage medium is provided in an embodiment of the present application, in which a computer program is stored, and when the computer program is executed by a processor, the computer program implements the following steps: acquiring a preference value of the information transmission path, wherein the preference value comprises a value representing the transmission performance of the information transmission path; determining a target transmission path meeting the transmission condition in the information transmission path with the maximum preference value; wherein the transmission condition includes that the sum of the preference values of the target transmission paths is greater than a preset value.
A computer-readable storage medium is provided in an embodiment of the present application, in which a computer program is stored, and when the computer program is executed by a processor, the computer program implements the following steps: determining a target transmission link based on the credit degree and the target transmission path; determining the data transmission quantity of each target transmission link; and transmitting target data to the cluster receiving node through the target transmission link based on the heartbeat mechanism and the data transmission quantity.
A computer-readable storage medium is provided in an embodiment of the present application, in which a computer program is stored, and when the computer program is executed by a processor, the computer program implements the following steps: and judging whether the frame loss rate of the target transmission link is greater than a preset frame loss value or not based on a heartbeat mechanism, and if so, generating first notification information representing poor reliability of the cluster receiving node.
A computer-readable storage medium is provided in an embodiment of the present application, in which a computer program is stored, and when the computer program is executed by a processor, the computer program implements the following steps: and judging whether the idle time of the sending queue of the target data exceeds a first preset time based on a heartbeat mechanism, if so, sending a heartbeat message and a response serial number to the cluster receiving node so as to maintain the target transmission link in a survival state.
A computer-readable storage medium is provided in an embodiment of the present application, in which a computer program is stored, and when the computer program is executed by a processor, the computer program implements the following steps: determining the number of blocked links in a target transmission link based on a heartbeat mechanism; judging whether the number of the blocked links is larger than a preset blocking value or not, wherein the cluster receiving nodes and the cluster sending nodes do not belong to the same cluster; and if so, generating second notification information representing poor reliability of the cluster receiving node.
A computer-readable storage medium provided in an embodiment of the present application stores a computer program, and when executed by a processor, the computer program implements the following steps: judging whether a transmitted but unresponsive transmission link to be judged exists in the target transmission link based on a heartbeat mechanism; if the target transmission link is judged to have the transmitted transmission link to be judged without responding based on the heartbeat mechanism, judging whether the blocking frequency of the transmission link to be judged is more than or equal to 2; if the blocking times of the transmission link to be judged are more than or equal to 2, updating the number of the blocked links; if the blocking times of the transmission link to be judged is less than 2, judging whether the maximum blocking time of the transmission link to be judged is greater than the blocking time; and if the maximum blocking duration of the transmission link to be judged is greater than the blocking duration, updating the number of the blocked links.
The computer-readable storage media to which this application relates include Random Access Memory (RAM), memory, Read Only Memory (ROM), electrically programmable ROM, electrically erasable programmable ROM, registers, hard disk, a removable disk, a CD-ROM, or any other form of storage media known in the art.
For a description of a relevant part in the system, the device, and the computer-readable storage medium for transmitting a hierarchical message between cluster nodes provided in the embodiment of the present application, reference is made to detailed descriptions of a corresponding part in the method for transmitting a hierarchical message between cluster nodes provided in the embodiment of the present application, and details are not repeated here. In addition, parts of the above technical solutions provided in the embodiments of the present application, which are consistent with the implementation principles of corresponding technical solutions in the prior art, are not described in detail so as to avoid redundant description.
It is further noted that, herein, relational terms such as first and second, and the like may be used solely to distinguish one entity or action from another entity or action without necessarily requiring or implying any actual such relationship or order between such entities or actions. Also, the terms "comprises," "comprising," or any other variation thereof, are intended to cover a non-exclusive inclusion, such that a process, method, article, or apparatus that comprises a list of elements does not include only those elements but may include other elements not expressly listed or inherent to such process, method, article, or apparatus. Without further limitation, an element defined by the phrase "comprising an … …" does not exclude the presence of other identical elements in a process, method, article, or apparatus that comprises the element.
The previous description of the disclosed embodiments is provided to enable any person skilled in the art to make or use the present application. Various modifications to these embodiments will be readily apparent to those skilled in the art, and the generic principles defined herein may be applied to other embodiments without departing from the spirit or scope of the application. Thus, the present application is not intended to be limited to the embodiments shown herein but is to be accorded the widest scope consistent with the principles and novel features disclosed herein.
Claims (9)
1. A method for transmitting layered messages among cluster nodes is applied to a cluster sending node and comprises the following steps:
acquiring target data to be sent;
determining an information transmission path between the cluster receiving node and the cluster receiving node;
determining a target transmission path which meets transmission conditions in the information transmission path based on the transmission performance of the information transmission path;
determining the credit degree of an information transmission link in the target transmission path;
transmitting the target data to the cluster receiving node through the target transmission path based on a heartbeat mechanism and the credit degree;
wherein the credit comprises information characterizing the transmission performance of the information transmission link;
wherein the determining, based on the transmission performance of the information transmission path, a target transmission path that satisfies a transmission condition in the information transmission path includes:
acquiring preference values of the information transmission path, wherein the preference values comprise values representing the transmission performance of the information transmission path;
determining the target transmission path meeting the transmission condition in the information transmission path with the maximum preference value;
wherein the transmission condition includes that the sum of the preference values of the target transmission paths is greater than a preset value.
2. The method of claim 1, wherein the transmitting the target data to the cluster receiving node through the target transmission path based on the heartbeat mechanism and the credit comprises:
determining a target transmission link based on the credit degree and the target transmission path;
determining the data transmission quantity of each target transmission link;
and transmitting the target data to the cluster receiving node through the target transmission link based on the heartbeat mechanism and the data transmission quantity.
3. The method according to claim 2, wherein the transmitting the target data to the cluster receiving node through the target transmission link based on the heartbeat mechanism and the data transmission amount comprises:
and judging whether the frame loss rate of the target transmission link is greater than a preset frame loss value or not based on the heartbeat mechanism, and if so, generating first notification information representing poor reliability of the cluster receiving node.
4. The method according to claim 2, wherein the transmitting the target data to the cluster receiving node through the target transmission link based on the heartbeat mechanism and the data transmission amount comprises:
and judging whether the idle time of the sending queue of the target data exceeds a first preset time based on the heartbeat mechanism, if so, sending a heartbeat message and a response serial number to the cluster receiving node so as to maintain the target transmission link in a survival state.
5. The method according to claim 2, wherein the transmitting the target data to the cluster receiving node through the target transmission link based on the heartbeat mechanism and the data transmission amount comprises:
determining a number of blocked links in the target transmission link based on the heartbeat mechanism;
judging whether the number of the blocked links is larger than a preset blocking value or not, and the cluster receiving node and the cluster sending node do not belong to the same cluster; and if so, generating second notification information representing the poor reliability of the cluster receiving node.
6. The method of claim 5, wherein the determining the number of blocked links in the target transmission link based on the heartbeat mechanism comprises:
judging whether a transmitted but unresponsive transmission link to be judged exists in the target transmission link based on the heartbeat mechanism;
if the target transmission link is judged to have the transmitted transmission link to be judged without responding based on the heartbeat mechanism, judging whether the blocking times of the transmission link to be judged are more than or equal to 2;
if the blocking times of the transmission link to be judged is more than or equal to 2, updating the number of the blocked links;
if the blocking times of the transmission link to be judged is less than 2, judging whether the maximum blocking time of the transmission link to be judged is greater than the blocking time;
and if the maximum blocking duration of the transmission link to be judged is greater than the blocking duration, updating the number of the blocked links.
7. A hierarchical message transmission system among cluster nodes is applied to a cluster sending node and comprises the following components:
the first acquisition module is used for acquiring target data to be sent;
the first determining module is used for determining an information transmission path between the first determining module and the cluster receiving node;
a second determining module, configured to determine, based on transmission performance of the information transmission path, a target transmission path that meets a transmission condition in the information transmission path;
the third determining module is used for determining the credit degree of an information transmission link in the target transmission path;
the first transmission module is used for transmitting the target data to the cluster receiving node through the target transmission path based on a heartbeat mechanism and the credit degree;
wherein the credit comprises information characterizing the transmission performance of the information transmission link;
wherein the second determining module comprises:
a first acquisition unit configured to acquire preference values of the information transmission path, the preference values including a value representing transmission performance of the information transmission path;
a first determining unit configured to determine the target transmission path that satisfies the transmission condition among the information transmission paths having the largest preference values;
wherein the transmission condition includes that the sum of the preference values of the target transmission paths is greater than a preset value.
8. An apparatus for hierarchical message transmission between cluster nodes, comprising:
a memory for storing a computer program;
a processor for implementing the steps of the method for hierarchical message transmission between cluster nodes according to any of claims 1 to 6 when executing said computer program.
9. A computer-readable storage medium, in which a computer program is stored which, when being executed by a processor, carries out the steps of the method for hierarchical message transmission between cluster nodes according to any one of claims 1 to 6.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202011023255.1A CN112134763B (en) | 2020-09-25 | 2020-09-25 | Method, system, equipment and medium for transmitting layered messages among cluster nodes |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202011023255.1A CN112134763B (en) | 2020-09-25 | 2020-09-25 | Method, system, equipment and medium for transmitting layered messages among cluster nodes |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN112134763A CN112134763A (en) | 2020-12-25 |
| CN112134763B true CN112134763B (en) | 2022-08-02 |
Family
ID=73840031
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202011023255.1A Active CN112134763B (en) | 2020-09-25 | 2020-09-25 | Method, system, equipment and medium for transmitting layered messages among cluster nodes |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN112134763B (en) |
Families Citing this family (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN113746574B (en) * | 2021-07-30 | 2023-01-24 | 苏州浪潮智能科技有限公司 | Information interaction method, system and equipment |
| CN115378872B (en) * | 2022-08-19 | 2023-08-18 | 苏州浪潮智能科技有限公司 | Flow control method, system, computer equipment and readable storage medium |
| CN116866450B (en) * | 2023-06-08 | 2024-12-31 | 兴华永恒（北京）科技有限责任公司 | Data transmission method, device, electronic device and storage medium |
Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN109257282A (en) * | 2018-08-09 | 2019-01-22 | 北京邮电大学 | A kind of data transmission method and device |
| CN110809054A (en) * | 2019-11-11 | 2020-02-18 | 腾讯科技（深圳）有限公司 | Data transmission method, apparatus, device and storage medium |
Family Cites Families (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| WO2010033919A2 (en) * | 2008-09-22 | 2010-03-25 | Jumpstart Wireless Corporation | System and method for dynamic automatic communication path selection, distributed device synchronization and task delegation |
| CN106162764A (en) * | 2015-04-03 | 2016-11-23 | 电信科学技术研究院 | A kind of routing resource and device |
| CN108337701B (en) * | 2017-01-19 | 2021-06-04 | 工业和信息化部电信研究院 | Transmission path switching method |
| CN107682264B (en) * | 2017-09-26 | 2018-11-16 | 迅雷计算机（深圳）有限公司 | Data transmission method and system based on real-time active path planning |
| CN110213065B (en) * | 2018-02-28 | 2022-11-25 | 杭州宏杉科技股份有限公司 | Method and device for switching paths |
| CN109889441B (en) * | 2019-03-21 | 2021-05-14 | 新华三技术有限公司 | Data forwarding method and device |
| CN111371879B (en) * | 2020-02-28 | 2022-12-23 | 中国工商银行股份有限公司 | Network path management method, device, system, service architecture and electronic equipment |
-
2020
- 2020-09-25 CN CN202011023255.1A patent/CN112134763B/en active Active
Patent Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN109257282A (en) * | 2018-08-09 | 2019-01-22 | 北京邮电大学 | A kind of data transmission method and device |
| CN110809054A (en) * | 2019-11-11 | 2020-02-18 | 腾讯科技（深圳）有限公司 | Data transmission method, apparatus, device and storage medium |
Also Published As
| Publication number | Publication date |
|---|---|
| CN112134763A (en) | 2020-12-25 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN112134763B (en) | Method, system, equipment and medium for transmitting layered messages among cluster nodes | |
| IL269497B2 (en) | Method for transmitting data, terminal device, and network device | |
| CN110659151B (en) | Data verification method and device and storage medium | |
| CN105468302B (en) | A kind of method, apparatus and system of processing data | |
| US11083004B2 (en) | Data transmission method and apparatus | |
| CN110808948B (en) | Remote procedure call method, device and system | |
| CN103841562A (en) | Time slot resource occupation processing method and time slot resource occupation processing device | |
| US20230161541A1 (en) | Screen projection method and system | |
| CN109040295A (en) | Determination method and device, terminal and the storage medium of abnormal broken line | |
| CN112486888A (en) | Market data transmission method, device, equipment and medium | |
| EP4009724B1 (en) | Terminal capability processing method, apparatus, and device | |
| CN112770358B (en) | Multi-rate mode data transmission control method and device based on service data | |
| CN109756464B (en) | Communication method, server and client | |
| JP2007221522A (en) | Polling device, terminal device, polling method and program | |
| WO2019010799A1 (en) | Internet of things terminal migration method and gateway | |
| CN104468337B (en) | Method for message transmission and device, message management central apparatus and data center | |
| CN109413180B (en) | Data acquisition method, system and equipment and storage medium | |
| CN113726608B (en) | Data processing method and device | |
| CN106790339A (en) | Metadata server, network device, and automatic resource management method | |
| CN111880742B (en) | Distributed storage volume creation method, system, device and computer medium | |
| CN111884921A (en) | Communication method, system, equipment and computer readable storage medium | |
| CN107786310B (en) | Data packet transmission method and node | |
| CN113641688A (en) | Node updating method, related device and computer program product | |
| CN112383491A (en) | Method, device and equipment for determining broadcast time slot and storage medium | |
| CN111970091A (en) | Communication method, system, equipment and computer readable 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 |