CN113872857B - Cross-machine-room data forwarding method, equipment and computer program product - Google Patents

Abstract

The invention discloses a cross-computer room data forwarding method, equipment and products. By using cross-computer room edge nodes to construct a block chain network, the underlying block chain account book can be used to record the entire operation process to ensure the consistency of global forwarding path information; Through the consensus verification function provided by the smart contract in the blockchain network, when the cross-computer room routing strategy changes, it is necessary for the adjacent edge nodes to perform consensus verification on the cross-computer room forwarding path before and after the change, even if the current routing strategy change is due to malicious or The wrong node configuration caused by the downtime node can also be identified in time through the consensus evaluation process; in the end, only the cross-computer room path changes that pass the consensus verification can take effect, avoiding the manual or other configuration of the cross-computer room data forwarding process The wrong node has a negative impact on the computer room, thus greatly improving the reliability of the forwarding path on the premise of ensuring the consistency of data forwarding methods across computer rooms.

Description

Method, device and computer program product for forwarding data across computer rooms

Technical Field

The present invention relates to the field of video live broadcast technology, and in particular to a method, device and computer program product for forwarding data across computer rooms.

Background Art

With the rapid development of live video technology, video conferencing, live video and other forms of instant communication can be seen everywhere in people's work and life. As a standard technology stack in the field of video conferencing and live broadcasting, WebRTC (Web Real-Time Communication) is gradually being widely recognized. At the same time, based on the SFU (Selective Forwarding Unit) communication architecture of WebRTC, the WebRTC system can quickly expand to a multi-node cascade connection mode, and achieve optimal forwarding in the same domain (computer room) through node forwarding and routing calculation.

However, in the scenario of cross-computer room data forwarding, it is necessary to establish an additional system to connect the entire data flow link in series, so as to accurately query the forwarding link and the corresponding computer room node when an accident occurs, and assist the operation and maintenance personnel to quickly locate the error problem. Therefore, the forwarding policy storage across computer rooms needs to ensure the consistency of the policy on a global scale. Since there is currently no recognized solution to the problem of WebRTC cross-computer room audio and video stream forwarding policy storage in the industry, the consistency of the forwarding path is generally ensured by the configuration of technical personnel. When the technical personnel are mismatched, it is easy for erroneous traffic to flow into the same computer room, which may cause the computer room to be overloaded and paralyzed. The above situation reflects the technical problem of poor reliability of the existing manual method of maintaining the consistency of cross-computer room data forwarding.

Summary of the invention

The main purpose of the present invention is to propose a method, device and computer program product for data forwarding across computer rooms, aiming to solve the technical problem of poor reliability of the existing manual method for maintaining consistency of data forwarding across computer rooms.

To achieve the above object, the present invention provides a method for forwarding data across computer rooms, the method comprising:

Monitoring cross-computer room routing policy change information from a blockchain network composed of edge nodes deployed in different computer rooms, wherein the blockchain network has deployed path forwarding related smart contracts;

Determine that the routing policy change information corresponds to a destination edge node in the blockchain network, and broadcast the routing policy change information to adjacent edge nodes of the destination edge node in the blockchain network according to the smart contract;

Performing consensus verification on the routing policy change information according to the adjacent edge nodes and the smart contract, so as to determine a target forwarding path after the routing policy change when the routing policy change information passes the consensus verification;

The target forwarding path is synchronized to the path edge nodes constituting the target forwarding path in the blockchain network, so that the path edge nodes can forward data according to the target forwarding path.

Optionally, the routing policy change information includes routing new information.

The step of determining that the routing policy change information corresponds to a destination edge node in the blockchain network, and broadcasting the routing policy change information to adjacent edge nodes of the destination edge node in the blockchain network according to the smart contract includes:

Determine a newly added destination edge node in the blockchain network and a source edge node corresponding to the newly added destination edge node from the newly added routing information, and generate a storage object of the newly added destination edge node based on the newly added destination edge node and the source edge node, so as to store the storage object in the smart contract;

Determine a first adjacent edge node adjacent to the newly added destination edge node from the blockchain network, and broadcast the newly added destination edge node to the first adjacent edge node.

Optionally, the step of performing consensus verification on the routing policy change information according to the adjacent edge node and the smart contract to determine a target forwarding path after the routing policy change when the routing policy change information passes the consensus verification includes:

Obtain a test result of a connectivity test performed by the first adjacent edge node on the newly added destination edge node, and obtain a quality assessment mean corresponding to the newly added destination edge node by combining the test result and the newly added consensus algorithm in the smart contract;

Determine whether the quality assessment mean is not less than a preset scoring threshold;

If yes, generating a new forwarding path consisting of the newly added destination edge node and the first adjacent edge node, and storing the newly added forwarding path in the blockchain network;

Based on the newly added forwarding path and the initial forwarding path in the blockchain network, the target forwarding path is generated according to a preset first path splicing principle.

Optionally, the routing policy change information includes routing update information.

The step of determining that the routing policy change information corresponds to a destination edge node in the blockchain network, and broadcasting the routing policy change information to adjacent edge nodes of the destination edge node in the blockchain network according to the smart contract includes:

Determine, from the routing update information, a historical destination edge node and a candidate destination edge node deployed in the same computer room in the blockchain network;

Determine a second adjacent edge node in the blockchain network that is adjacent to the candidate destination edge node, and broadcast the historical destination edge node and the candidate destination edge node to the second adjacent edge node.

Optionally, the step of performing consensus verification on the routing policy change information according to the adjacent edge node and the smart contract to determine a target forwarding path after the routing policy change when the routing policy change information passes the consensus verification includes:

Acquire a historical link evaluation index obtained by the second adjacent edge node performing link quality evaluation on the historical destination edge node, and a candidate link evaluation index obtained by performing link quality evaluation on the candidate destination edge node;

Determine whether the candidate destination edge node is valid by combining the historical link evaluation index, the candidate link evaluation index and the updated consensus algorithm in the smart contract;

If yes, generating an updated forwarding path consisting of the candidate destination edge node and the second adjacent edge node, and storing the updated forwarding path in the blockchain network;

Based on the updated forwarding path and the initial forwarding path in the blockchain network, the target forwarding path is generated according to a preset second path splicing principle.

Optionally, before the step of monitoring the cross-computer room routing policy change information from the blockchain network formed by the edge nodes deployed in different computer rooms, the step further includes:

Obtain the intra-computer room forwarding path information of each computer room in the blockchain network, and store the intra-computer room forwarding path information in the blockchain network in a hashed manner.

Optionally, after the step of obtaining the forwarding path information in the computer room and storing the forwarding path information in the computer room in a hashed manner in the blockchain network, the method further includes:

When it is detected that wrong routing data forwarding occurs in the blockchain network, actual data forwarding information inside each computer room of the blockchain network is obtained from each computer room of the blockchain network;

The actual data forwarding information is compared with the forwarding path information in the computer room to obtain a comparison result, so as to troubleshoot the cause of the erroneous forwarding based on the comparison result.

Optionally, before the step of monitoring the cross-computer room routing policy change information from the blockchain network formed by the edge nodes deployed in different computer rooms, the step further includes:

