CN102710481B - Token turnover control method, device and system - Google Patents

Abstract

The embodiment of the present invention discloses a token turnover control method, device, and system, wherein the method includes: obtaining information about the message sending status of each node in the current logical token transfer ring during the past M rounds of token turnover Historical record information: update the node turnover sequence indicated in the node turnover record information contained in the token according to the historical record information, and the node turnover record information is used to indicate that the token is in the logical token transfer ring The node turnover sequence; according to the node turnover sequence indicated by the updated node turnover record information, the updated token is passed to the corresponding next node. It can allow nodes with message sending needs to send messages faster, reduce the backlog of messages on these nodes, reduce message delay, improve node performance and availability, and increase message throughput.

Description

A token turnover control method, device and system

technical field

The invention relates to the field of token turnover control, in particular to a token turnover control method, device and system.

Background technique

The totem single-ring ordered protocol provides a mechanism for sending globally orderly delivery messages in the domain to upper-layer services. This means that messages require reliability and ordering guarantees. Imposed on the sending domain is a logical token-passing ring within which tokens are passed to control access to the ring, and only Nodes holding tokens are able to send messages. Each node in a logical token-passing ring can send multiple messages each time it gets a token. When all nodes have no messages to send, tokens continue to circulate in the ring.

In the totem system, each node needs to wait for the token before sending a message, which causes a certain delay in sending a message. The larger the node size, the higher the delay; if a node suddenly has a large number of messages It needs to be sent, and the node needs to go through multiple token turnovers to send all the messages. The later the message in the node, the higher the sending delay.

Contents of the invention

Embodiments of the present invention provide a token turnover control method, device and system, which can update the token turnover sequence according to the historical transmission status of each node in the logical token transfer ring, reduce message delay, and improve message throughput.

On the one hand, an embodiment of the present invention provides a token turnover control method, including:

Obtain the historical record information of the message sending situation of each node in the current logical token passing ring during the past M rounds of token turnover;

Update the node turnover sequence indicated in the node turnover record information contained in the token according to the historical record information, and the node turnover record information is used to indicate the node turnover sequence of the token in the logical token transfer ring ;

The updated token is passed to the corresponding next node according to the node turnover sequence indicated by the updated node turnover record information.

On the other hand, the embodiment of the present invention also provides a token turnover method, including:

After the current node receives the token passed in the logical token passing ring, it sends the message to be sent;

Based on the number of messages sent by the node during the token turnover process of the current round, record the number of messages sent in the current round into the node turnover record information corresponding to the node identifier in the token;

The updated token is passed to the corresponding next node according to the node turnover sequence indicated by the node turnover record information in the token.

In another aspect, the embodiment of the present invention also provides a token turnover control device, including:

The obtaining module is used to obtain the historical record information of the message sending situation of each node in the current logical token passing ring during the past M rounds of token turnover;

An update module, configured to update the node turnover sequence indicated in the node turnover record information contained in the token according to the historical record information, the node turnover record information is used to indicate that the token is in the logical token passing ring The node turnover sequence in ;

A sending module, configured to deliver the updated token to the corresponding next node according to the node turnover sequence indicated by the updated node turnover record information.

In another aspect, the embodiment of the present invention also discloses a node for sending messages based on token turnover, including:

The communication module is used to send the message to be sent after receiving the token passed in the logical token passing ring;

A recording module, configured to record the number of messages sent in this round into the node turnover record information corresponding to the node identifier in the token based on the number of messages sent by the node during the token turnover process of the current round ;

The communication module is further configured to transfer the updated token to the corresponding next node according to the node turnover sequence indicated by the node turnover record information in the token.

Finally, the embodiment of the present invention also provides a cluster system using a token ring mechanism, including multiple nodes, and the multiple nodes include: a master node and a slave node, wherein,

The master node is used to obtain the historical record information of each node in the current logic token passing ring in the past M rounds of token turnover process; according to the historical record information, the node contained in the token The node turnover sequence indicated in the turnover record information is updated, and the node turnover record information is used to indicate the node turnover sequence of the token in the logical token transfer ring; according to the node turnover sequence indicated by the updated node turnover record information The turnover sequence passes the updated token to the corresponding next node;

The slave node is used to send the message to be sent after receiving the token passed in the logical token transfer ring, based on the number of messages sent by the node in the token turnover process of the current round, the message sent in the current round The quantity of the token is recorded in the node turnover record information corresponding to the node identification in the token, and the updated token is passed to the corresponding next node according to the node turnover sequence indicated by the node turnover record information in the token. a node.

Implementing the embodiment of the present invention has the following beneficial effects:

It is possible to update the turnover sequence of tokens in nodes according to the historical sending status of each node, which can allow nodes with message sending needs to send messages faster, reduce the backlog of messages on these nodes, reduce message delay, and improve node performance and availability, improving message throughput.

Description of drawings

In order to more clearly illustrate the technical solutions in the embodiments of the present invention or the prior art, the following will briefly introduce the drawings that need to be used in the description of the embodiments or the prior art. Obviously, the accompanying drawings in the following description are only These are some embodiments of the present invention. Those skilled in the art can also obtain other drawings based on these drawings without creative work.

Fig. 1 is a schematic flow chart of the first embodiment of the token turnover control method of the present invention;

Fig. 2 is a schematic flow chart of an embodiment of a token turnover method according to an embodiment of the present invention;

Fig. 3 is a schematic flow chart of the second embodiment of the token turnover control method of the present invention;

Fig. 4 is a schematic diagram of the transfer sequence of tokens in nodes in one of the logical token transfer rings according to an embodiment of the present invention;

Fig. 5 is a schematic structural composition diagram of the first embodiment of the token turnover control device of the present invention;

Fig. 6 is a schematic structural composition diagram of the second embodiment of the token turnover control device of the present invention;

Fig. 7 is a schematic diagram of the structural composition of a node sending messages based on token turnover in the present invention;

FIG. 8 is a schematic diagram of the structural composition of the cluster system using the token ring mechanism of the present invention.

Detailed ways

The following will clearly and completely describe the technical solutions in the embodiments of the present invention with reference to the accompanying drawings in the embodiments of the present invention. Obviously, the described embodiments are only some, not all, embodiments of the present invention. Based on the embodiments of the present invention, all other embodiments obtained by persons of ordinary skill in the art without creative efforts fall within the protection scope of the present invention.

Please refer to FIG. 1 , which is a schematic flow chart of the first embodiment of the token turnover control method of the present invention. In this embodiment, the logical token transfer ring includes multiple nodes, including a token initiation node responsible for token creation , the token initiating node also stores in the token a node turnover record information for indicating the node turnover order of the token in the token transfer ring. After the token initiating node issues the token, according to the node turnover record information, the token is transferred between nodes in the logical token transfer ring, and each node on the ring sends a message when receiving the token. The method in this embodiment specifically includes:

S101: Obtain historical record information of message sending situations of each node in the current logical token passing ring during past M rounds of token turnover.

The method of S101 to obtain the record information of the historical transmission status of each node in the logical token transfer ring may be as follows: the token originating node may save the node turnover record information in the token, and the node turnover record information may be represented by the node turnover table In the form of , in the process of issuing tokens for turnover transfer, after each node obtains the token and sends a message, it will record the number of messages sent in this round into the corresponding node ID in the token In the node turnover record information, the node identifier may be the name of the corresponding node, or other identifiers that can uniquely represent the node.

After each round of token turnover, when the token returns to the token originating node, the token originating node will update and record the historical sending status of each node according to the node turnover record information obtained after the current round of circulation. After the M rounds of token turnover, the statistical results recorded for each node are the historical record information of the message sending situation of each node. The value of M can be adjusted and changed according to the specific conditions of the nodes in the logical token passing ring, so as to better reduce the message sending delay of each node.

The way to obtain the record information of each node’s historical transmission situation in S101 can also be: directly set and save the node turnover record information in the token, and after obtaining the token in each round, according to the described in the token The number of messages sent by each node in this round recorded in the node turnover record information updates the cumulative number of messages sent by each node in the historical record information locally maintained by the token originating node; after the M round of token turnover ends, the The cumulative number of messages sent corresponding to each node recorded in the history record information is used as the history record information of the message sending situation of each node in the logical token passing ring. Wherein, the history record information may be represented in the form of a history record table, and of course may also be represented in the form of a script file or metadata.

S102: According to the historical record information, update the node turnover sequence indicated in the node turnover record information contained in the token. As mentioned above, the node turnover record information is used to indicate the node turnover order of the token in the logical token passing ring.

In said S102, according to the historical record information, determine the nodes in the logical token passing ring that seldom send messages or do not send messages in the historical M rounds of token turnover transfer process, and in the updated node turnover order , in the subsequent N rounds of token turnover, skip these nodes that rarely send messages or do not send messages, that is, do not pass tokens to nodes that rarely send messages or do not send messages, and exploit the right of these nodes to send messages, It is convenient for other nodes that often send messages to send data, and reduces the message sending delay on nodes that often send messages.

S103: Transfer the updated token to a corresponding next node according to the node turnover sequence indicated by the updated node turnover record information. That is, according to the new node turnover sequence, some nodes that rarely send messages or do not send messages are skipped to pass tokens.

As can be seen from the description of the foregoing embodiments, the present invention has the following advantages:

It is possible to update the turnover order of tokens in nodes according to the historical sending status of each node, which can allow nodes with large message sending needs to send messages faster, reduce the backlog of messages on these nodes, reduce message delays, and improve Node performance and availability, improving message throughput.

Please refer to FIG. 2 , which is a schematic flow chart of an embodiment of a token turnover method according to an embodiment of the present invention. In this embodiment, a token turnover method executed by each node within a logical token transfer ring, the method includes:

S201: After the current node receives the token passed in the logical token passing ring, it sends a message to be sent. The node can send one or more messages.

S202: Based on the number of messages sent by the node in the token turnover process of the current round, record the number of messages sent in the current round in the node turnover record information corresponding to the node identifier in the token. The node turnover record information is stored in the token, and the node turnover record information may be expressed in the form of a node turnover table.

S203: Pass the updated token to the corresponding next node according to the node turnover sequence indicated by the node turnover record information in the token.

The tokens in the embodiments of the present invention store node turnover record information, and each token will record the number of messages sent in the current round in the node turnover order after each token obtains the token sending message in each round, so that The token initiating nodes in the logical token transfer ring can arrange the node turnover sequence according to the quantity information recorded in the node turnover sequence.

The token turnover control method of the present invention will be described in detail below in conjunction with FIG. 3 and FIG. 4. FIG. 3 is a schematic flow chart of the second embodiment of the token turnover control method of the present invention. In this embodiment, the method specifically includes:

S301: After the token initiating node obtains the token in each round, update the historical record information locally maintained by the token initiating node according to the number of messages sent by each node in the current round recorded in the node turnover record information in the token The cumulative number of messages sent corresponding to each node in .

S302: After the M rounds of token turnover, the token originating node takes the cumulative message sending quantity corresponding to each node recorded in the historical record information as the historical record of the message sending situation of each node in the logical token transfer ring information.

The value of M is a preset value, which can be modified and adjusted according to user requirements.

The token originating node saves and maintains the node turnover record information in the token while creating the token. The node turnover distance information can be expressed in the form of a node turnover table. Specifically, the node turnover table can include node identification and The node identifies the entry of the number of messages sent by the corresponding node in this round, and in this embodiment, the node turnover table further includes a turnover flag, which is used to indicate that the corresponding node rarely sends messages or does not send messages Cold nodes, or normal nodes that often send messages, when the turnover flag is set to 1, the corresponding node is a normal node, and the token passes through this node when the token is cycled, and when the turnover flag is 0, the corresponding node is a cold node. This node is skipped when the token is cycled.

When the node turnover record information is expressed in the form of a node turnover table, the node turnover table indicates the node turnover sequence by: determining the node turnover sequence according to the sequence of node identifiers and their turnover flags recorded in the entry.

While the token originating node maintains the node turnover record information in the token, it also maintains historical record information locally. The historical record information includes node identification, the cumulative number of messages sent and the turnover identification bit. The cumulative number of messages sent by each node is recorded in the historical record information. Wherein, in this embodiment, the historical record information is represented in the form of a historical record table.

Among them, recording the number of messages sent by each node in each round is through: after each node obtains the token and sends the message, it records the number of messages sent this time in the entry corresponding to the node on the node turnover record information middle.

Specifically, the following Table 1 is one of the manifestations of node turnover record information, and Figure 4 is a schematic diagram of the transfer sequence of tokens in nodes in one of the logical token passing rings, and node A is a logical token passing ring The token initiator above, the S301 and the S302 may specifically include the following steps:

In the first round of token turnover process, the turnover identifier of each node is 1, and the node turnover sequence indicated by the node turnover record information is node A->node B->node C->node D- in Figure 4 > Node A.

After node A obtains the token, it sends 10 messages, and node A records 10 messages in the corresponding number of messages sent in this round in the node turnover table shown in Table 1. Node A passed the token to the node B, and the node B sent 20 messages after obtaining the token, and the node B passed the token to the node C, and the node C did not send a message, and the recorded The number is 0, node C passes the token to the node D, the node D does not send a message, and the number of records is 0. Node D finally passes the token back to said node A.

After the node A obtains the token after the first round of token turnover, the token turnover table in the token is as described in Table 1.

Table 1:

Node ID The number of messages sent in this round Turnover flag Node A 10 1 Node B 20 1 Node C 0 1 Node D 0 1

Node A, as the token originating node, counts the historical sending status of each node in the current round of token turnover process, that is, the cumulative number of messages sent, according to the record of the node turnover table in the history record table, and obtains as described in Table 2 history table.

Table 2:

Node ID Cumulative number of messages sent Turnover flag Node A 10 1 Node B 20 1 Node C 0 1 Node D 0 1

