CN116366671A - Data synchronization method and device, storage medium and electronic device - Google Patents

Abstract

The application discloses a data synchronization method and device, a storage medium and an electronic device, and relates to the technical field of smart families, wherein the data synchronization method comprises the following steps: under the condition that an instruction for indicating a source cluster to synchronize data to a target cluster is received, traversing data to be synchronized of the source cluster through a data synchronization process to acquire node data of a plurality of nodes in a tree structure corresponding to the data to be synchronized and a hierarchical relationship of the plurality of nodes, wherein the plurality of node data are respectively stored on the plurality of nodes; the node data and the hierarchical relationship are sent to the target cluster based on the first connection relationship, so that the target cluster is instructed to establish nodes according to the hierarchical relationship, and the node data are stored in the nodes established by the target cluster.

Description

Data synchronization method and device, storage medium and electronic device

technical field

The present application relates to the communication field, and in particular, to a data synchronization method and device, a storage medium, and an electronic device.

Background technique

The data synchronization of the Zookeeper (zk for short) cluster is a scene that often occurs in the work of operation and maintenance and development.

At present, if you want to synchronize the data of one zk cluster to another cluster, you usually need to copy the registered node data files of the source zk cluster first, and then manually copy them to the specified directory of the destination cluster, and then restart the The data can only be synchronized in the way of zk cluster. If the cluster wants to synchronize the data of another cluster in the future, the above operations need to be repeated, and the zk cluster needs to be restarted to synchronize the data during the synchronization process. The operation is cumbersome , it is impossible to synchronize data for multiple clusters at the same time, and during the restart period, there will be problems such as services that depend on the cluster cannot be used normally.

In the related technology, the data synchronization of the source cluster has problems such as complex operation and low efficiency, and no effective solution has been proposed.

Contents of the invention

Embodiments of the present application provide a data synchronization method and device, a storage medium, and an electronic device, so as to at least solve the problems of complex operations and low efficiency in data synchronization of source clusters in related technologies.

According to an embodiment of the embodiment of the present application, a data synchronization method is provided, including: in the case of receiving an instruction instructing the source cluster to synchronize data with the destination cluster, traversing the data to be synchronized of the source cluster through a data synchronization process , to obtain the node data of multiple nodes in the tree structure corresponding to the data to be synchronized and the hierarchical relationship of the multiple nodes, wherein the multiple node data are respectively stored on the multiple nodes; according to the The Internet protocol address of the destination cluster establishes a first connection relationship between the data synchronization process and the destination cluster; based on the first connection relationship, the node data and the hierarchical relationship are sent to the destination cluster to indicate the The target cluster creates nodes according to the hierarchical relationship, and stores the node data into the nodes created by the target cluster.

In an exemplary embodiment, traversing the data to be synchronized in the source cluster through a data synchronization process to obtain the node data of multiple nodes of the data to be synchronized and the hierarchical relationship of the multiple nodes includes: through the The data synchronization process determines whether there is a next-level node in the i-th level node in the tree structure corresponding to the data to be synchronized, wherein, i is a positive integer, 1≤i≤N, and N is the node corresponding to the data to be synchronized The number of levels of the tree structure; when there is a next-level node in the i-th level node, store the node name of the next-level node of the i-th level node in the container to be recursed, and determine the to-be-recursive container Synchronize node data and hierarchical relationships between the first-level nodes of the data and the i-th level nodes.

In an exemplary embodiment, after determining through the data synchronization process whether there is a next-level node in the i-th level node in the tree structure corresponding to the data to be synchronized, the method further includes: When the synchronization process has traversed the i-th level node, determine whether there is a node name in the container to be recursed, wherein the i-th level node includes: one or more i-th level nodes; in the container to be recursed In the absence of a node name, determine that the data synchronization process traverses from the first level node in the tree structure to the Nth level node in the tree structure; there is a node in the recursive container In the case of a name, the data synchronization process accesses the next-level node of the i-th level node based on the node name.

In an exemplary embodiment, after determining through the data synchronization process whether there is a next-level node in the i-th level node in the tree structure corresponding to the data to be synchronized, the method further includes: a storing step: in the In the case that the i-th level node in the tree structure does not have a next-level node, the node data and hierarchical relationship from the first level node to the i-level node of the data to be synchronized are stored in the node container to be created Middle; the storage step is repeated until the node data and hierarchical relationship of the first level node to the Nth level node are stored in the node container to be created.