Determine the edge nodes deployed in different computer rooms, build a blockchain network based on the edge nodes, and deploy smart contracts related to the forwarding path;

Initial configuration information is obtained, a physical adjacency relationship between the edge nodes is established according to the initial configuration information, and an initial forwarding path of the blockchain network is determined based on the physical adjacency relationship.

In addition, to achieve the above-mentioned purpose, the present invention also provides a cross-computer room data forwarding system, the cross-computer room data forwarding system comprising:

A routing policy change module, used to monitor the routing policy change information across computer rooms from a blockchain network composed of edge nodes deployed in different computer rooms, wherein the blockchain network has deployed smart contracts related to path forwarding;

An adjacent node broadcast module, used to determine that the routing policy change information corresponds to a destination edge node in the blockchain network, and broadcast the routing policy change information to adjacent edge nodes of the destination edge node in the blockchain network according to the smart contract;

A change consensus verification module, used to perform consensus verification on the routing policy change information according to the adjacent edge nodes and the smart contract, so as to determine the target forwarding path after the routing policy change when the routing policy change information passes the consensus verification;

The target path synchronization module is used to synchronize the target forwarding path to the path edge nodes constituting the target forwarding path in the blockchain network, so that the path edge nodes can forward data according to the target forwarding path.

In addition, to achieve the above-mentioned purpose, the present invention also provides a cross-computer room data forwarding device, which includes: a memory, a processor, and a cross-computer room data forwarding program stored on the memory and executable on the processor, and when the cross-computer room data forwarding program is executed by the processor, the steps of the cross-computer room data forwarding method as described above are implemented.

In addition, to achieve the above objectives, the present invention also provides a computer-readable storage medium, on which a cross-computer room data forwarding program is stored, and when the cross-computer room data forwarding program is executed by a processor, the steps of the cross-computer room data forwarding method as described above are implemented.

In addition, to achieve the above-mentioned purpose, the present invention also provides a computer program product, including a computer program, and when the computer program is executed by a processor, the steps of the above-mentioned method for forwarding data across computer rooms are implemented.

The present invention uses edge nodes across computer rooms to build a blockchain network and deploys smart contracts related to path forwarding, so that the entire operation process can be recorded using the underlying blockchain account book to ensure the consistency of global forwarding path information; by using the consensus verification function for the cross-computer room forwarding path provided by the smart contract technology, when the routing strategy changes, the relevant adjacent edge nodes are required to perform consensus verification on the cross-computer room forwarding path before and after the change, so that even if the current routing strategy change is caused by an erroneous node configuration such as a malicious or downtime node, it can be timely identified through the consensus evaluation process; ultimately, only the cross-computer room path change that passes the consensus verification can take effect, avoiding the negative impact on the computer room caused by the erroneous nodes configured manually or in other ways in the cross-computer room data forwarding process, greatly improving the reliability of cross-computer room data forwarding, that is, on the premise of ensuring the consistency of the cross-computer room data forwarding method, the reliability of the forwarding path is greatly improved, thereby solving the technical problem of poor reliability of the existing manual method for maintaining the consistency of cross-computer room data forwarding.

BRIEF DESCRIPTION OF THE DRAWINGS

FIG1 is a schematic diagram of the device structure of the hardware operating environment involved in the embodiment of the present invention;

FIG2 is a schematic diagram of a flow chart of a first embodiment of a method for forwarding data across computer rooms according to the present invention;

3 is a schematic diagram of the functional module division of an audio and video stream cross-machine room routing smart contract in a specific embodiment of the second embodiment of the cross-machine room data forwarding method of the present invention;

4 is a schematic diagram of path addition and update operations of a cross-computer room routing smart contract in a specific embodiment of the second embodiment of the cross-computer room data forwarding method of the present invention;

5 is a schematic diagram of a contract call logic flow of a specific embodiment of the second embodiment of the cross-machine room data forwarding method of the present invention;

6 is a schematic diagram of blockchain network construction and routing smart contract deployment of multiple computer room edge nodes in a specific embodiment of the third embodiment of the cross-computer room data forwarding method of the present invention;

7 is a schematic diagram of data flow forwarding across physical nodes in computer rooms in a specific embodiment of the third embodiment of the method for forwarding data across computer rooms of the present invention;

8 is a schematic diagram of the overall flow of another specific embodiment of the third embodiment of the method for forwarding data across computer rooms of the present invention;

FIG. 9 is a schematic diagram of the functional modules of the inter-computer room data forwarding system of the present invention.

The realization of the purpose, functional features and advantages of the present invention will be further explained in conjunction with embodiments and with reference to the accompanying drawings.

DETAILED DESCRIPTION

It should be understood that the specific embodiments described herein are only used to explain the present invention and are not intended to limit the present invention. The present invention relates to the following technologies:

Content Delivery Network (CDN) technology. Digital content service providers deploy edge nodes close to users and distribute content to corresponding nodes according to rules. When users request content, CDN forwards requests from different regions to the edge nodes closest to users through global load balancing technology, aiming to provide users with low-latency services.

WebRTC is an API standard for browsers to conduct real-time voice or video conversations. Currently, there are multiple open source projects that support the construction of enterprise-level conferences and live broadcast systems, and it has gradually become a more commonly used technology in the field of audio and video live broadcasting.

At present, the SFU architecture in the WebRTC system is the current mainstream choice. By establishing the production and consumption data flow of audio and video streams, multi-node and cross-computer room data flow forwarding is realized, which increases the flexibility of networking. WebRTC node cascading is the standard solution for current large-scale video conferencing systems. The forwarding of audio and video streams is established between nodes to achieve the transparency of end-to-end data flow forwarding on the user side. Users do not need to perceive the intermediate forwarding rules. The system automatically creates forwarding links in the same computer room or across regional computer rooms for selected users through routing calculation. Based on the SFU communication architecture of WebRTC, the WebRTC system can quickly expand to a multi-node cascade connection mode, and achieve optimal forwarding in the same domain (computer room) through node forwarding and routing calculation. However, in the scenario of cross-computer room data forwarding, it is necessary to establish an additional system to connect the entire data flow link in series, so that the forwarding link and the corresponding computer room node can be accurately queried when an accident occurs, and the operation and maintenance personnel can quickly locate the error problem. Therefore, the forwarding policy storage across computer rooms needs to ensure the consistency of the policy in a global scope. Since there is no recognized solution to the problem of WebRTC cross-machine room audio and video stream forwarding strategy storage in the industry, the consistency of the forwarding path is generally ensured by the configuration of technical personnel. When the technical personnel are mismatched, it is easy for the wrong traffic to flow into the same machine room, which may cause the machine room to be overloaded and paralyzed. The above situation reflects the technical problem of poor reliability of the existing manual method of maintaining the consistency of cross-machine room data forwarding.