After the statistics are completed, initialize the node turnover table, then send messages again as needed and record the number of messages sent in this round in the node turnover record information, enter the next round of token turnover, and obtain tokens at the end of the turnover, The accumulated message sending quantity corresponding to each node in the historical record information is updated again according to the node turnover record information.

Then execute the next round of token circulation to record the cumulative number of messages sent. After the preset M rounds of token turnover are completed, the token originating node is updated to obtain the final history record table. Take Table 3 as an example.

table 3:

Node ID Cumulative number of messages sent Turnover flag Node A 30 1 Node B 45 1 Node C 0 1 Node D 0 1

After the M round of token turnover is over, the token originating node can determine the cumulative number of messages sent by each node according to the historical record information shown in Table 3 above, as described in Table 3: In the past M rounds In the card cycle, the token passes through each node, and the number of messages sent by the corresponding node is: 30 for node A, 45 for node B, and 0 for node C and node D.

S303: Record the nodes whose cumulative number of message sending recorded in the historical record information after M rounds of token turnover is lower than or equal to a preset number threshold as cold nodes.

The preset quantity threshold is set by the user according to the actual situation. In this embodiment, it is set to 0, that is, only nodes that do not send messages are controlled.

The token initiating node A updates the locally stored node history record information to obtain the node history record information as described in Table 4.

Table 4:

S304: Mark the cold node in the node turnover record information, and update the node turnover sequence indicated in the node turnover record information contained in the token according to the marked cold node, and update the node turnover sequence does not include the marked cold nodes.

Specifically, the S304 may specifically include:

The cold node is marked in the node turnover record information; the way of marking the cold node is by setting the turnover identifier corresponding to the corresponding node identifier in the entry as a skip identifier 0.

Set the turnover flag corresponding to the cold node in the node turnover record information as a skip flag, and complete the update of the node turnover sequence indicated in the node turnover record information contained in the token, so that in the next N rounds of tokens During the turnover process, when the tokens are passed according to the node turnover sequence on the node turnover record information, the cold nodes with the skip turnover mark as the skip flag will be skipped and the tokens will be delivered.

The token initiating node A re-initializes the node turnover table, and sets the turnover flags of node C and node D, marks the node C and node D of the cold node in the node turnover table, and completes the node turnover record contained in the token The node turnover order indicated in the information is updated to obtain the node turnover table shown in Table 5, and the updated node turnover order is node A->node B->node A.

table 5:

Node ID The number of messages sent in this round Turnover flag Node A 0 1 Node B 0 1 Node C 0 0 Node D 0 0

According to the record order of the node identification and the node turnover order indicated by the node turnover table bit in the node turnover table shown in the initialized table 5, the token containing the node turnover table is passed between node A and node B. That is, node A sends a message according to the token, and then passes the token to the node B whose node ID is recorded in the next item in the table and whose turnover flag is 1 according to the turnaround flag. After sending the message, node B sends the message according to the turnaround Flag bit, skip node C and node D marked as cold nodes, and pass it directly to node A.

S305: After the end of the next N rounds of token turnover, set the turnover flag of the cold node set as a skip flag in the node turnover record information to a normal flag, so that in the next token turnover process according to When the node turnover sequence on the node turnover record information passes the token, the token passes through the node. The N value can also be set according to specific conditions.

During the next N rounds of token turnover, node A and node D do not need to record the number of their own messages sent in this round until the end of N rounds of turnover.

S306: Initialize the node turnover record information and the historical record information, so as to execute the above S301 to S305 again.

Repeat S301-S306 until each node in the logic token passing ring stops using.

After node A detects that the token circulates between node A and node B for N rounds, it initializes the node turnover record information and the history record information, and sets the node turnover record information as the cold key of the skip flag. The node's turnaround flag is set to the normal flag. Re-execute said S301 to S305.

It should be noted that node A acts as a token originating node, and the turnover flag remains as a normal flag of 1.

As can be seen from the description of the foregoing embodiments, the present invention has the following advantages:

On the one hand, compared with the existing technology, the node needs to wait for the token to send a message each time, which causes a certain delay for the node to send a message. The larger the node size, the higher the delay; if a node Suddenly there are a large number of messages to be sent, and the node needs to go through multiple token turnovers to send all the messages, and the later the message, the higher the sending delay. In some peer-to-peer architectures, there will be a master control node master (such as the master in citrix XenServer, the DC in pacemaker, etc.). As a master node, it usually needs to process more services (such as data synchronization, etc.). Compared with the non-master node, the master node has more messages to send, and the non-master node needs to send fewer messages. If a single-ring order protocol (totem) is adopted in the peer-to-peer architecture, based on the above scenario, in most of the time, the non-master node does not take any action after getting the token, while a large number of messages on the master node will be backlogged, In the case of message delay, in the embodiment of the present invention, a method that can improve the performance of the master control node and the message throughput of the cluster system is proposed. Specifically, it can selectively skip the message according to the historical sending situation of each node. Some nodes with a small amount of message sending enable tokens to be quickly passed between nodes that need to send messages, thereby enabling nodes that need to send messages to send messages faster, reducing the backlog of messages on these nodes, and reducing the number of messages Delay, improve node performance and availability, and improve the message throughput of the cluster system.