In an exemplary embodiment, after storing the node data and hierarchical relationships from the first level node to the Nth level node in the node container to be created, the method further includes: disconnecting the data synchronization process from the The second connection relationship of the source cluster, and establish the first connection relationship between the data synchronization process and the destination cluster according to the Internet protocol address of the destination cluster; based on the first connection relationship, the node container to be created will be The node data and hierarchical relationships from the first level node to the Nth level node are sent to the destination cluster.

In an exemplary embodiment, establishing the first connection relationship between the data synchronization process and the destination cluster according to the IP address of the destination cluster includes: according to the number of the destination clusters, in the data synchronization process Establish a plurality of data synchronization threads, wherein, the number of the plurality of data synchronization threads is the same as the number of the target clusters; respectively establish the plurality of data synchronization threads and the number of the target clusters according to the Internet of Things addresses of the plurality of target clusters The first connection relationship of the plurality of target clusters.

In an exemplary embodiment, establishing the first connection relationship between the data synchronization process and the destination cluster according to the IP address of the destination cluster includes: obtaining a key corresponding to the destination cluster, and verifying the the key; in the case that the verification result satisfies the first preset condition, obtain the Internet Protocol address of the destination cluster and the verification value of the destination cluster; determine according to the Internet Protocol address and the verification value An interface corresponding to the target cluster, and establishing a first connection relationship between the data synchronization process and the target cluster through the interface.

According to another embodiment of the embodiment of the present application, there is also provided a data synchronization device, including: a traversal module, configured to traverse all The data to be synchronized of the source cluster to obtain the node data of multiple nodes in the tree structure corresponding to the data to be synchronized and the hierarchical relationship of the multiple nodes, wherein the multiple node data are respectively stored in the multiple on a node; an establishment module, configured to establish a first connection relationship between the data synchronization process and the destination cluster according to the IP address of the destination cluster; a sending module, configured to transfer the first connection relationship based on the first connection relationship The node data and the hierarchical relationship are sent to the target cluster, so as to instruct the target cluster to create nodes according to the hierarchical relationship, and store the node data into the nodes created by the target cluster.

According to yet another aspect of the embodiments of the present application, a computer-readable storage medium is also provided, and a computer program is stored in the computer-readable storage medium, wherein the computer program is configured to execute the above-mentioned data synchronization method when running .

According to yet another aspect of the embodiments of the present application, there is also provided an electronic device, including a memory, a processor, and a computer program stored on the memory and operable on the processor, wherein the above-mentioned processor executes the above-mentioned Data synchronization method.

In the embodiment of the present application, when an instruction instructing the source cluster to synchronize data with the target cluster is received, the data to be synchronized of the source cluster is traversed through the data synchronization process to obtain the tree structure corresponding to the data to be synchronized The node data of multiple nodes and the hierarchical relationship of the multiple nodes, wherein the multiple node data are respectively stored on the multiple nodes; the data synchronization process and the data synchronization process are established according to the Internet Protocol address of the target cluster a first connection relationship of the destination cluster; sending the node data and the hierarchical relationship to the destination cluster based on the first connection relationship, to instruct the destination cluster to create nodes according to the hierarchical relationship, and The node data is stored in the node created by the destination cluster; using the above technical solution, the data synchronization of the source cluster is solved, and there are problems such as complicated operation and low efficiency. In the embodiment of the present invention, the data synchronization process passes through the The node data of multiple nodes of the node to be synchronized and the hierarchical relationship of the multiple nodes are obtained by means of the method, and then the Internet protocol address of the destination cluster is passed to the data synchronization process, so that the data to be synchronized can be synchronized to the destination cluster, and the efficiency extremely high.

Description of drawings

The accompanying drawings, which are incorporated in and constitute a part of this specification, illustrate embodiments consistent with the application and together with the description serve to explain the principles of the application.

In order to more clearly illustrate the technical solutions in the embodiments of the present application 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, for those of ordinary skill in the art, In other words, other drawings can also be obtained from these drawings without paying creative labor.

FIG. 1 is a schematic diagram of a hardware environment of a data synchronization method according to an embodiment of the present application;

Fig. 2 is a flowchart of a data synchronization method according to an embodiment of the present application;

FIG. 3 is a schematic diagram of a data synchronization method according to an embodiment of the present application;

FIG. 4 is a structural block diagram (1) of a data synchronization device according to an embodiment of the present application;

Fig. 5 is a structural block diagram (2) of a data synchronization device according to an embodiment of the present application.

Detailed ways