In order to solve the above problems, the present invention provides a cross-computer room data forwarding method, that is, by using the edge nodes across computer rooms to build a blockchain network and deploying smart contracts related to path forwarding, the underlying blockchain account book can be used to record the entire operation process to ensure the consistency of the global forwarding path information; by using the consensus verification function for the cross-computer room forwarding path provided by the smart contract technology, when the routing strategy changes, the relevant adjacent edge nodes are required to perform consensus verification on the cross-computer room forwarding path before and after the change, so that even if the current routing strategy change is caused by an erroneous node configuration such as a malicious or downtime node, it can be timely identified through the consensus evaluation process; finally, only the cross-computer room path change that passes the consensus verification can take effect, avoiding the negative impact of the cross-computer room data forwarding process on the computer room caused by the erroneous nodes configured manually or in other ways, greatly improving the reliability of the cross-computer room data forwarding, that is, on the premise of ensuring the consistency of the cross-computer room data forwarding method, the reliability of the forwarding path is greatly improved, thereby solving the technical problem of poor reliability of the existing manual method of maintaining the consistency of cross-computer room data forwarding.

As shown in FIG. 1 , FIG. 1 is a schematic diagram of the device structure of the hardware operating environment involved in the embodiment of the present invention.

As shown in Figure 1, the cross-computer room data forwarding system may include: a processor 1001, such as a CPU, a user interface 1003, a network interface 1004, a memory 1005, and a communication bus 1002. Among them, the communication bus 1002 is used to realize the connection and communication between these components. The user interface 1003 may include a display screen (Display), an input unit such as a keyboard (Keyboard), and the optional user interface 1003 may also include a standard wired interface and a wireless interface. The network interface 1004 may optionally include a standard wired interface and a wireless interface (such as a WI-FI interface). The memory 1005 may be a high-speed RAM memory, or a stable memory (non-volatile memory), such as a disk memory. The memory 1005 may also be a storage device independent of the aforementioned processor 1001.

Those skilled in the art will appreciate that the device structure shown in FIG. 1 does not constitute a limitation on the device, and may include more or fewer components than shown, or a combination of certain components, or a different arrangement of components.

As shown in FIG. 1 , the memory 1005 as a computer storage medium may include an operating system, a network communication module, a user interface module, and an inter-computer room data forwarding program.

In the device shown in Figure 1, the network interface 1004 is mainly used to connect to the background server and communicate data with the background server; the user interface 1003 is mainly used to connect to the client (programmer side) and communicate data with the client; and the processor 1001 can be used to call the cross-computer room data forwarding program stored in the memory 1005, and perform the operations in the following cross-computer room data forwarding method.

Based on the above hardware structure, an embodiment of the method for forwarding data across computer rooms of the present invention is proposed.

Referring to Figure 2, Figure 2 is a flow chart of a first embodiment of a method for forwarding data across computer rooms of the present invention. The method for forwarding data across computer rooms includes:

Step S10, monitoring the cross-computer room routing policy change information from the blockchain network composed of edge nodes deployed in different computer rooms, wherein the blockchain network has deployed a smart contract related to path forwarding;

In this embodiment, the present invention is applied to a cross-computer room data forwarding system (hereinafter referred to as the system) based on CDN technology and SFU architecture. The blockchain network is composed of multiple edge nodes deployed in different computer rooms, and the blockchain network stores the relevant information of each edge node. Smart contracts are related to path forwarding in the blockchain network.

Since the initial forwarding path between edge nodes across computer rooms is set by default at the beginning of the blockchain network construction, when the system captures a node or path different from the initial forwarding path through active detection or receiving external instructions, it will be regarded as a routing policy change and the corresponding information will be obtained as the above-mentioned routing policy change information.

There may be two situations when the routing strategy changes. The first situation is that when the system queries the forwarding path, it detects a newly added and physically reachable edge node and treats it as a newly added edge node. The second situation is that when the system executes the internal routing algorithm, it finds that the original edge node in the initial forwarding path may not be the optimal edge node, and uses other edge nodes in the blockchain network that are not in the initial forwarding path as candidate edge nodes.

Specifically, the system constructs a blockchain network through edge nodes in each computer room, deploys the above-mentioned smart contract in the blockchain network, and generates a storage object for each edge node in the smart contract to store relevant information of each edge node, which may include the starting computer room information of the edge node, the next-hop neighbor computer room information, etc. When each computer room in the system starts to execute the data flow forwarding routing strategy within the private domain, if the edge node in the same computer room switches, the routing strategy change information at this time is captured.

Step S20, determining that the routing policy change information corresponds to a destination edge node in the blockchain network, and broadcasting the routing policy change information to adjacent edge nodes of the destination edge node in the blockchain network according to the smart contract;

In this embodiment, the destination edge node is the node where data flows into the destination computer room, which may be the newly added edge node in the first case or the candidate edge node in the second case. The adjacent edge node refers to the edge node in the blockchain network that has a physical adjacent relationship with the destination edge node.

Specifically, when a routing policy changes, whether it is a new routing policy or a changed routing policy, the system cannot directly obtain whether the new routing policy is feasible or whether the changed routing policy is better than the routing policy before the change, so the assistance of the relevant adjacent edge nodes is required. The system determines the new edge nodes or candidate edge nodes that have changed at this time based on the routing policy change information, and determines the adjacent edge nodes that have a physical link relationship with the new edge nodes or candidate edge nodes in the blockchain network (the specific number is determined by the actual situation), and then broadcasts the routing policy change information to each adjacent edge node.

Step S30, performing consensus verification on the routing policy change information according to the adjacent edge node and the smart contract, so as to determine a target forwarding path after the routing policy change when the routing policy change information passes the consensus verification;

Step S40, synchronizing the target forwarding path to the path edge nodes constituting the target forwarding path in the blockchain network, so that the path edge nodes forward data according to the target forwarding path.

In this embodiment, the system allows the relevant adjacent edge nodes to conduct consensus verification when a policy change is discovered, for example, at least the link communication quality is examined, so that the impact of the policy change on the link communication quality can be examined, especially the mismatch forwarding strategy caused by human or other means can be captured. The link communication quality can be specifically reflected by one or more performance indicators, such as connectivity, bandwidth, delay, jitter, etc.

Specifically, after receiving the broadcast, the adjacent edge nodes in the system verify the link communication quality corresponding to the routing policy change information, obtain the verification result, and report the verification result to the smart contract. The smart contract uses the verification result as the input of the preset consensus formula to determine whether the routing policy change can take effect based on the consensus formula. If the adjacent edge node has not completed the verification of the destination edge node, but the timeout has been triggered at this time, the smart contract directly performs consensus calculation to determine whether the routing policy change can take effect. If it can take effect, the system determines the target forwarding path after the change based on the routing policy change information; if it cannot take effect, the current change is abandoned. In addition, in the process of determining the target forwarding path, in addition to examining the link communication quality, the principles of shortest distance, latest path and load balancing can also be considered.

After determining the target forwarding path, the system deploys the routing strategy of this target forwarding path to each path edge node. After deployment, if the blockchain network needs to perform the task of forwarding data streams across computer rooms, it can forward the audio and video data streams along the target forwarding path according to this updated routing strategy.