On the other hand, in the embodiment of the present invention, in the cluster system using the Token Ring mechanism, the present invention can allow the node that needs to send the message (indicated by the master control node in this embodiment) to send the message faster, reducing The backlog of a large number of messages on the node in an instant reduces message delay, improves node performance and availability, and improves the message throughput of the cluster system to a certain extent.

The token control device of the present invention will be described in detail below.

Please refer to FIG. 5 , which is a schematic structural diagram of the first embodiment of the token turnover control device of the present invention. In this embodiment, the logical token transfer ring includes a plurality of nodes, and the token turnover control device is used to The creation of tokens and the maintenance of the token turnover mechanism are set in the token originating node. After the token originating node issues the token, the token circulates in the ring, and each node on the ring sends a token when it receives the token. information.

As shown in Figure 5, the token turnover control device includes:

The obtaining module 11 is used to obtain the historical record information of the message sending situation of each node in the current logical token passing ring during the past M rounds of token turnover;

Specifically, the acquisition module 11 can acquire the record information of the historical transmission situation of each node by: saving the node turnover record information in the token, and during the process of issuing the token for circulation, each node obtains After the token is sent and the message is sent, the number of messages sent in this round will be recorded in the node turnover record information corresponding to the node ID in the token. After the current cycle ends, when the token returns to the token initiating node provided with the token turnover control device, the acquisition module 11 checks the history of each node according to the node turnover record information obtained after the current cycle The message sending status is statistically updated and recorded. When the preset cycle number threshold is reached, the statistical result recorded for each node is the historical sending status record information of each node.

For example, in this round of token circulation, after each node obtains a token and sends a message, it records the number of messages sent in this round into the node turnover record information corresponding to the node ID in the token, At the end of the current cycle, the acquisition module 11 accumulates and counts the number of sent messages corresponding to each node recorded on the node turnover record information in the current cycle and the number of sent messages of the corresponding node recorded locally , obtain and record the total number of messages sent by each node after the end of the current cycle, after the preset M rounds of token cycles, the total number of messages sent by each node recorded by the acquisition module 11 is each The node's message sending history information.

The above-mentioned node turnover record information can be expressed in the form of a node turnover table, and of course it can also be expressed in other forms such as script files and metadata.

The update module 12 is configured to update the node turnover sequence indicated in the node turnover record information contained in the token according to the historical record information, and the node turnover record information is used to indicate that the token is in the logical token transfer The order of node turnover within the ring.

The update module 12 can determine the nodes in the logical token passing ring that rarely send messages or do not send messages during the historical M rounds of token turnover transfer according to the historical record information obtained by the obtaining module 11. After the update In the node turnover order of , in the subsequent N rounds of token turnover, skip these nodes that rarely send messages or do not send messages, that is, do not pass tokens to nodes that rarely send messages or do not send messages, and exploit these nodes The right to send messages is convenient for other nodes that often send messages to send data, and reduces the message sending delay on nodes that often send messages.

The sending module 13 is configured to deliver the updated token to the corresponding next node according to the node turnover sequence indicated by the updated node turnover record information.

Implementing the embodiment of the present invention has the following beneficial effects:

It is possible to update the turnover sequence of tokens in nodes according to the historical sending status of each node, which can allow nodes with message sending needs to send messages faster, reduce the backlog of messages on these nodes, reduce message delay, and improve node performance and availability, improving message throughput.

Please refer to FIG. 6 again, which is a schematic structural diagram of the second embodiment of the token turnover control device of the present invention. In this embodiment, the token turnover control device includes the acquisition module 11 in the first embodiment of the above-mentioned device, The update module 12 and the sending module 13, further, the acquisition module 11 in the token turnover control device described in this embodiment may specifically include:

The statistical unit 111 is used to update the historical record information locally maintained by the token originating node according to the number of messages sent by each node in the current round recorded in the node turnover record information in the token after obtaining the token in each round The cumulative number of messages sent corresponding to each node in ;

The acquisition unit 112 is configured to use the cumulative number of message transmissions corresponding to each node recorded in the historical record information as the historical record of the message transmission status of each node in the logical token passing ring after the M rounds of token turnover are completed information;