In order to enable those skilled in the art to better understand the solution of the present application, the technical solution in the embodiment of the application will be clearly and completely described below in conjunction with the accompanying drawings in the embodiment of the application. Obviously, the described embodiment is only It is an embodiment of a part of the application, but not all of the embodiments. Based on the embodiments in this application, all other embodiments obtained by persons of ordinary skill in the art without creative efforts shall fall within the scope of protection of this application.

It should be noted that the terms "first" and "second" in the description and claims of the present application and the above drawings are used to distinguish similar objects, but not necessarily used to describe a specific sequence or sequence. It is to be understood that the data so used are interchangeable under appropriate circumstances such that the embodiments of the application described herein can be practiced in sequences other than those illustrated or described herein. Furthermore, the terms "comprising" and "having", as well as any variations thereof, are intended to cover a non-exclusive inclusion, for example, a process, method, system, product or device comprising a sequence of steps or elements is not necessarily limited to the expressly listed instead, may include other steps or elements not explicitly listed or inherent to the process, method, product or apparatus.

According to an aspect of the embodiments of the present application, a data synchronization method is provided. This data synchronization method is widely used in whole-house intelligent digital control application scenarios such as smart home (Smart Home), smart home, smart home device ecology, and smart house (Intelligence House) ecology. Optionally, in this embodiment, the above data synchronization method may be applied to a hardware environment composed of a terminal device 102 and a server 104 as shown in FIG. 1 . As shown in Figure 1, the server 104 is connected to the terminal device 102 through the network, and can be used to provide services (such as application services, etc.) for the terminal or the client installed on the terminal. To provide data storage services for the server 104, cloud computing and/or edge computing services may be configured on the server or independently of the server to provide data computing services for the server 104.

The foregoing network may include but not limited to at least one of the following: a wired network and a wireless network. The above-mentioned wired network may include but not limited to at least one of the following: wide area network, metropolitan area network, and local area network, and the above-mentioned wireless network may include but not limited to at least one of the following: WIFI (Wireless Fidelity, Wireless Fidelity), Bluetooth. The terminal device 102 is not limited to PC, mobile phone, tablet computer, smart air conditioner, smart hood, smart refrigerator, smart oven, smart stove, smart washing machine, smart water heater, smart washing device, smart dishwasher, smart projection device , smart TV, smart drying rack, smart curtain, smart video, smart socket, smart audio, smart speaker, smart fresh air equipment, smart kitchen and bathroom equipment, smart bathroom equipment, smart sweeping robot, smart window cleaning robot, smart mopping robot, Smart air purification equipment, smart steamer, smart microwave oven, smart kitchen treasure, smart purifier, smart water dispenser, smart door lock, etc.

In this embodiment, a data synchronization method is provided, which is applied to a computer terminal. FIG. 2 is a flowchart of a data synchronization method according to an embodiment of the present application. The process includes the following steps:

Step S202, when receiving an instruction instructing the source cluster to synchronize data with the target cluster, traverse the data to be synchronized of the source cluster through the data synchronization process to obtain multiple data in the tree structure corresponding to the data to be synchronized The node data of the node and the hierarchical relationship of the plurality of nodes, wherein the plurality of node data are respectively stored on the plurality of nodes;

It should be noted that the data type of the data to be synchronized is a tree structure type, and the node data corresponding to the data to be synchronized is stored on the data nodes of the tree structure.

Step S204, establishing a first connection relationship between the data synchronization process and the destination cluster according to the IP address of the destination cluster;

Step S206, sending the node data and the hierarchical relationship to the destination cluster based on the first connection relationship, so as to instruct the destination cluster to create a node according to the hierarchical relationship, and store the node data in the In the nodes created by the target cluster.

Through the above steps, when an instruction instructing the source cluster to synchronize data with the target cluster is received, the data to be synchronized of the source cluster is traversed through the data synchronization process to obtain multiple data in the tree structure corresponding to the data to be synchronized. The node data of a node and the hierarchical relationship of the multiple nodes, wherein the multiple node data are respectively stored on the multiple nodes; the data synchronization process and the target cluster are established according to the Internet protocol address of the target cluster The first connection relationship of the cluster; based on the first connection relationship, the node data and the hierarchical relationship are sent to the target cluster to instruct the target cluster to create a node according to the hierarchical relationship, and the node The data is stored in the node created by the target cluster, which solves the problems of complex operation and low efficiency in the data synchronization of the source cluster in the related technology. The node data of multiple nodes of the node and the hierarchical relationship of the multiple nodes, and then the data synchronization process is passed to the Internet protocol address of the target cluster, so that the data to be synchronized can be synchronized to the target cluster, which is extremely efficient.