The present embodiment provides a cross-computer room data forwarding method, which uses edge nodes across computer rooms to build a blockchain network and deploy smart contracts related to path forwarding, so that the entire operation process can be recorded using the underlying blockchain account book to ensure the consistency of global forwarding path information; by using the consensus verification function for the cross-computer room forwarding path provided by the smart contract technology, when the routing policy changes, the relevant adjacent edge nodes are required to perform consensus verification on the cross-computer room forwarding path before and after the change, so that even if the current routing policy change is caused by an erroneous node configuration such as a malicious or downtime node, it can be timely identified through the consensus evaluation process; finally, only the cross-computer room path change that passes the consensus verification can take effect, avoiding the negative impact of the cross-computer room data forwarding process on the computer room caused by the erroneous nodes configured manually or in other ways, greatly improving the reliability of cross-computer room data forwarding, that is, on the premise of ensuring the consistency of the cross-computer room data forwarding method, the reliability of the forwarding path is greatly improved, thereby solving the technical problem of poor reliability of the existing manual method of maintaining the consistency of cross-computer room data forwarding.

Further, based on the first embodiment shown in FIG2 , a second embodiment of the cross-computer room data forwarding method of the present invention is proposed. In this embodiment, the routing policy change information includes routing new information, and step S20 includes:

Step S211, determining a newly added destination edge node in the blockchain network and a source edge node corresponding to the newly added destination edge node from the newly added routing information, and generating a storage object of the newly added destination edge node based on the newly added destination edge node and the source edge node, so as to store the storage object in the smart contract;

Step S212: determine a first adjacent edge node adjacent to the newly added destination edge node from the blockchain network, and broadcast the newly added destination edge node to the first adjacent edge node.

In this embodiment, the first case is mainly described, and the newly added destination edge node corresponds to the first case. When the smart contract receives a new forwarding routing path node (i.e., the newly added destination edge node), a corresponding storage object will be generated in the contract according to the acquired routing information. As a specific implementation method, the storage object can be abbreviated as R, which contains at least the source computer room information and the destination computer room information.

Source computer room information: represents the starting computer room of the forwarding path and the edge node in the source computer room where the data flow flows out. It is used for the outflow of data across computer rooms and is stored in the form of key-value pairs:

pos _s :node _s ;

Among them, pos _s represents the name of the source computer room, and node _s is the name of the edge node in the source computer room. In the specific implementation process, it can be replaced by IP information;

Destination room information: represents the destination (next-hop neighbor) room information of the path, and the edge node where the data flows into the destination room, which is used to receive the data stream and is stored in key-value pairs:

pos _d :node _d ;

Among them, pos _d represents the name of the destination computer room, node _d is the name of the edge node in the destination computer room, and IP information can also be replaced during the specific implementation process.

In addition to the above-mentioned source computer room information and destination computer room information, R may also include an extension field, which is used to expand the storage object function in the future.

After the system generates a corresponding storage object for the newly added destination edge node in the smart contract, it determines several adjacent edge nodes adjacent to the newly added destination edge node from the blockchain network as the above-mentioned first adjacent edge nodes, and then broadcasts the relevant information of the newly added destination edge node to each first adjacent edge node.

Further, step S30 includes:

Step S311, obtaining a test result of a connectivity test performed by the first adjacent edge node on the newly added destination edge node, and combining the test result and the newly added consensus algorithm in the smart contract to obtain a quality assessment mean corresponding to the newly added destination edge node;

Step S312, determining whether the quality assessment mean is not less than a preset scoring threshold;

Step S313: If yes, generate a new forwarding path consisting of the newly added destination edge node and the first adjacent edge node, and store the newly added forwarding path in the blockchain network;

Step S314: Based on the newly added forwarding path and the initial forwarding path in the blockchain network, the target forwarding path is generated according to a preset first path splicing principle.

In this embodiment, the number of the first adjacent edge nodes is multiple for illustration. Each adjacent edge node verifies the connectivity between itself and the newly added destination edge node, and reports the connectivity verification result (i.e., the above test result) to the smart contract. The smart contract uses this test result as the input of the newly added consensus algorithm to perform corresponding calculations and obtain the quality assessment mean of the newly added destination edge node.

As a specific implementation method, the formula of the newly added consensus algorithm is as follows:

Among them, j represents the forwarding node corresponding to the newly added destination computer room, m is the number of all edge nodes in the computer room adjacent to the destination computer room, score _i->j is the link evaluation index of the i-th node for the edge node j of the destination computer room corresponding to the newly added path (that is, the above test result), and S is the mean value of the link quality evaluation.

When S≥T _conf (that is, the preset scoring threshold mentioned above, which can be flexibly configured according to actual needs), the newly added path is passed, and the path record contained in the object R is stored in the smart contract; when S<T _conf , the newly added route fails to pass this consensus, and the storage object R is rejected.

When the newly added destination edge node passes this consensus, the system combines all the data center storage objects R that have passed the consensus, uses the breadth or depth traversal search method to perform path splicing, and converts it into an actual data flow path. The specific first path splicing principle adopted may include one or more of the following principles:

Shortest distance principle: When there are multiple paths between the source computer room and the destination computer room, the path with the least number of forwarding nodes is selected;

The latest path principle: When the number of path nodes is the same, the most recently updated path is selected;

Load balancing principle: When the number of path nodes is the same and the path update time is similar, select an appropriate random formula to achieve the purpose of data flow load balancing.

This embodiment uses a new forwarding path and consensus method based on smart contracts. When the routing strategy changes, a consensus evaluation of the edge nodes in the neighboring computer room is required. Only the path change after the contract consensus can take effect, that is, through the path consensus formula of the routing contract, it prevents mismatched routing or low link quality paths from reducing forwarding efficiency, and the consensus execution rules of the contract will not be affected by a small number of malicious or downtime nodes. In addition, by setting the path splicing principle, the purpose of the shortest path and preventing the path from forming a loop is achieved.

Further, the routing policy change information includes routing update information, and step S20 includes:

Step S221, determining the historical destination edge nodes and candidate destination edge nodes deployed in the same computer room in the blockchain network from the routing update information;

Step S222, determine a second adjacent edge node adjacent to the candidate destination edge node in the blockchain network, and broadcast the historical destination edge node and the candidate destination edge node to the second adjacent edge node.

In this embodiment, the second case is mainly described, and the candidate destination edge node corresponds to the second case.

The system receives the path information to be changed, including the historical source computer room and historical source edge nodes before the update, and the candidate destination computer room and candidate destination edge nodes after the update. After receiving the update information, the smart contract will notify the nodes adjacent to the edge nodes in the new and old destination computer rooms before and after the update in the blockchain network (i.e., the second adjacent edge nodes) to perform path verification.

Further, step S30 includes:

Step S321, obtaining a historical link evaluation index obtained by the second adjacent edge node performing link quality evaluation on the historical destination edge node, and a candidate link evaluation index obtained by performing link quality evaluation on the candidate destination edge node;

Step S322, combining the historical link evaluation index, the candidate link evaluation index and the update consensus algorithm in the smart contract, determining whether the candidate destination edge node is valid;

Step S323: If yes, generate an updated forwarding path consisting of the candidate destination edge node and the second adjacent edge node, and store the updated forwarding path in the blockchain network;

Step S324: Based on the updated forwarding path and the initial forwarding path in the blockchain network, the target forwarding path is generated according to a preset second path splicing principle.