Among them, the number of messages sent by each node in the logical token passing ring during the token turnover process of the current round is recorded by the following method: after each node obtains the token and sends the message, it will send the message sent in the current round The number of is recorded in the node turnover record information corresponding to the node ID in the token

Further specifically, the updating module 12 includes:

The determining unit 121 is configured to record the nodes whose cumulative number of message sending recorded in the historical record information after M rounds of token turnover is lower than or equal to a preset number threshold as cold nodes;

The update unit 122 is configured to mark the cold node in the node turnover record information, and update the node turnover order indicated in the node turnover record information contained in the token according to the marked cold node, after updating The marked cold node is not included in the node turnover order of ; wherein, the N value is a preset value.

Wherein, the updating unit 122 is specifically used to set the turnover flag corresponding to the cold node determined by the determining unit in the node turnover record information in the token as a skip flag, so as to complete the verification of the The node turnover sequence indicated in the node turnover record information is updated.

The turnover flag in the node turnover record information is used to record normal nodes and cold nodes. When each node passes the token, the node is determined according to the order of the node identification listed on the turnover table and the value of the turnover flag Which node to pass the token to.

Specifically taking the above-mentioned Table 5 as an example, node A as a token originating node is provided with the token turnover control device in this embodiment, and Table 5 indicates that the order of token transfer is from node A to node B to node C to After node D and node A record the number of messages sent in this round in the corresponding entries, it is determined that the turnaround flag of node B is normal flag 1, and then pass the token to the node B. After node B has recorded the number of messages sent in this round, it is determined that the turnover flags of node C and node D are all skip flags 0, so node B will skip node C and node D, and pass the token directly to A.

Finally, after N rounds of token turnover are completed, the updating unit 122 of the token turnover control device is further configured to set the turnover flag of the cold node set as a skip flag in the node turnover record information as a normal flag, In order to pass the token through the node when passing the token according to the node turnover sequence on the node turnover record information in the next token turnover process.

At the same time, the token turnover control device may also include an initialization module 14 for initializing and updating node turnover information and historical record information, specifically,

The initialization module 14 is configured to initialize the node turnover record information and the history record information, and notify the acquisition module to continue to perform the acquisition of the past M rounds of each node in the current logical token passing ring after the initialization is completed. Historical information about message sending during the token rollover process.

After the node turnover record information and the history record information are initialized by the initialization module 14, the next round of token turnover control is entered.

Specifically, the above-mentioned historical record information and node turnover record information can be expressed in the form of a record table, and of course can also be identified in the form of a script file or metadata.

Please refer to FIG. 7 again, which is a schematic diagram of the structure of a node that sends messages based on token turnover in the present invention. In this embodiment, the node that sends messages based on token turnover is used as a logical token transfer ring, except Nodes other than the initiating node, including:

The communication module 21 is configured to send a message to be sent after receiving the token passed in the logical token passing ring. The node that sends messages based on token turnover may send one or more messages.

Recording module 22, configured to record the number of messages sent in this round into the node turnover record information corresponding to the node identifier in the token based on the number of messages sent by the node in the token turnover process of the current round middle. The node turnover record information is stored in the token, and the node turnover record information may be expressed in the form of a node turnover table.

The communication module 21 is further configured to transfer the updated token to the corresponding next node according to the node turnover sequence indicated by the node turnover record information in the token.

The tokens in the embodiments of the present invention store node turnover record information, and each token will record the number of messages sent in the current round in the node turnover order after each token obtains the token sending message in each round, so that The token initiating nodes in the logical token transfer ring can arrange the node turnover sequence according to the quantity information recorded in the node turnover sequence.

Please refer to FIG. 8 , which is a schematic diagram of the structural composition of the cluster system using the token ring mechanism of the present invention. node) and slave nodes (i.e. slave node in Figure 8), in this embodiment, the master node is used as a token originating node for creating and maintaining tokens, and each slave node receives the token as token After the token issued by the master node of the initiating node, send the message to be sent and pass the token, specifically,

The master node is used to obtain the historical record information of each node in the current logic token passing ring in the past M rounds of token turnover process; according to the historical record information, the node contained in the token The node turnover sequence indicated in the turnover record information is updated, and the node turnover record information is used to indicate the node turnover sequence of the token in the logical token transfer ring; according to the node turnover sequence indicated by the updated node turnover record information The turnover sequence passes the updated token to the corresponding next node;