In an exemplary embodiment, traversing the data to be synchronized in the source cluster through a data synchronization process to obtain the node data of multiple nodes of the data to be synchronized and the hierarchical relationship of the multiple nodes includes: through the The data synchronization process determines whether there is a next-level node in the i-th level node in the tree structure corresponding to the data to be synchronized, wherein, i is a positive integer, 1≤i≤N, and N is the node corresponding to the data to be synchronized The number of levels of the tree structure; when there is a next-level node in the i-th level node, store the node name of the next-level node of the i-th level node in the container to be recursed, and determine the to-be-recursive container Synchronize node data and hierarchical relationships between the first-level nodes of the data and the i-th level nodes.

Specifically, traverse the tree structure of the source cluster through the data synchronization process, and determine whether each node traversed has a lower-level node, and if each node has a lower-level node, indicate the node traversed at this time It is not a leaf node of the tree structure, that is, the last node of the data to be synchronized has not been traversed at this time, and then the node name of the next-level node of the i-th level node is stored in the to-be-recursive container.

Optionally, traversing the data to be synchronized in the source cluster through a data synchronization process to obtain node data of multiple nodes of the data to be synchronized and the hierarchical relationship of the multiple nodes includes: generalized traversal through the data synchronization process The data to be synchronized of the source cluster; the data to be synchronized of the source cluster is deeply traversed through the data synchronization process.

In an exemplary embodiment, after determining through the data synchronization process whether there is a next-level node in the i-th level node in the tree structure corresponding to the data to be synchronized, after traversing the i-th level node through the data synchronization process In the case of a hierarchical node, determine whether there is a node name in the container to be recursed, wherein the i-th hierarchical node includes: one or more i-th level nodes; if there is no node name in the container to be recursed Next, it is determined to traverse from the first level node in the tree structure to the Nth level node in the tree structure through the data synchronization process; if there is a node name in the recursive container, the The data synchronization process accesses the next-level node of the i-th level node based on the node name.

Optionally, when traversing the data to be synchronized in the source cluster in a broad sense through the data synchronization process, first traverse all the nodes at the first level, then traverse all the nodes at the second level... and traverse all the nodes at the Nth level.

In the embodiment of the present invention, after traversing the nodes of each level, it is determined whether there is a node name in the container to be recursed, and when it is determined that there is no node name in the container to be recursed, it is determined that the The first level node in the tree structure traverses to the Nth level node in the tree structure, and then ends the traversal; if there is a node name in the container to be recursed, the data synchronization process is based on the The above-mentioned node name accesses the next-level node of the i-th level node, and continues to traverse the nodes according to the node name in the container to be recursed. Through the above embodiments, the hierarchical relationship of the nodes of the data to be synchronized and the node data included in each node can be completely obtained.

In an exemplary embodiment, after determining through the data synchronization process whether there is a next-level node in the i-th level node in the tree structure corresponding to the data to be synchronized, the storing step: in the tree structure When there is no next-level node in the i-level node, store the node data and hierarchical relationship from the first-level node to the i-level node of the data to be synchronized in the node container to be created; cycle the storage Step until the node data and hierarchical relationship of the first level node to the Nth level node are stored in the node container to be created.

For example, the N-level nodes include: N1-level nodes, N2-level nodes, and N2-level nodes, and store the node data and hierarchical relationships from the 1st-level nodes to the N1-level nodes in the node container to be created Afterwards, store the node data and hierarchical relationship from the 1st level node to the N2th level node in the node container to be created until the node data and hierarchical relationship from the 1st level node to the N3rd level node are stored in the node to be created container, end the loop.

In an exemplary embodiment, after storing the node data and hierarchical relationships from the first level node to the Nth level node in the node container to be created, disconnect the data synchronization process from the second node of the source cluster. connection relationship, and establish the first connection relationship between the data synchronization process and the destination cluster according to the Internet protocol address of the destination cluster; based on the first connection relationship, connect the first-level node in the node container to be created to the The node data and hierarchical relationship of the Nth level node are sent to the target cluster.