In this embodiment, the specific implementation method of the second adjacent edge node performing link quality evaluation on the historical destination edge node and the candidate destination edge node can be to calculate an evaluation index. For example, the evaluation index is recorded as score, which can be divided into a score interval of [0, 100] and is positively correlated with the link quality. The evaluation basis includes performance indicators such as connectivity, bandwidth, delay, and jitter between the verification node and the destination edge node.

The smart contract uses the historical link evaluation index and the candidate link evaluation index as input to the newly added consensus algorithm to perform corresponding calculations and obtain the quality evaluation mean of the candidate destination edge nodes.

As a specific implementation method, the above evaluation index is used as the input of the following consensus formula, and the formula for updating the consensus algorithm is as follows:

j _new =argmaxS(j;i∈[1,m]);

代表目的机房的历史转发节点集合，j是所有属于历史集合的节点，m是与目的机房邻接机房的所有边缘节点个数，score_i->j是第i个节点对更新路径对应目的机房边缘节点j的链路评估指数，S(j)是第j个节点获得的链路质量评估均值，j_new即为本次共识后对应的目的机房转发节点，选取方式是在所有m个邻居节点的评估下，获得评估值最高的目的机房转发节点，当候选更新节点j_candidate＝j_new时，更新路径通过共识，智能合约将最新的转发节点记录，并将移除的旧节点放入

作为备选转发路径。in,

represents the historical forwarding node set of the destination computer room, j is all the nodes belonging to the historical set, m is the number of all edge nodes in the computer room adjacent to the destination computer room, score _i->j is the link evaluation index of the i-th node for the destination computer room edge node j corresponding to the update path, S(j) is the mean link quality evaluation obtained by the j-th node, j _new is the destination computer room forwarding node corresponding to this consensus, and the selection method is to obtain the destination computer room forwarding node with the highest evaluation value under the evaluation of all m neighboring nodes. When the candidate update node j _candidate = j _new , the update path passes the consensus, and the smart contract records the latest forwarding node and puts the removed old node into

As an alternative forwarding path.

When the candidate destination edge node passes this consensus, the system combines all the data center storage objects R that have passed the consensus, uses the breadth or depth traversal search method to perform path splicing, and converts it into an actual data flow path. The specific second path splicing principle adopted may include one or more of the following principles:

Shortest distance principle: When there are multiple paths between the source computer room and the destination computer room, the path with the least number of forwarding nodes is selected;

The latest path principle: When the number of path nodes is the same, the most recently updated path is selected;

Load balancing principle: When the number of path nodes is the same and the path update time is similar, select an appropriate random formula to achieve the purpose of data flow load balancing.

The first path splicing principle and the second path splicing principle may be the same or different, and may be flexibly configured according to actual needs.

This embodiment uses a forwarding path update and consensus method based on smart contracts. When the routing strategy changes, a consensus evaluation of the edge nodes in the neighboring computer room is required. Only the path change after the contract consensus can take effect, that is, through the path consensus formula of the routing contract, it prevents mismatched routing or low link quality paths from reducing forwarding efficiency, and the consensus execution rules of the contract will not be affected by a small number of malicious or downtime nodes. In addition, by setting the path splicing principle, the purpose of the shortest path and preventing the path from forming a loop is achieved.

As a specific embodiment, it is shown in Figure 3-5.

Figure 3 is a schematic diagram of the functional module division of the audio and video stream cross-computer room routing smart contract.

The path announcement module, corresponding to the first case above, is mainly responsible for receiving, storing and broadcasting new forwarding routes;

The path update module, corresponding to the second case above, is mainly responsible for the reception and broadcasting functions of updating the forwarding route;

The path verification module receives all link communication quality verifications for the edge nodes in the destination computer room. For specific verification methods, please refer to the above description;

The path consensus module determines whether the new routing strategy is effective through the consensus formula. The consensus calculation is triggered when all relevant nodes have evaluated the new and old links, or when the timeout clock is triggered. It includes new path consensus and path update consensus;

The forwarding path storage and query module provides end-to-end path storage and query functions. It combines all the computer room storage objects R that have passed the consensus, uses the breadth or depth traversal search method to perform path splicing, converts it into an actual data flow path, and displays it to the caller.

Figure 4 is a schematic diagram of the path addition and update operations of the cross-computer room routing smart contract.

Assume that there are 4 computer rooms {1, 2, 3, 4}, with computer room edge forwarding nodes {A}, {B, C}, {D, E} and {F} respectively. The initial connection state is: {computer room 4: F} <-> {computer room 1: A} <-> {computer room 2: C} <-> {computer room 3: E};

When computer room 2 executes the internal routing algorithm and node C is no longer the optimal edge node, the contract update operation will be called, node B will be used as a candidate node, that is, B = j _candidate , and the routing update consensus operation will be triggered. Adjacent to node B are {computer room 1: A} and {computer room 3: D, E}, so {A, D, E} will evaluate the link quality between B and C, and evaluate whether the update is valid through the path update consensus formula of the path consensus module. When j _new = B, the routing update is passed, and the link forwarding state changes to: {computer room 4: F} <-> {computer room 1: A} <-> {computer room 2: B} <-> {computer room 3: E};

当公开的新节点是错误配置或与B的实际综合链路质量低时，会得出j_new≠B，即拒绝更新，维持原转发策略。At the same time, the smart contract adds C to the historical edge forwarding node set of computer room 2

When the new node disclosed is misconfigured or the actual integrated link quality with B is low, it will be concluded that j _new ≠ B, that is, the update is rejected and the original forwarding strategy is maintained.

When computer room 4 queries the contract path forwarding path, it detects that {computer room 3: E} is in the destination computer room storage R and is physically reachable, so it calls the new path operation, that is, triggers the routing new consensus operation, and then the contract generates the path storage object R = [source = {computer room 4: F}, destination = {computer room 3: E}, extension field = {new path detection, new path}], and the neighbor node set {B, C} of the destination computer room {computer room 3: E} executes the new path consensus formula. When the new threshold requirement T _conf is met, a new forwarding path {computer room 4: F}->{computer room 3: E} is established. Similarly, when {computer room 3: E} detects that F is reachable, it will trigger the new path {computer room 3: E}->{computer room 4: F}, forming a new bidirectional link, otherwise, the data flow is only forwarded by the unidirectional path F->E. When the bidirectional link is established, a ring path is formed: {machine room 4: F}<->{machine room 1: A}<->{machine room 2: B}<->{machine room 3: E}<->{machine room 4: F};

When the forwarding path storage and query module queries the path forwarding from computer room 1 to computer room 3, there are two paths, A->B->E and A->F->E. Since A->F->E is the latest update, the path {computer room 1: A}<->{computer room 2: B}<->{computer room 3: E} is returned according to the path latest principle, avoiding loops. The corresponding edge forwarding node establishes a new audio and video stream connection with the adjacent computer room according to this path for data forwarding.

In addition, as shown in FIG5 , FIG5 is a schematic diagram of the contract call logic flow.

When the system performs cross-computer room routing calculations on edge forwarding nodes, if path reconstruction is triggered (equivalent to capturing routing policy changes), it will further determine whether the change corresponds to a newly added path. If the change corresponds to a newly added path, it will further perform a connectivity test on it through the corresponding adjacent edge nodes, and then enter the consensus calculation process; if the change does not correspond to a newly added path, but corresponds to a path update, it will further perform a quality assessment of the new and old paths through the corresponding adjacent edge nodes, and determine whether to accept the current path update. If not, the original forwarding path will still be maintained. If accepted, the consensus calculation process will be entered.