The slave node is used to send the message to be sent after receiving the token passed in the logical token transfer ring (indicated by MSG1, MSG2, MSG3... in FIG. The number of messages sent during the card turnover process, the number of messages sent in this round is recorded in the node turnover record information corresponding to the node identification in the token, according to the node turnover record information in the token The node turnover order of will pass the updated token to the corresponding next node.

Specifically, the master node may specifically be the token turnover control device in the first embodiment of the above-mentioned token turnover control device, or the token turnover control device in the second embodiment of the above-mentioned token turnover control device In the control device, the slave node may be the node that sends messages based on token turnover in the above embodiment.

For the cluster system using the token ring mechanism of the present invention, on the one hand, compared with the prior art, the node needs to wait to get the token before sending a message, which causes a certain delay for the node to send the message , the larger the node size, the higher the delay; if a node suddenly has a large number of messages to send, and the node needs to go through multiple token turnovers to send all the messages, the further behind the message, the higher the delay . In some peer-to-peer architectures, there will be a master control node master (such as the master in citrix XenServer, the DC in pacemaker, etc.). As a master node, it usually needs to process more services (such as data synchronization, etc.). Compared with the non-master node, the master node has more messages to send, and the non-master node needs to send fewer messages.

If a single-ring order protocol (totem) is adopted in the peer-to-peer architecture, based on the above scenario, in most of the time, the non-master node does not take any action after getting the token, while a large number of messages on the master node will be backlogged, In the case of message delay, in the embodiment of the present invention, a method that can improve the performance of the master control node and the message throughput of the cluster system is proposed. Specifically, it can selectively skip the message according to the historical sending situation of each node. Some nodes with a small amount of message sending enable tokens to be quickly passed between nodes that need to send messages, thereby enabling nodes that need to send messages to send messages faster, reducing the backlog of messages on these nodes, and reducing the number of messages Delay, improve node performance and availability, and improve the message throughput of the cluster system.

On the other hand, in the embodiment of the present invention, in the cluster system using the Token Ring mechanism, the present invention can allow the node that needs to send the message (indicated by the master control node in this embodiment) to send the message faster, reducing The backlog of a large number of messages on the node in an instant reduces message delay, improves node performance and availability, and improves the message throughput of the cluster system to a certain extent.

Those of ordinary skill in the art can understand that all or part of the processes in the methods of the above embodiments can be implemented through computer programs to instruct related hardware, and the programs can be stored in a computer-readable storage medium. During execution, it may include the processes of the embodiments of the above-mentioned methods. Wherein, the storage medium may be a magnetic disk, an optical disk, a read-only memory (Read-Only Memory, ROM) or a random access memory (Random Access Memory, RAM), etc.

The above disclosures are only preferred embodiments of the present invention, and certainly cannot limit the scope of rights of the present invention. Therefore, equivalent changes made according to the claims of the present invention still fall within the scope of the present invention.

Claims (11)

1. a token turnover control, is characterized in that, comprising:

Obtain the history information that each node M in the past in current logic token-passing ring takes turns message transmission situation in token circular flow;

According to described history information, upgrade the node turnover order indicated in the node turnover recorded information comprised in token, described node turnover recorded information is used to indicate the node turnover order of described token in logical token passing ring;

The node turnover order indicated according to the node turnover recorded information after described renewal is by the next node of the alternative space after described renewal to correspondence.

2. the method for claim 1, is characterized in that, described node turnover recorded information is also for recording the message quantity forwarded of each node in the token circular flow of epicycle in logical token passing ring;

In described acquisition current logic token-passing ring, in each node M wheel token circular flow in the past, the history information of message transmission situation comprises:

After each is taken turns and gets token, upgrade token according to the message quantity forwarded of each the node epicycle recorded in the described node turnover recorded information in token and initiate the total message quantity forwarded that in the history information of node local maintenance, each node is corresponding;

Take turns after token turnover terminates at M, total message quantity forwarded corresponding to each node recorded by described history information sends the history information of situation as the message of each node in logical token passing ring;

Wherein, the message quantity forwarded of each node in the token circular flow of epicycle records by the following method in logical token passing ring: each node is getting token and after sending message, the quantity of message epicycle sent is recorded in the node turnover recorded information corresponding with this node identification in described token.

3. method as claimed in claim 2, is characterized in that, described according to described history information, carries out renewal comprise the node turnover order indicated in the node turnover recorded information comprised in token:

M is taken turns token turnover terminate after described history information in the total message quantity forwarded that records be cold node less than or equal to the nodes records of the amount threshold preset;

Described cold node is marked in described node turnover recorded information, and according to the cold node marked, the node turnover order indicated in the node turnover recorded information comprised in token is upgraded, the cold node be labeled out described in not comprising in node turnover order in the updated.

4. method as claimed in claim 3, is characterized in that, also comprises the turnover mark for recording each node in described node turnover recorded information;

Describedly in described node turnover recorded information, mark described cold node, and according to the cold node marked, renewal carried out to the node turnover order indicated in the node turnover recorded information comprised in token and comprise:

Described cold node is marked in described node turnover recorded information;

Turnover mark corresponding for cold node in described node turnover recorded information is set to and skips mark, complete the renewal to the node turnover order indicated in the node turnover recorded information comprised in token, so that when ensuing N takes turns in token circular flow the node turnover sequence delivery token had enough to meet the need according to described node in recorded information, turnover will be skipped and will be masked as the cold node transmission token skipping mark.

5. method as claimed in claim 4, is characterized in that, also comprise:

After the turnover of ensuing N wheel token terminates, the turnover traffic sign placement of the cold node skipping mark is set to for normal mark by described node turnover recorded information, so that when having enough to meet the need sequence delivery token according to the node in described node turnover recorded information in ensuing token circular flow, token is through this node;

Node turnover recorded information and described history information described in initialization, again to perform the history information that each node M in the past in described acquisition current logic token-passing ring takes turns message transmission situation in token circular flow.

6. all rotation control apparatus of token, is characterized in that, comprising:

Acquisition module, takes turns the history information of message transmission situation in token circular flow for obtaining each node M in the past in current logic token-passing ring;

Update module, for according to described history information, upgrade the node turnover order indicated in the node turnover recorded information comprised in token, described node turnover recorded information is used to indicate the node turnover order of described token in logical token passing ring;

Sending module, for the node turnover order according to the node turnover recorded information instruction after described renewal by the next node of the alternative space after described renewal to correspondence.

7. device as claimed in claim 6, is characterized in that, described node turnover recorded information is also for recording the message quantity forwarded of each node in the token circular flow of epicycle in logical token passing ring, and described acquisition module comprises:

Statistic unit, after taking turns at each and getting token, upgrade token according to the message quantity forwarded of each the node epicycle recorded in the described node turnover recorded information in token and initiate the total message quantity forwarded that in the history information of node local maintenance, each node is corresponding;

Acquiring unit, for taking turns after token turnover terminates at M, total message quantity forwarded corresponding to each node recorded by described history information sends the history information of situation as the message of each node in logical token passing ring;

Wherein, the message quantity forwarded of each node in the token circular flow of epicycle records by the following method in logical token passing ring: each node is getting token and after sending message, the quantity of message epicycle sent is recorded in the node turnover recorded information corresponding with this node identification in described token.

8. device as claimed in claim 7, it is characterized in that, described update module comprises:

Determining unit, for M is taken turns token turnover terminate after described history information in the total message quantity forwarded that records be cold node less than or equal to the nodes records of the amount threshold preset;

Updating block, for marking described cold node in described node turnover recorded information, and according to the cold node marked, the node turnover order indicated in the node turnover recorded information comprised in token is upgraded, the cold node be labeled out described in not comprising in node turnover order in the updated.

9. device as claimed in claim 8, is characterized in that, also comprises the turnover mark for recording each node in described node turnover recorded information;

Described updating block is specifically set to for corresponding turnover mark in described node turnover recorded information in token of the cold node described determining unit determined and skips mark, upgrades with the node turnover order completed indicating in the node turnover recorded information comprised in token.

10. device as claimed in claim 9, is characterized in that,

Described updating block is also for after the turnover of ensuing N wheel token terminates, the turnover traffic sign placement of the cold node skipping mark is set to for normal mark by described node turnover recorded information, so that when having enough to meet the need sequence delivery token according to the node in described node turnover recorded information in ensuing token circular flow, token is through this node;

Described device also comprises:

Initialization module, for node turnover recorded information and described history information described in initialization, and after initialization completes, notify that in described acquisition module continuation execution acquisition current logic token-passing ring, in each node M wheel token circular flow in the past, message sends the history information of situation.

11. 1 kinds of group systems using token ring mechanism, it is characterized in that, comprise multiple node, described multiple node comprises: host node and from node, wherein,

Described host node, takes turns the history information of message transmission situation in token circular flow for obtaining each node M in the past in current logic token-passing ring; According to described history information, upgrade the node turnover order indicated in the node turnover recorded information comprised in token, described node turnover recorded information is used to indicate the node turnover order of described token in logical token passing ring; The node turnover order indicated according to the node turnover recorded information after described renewal is by the next node of the alternative space after described renewal to correspondence;

Described from node, for after the token that passes in receive logic token-passing ring, send message to be sent, in the token circular flow of epicycle, the quantity of message is sent based on this node, the quantity of the message of epicycle transmission be recorded in the node turnover recorded information corresponding with this node identification in described token, the node turnover order indicated by the node turnover recorded information in described token is by the next node of the alternative space after renewal to correspondence.