That is to say, when all nodes have traversed to the leaf nodes, the connection between the process and the source cluster is closed to release resources; then the process creates the first connection relationship according to the ip of the destination cluster that needs to synchronize data input by the user, Further, based on the first connection relationship, the node data and hierarchical relationship from the first level node to the Nth level node in the node container to be created are sent to the target cluster, and the target cluster is based on the hierarchical relationship Create a node, and store the node data in the node created by the destination cluster, which solves the problems of complex operation and low efficiency in the data synchronization of the source cluster in the related technology. In the embodiment of the present invention, the data synchronization The process obtains the node data of multiple nodes of the node to be synchronized and the hierarchical relationship of the multiple nodes through traversal, and then passes the Internet Protocol address of the destination cluster to the data synchronization process, so that the data to be synchronized can be synchronized to the destination In a cluster, the efficiency is extremely high.

In an exemplary embodiment, establishing the first connection relationship between the data synchronization process and the destination cluster according to the IP address of the destination cluster includes: according to the number of the destination clusters, in the data synchronization process Establish a plurality of data synchronization threads, wherein, the number of the plurality of data synchronization threads is the same as the number of the target clusters; respectively establish the plurality of data synchronization threads and the number of the target clusters according to the Internet of Things addresses of the plurality of target clusters The first connection relationship of the plurality of target clusters.

It should be noted that the process creates the same number of threads according to the number of Internet of Things addresses of the destination clusters that need to synchronize data input by the user, and the threads are executed in parallel, and multiple threads are respectively connected to the destination cluster, so that the destination cluster according to The hierarchical relationship creation node closes the connection with the target cluster after all the threads are finished, releases resources, and then completes data synchronization.

In an exemplary embodiment, establishing the first connection relationship between the data synchronization process and the destination cluster according to the IP address of the destination cluster includes: obtaining a key corresponding to the destination cluster, and verifying the the key; in the case that the verification result satisfies the first preset condition, obtain the Internet Protocol address of the destination cluster and the verification value of the destination cluster; determine according to the Internet Protocol address and the verification value An interface corresponding to the target cluster, and establishing a first connection relationship between the data synchronization process and the target cluster through the interface.

In the embodiment of the present invention, in order to enhance the security of information transmission, the data synchronization process needs to perform security verification on the target cluster before establishing a connection relationship with the target cluster, specifically: obtain the key corresponding to the target cluster, and verifying the key, and obtaining the IP address of the destination cluster and the check value of the destination cluster when the verification is passed; determining the destination cluster according to the IP address and the check value corresponding interface, and establish the first connection relationship between the data synchronization process and the target cluster through the interface; if the verification fails, refuse to establish the connection relationship with the target cluster.

In order to better understand the process of the above data synchronization method, the flow of the above data synchronization implementation method will be described below in conjunction with an optional embodiment, but it is not intended to limit the technical solution of the embodiment of the present application.

A data synchronization method is provided in this embodiment, and FIG. 3 is a schematic diagram of a data synchronization method according to an embodiment of the present application, as shown in FIG. 3 , and the specific steps are as follows:

Step S301: Establish a connection relationship with the source cluster according to the IP address of the source cluster;

Step S302: Obtain the data to be synchronized of the source cluster;

Step S303: Obtain node data corresponding to the current node through traversal;

Step S304: Determine whether the current node has a lower-level node, and if the current node has a lower-level node, execute step S305, otherwise execute step S306;

Step S305: put the node name of the next level node into the node container to be recursed;

Step S306: put the node data and hierarchical relationship of the current node into the node container to be created;

Step S307: Determine whether all nodes of the level corresponding to the current node have been traversed, and if all nodes of the level corresponding to the current node have been traversed, step S303 is executed, otherwise step S308 is executed;

Step S308: Determine whether there is a node name in the container to be recursed;

If there is, it means that there is still data that has not been traversed to the root node, then continue to traverse recursively, if there is no node name in the container, it means that all nodes have traversed to the root node, then close the connection between the process and the source zk cluster, and release resource.

Step S309: The process creates the same number of threads according to the number of ip addresses of the destination clusters that need to synchronize data, and the threads are executed in parallel to connect to the destination clusters respectively;

Step S310: Create nodes according to the hierarchical relationship;

Step S311: storing node data into corresponding nodes;

Step S312: close the connection with the destination cluster, and release resources.

In the embodiment of the present invention, the user only needs to pass in the ip of the source zk cluster and the ip of the destination cluster to the program, without other cumbersome operations. Data synchronization of multiple clusters can be performed at the same time through multi-threading, which is extremely efficient. Even when the cluster is in use, data synchronization can still be performed without restarting the cluster to achieve hot synchronization without affecting services that depend on the cluster. After the solution is implemented, the user only needs to maintain the ip of the incoming program when using it.