Based on the smart contract, the system determines whether the current new or updated path has passed the consensus. If it has passed the consensus, a new forwarding path will be established according to the current policy changes; if it has not passed the consensus, the forwarding path change will be abandoned and the original forwarding path will remain unchanged. The above whole process can be recorded using the underlying blockchain account book.

This embodiment calls the smart contract, which mainly completes the four functions of forwarding path notification, update, verification and consensus. At the same time, it uses the underlying blockchain account book to record the entire process of the entire operation, ensure the consistency of the global forwarding path information, and finally synchronize the latest routing information to the edge nodes on all paths to guide them to establish a new forwarding path.

Further, based on the first embodiment shown in FIG. 2 , a third embodiment of the method for forwarding data across computer rooms of the present invention is proposed. In this embodiment, before step S10, the method further includes:

Step A1, obtaining the intra-computer room forwarding path information of each computer room in the blockchain network, and storing the intra-computer room forwarding path information in the blockchain network in a hashed manner.

In this embodiment, as shown in FIG6 , FIG6 is a schematic diagram of the construction of a blockchain network of edge nodes in multiple computer rooms and the deployment of a routing smart contract. FIG1 shows a blockchain network composed of edge nodes and a routing consensus contract deployed on the blockchain. The blockchain network mainly completes three functions: recording forwarding paths within the computer room, recording forwarding paths across computer rooms, and recording evidence of incorrect forwarding paths. The first two functions are described below:

Records of forwarding paths within the computer room. In order to protect the security of the forwarding paths within a single computer room, the forwarding path records within the computer room are stored in a hash format. The specific formula is as follows:

Record = Hash(p);

Among them, record is the chain record, p is the forwarding path information in the computer room, and Hash() is a hash function used to hide the original data. For example, in the same computer room, the p forwarding path is recorded in a chain. Assuming that it is forwarded from edge node A in the computer room to edge node B, p = A->m1->m2->B, including two internal forwarding nodes m1 and m2.

Records of cross-machine room forwarding paths. Mainly records the entire operation process of routing smart contracts in cross-machine room routing notifications, consensus, and updates. It can also perform sampling tests by time period and record the actual forwarding path on the chain, providing reliable data evidence for subsequent problem investigation.

Furthermore, after step A1, the method further includes:

Step A2, when it is detected that wrong routing data forwarding occurs in the blockchain network, actual data forwarding information inside each computer room is obtained from each computer room of the blockchain network;

Step A3, comparing the actual data forwarding information with the forwarding path information in the computer room and obtaining a comparison result, so as to troubleshoot the cause of the erroneous forwarding based on the comparison result.

In this embodiment, the function of storing evidence of the wrong forwarding path implemented by the blockchain network is explained. When the wrong routing of the audio and video stream forwarding occurs, each computer room will upload the relevant actual forwarding information to the chain in plain text, and compare it with the hash storage of the forwarding path in the computer room to ensure the correctness of the information on the chain. Ensure that when troubleshooting errors, the operation and maintenance personnel can obtain the real end-to-end routing strategy path and the actual forwarding path of the entire link, which is used to quickly locate the nodes that are not forwarded according to the path agreed upon by the contract, analyze the reasons for not forwarding according to the routing strategy, and conduct further troubleshooting.

作为备选，此时拒绝更新转发路径的节点可维持原始历史转发路径，并将此情况按照图6所示区块链哈希存储规则进行实际跨机房路径转发信息的上链存证。当出现转发路径出现不属于

的节点等情况时，即视为出现了路径转发策略的错误，区块链存储的转发信息用于运维人员后续对相关问题的分析。As for the judgment of errors, generally speaking, when setting up the actual WebRTC computer room, we should try to ensure the connectivity of the edge nodes across computer rooms. When connectivity cannot be guaranteed, the route update obtained through consensus verification by smart contracts may result in some nodes being unreachable to the candidate nodes in the destination computer room, low link quality, and other special situations. At this time, although the contract path has been updated, the original node will still be recorded in the historical edge forwarding node set by the contract.

As an alternative, the node that refuses to update the forwarding path can maintain the original historical forwarding path and store the actual cross-computer room path forwarding information on the chain according to the blockchain hash storage rules shown in Figure 6.

When there is a situation such as a node being blocked, it is considered that an error in the path forwarding strategy has occurred. The forwarding information stored in the blockchain is used by the operation and maintenance personnel to analyze related issues later.

This embodiment verifies the matching of routing information by hash storage on the chain when troubleshooting forwarding errors, especially in computer rooms across different departments or manufacturers. This can ensure that the forwarding of erroneous routing in the computer room is non-repudiable and prevent the privacy leakage of internal routing.

Furthermore, before step S10, the method further includes:

Step S01, determining edge nodes deployed in different computer rooms, building a blockchain network based on the edge nodes, and deploying smart contracts related to the forwarding path;

Step S02: obtain initial configuration information, establish a physical adjacency relationship between the edge nodes according to the initial configuration information, and determine an initial forwarding path of the blockchain network based on the physical adjacency relationship.

In this embodiment, as shown in FIG7 , FIG7 is a schematic diagram of data flow forwarding across physical nodes in computer rooms. FIG2 shows i) initial configuration information to establish physical adjacency between neighboring computer rooms, and ii) physical forwarding link information dynamically adjusted during the deployment operation phase. Unlike the blockchain network of FIG6 , FIG7 is a physical link for forwarding audio and video streams, which mainly includes internal routing nodes and corresponding forwarding links within a single computer room, as well as computer room edge nodes and forwarding links for data across computer rooms.

Internal routing within a single computer room is mainly used for routing audio and video streams within the same computer room, including edge forwarding nodes and internal forwarding nodes, i.e., the forwarding links within the domains of computer rooms A, B, and C in Figure 2. When data streams are generated, data links will be established between internal forwarding nodes to forward audio and video data streams within the computer room; edge forwarding nodes mainly perform two functions:

1. Forwarding the data flow in the computer room to the neighboring computer room. Through the connection with the edge nodes of other computer rooms, the data flow in this computer room is forwarded to other computer rooms.

The data stream of the neighboring computer room is forwarded to this computer room. The data content of the edge node of the neighboring computer room is received, and the data stream is forwarded to the next-hop computer room through the routing formula in the private domain of this computer room, or the data is directly forwarded and presented to the WebRTC client connected to the internal node. Generally, in the specific implementation process, the forwarding path within a single computer room is not exposed to the outside, so as to facilitate management and protect the privacy of internal forwarding of data streams.

Second, data forwarding across computer rooms is mainly completed by the data links between the edge nodes of all computer rooms. Since the routing strategy within a single computer room is not exposed to the outside, when forwarding across computer rooms, the edge node will broadcast the forwarding information to other neighboring nodes, trigger the routing consensus and update of the smart contract, and finally determine the routing strategy. After the routing strategy is determined, all relevant nodes on the path establish a new data path according to the routing information, that is, the forwarding path of the audio and video stream across computer rooms shown in the dotted box in Figure 2.