Through the description of the above embodiments, those skilled in the art can clearly understand that the method according to the above embodiments can be implemented by means of software plus a necessary general-purpose hardware platform, and of course also by hardware, but in many cases the former is better implementation. Based on such an understanding, the technical solution of the present application can be embodied in the form of a software product in essence or the part that contributes to the prior art, and the computer software product is stored in a storage medium (such as ROM/RAM, disk, CD) contains several instructions to make a terminal device (which may be a mobile phone, a computer, a server, or a network device, etc.) execute the method of each embodiment of the present application.

Fig. 4 is a structural block diagram (1) of a data synchronization device according to an embodiment of the present application; as shown in Fig. 4 , it includes:

The traversal module 42 is configured to traverse the data to be synchronized of the source cluster through the data synchronization process to obtain the tree structure corresponding to the data to be synchronized The node data of the multiple nodes and the hierarchical relationship of the multiple nodes, wherein the multiple node data are respectively stored on the multiple nodes;

An establishment module 44, configured to establish a first connection relationship between the data synchronization process and the destination cluster according to the IP address of the destination cluster;

A sending module 46, configured to send the node data and the hierarchical relationship to the destination cluster based on the first connection relationship, so as to instruct the destination cluster to create a node according to the hierarchical relationship, and send the node data stored in the node created by the destination cluster.

With the above device, when receiving an instruction instructing the source cluster to synchronize data with the target cluster, the data to be synchronized of the source cluster is traversed through the data synchronization process to obtain multiple data in the tree structure corresponding to the data to be synchronized. The node data of a node and the hierarchical relationship of the multiple nodes, wherein the multiple node data are respectively stored on the multiple nodes; the data synchronization process and the target cluster are established according to the Internet protocol address of the target cluster The first connection relationship of the cluster; based on the first connection relationship, the node data and the hierarchical relationship are sent to the target cluster to instruct the target cluster to create a node according to the hierarchical relationship, and the node The data is stored in the node created by the target cluster, which solves the problems of complex operation and low efficiency in the data synchronization of the source cluster in the related technology. The node data of multiple nodes of the node and the hierarchical relationship of the multiple nodes, and then the data synchronization process is passed to the Internet protocol address of the target cluster, so that the data to be synchronized can be synchronized to the target cluster, which is extremely efficient.

In an exemplary embodiment, the traversal module 42 is configured to determine whether there is a next-level node in the i-th level node in the tree structure corresponding to the data to be synchronized through the data synchronization process, where i is a positive integer , 1≤i≤N, N is the number of levels of the tree structure corresponding to the data to be synchronized; in the case that the i-th level node has a next-level node, the next level of the i-th level node The node name of the node is stored in the container to be recursed, and the node data and hierarchical relationship from the first level node to the i-th level node of the data to be synchronized are determined.

In an exemplary embodiment, the traversal module 42 is configured to determine whether there is a node name in the container to be recursed after traversing the i-th level nodes through the data synchronization process, wherein the i-th level The nodes include: one or more i-th level nodes; if there is no node name in the container to be recursed, it is determined to traverse from the first level node in the tree structure to the An Nth level node in a tree structure; if there is a node name in the container to be recursed, the data synchronization process accesses the next level node of the i level node based on the node name.

In an exemplary embodiment, FIG. 5 is a structural block diagram (2) of a data synchronization device according to an embodiment of the present application; as shown in FIG. 5 , it includes: a storage module 52 for performing a storage step: in the If there is no next-level node in the i-level node in the tree structure, store the node data and hierarchical relationship from the first-level node to the i-level node of the data to be synchronized in the node container to be created ; The storage step is looped until the node data and hierarchical relationships of the first level node to the Nth level node are stored in the node container to be created.

In an exemplary embodiment, the sending module 46 is configured to disconnect the second connection relationship between the data synchronization process and the source cluster, and establish the data synchronization process and the destination cluster according to the Internet protocol address of the destination cluster. The first connection relationship of the cluster; sending the node data and hierarchical relationship from the first level node to the Nth level node in the to-be-created node container to the destination cluster based on the first connection relationship.

In an exemplary embodiment, the establishing module 44 is configured to establish multiple data synchronization threads in the data synchronization process according to the number of the target clusters, wherein the number of the multiple data synchronization threads is the same as the number of the The number of destination clusters is the same; the first connection relationship between the plurality of data synchronization threads and the plurality of destination clusters is respectively established according to the Internet of Things addresses of the plurality of destination clusters.

In an exemplary embodiment, the establishment module 44 is configured to obtain the key corresponding to the target cluster, and verify the key; if the verification result satisfies the first preset condition, obtain the target The Internet protocol address of the cluster and the verification value of the destination cluster; determine the interface corresponding to the destination cluster according to the Internet protocol address and the verification value, and establish a data synchronization process with the destination cluster through the interface the first connection relationship.

An embodiment of the present application further provides a storage medium, the storage medium includes a stored program, wherein the above-mentioned program executes any one of the above-mentioned methods when running.

Optionally, in this embodiment, the above-mentioned storage medium may be configured to store program codes for performing the following steps:

S1. In the case of receiving an instruction instructing the source cluster to synchronize data with the target cluster, traverse the data to be synchronized of the source cluster through a data synchronization process to obtain multiple nodes in the tree structure corresponding to the data to be synchronized The node data and the hierarchical relationship of the plurality of nodes, wherein the plurality of node data are respectively stored on the plurality of nodes;

S2. Establish a first connection relationship between the data synchronization process and the destination cluster according to the IP address of the destination cluster;

S3. Send the node data and the hierarchical relationship to the destination cluster based on the first connection relationship, so as to instruct the destination cluster to create a node according to the hierarchical relationship, and store the node data in the In the node created by the destination cluster.

An embodiment of the present application also provides an electronic device, including a memory and a processor, where a computer program is stored in the memory, and the processor is configured to run the computer program to perform the steps in any one of the above method embodiments.

Optionally, the above-mentioned electronic device may further include a transmission device and an input-output device, wherein the transmission device is connected to the above-mentioned processor, and the input-output device is connected to the above-mentioned processor.

Optionally, in this embodiment, the above-mentioned processor may be configured to execute the following steps through a computer program:

S1. In the case of receiving an instruction instructing the source cluster to synchronize data with the target cluster, traverse the data to be synchronized of the source cluster through a data synchronization process to obtain multiple nodes in the tree structure corresponding to the data to be synchronized The node data and the hierarchical relationship of the plurality of nodes, wherein the plurality of node data are respectively stored on the plurality of nodes;

S2. Establish a first connection relationship between the data synchronization process and the destination cluster according to the IP address of the destination cluster;

S3. Send the node data and the hierarchical relationship to the destination cluster based on the first connection relationship, so as to instruct the destination cluster to create a node according to the hierarchical relationship, and store the node data in the In the node created by the destination cluster.

Optionally, in this embodiment, the above-mentioned storage medium may include but not limited to: U disk, read-only memory (Read-Only Memory, ROM for short), random access memory (Random Access Memory, RAM for short), Various media that can store program codes such as removable hard disks, magnetic disks, or optical disks.

Optionally, for specific examples in this embodiment, reference may be made to the examples described in the foregoing embodiments and optional implementation manners, and details are not repeated in this embodiment.

Obviously, those skilled in the art should understand that each module or each step of the above-mentioned application can be realized by a general-purpose computing device, and they can be concentrated on a single computing device, or distributed in a network composed of multiple computing devices Alternatively, they may be implemented in program code executable by a computing device so that they may be stored in a storage device to be executed by a computing device, and in some cases in an order different from that shown here The steps shown or described are carried out, or they are separately fabricated into individual integrated circuit modules, or multiple modules or steps among them are fabricated into a single integrated circuit module for implementation. As such, the present application is not limited to any specific combination of hardware and software.

The above description is only the preferred embodiment of the present application. It should be pointed out that for those of ordinary skill in the art, without departing from the principle of the present application, some improvements and modifications can also be made. These improvements and modifications are also It should be regarded as the protection scope of this application.

Claims (10)

1. A method of data synchronization, comprising:

under the condition that an instruction for indicating a source cluster to synchronize data to a target cluster is received, traversing data to be synchronized of the source cluster through a data synchronization process to acquire node data of a plurality of nodes in a tree structure corresponding to the data to be synchronized and a hierarchical relationship of the plurality of nodes, wherein the plurality of node data are respectively stored on the plurality of nodes;

establishing a first connection relation between the data synchronization process and the target cluster according to the Internet protocol address of the target cluster;

and sending the node data and the hierarchical relationship to the target cluster based on the first connection relationship to instruct the target cluster to create nodes according to the hierarchical relationship, and storing the node data into the nodes created by the target cluster.