As a specific embodiment, it is shown in Figure 8. Figure 8 is a schematic diagram of the overall process. The overall process includes the preparation stage of the system blockchain network and smart contracts, as well as the consensus and update steps of the cross-computer room forwarding path in the operation stage.

In the preparation phase, the system first builds a blockchain network based on the cross-computer room edge forwarding nodes and deploys smart contracts related to the forwarding path. Then, based on the initial configuration information, the system establishes the physical adjacency between the edge node and its neighboring computer room, and establishes the initial forwarding link based on the default forwarding path determined by the initial configuration information. At this point, the preparation phase is completed.

During the operation phase, the data flow forwarding routing method in the private domain is executed inside the computer room in the system; when the edge node in the same computer room switches, the new path information is broadcast to the neighboring computer room, triggering the contract path addition and update method; the smart contract stores all cross-computer room paths and related edge nodes according to the source computer room and the destination computer room; after triggering the update method, all relevant neighbor nodes are notified to verify the path of the new and old nodes of the destination computer room; all nodes verify the link quality with the neighboring nodes according to the new and old path information, and report the quality information to the smart contract; when the quality reports of all paths are reported, or the timeout is triggered, the smart contract executes the consensus method according to the quality information of all new and old paths to select new path information; finally, all relevant edge nodes receive the new path information (that is, the above-mentioned target forwarding path), and forward the route according to the new path decision, and wait for the next path addition or update.

This embodiment provides cross-domain path notification, consensus and update functions based on smart contracts in the scenario of WebRTC cross-computer room data forwarding. At the same time, the blockchain network composed of edge nodes stores the update operations of the forwarding path to ensure the traceability of the cross-computer room path history, which is convenient for operation and maintenance personnel to accurately locate the error location when problems occur.

As shown in FIG9 , the present invention further provides a cross-computer room data forwarding system, the cross-computer room data forwarding system comprising:

A routing strategy change module 10, used to monitor the routing strategy change information across computer rooms from a blockchain network composed of edge nodes deployed in different computer rooms, wherein the blockchain network has deployed a smart contract related to path forwarding;

An adjacent node broadcasting module 20, used to determine that the routing policy change information corresponds to a destination edge node in the blockchain network, and broadcast the routing policy change information to adjacent edge nodes of the destination edge node in the blockchain network according to the smart contract;

A change consensus verification module 30, configured to perform consensus verification on the routing policy change information according to the adjacent edge nodes and the smart contract, so as to determine a target forwarding path after the routing policy change when the routing policy change information passes the consensus verification;

The target path synchronization module 40 is used to synchronize the target forwarding path to the path edge nodes constituting the target forwarding path in the blockchain network, so that the path edge nodes can forward data according to the target forwarding path.

Optionally, the routing policy change information includes routing new information.

The adjacent node broadcast module 20 includes:

A newly added object storage unit, used to determine a newly added destination edge node in the blockchain network and a source edge node corresponding to the newly added destination edge node from the newly added routing information, and generate a storage object of the newly added destination edge node based on the newly added destination edge node and the source edge node, so as to store the storage object in the smart contract;

The first node broadcast unit is used to determine a first adjacent edge node adjacent to the newly added destination edge node from the blockchain network, and broadcast the newly added destination edge node to the first adjacent edge node.

Optionally, the change consensus verification module 30 includes:

A new consensus calculation unit is added, which is used to obtain the test result of the connectivity test performed by the first adjacent edge node on the newly added destination edge node, and to obtain the quality assessment mean corresponding to the newly added destination edge node by combining the test result and the new consensus algorithm in the smart contract;

A scoring mean judgment unit, used to judge whether the quality assessment mean is not less than a preset scoring threshold;

a newly added path generation unit, configured to generate a newly added forwarding path consisting of the newly added destination edge node and the first adjacent edge node, and store the newly added forwarding path in the blockchain network;

The first path splicing unit is used to generate the target forwarding path according to a preset first path splicing principle based on the newly added forwarding path and the initial forwarding path in the blockchain network.

Optionally, the routing policy change information includes routing update information.

The adjacent node broadcast module 20 includes:

A candidate node determination unit, configured to determine, from the routing update information, a historical destination edge node and a candidate destination edge node deployed in the same computer room in the blockchain network;

The second node broadcasting unit is used to determine a second adjacent edge node adjacent to the candidate destination edge node in the blockchain network, and broadcast the historical destination edge node and the candidate destination edge node to the second adjacent edge node.

Optionally, the change consensus verification module 30 includes:

An evaluation index acquisition unit, used to acquire a historical link evaluation index obtained by the second adjacent edge node performing link quality evaluation on the historical destination edge node, and a candidate link evaluation index obtained by performing link quality evaluation on the candidate destination edge node;

An update consensus calculation unit, used to determine whether the candidate destination edge node is valid by combining the historical link evaluation index, the candidate link evaluation index and the update consensus algorithm in the smart contract;

an update path generation unit, configured to generate an update forwarding path consisting of the candidate destination edge node and the second adjacent edge node, and store the update forwarding path in the blockchain network;

The second path splicing unit is used to generate the target forwarding path according to a preset second path splicing principle based on the updated forwarding path and the initial forwarding path in the blockchain network.

Optionally, the inter-computer room data forwarding system further includes:

The internal hash storage module is used to obtain the intra-computer room forwarding path information of each computer room in the blockchain network, and store the intra-computer room forwarding path information in the blockchain network in a hash manner.

Optionally, the inter-computer room data forwarding system further includes:

An error forwarding detection module is used to obtain actual data forwarding information inside each computer room of the blockchain network from each computer room of the blockchain network when an error routing data forwarding occurs in the blockchain network;

The forwarding information comparison module is used to compare the actual data forwarding information with the forwarding path information in the computer room and obtain a comparison result, so as to troubleshoot the cause of the incorrect forwarding based on the comparison result.

Optionally, the inter-computer room data forwarding system further includes:

A smart contract deployment module is used to determine the edge nodes deployed in different computer rooms, build a blockchain network based on the edge nodes, and deploy smart contracts related to the forwarding path;

The adjacency relationship establishment module is used to obtain initial configuration information, establish physical adjacency relationships between the edge nodes according to the initial configuration information, and determine the initial forwarding path of the blockchain network based on the physical adjacency relationships.

The invention also provides a cross-machine room data forwarding device.

The cross-computer room data forwarding device includes a processor, a memory, and a cross-computer room data forwarding program stored in the memory and executable on the processor, wherein when the cross-computer room data forwarding program is executed by the processor, the steps of the cross-computer room data forwarding method described above are implemented.

Among them, the method implemented when the cross-computer room data forwarding program is executed can refer to the various embodiments of the cross-computer room data forwarding method of the present invention, and will not be repeated here.

The present invention also provides a computer-readable storage medium.

The computer-readable storage medium of the present invention stores an inter-computer room data forwarding program, and when the inter-computer room data forwarding program is executed by a processor, the steps of the inter-computer room data forwarding method described above are implemented.

Among them, the method implemented when the cross-computer room data forwarding program is executed can refer to the various embodiments of the cross-computer room data forwarding method of the present invention, and will not be repeated here.