2. The data synchronization method according to claim 1, wherein traversing the data to be synchronized of the source cluster by a data synchronization process to obtain node data of a plurality of nodes of the data to be synchronized and a hierarchical relationship of the plurality of nodes comprises:

determining whether an ith node in the tree structure corresponding to the data to be synchronized exists as a next node or not through the data synchronization process, wherein i is a positive integer, i is more than or equal to 1 and less than or equal to N, and N is the number of layers of the tree structure corresponding to the data to be synchronized;

and storing the node name of the next-level node of the ith-level node into a container to be recursion under the condition that the next-level node exists in the ith-level node, and determining the node data and the hierarchical relationship from the 1 st-level node to the ith-level node of the data to be synchronized.

3. The data synchronization method according to claim 2, wherein after determining, by the data synchronization process, whether a next level node exists in an i-th level node in a tree structure corresponding to the data to be synchronized, the method further comprises:

determining whether a node name exists in the container to be recursion under the condition that an ith level node is traversed through the data synchronization process, wherein the ith level node comprises: one or more i-th level nodes;

determining traversing from a 1 st level node in the tree structure to an nth level node in the tree structure by the data synchronization process in the case that no node name exists in the container to be recursion; in the case that a node name exists in the container to be recursively, the data synchronization process accesses a next level node of the ith level node based on the node name.

4. The data synchronization method according to claim 2, wherein after determining, by the data synchronization process, whether a next level node exists in an i-th level node in a tree structure corresponding to the data to be synchronized, the method further comprises:

the storage step: in case that the i-th level node in the tree structure does not have a next level node,

storing node data and a hierarchical relation from the 1 st level node to the i-th level node of the data to be synchronized into a node container to be created;

and cycling the storing step until the node data and the hierarchical relation from the 1 st hierarchical node to the N th hierarchical node are stored into the node container to be created.

5. The data synchronization method according to claim 4, wherein after storing node data and hierarchical relationships of 1 st-level nodes to the N-th-level nodes into a node container to be created, the method further comprises:

disconnecting the second connection relation between the data synchronization process and the source cluster, and establishing the first connection relation between the data synchronization process and the destination cluster according to the Internet protocol address of the destination cluster;

and transmitting node data and a hierarchical relationship from the 1 st hierarchical node to the N th hierarchical node in the node container to be created to the target cluster based on the first connection relationship.

6. The method according to claim 1, wherein establishing a first connection relationship between the data synchronization process and the destination cluster according to an internet protocol address of the destination cluster comprises:

establishing a plurality of data synchronization threads in the data synchronization process according to the number of the target clusters, wherein the number of the plurality of data synchronization threads is the same as the number of the target clusters;

and respectively establishing first connection relations between the plurality of data synchronization threads and the plurality of target clusters according to the Internet of things addresses of the plurality of target clusters.

7. The method according to claim 1, wherein establishing a first connection relationship between the data synchronization process and the destination cluster according to an internet protocol address of the destination cluster comprises:

acquiring a key corresponding to the target cluster, and checking the key;

under the condition that the verification result meets a first preset condition, acquiring an internet protocol address of the target cluster and a verification value of the target cluster;

and determining an interface corresponding to the target cluster according to the Internet protocol address and the check value, and establishing a first connection relation between a data synchronization process and the target cluster through the interface.

8. A data synchronization device, comprising:

the system comprises a traversing module, a data synchronization module and a data synchronization module, wherein the traversing module is used for traversing the data to be synchronized of a source cluster through a data synchronization process under the condition of receiving an instruction for indicating the source cluster to synchronize the data to a target cluster so as to acquire node data of a plurality of nodes in a tree structure corresponding to the data to be synchronized and the hierarchical relationship of the plurality of nodes, wherein the plurality of node data are respectively stored on the plurality of nodes;

the establishing module is used for establishing a first connection relation between the data synchronization process and the target cluster according to the Internet protocol address of the target cluster;

and the sending module is used for sending the node data and the hierarchical relationship to the target cluster based on the first connection relationship so as to instruct the target cluster to create a node according to the hierarchical relationship and store the node data into the node created by the target cluster.

9. A computer readable storage medium, characterized in that the computer readable storage medium comprises a stored program, wherein the program when run performs the method of any of the preceding claims 1 to 7.

10. An electronic device comprising a memory and a processor, characterized in that the memory has stored therein a computer program, the processor being arranged to execute the method according to any of the claims 1 to 7 by means of the computer program.

Images