The present invention also provides a computer program product, including a computer program, wherein when the computer program is executed by a processor, the steps of the above-mentioned method for forwarding data across computer rooms are implemented.

Among them, the method implemented when the computer program is executed can refer to the various embodiments of the cross-computer room data forwarding method of the present invention, and will not be repeated here.

It should be noted that, in this article, the terms "include", "comprises" or any other variations thereof are intended to cover non-exclusive inclusion, so that a process, method, article or system including a series of elements includes not only those elements, but also other elements not explicitly listed, or also includes elements inherent to such process, method, article or system. In the absence of further restrictions, an element defined by the sentence "comprises a ..." does not exclude the existence of other identical elements in the process, method, article or system including the element.

The serial numbers of the above embodiments of the present invention are only for description and do not represent the advantages or disadvantages of the embodiments.

Through the description of the above implementation methods, those skilled in the art can clearly understand that the above-mentioned embodiment methods can be implemented by means of software plus a necessary general hardware platform, and of course by hardware, but in many cases the former is a better implementation method. Based on such an understanding, the technical solution of the present invention is essentially or the part that contributes to the prior art can be embodied in the form of a software product, which is stored in a storage medium (such as ROM/RAM, magnetic disk, optical disk) as described above, and includes a number of instructions for a terminal device (which can be a mobile phone, computer, server, air conditioner, or network device, etc.) to execute the methods described in each embodiment of the present invention.

The above are only preferred embodiments of the present invention, and are not intended to limit the patent scope of the present invention. Any equivalent structure or equivalent process transformation made using the contents of the present invention specification and drawings, or directly or indirectly applied in other related technical fields, are also included in the patent protection scope of the present invention.

Claims (9)

1. A cross-machine room data forwarding method is characterized by comprising the following steps:

monitoring routing strategy change information crossing machine rooms from a block chain network formed by edge nodes deployed in different machine rooms, wherein a deployed path in the block chain network forwards a related intelligent contract;

determining that the routing strategy change information corresponds to a destination edge node in the block chain network, and broadcasting the routing strategy change information to an adjacent edge node of the destination edge node in the block chain network according to the intelligent contract;

performing consensus verification on the routing policy change information according to the adjacent edge node and the intelligent contract so as to determine a target forwarding path after the routing policy change when the routing policy change information passes the consensus verification;

synchronizing the target forwarding path to a path edge node forming the target forwarding path in the block chain network, so that the path edge node performs data forwarding according to the target forwarding path;

the routing policy change information includes routing addition information, and the step of determining that the routing policy change information corresponds to a destination edge node in the blockchain network and broadcasting the routing policy change information to an adjacent edge node of the destination edge node in the blockchain network according to the intelligent contract includes:

determining a newly-added destination edge node and a source edge node corresponding to the newly-added destination edge node in the block chain network from the route newly-added information, and generating a storage object of the newly-added destination edge node based on the newly-added destination edge node and the source edge node so as to store the storage object in the intelligent contract;

and determining a first adjacent edge node adjacent to the new destination edge node from the block chain network, and broadcasting the new destination edge node to the first adjacent edge node.

2. The cross-computer room data forwarding method according to claim 1, wherein the step of performing consensus verification on the routing policy change information according to the adjacent edge node and the intelligent contract to determine a target forwarding path after the routing policy change when the routing policy change information passes the consensus verification comprises:

obtaining a test result of the connectivity test of the first adjacent edge node on the newly-added target edge node, and obtaining a quality evaluation average value corresponding to the newly-added target edge node by combining the test result and a newly-added consensus algorithm in the intelligent contract;

judging whether the quality evaluation mean value is not less than a preset grading threshold value or not;

if so, generating a new forwarding path consisting of the new destination edge node and the first adjacent edge node, and storing the new forwarding path in the block chain network;

and generating the target forwarding path according to a preset first path splicing principle based on the newly-added forwarding path and the initial forwarding path in the block chain network.

3. The cross-machine room data forwarding method of claim 1, wherein the routing policy change information comprises routing update information,

the step of determining that the routing policy change information corresponds to a destination edge node in the blockchain network, and broadcasting the routing policy change information to an adjacent edge node of the destination edge node in the blockchain network according to the intelligent contract includes:

determining historical destination edge nodes and candidate destination edge nodes deployed in the same machine room in the blockchain network from the routing update information;

determining a second adjacent edge node adjacent to the candidate destination edge node in the blockchain network, and broadcasting the historical destination edge node and the candidate destination edge node to the second adjacent edge node.

4. The cross-computer room data forwarding method according to claim 3, wherein the step of performing consensus verification on the routing policy change information according to the adjacent edge node and the intelligent contract to determine a target forwarding path after the routing policy change when the routing policy change information passes the consensus verification comprises:

obtaining a historical link evaluation index obtained by the second adjacent edge node performing link quality evaluation on the historical target edge node, and obtaining a candidate link evaluation index obtained by performing link quality evaluation on the candidate target edge node;

judging whether the candidate target edge node is effective or not by combining the historical link evaluation index, the candidate link evaluation index and an updating consensus algorithm in the intelligent contract;

if so, generating an updated forwarding path consisting of the candidate destination edge node and the second adjacent edge node, and storing the updated forwarding path in the block chain network;

and generating the target forwarding path according to a preset second path splicing principle based on the updated forwarding path and the initial forwarding path in the block chain network.

5. The cross-room data forwarding method of claim 1, wherein before the step of monitoring the routing policy change information across rooms from the blockchain network formed by edge nodes deployed in different rooms, the method further comprises:

and acquiring the in-machine room forwarding path information of each machine room in the block chain network, and storing the in-machine room forwarding path information in the block chain network in a Hash mode.

6. The cross-room data forwarding method of claim 5, wherein after the step of obtaining the in-room forwarding path information of each room in the blockchain network and storing the in-room forwarding path information in the blockchain network in a hash manner, the method further comprises:

when the situation that error routing data forwarding occurs in the block chain network is detected, actual data forwarding information inside each machine room is obtained from each machine room of the block chain network;

and comparing the actual data forwarding information with the forwarding path information in the machine room to obtain a comparison result, and checking the error forwarding reason based on the comparison result.

7. The cross-room data forwarding method of any one of claims 1-6, wherein before the step of monitoring the routing policy change information across rooms from the blockchain network formed by edge nodes deployed in different rooms, the method further comprises:

determining edge nodes deployed in different machine rooms, constructing a block chain network according to the edge nodes, and deploying intelligent contracts related to forwarding paths;

acquiring initial configuration information, establishing a physical adjacency relation between the edge nodes according to the initial configuration information, and determining an initial forwarding path of the block chain network based on the physical adjacency relation.

8. A cross-machine-room data forwarding device is characterized by comprising: a memory, a processor and a cross-room data forwarding program stored on the memory and executable on the processor, the cross-room data forwarding program when executed by the processor implementing the steps of the cross-room data forwarding method according to any one of claims 1 to 7.

9. A computer-readable storage medium, on which a cross-room data forwarding program is stored, which when executed by a processor implements the steps of the cross-room data forwarding method according to any one of claims 1 to 7.

Images