CN114125812A - Data synchronization method, device, server and storage medium - Google Patents
Data synchronization method, device, server and storage medium Download PDFInfo
- Publication number
- CN114125812A CN114125812A CN202111342917.6A CN202111342917A CN114125812A CN 114125812 A CN114125812 A CN 114125812A CN 202111342917 A CN202111342917 A CN 202111342917A CN 114125812 A CN114125812 A CN 114125812A
- Authority
- CN
- China
- Prior art keywords
- data
- udm
- user group
- data synchronization
- block chain
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Granted
Links
Images
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04W—WIRELESS COMMUNICATION NETWORKS
- H04W8/00—Network data management
- H04W8/18—Processing of user or subscriber data, e.g. subscribed services, user preferences or user profiles; Transfer of user or subscriber data
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/10—Protocols in which an application is distributed across nodes in the network
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04W—WIRELESS COMMUNICATION NETWORKS
- H04W12/00—Security arrangements; Authentication; Protecting privacy or anonymity
- H04W12/10—Integrity
- H04W12/106—Packet or message integrity
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04W—WIRELESS COMMUNICATION NETWORKS
- H04W8/00—Network data management
- H04W8/18—Processing of user or subscriber data, e.g. subscribed services, user preferences or user profiles; Transfer of user or subscriber data
- H04W8/20—Transfer of user or subscriber data
-
- Y—GENERAL TAGGING OF NEW TECHNOLOGICAL DEVELOPMENTS; GENERAL TAGGING OF CROSS-SECTIONAL TECHNOLOGIES SPANNING OVER SEVERAL SECTIONS OF THE IPC; TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
- Y02—TECHNOLOGIES OR APPLICATIONS FOR MITIGATION OR ADAPTATION AGAINST CLIMATE CHANGE
- Y02D—CLIMATE CHANGE MITIGATION TECHNOLOGIES IN INFORMATION AND COMMUNICATION TECHNOLOGIES [ICT], I.E. INFORMATION AND COMMUNICATION TECHNOLOGIES AIMING AT THE REDUCTION OF THEIR OWN ENERGY USE
- Y02D10/00—Energy efficient computing, e.g. low power processors, power management or thermal management
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Computer Security & Cryptography (AREA)
- Databases & Information Systems (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
- Information Transfer Between Computers (AREA)
Abstract
The invention provides a data synchronization method, a data synchronization device, a server and a storage medium, relates to the technical field of communication, and solves the technical problems that equipment in a private network may acquire wrong data, the use environment of the data in the private network is influenced, and the communication experience of a user is reduced. The method comprises the following steps: the block chain node sends a block chain account book query request to the data sharing equipment; the block chain link point receives a block chain account book query response sent by the data sharing equipment; the block link point acquires the target file based on the IP address of the UDM; the block chain link point obtains a second abstract based on the preset abstract algorithm and the target file; the block link point determining whether the first summary and the second summary are the same; in the case that the first digest is the same as the second digest, the block link node sends the target file to a local UDM.
Description
Technical Field
The present invention relates to the field of communications technologies, and in particular, to a data synchronization method, an apparatus, a server, and a storage medium.
Background
Currently, after a certain private network is deployed, a unified data management function (UDM) in the private network, that is, the private network UDM may send a data synchronization request to a UDM (core network UDM) in an operator network based on information of a Subscriber Identity Module (SIM) to request synchronization of related data of a subscriber in the private network, and then the core network UDM may return the related data to the private network UDM.
However, in the above method, the private network UDM may not be able to determine whether there is an error in the related data sent by the core network UDM at the first time, and thus, the device in the private network may acquire the error data, which affects the data usage environment in the private network and reduces the communication experience of the user.
Disclosure of Invention
The invention provides a data synchronization method, a data synchronization device, a server and a storage medium, and solves the technical problems that equipment in a private network may acquire wrong data, the use environment of the data in the private network is influenced, and the communication experience of a user is reduced.
In a first aspect, the present invention provides a data synchronization method, including: the block chain node sends a block chain account book query request to the data sharing equipment, wherein the block chain account book query request comprises an identifier of a first user group, and the block chain account book query request is used for requesting to query a synchronous record of subscription data corresponding to the first user group; the block chain link point receives a block chain account book query response sent by the data sharing device, wherein the block chain account book query response comprises a first abstract, a preset abstract algorithm and an Internet Protocol (IP) address of the UDM, the first abstract is obtained by the UDM based on the preset abstract algorithm and a target file, and the target file is a file generated after signing data corresponding to the first user group is packaged; the block link point acquires the target file based on the IP address of the UDM; the block chain link point obtains a second abstract based on the preset abstract algorithm and the target file; the block link point determining whether the first summary and the second summary are the same; in the case that the first digest is the same as the second digest, the block link node sends the target file to a local UDM.
In a second aspect, the present invention provides a data synchronization method, including: the data sharing device receives a block chain account book query request sent by a block chain node, wherein the block chain account book query request comprises an identifier of a first user group, and the block chain account book query request is used for requesting to query a synchronous record of subscription data corresponding to the first user group; the data sharing device acquires a first abstract, a preset abstract algorithm and an IP address of the UDM from a data synchronization information book based on the identification of the first user group, wherein the first abstract is obtained by the UDM based on the preset abstract algorithm and a target file, and the target file is a file generated after the signing data corresponding to the first user group are packaged; the data sharing device sends a block chain ledger query response to the block chain linked node, wherein the block chain ledger query response comprises the first abstract, the preset abstract algorithm and the IP address of the UDM. .
In a third aspect, the present invention provides a data synchronization method, including: the method comprises the steps that a data synchronization request sent by data sharing equipment is received by the UDM, the data synchronization request comprises an identifier of a first user group, and the data synchronization request is used for requesting to synchronize subscription data corresponding to the first user group; the UDM acquires subscription data corresponding to the first user group based on the identifier of the first user group; the UDM packs the signing data to generate a target file; the UDM obtains a first abstract based on a preset abstract algorithm and the target file; and the UDM sends a data synchronization response to the data sharing equipment, wherein the data synchronization response comprises the first abstract, the preset abstract algorithm and the IP address of the UDM.
In a fourth aspect, the present invention provides a data synchronization apparatus, including: the device comprises a sending module, a receiving module, an obtaining module, a processing module and a determining module; the sending module is configured to send a block chain account book query request to the data sharing device, where the block chain account book query request includes an identifier of a first user group, and the block chain account book query request is used to request to query a synchronization record of subscription data corresponding to the first user group; the receiving module is configured to receive a block chain ledger query response sent by the data sharing device, where the block chain ledger query response includes a first abstract, a preset abstract algorithm, and an IP address of the UDM, the first abstract is obtained by the UDM based on the preset abstract algorithm and a target file, and the target file is a file generated after signing data corresponding to the first user group is packaged; the obtaining module is used for obtaining the target file based on the IP address of the UDM; the processing module is used for obtaining a second abstract based on the preset abstract algorithm and the target file; the determining module is used for determining whether the first abstract and the second abstract are the same; the sending module is further configured to send the target file to the local UDM in a case that the first digest is the same as the second digest.
In a fifth aspect, the present invention provides a data synchronization apparatus, including: the device comprises a receiving module, an obtaining module and a sending module; the receiving module is configured to receive a block chain account book query request sent by a block chain node, where the block chain account book query request includes an identifier of a first user group, and the block chain account book query request is used to request to query a synchronization record of subscription data corresponding to the first user group; the acquisition module is configured to acquire a first abstract, a preset abstract algorithm, and an IP address of the UDM from a data synchronization information book based on an identifier of the first user group, where the first abstract is obtained by the UDM based on the preset abstract algorithm and a target file, and the target file is a file generated after the subscription data corresponding to the first user group is packaged; the sending module is configured to send a block chain ledger query response to the block chain link point, where the block chain ledger query response includes the first abstract, the preset abstract algorithm, and the IP address of the UDM.
In a sixth aspect, the present invention provides a data synchronization apparatus, including: the device comprises a receiving module, an obtaining module, a processing module and a sending module; the receiving module is configured to receive a data synchronization request sent by a data sharing device, where the data synchronization request includes an identifier of a first user group, and the data synchronization request is used to request synchronization of subscription data corresponding to the first user group; the obtaining module is configured to obtain subscription data corresponding to the first user group based on the identifier of the first user group; the processing module is used for packaging the signing data to generate a target file; the processing module is also used for obtaining a first abstract based on a preset abstract algorithm and the target file; the sending module is configured to send a data synchronization response to the data sharing device, where the data synchronization response includes the first digest, the preset digest algorithm, and an IP address of the UDM.
In a seventh aspect, the present invention provides a server, including: a processor and a memory configured to store processor-executable instructions; wherein the processor is configured to execute the instructions to implement any of the above-described optional data synchronization methods of the first aspect, or to implement any of the above-described optional data synchronization methods of the second aspect, or to implement any of the above-described optional data synchronization methods of the third aspect.
In an eighth aspect, the present invention provides a computer-readable storage medium having instructions stored thereon, which, when executed by a server, enable the server to perform any one of the above-mentioned first aspect optional data synchronization methods, or perform any one of the above-mentioned second aspect optional data synchronization methods, or perform any one of the above-mentioned third aspect optional data synchronization methods.
In a ninth aspect, the present invention provides a computer program product comprising computer instructions which, when run on a server, cause the server to perform any one of the optional data synchronization methods of the first aspect, or perform any one of the optional data synchronization methods of the second aspect described above, or perform any one of the optional data synchronization methods of the third aspect described above.
According to the data synchronization method, the data synchronization device, the server and the storage medium, the block chain link point can send a block chain account book query request to the data sharing equipment, namely, the block chain account book query request requests for querying the synchronous record of the subscription data corresponding to the first user group; after receiving the query request for the blockchain ledger, the data sharing device may determine the synchronization record based on the identifier of the first subscriber group and send a blockchain ledger query response to the blockchain nodes, where the blockchain ledger query response includes the first abstract, a preset abstract algorithm, and an IP address of the UDM; the block link point can acquire a target file based on the IP address of the UDM and obtain a second abstract by combining the preset abstract algorithm; since the first digest is obtained by the UDM based on the predetermined digest algorithm and the target file, the blockchain node determines whether the first digest is the same as the second digest, that is, whether the target file (specifically, the subscription data) is tampered or has error data, and sends the target file to the local UDM when the first digest is the same as the second digest, that is, the subscription data has no error data. In this manner, the local UDM may obtain subscription data that has not been tampered with or that has no error data. Whether the signing data of the user has errors can be quickly and effectively determined, correct and effective data can be used by equipment in the private network, and user experience is improved.
Drawings
In order to more clearly illustrate the embodiments of the present invention or the technical solutions in the prior art, the drawings used in the description of the embodiments or the prior art will be briefly described below.
Fig. 1 is a schematic network architecture diagram of a data synchronization system according to an embodiment of the present invention;
fig. 2 is a hardware schematic diagram of a server according to an embodiment of the present invention;
fig. 3 is a schematic flowchart of a data synchronization method according to an embodiment of the present invention;
fig. 4 is a schematic flow chart of another data synchronization method according to an embodiment of the present invention;
fig. 5 is a schematic structural diagram of a data synchronization apparatus according to an embodiment of the present invention;
FIG. 6 is a schematic structural diagram of another data synchronization apparatus according to an embodiment of the present invention;
FIG. 7 is a schematic structural diagram of another data synchronization apparatus according to an embodiment of the present invention;
FIG. 8 is a schematic structural diagram of another data synchronization apparatus according to an embodiment of the present invention;
FIG. 9 is a schematic structural diagram of another data synchronization apparatus according to an embodiment of the present invention;
fig. 10 is a schematic structural diagram of another data synchronization apparatus according to an embodiment of the present invention.
Detailed Description
Hereinafter, a data synchronization method, an apparatus, a server, and a storage medium according to embodiments of the present invention will be described in detail with reference to the accompanying drawings.
The terms "first" and "second", etc. in the description and drawings of the present application are used for distinguishing between different objects and not for describing a particular order of the objects.
Furthermore, the terms "including" and "having," and any variations thereof, as referred to in the description of the present application, are intended to cover non-exclusive inclusions. For example, a process, method, system, article, or apparatus that comprises a list of steps or elements is not limited to only those steps or elements but may alternatively include other steps or elements not expressly listed or inherent to such process, method, article, or apparatus.
It should be noted that, in the embodiments of the present invention, words such as "exemplary" or "for example" are used to indicate examples, illustrations or explanations. Any embodiment or design described as "exemplary" or "e.g.," an embodiment of the present invention is not necessarily to be construed as preferred or advantageous over other embodiments or designs. Rather, use of the word "exemplary" or "such as" is intended to present concepts related in a concrete fashion.
The term "and/or" as used herein includes the use of either or both of the two methods.
In the description of the present application, the meaning of "a plurality" means two or more unless otherwise specified.
Based on the description in the background art, in the prior art, a private network UDM may not be able to determine whether there is an error in the user related data sent by a core network UDM in the first time, so that a device (including the private network UDM) in the private network may acquire the error data, which affects the data usage environment in the private network and reduces the communication experience of the user. Based on this, embodiments of the present invention provide a data synchronization method, apparatus, server, and storage medium, which can quickly and effectively determine whether a user has an error in subscription data, ensure that a device in a private network can use correct and effective data, and improve user experience.
The data synchronization method, the data synchronization device, the server and the storage medium provided by the embodiment of the invention can be applied to a data synchronization system. As shown in fig. 1, the data synchronization system includes a private network 10, a data sharing system 20, and an operator network 30. Specifically, the private network 10 includes the UDM 101 and the block link node 102, the data sharing system 20 includes the data sharing device 201, and the carrier network 30 includes the UDM 301. In general, in practical applications, the connections between the above-mentioned devices or service functions may be wireless connections, and fig. 1 illustrates the connections between the devices by solid lines for convenience of intuitively representing the connections between the devices.
The UDM 101 is configured to receive a target file sent by the blockchain node 102.
The block chain node 102 is configured to send a block chain ledger query request to the data sharing device 201, that is, request to query a synchronization record of subscription data corresponding to the first user group.
The data sharing device 201 is configured to receive the blockchain ledger query request sent by the blockchain node 102, and send a blockchain ledger query response to the blockchain linked node 102. In this embodiment of the present invention, the data sharing device 201 is further configured to receive a data synchronization request sent by the blockchain node 102, that is, request to synchronize subscription data corresponding to the first user group.
The UDM 301 is configured to receive a data synchronization request sent by the data sharing device 201, and is also configured to send a data synchronization response to the data sharing device 201.
In one implementation of the embodiment of the present invention, a block chain node (not shown in fig. 1) may be included in the UDM 301, and the block chain node may be understood as a functional module in the UDM 301. Similarly, the above blockchain node 102 can be a functional module in the UDM 101, and the interaction process of the blockchain 102 is performed by the UDM 101.
In another implementation of the embodiment of the present invention, a blockchain node (not shown in fig. 1) may be included in the operator network 30, and the function of the blockchain node is similar to that of the blockchain node 102. It should be understood that when the block chain node is included in the carrier network 30, the interaction process between the UDM 301 and the data sharing device 201 needs to be completed by relying on the block chain node, i.e. the data synchronization request sent by the data sharing device 201 needs to reach the UDM 301 via the block chain node.
It should be noted that 1 blockchain node, 1 data sharing device, and 2 UDMs shown in fig. 1 are only one example of the embodiment of the present invention. The number of the respective devices shown in fig. 1 is not particularly limited in the embodiment of the present invention.
Alternatively, the functions of the blockchain node, the data sharing device, or the UDM shown in fig. 1 may be integrated in a single physical device, such as a server. For example, the function of the above block chain node is integrated in a server, and a schematic diagram of a hardware structure of the server provided by the embodiment of the present invention is introduced. As shown in fig. 2, the server 20 includes a processor 201, a memory 202, a network interface 203, and the like.
The processor 201 is a core component of the server 20, and the processor 201 is configured to run an operating system of the server 20 and application programs (including a system application program and a third-party application program) on the server 20, so as to implement a data synchronization method performed by the server 20.
In this embodiment, the processor 201 may be a Central Processing Unit (CPU), a microprocessor, a Digital Signal Processor (DSP), an application-specific integrated circuit (ASIC), a Field Programmable Gate Array (FPGA) or other programmable logic device, a transistor logic device, a hardware component, or any combination thereof, which is capable of implementing or executing various exemplary logic blocks, modules, and circuits described in connection with the disclosure of the embodiment of the present invention; a processor may also be a combination of computing functions, e.g., comprising one or more microprocessors, a DSP and a microprocessor, or the like.
Optionally, the processor 201 of the server 20 includes one or more CPUs, which are single-core CPUs (single-CPUs) or multi-core CPUs (multi-CPUs).
The memory 202 includes, but is not limited to, a Random Access Memory (RAM), a Read Only Memory (ROM), an erasable programmable read-only memory (EPROM), a flash memory, an optical memory, or the like. The memory 202 holds the code for the operating system.
Optionally, the processor 201 implements the data synchronization method in the embodiment of the present invention by reading the instruction stored in the memory 202, or the processor 201 implements the data synchronization method provided in the embodiment of the present invention by using an instruction stored inside. In the case that the processor 201 implements the data synchronization method provided by the embodiment of the present invention by reading the execution saved in the memory, the memory stores the instruction for implementing the data synchronization method provided by the embodiment of the present invention.
The network interface 203 is a wired interface, such as a Fiber Distributed Data Interface (FDDI) interface or a Gigabit Ethernet (GE) interface. Alternatively, the network interface 203 is a wireless interface. The network interface 203 is used for the server 20 to communicate with other devices.
The memory 202 is used for storing the first digest, the preset digest algorithm and the IP address of the UDM. The at least one processor 201 further executes the method described in the embodiment of the present invention according to the first digest stored in the memory 202, the preset digest algorithm, and the IP address of the UDM. For more details of the above functions implemented by the processor 201, reference is made to the following description of various method embodiments.
Optionally, the server 20 further includes a bus, and the processor 201 and the memory 202 are connected to each other through the bus 204, or in other manners.
Optionally, the server 20 further includes an input/output interface 205, where the input/output interface 205 is configured to connect with an input device, and receive a blockchain ledger query request input by a user through the input device. Input devices include, but are not limited to, a keyboard, a touch screen, a microphone, and the like. The input/output interface 205 is also used to connect with an output device, outputting the blockchain ledger query response of the processor 201. Output devices include, but are not limited to, a display, a printer, and the like.
It should be understood that, in the embodiment of the present invention, the hardware structure of the data sharing device and the hardware structure of the UDM are similar to the hardware structure of the server 20 shown in fig. 2, and the description about the hardware structure of the data sharing device and the hardware structure of the UDM may refer to the description about the hardware structure of the server 20, which is not described in detail herein.
The data synchronization method, the data synchronization device, the server and the storage medium provided by the embodiment of the invention are applied to a scene that a private network UDM needs to synchronize user data in a core network UDM. When the private network UDM needs to perform data synchronization, based on the data synchronization method provided in the embodiment of the present invention, a synchronization record of subscription data corresponding to the first user group is queried from the data sharing device, and the target file is obtained from the core network UDM, and then the target file (specifically, the subscription data) is sent to the private network UDM by the block link node when the target file is tampered or damaged, so that the private network UDM can quickly and effectively obtain correct data.
With reference to the data synchronization system shown in fig. 1, the following completely describes the data synchronization method provided by the embodiment of the present invention from the perspective of interaction among devices in the data synchronization system, so as to describe a process in which a data sharing device completes packaging of related subscription data and a process in which a block chain node sends a target file to a local UDM (i.e., UDM 101).
As shown in fig. 3, the data synchronization method provided by the embodiment of the present invention may include S101 to S111.
S101, the block chain node sends a data synchronization request to the data sharing equipment.
The data synchronization request includes an identifier of a first user group, and the data synchronization request is used for requesting synchronization of subscription data corresponding to the first user group.
It should be understood that the blockchain node is a blockchain node deployed (or included) in a certain private network (e.g., a first private network). When a UDM (hereinafter, referred to as a local UDM) in the first private network needs to synchronize the subscription data from a UDM (hereinafter, referred to as a core network UDM) in a certain operator network (that is, the subscription data is obtained from the core network UDM and stored in the local UDM), the data synchronization request may be sent to the data sharing device by the block link node.
Similarly, when the UDMs in other private networks (e.g. a second private network) need to synchronize subscription data from the core network UDM, a data synchronization request may also be sent to the data sharing device by the block link node included in the second private network.
In an implementation manner of the embodiment of the present invention, the data synchronization request may also include an identifier of the first private network, so that the core network UDM may determine whether the first user group is a user group corresponding to the first private network, and further determine whether to return subscription data.
It is to be understood that the subscription data corresponding to the first user group includes subscription data of each user included in the first user group. The subscription data of a user may be understood as account opening data of the user, and the account opening data may include related identity information of the user (e.g., user identification, user name, company to which the user belongs, etc.), subscription information corresponding to the user (i.e., which types of services the user subscribes to, whether the user subscribes to both private network services and large network services, etc.), and slice information corresponding to the user (whether the user has subscription slice information, whether the user is an end-to-end slice, whether the user is a shared slice, etc.).
Optionally, the data synchronization request may further include an identifier of the operator and an identifier of each user in the first user group. Specifically, the identifier of the operator is used to characterize which data of the UDM in the core network of the operator the local UDM needs to synchronize; the identifier of each user is used for characterizing which subscription data of the users specifically need to be synchronized by the local UDM.
S102, the data sharing equipment receives a data synchronization request sent by the block chain node.
S103, the data sharing equipment sends a data synchronization request to the UDM.
Wherein, the UDM is the above core network UDM, i.e. the UDM included in the operator network.
S104, the UDM receives a data synchronization request sent by the data sharing equipment.
In connection with the above description of the embodiments, it should be understood that the data synchronization request includes an identification of the first user group, and the data synchronization request is used to request synchronization of subscription data corresponding to the first user group.
S105, the UDM acquires the subscription data corresponding to the first user group based on the identification of the first user group.
It is understood that the UDM, and in particular, a Unified Data Repository (UDR) function in the UDM, may store subscription data corresponding to each of a plurality of user groups. After receiving the data synchronization request sent by the data sharing device, the UDM may determine and acquire subscription data corresponding to the first user group based on an identifier of the user group (i.e., an identifier of the first user group) included in the data synchronization request.
In an implementation manner of the embodiment of the present invention, the data synchronization request further includes an identifier of the first private network, and before the UDM acquires the subscription data corresponding to the first user group based on the identifier of the first user group, the data synchronization method provided in the embodiment of the present invention further includes step a.
Step A, UDM determines whether the first private network is a user group corresponding to the first private network based on the identifier of the first private network and the target correspondence.
The target corresponding relation comprises a plurality of private networks and identifications of user groups corresponding to the private networks, and the first private network is one of the private networks.
It should be understood that when the identifier of the user group corresponding to the first private network includes the identifier of the first user group, it indicates that the first user group is the user group corresponding to the first private network. Otherwise, that is, when the identifier of the user group corresponding to the first private network does not include the identifier of the first user group, it indicates that the first user group is not the user group corresponding to the first private network.
The UDM obtains the subscription data corresponding to the first user group based on the identifier of the first user group, and specifically includes step B.
And step B, under the condition that the first user group is a user group corresponding to the first private network, the UDM acquires the subscription data corresponding to the first user group based on the identifier of the first user group.
It can be understood that, when the first user group is a user group corresponding to the first private network, it indicates that the data synchronization request is legal, and at this time, the UDM may obtain the subscription data based on the identifier of the first user group. Correspondingly, when the first user group is not the user group corresponding to the first private network, it indicates that the data synchronization request is illegal, and the UDM cannot perform the acquisition operation of the subscription data and may also send an alarm message.
S106, packaging the signing data by the UDM to generate a target file.
It should be understood that the subscription data is the subscription data corresponding to the first user group.
Alternatively, the target file may be an excel file.
S107, the UDM obtains a first abstract based on a preset abstract algorithm and the target file.
Specifically, the UDM may calculate the target file according to the preset digest algorithm, and generate the first digest. The first abstract is an abstract of the target file, and can be understood as a character string.
And S108, the UDM sends a data synchronization response to the data sharing equipment.
Wherein the data synchronization response includes the first digest, the predetermined digest algorithm, and the IP address of the UDM.
It is to be understood that the UDM may store the above-mentioned target file, and in particular, the target file may be stored in the UDR of the UDM. And, the data synchronization response sent by the UDM to the data sharing device includes the IP address of the UDM, so that a device (e.g. the above block chain node) can obtain the target file from the UDM based on the IP address.
In one implementation of the embodiment of the present invention, the data synchronization response may also include port information of the UDM, that is, the block link point may obtain the target file from the UDM based on a specific port.
In another implementation manner of the embodiment of the present invention, the data synchronization response may include the first digest, the preset digest algorithm, an IP address of a File Transfer Protocol (FTP) server, and a user name and a password of the FTP server. In this way, the blockchain node can reach the FTP server based on the IP address of the FTP server and log in the FTP server based on the user name and password to obtain the target file from the FTP server. The FTP server can be understood as a storage server.
It should be noted that the above-mentioned operator network also includes a block chain node (hereinafter, referred to as an operator block chain node), and in the embodiment of the present invention, the operator block chain node may be understood as a functional module in the UDM (i.e., the core network UDM), which is similar to the function of the block chain node in the above-mentioned first private network.
In one case, the operator block chaining point may also be deployed in the operator network separately, that is, the interaction process between the data sharing device and the UDM needs to rely on the operator block chaining node, for example, the UDM may send the data synchronization response to the operator block chaining node, so that the operator block chaining point may send the data synchronization response to the data sharing device.
S109, the data sharing equipment receives the data synchronization response sent by the UDM.
In connection with the above description of the embodiments, it should be understood that the data synchronization response includes the first digest, the preset digest algorithm, and the IP address of the UDM.
S110, the data sharing device stores the first abstract, a preset abstract algorithm and the IP address of the UDM into a data synchronization information book, and sends a data packaging notification message to the block link points.
Wherein the data packing notification message is used to notify the block link point that the subscription data corresponding to the first subscriber group has been packed.
It should be understood that the data synchronization information ledger is used to characterize the record of each time the data is synchronized. Specifically, the data synchronization information book includes a record of this time of synchronization data, that is, includes the first digest, the preset digest algorithm, and the IP address of the UDM.
In an implementation manner of the embodiment of the present invention, the data synchronization information book (specifically, the record of the current synchronization data) may further include an identifier of an operator, a data synchronization timestamp, a service validity period, and the like.
It will be appreciated that the identity of the operator is used to characterize from which operator's UDM the data was synchronized; the data synchronization timestamp is used for representing the time when the data sharing device stores the related information into the data synchronization information account book, and the service validity period is used for representing the valid time of the subscription data. Specifically, when a certain block link point requests to query the subscription data, if the time (i.e., the time of data query) is outside the service validity period, the subscription data acquired by the block link point may be invalid data.
And S111, the block chain node receives a data packaging notification message sent by the data sharing equipment.
In conjunction with the above description of the embodiments, it should be understood that the data packing notification message is used to notify the block link point that the subscription data corresponding to the first subscriber group has been packed.
It should be understood that the data sharing device notifies the block link point that the subscription data corresponding to the first subscriber group has been completely packaged, that is, notifies the block link point that the data synchronization information book may be requested to be queried, so as to obtain the record of the current synchronization data, specifically, obtain the first abstract, the preset abstract algorithm, the IP address of the UDM, and the like.
In the data synchronization method provided by the embodiment of the present invention, a block link point may send a data synchronization request to a UDM (specifically, a UDM in an operator network) via a data sharing device; after receiving the data synchronization request, the UDM may obtain subscription data corresponding to the first user group based on an identifier of the first user group included in the data synchronization request; then the UDM packs the signing data to generate a target file, and a first abstract is obtained based on a preset abstract algorithm and the target file; the UDM then sends a data synchronization response to the data sharing device, the data synchronization response including the first digest, the predetermined digest algorithm, and the IP address of the UDM. After receiving the data synchronization response, the data sharing device may store the first abstract, the preset abstract algorithm, and the IP address of the UDM in a data synchronization information book, and send a data packing notification message to the block link point, that is, notify the block link point that the subscription data corresponding to the first user group has been packed. The relevant records of the current synchronous data can be accurately acquired, and the relevant records are stored in the data synchronization information book.
Furthermore, when the block link point needs to query the data synchronization information book, the related records can be effectively acquired, and then whether the target file (namely the subscription data) is acquired from the UDM can be determined, so that the acquisition efficiency of the subscription data can be improved.
As shown in fig. 4, the data synchronization method provided in the embodiment of the present invention may further include S301-S310.
S301, the block chain node sends a block chain account book query request to the data sharing device.
The block chain account book query request includes an identifier of a first user group, and the block chain account book query request is used for requesting to query a synchronous record of subscription data corresponding to the first user group.
It should be understood that the data synchronization information book includes (or stores) a synchronization record having a plurality of contract data. The block link node requests to query the synchronization record of the subscription data corresponding to the first subscriber group, that is, the synchronization record is queried from the data synchronization information book.
Specifically, the block link point may implement the sending process of the block link account book query request by running an intelligent contract.
S302, the data sharing equipment receives a block chain account book inquiry request sent by a block chain node.
The block chain account book query request includes an identifier of a first user group, and the block chain account book query request is used for requesting to query a synchronous record of subscription data corresponding to the first user group.
S303, the data sharing device acquires the first abstract, the preset abstract algorithm and the IP address of the UDM from the data synchronization information book based on the identification of the first user group.
The first abstract is obtained by the UDM based on the preset abstract algorithm and a target file, and the target file is a file generated after the subscription data corresponding to the first user group is packaged.
It should be understood that the data sharing device may obtain, from the data synchronization information ledger, a synchronization record of the subscription data corresponding to the first user group based on the identifier of the first user group, where the synchronization record includes the first digest, the predetermined digest algorithm, and the IP address of the UDP.
S304, the data sharing equipment sends the block chain account book inquiry response to the block chain link points.
The block chain ledger query response comprises the first abstract, the preset abstract algorithm and the IP address of the UDM.
In an optional implementation manner, the data synchronization method provided in the embodiment of the present invention may further include step C.
And step C, the data sharing equipment stores the query result corresponding to the synchronous record into a data synchronous operation book.
It should be understood that the synchronization record is a synchronization record of the subscription data corresponding to the first user group. The data synchronization operation book is used for representing which device (which block chain node or which private network) performs query operation on subscription data of which users at what time, and how the query result is. That is, for the above steps, the data synchronization operation ledger may include a data query timestamp, an identification of the first private network, an identification of the operator, an identification of the first user group, and a query result.
Specifically, the data query timestamp is used for representing the time when the data sharing device acquires the first abstract, the preset abstract algorithm and the IP address of the UDM from the data synchronization information book. The query result includes: query success and query failure, where query failure indicates that the synchronization record has not been queried, or that the synchronization record has failed (e.g., the data query timestamp is outside the service validity period), etc.
S305, the block link node receives a block chain account query response sent by the data sharing device.
The block chain account book query response comprises the first abstract, the preset abstract algorithm and the IP address of the UDM, the first abstract is obtained by the UDM based on the preset abstract algorithm and a target file, and the target file is a file generated after the signing data corresponding to the first user group are packaged.
S306, the block chain link point acquires the target file based on the IP address of the UDM.
Optionally, the block link point may also obtain the target file based on the IP address of the UDM and the port information of the UDM; the block link point may further obtain the target file based on the IP address of the FTP server.
In an implementation manner of the embodiment of the present invention, the obtaining, by the block link point, a target file based on an IP address of the UDM specifically includes step D and step H.
And D, sending a file acquisition request to the UDM by the block chain link point.
The file acquisition request includes an identifier of the first user group, and the file acquisition request is used for requesting to acquire the target file.
Step E, UDM receives a file fetch request sent by a blockchain node.
The file acquisition request includes an identifier of the first user group, and the file acquisition request is used for requesting to acquire the target file.
Step F, UDM determining a target file based on the identity of the first group of users;
step G, UDM sends a file acquisition response to the chunk link point.
Wherein the file acquisition response includes the target file.
And step H, receiving a file acquisition response sent by the UDM by the block chain node point.
Wherein the file acquisition response includes the target file.
It should be noted that, the above steps D and H are the execution steps of the block chain node, that is, the specific process of obtaining the target file by the block chain node. And E-G is an execution step of the UDM, specifically a process of receiving a file acquisition request and sending a target file to a block link point.
S307, obtaining a second abstract based on the block link point and a preset abstract algorithm and the target file.
In conjunction with the above description, it should be understood that the block link point may calculate the target file according to the predetermined summarization algorithm to generate the second summary.
S308, the block link point determines whether the first abstract and the second abstract are the same.
It is understood that when the first digest is the same as the second digest, it indicates that the target file (specifically, the subscription data corresponding to the first user group) is not tampered or has no error, i.e., the local UDM can synchronize (or acquire) the subscription data. Accordingly, when the first digest is different from the second digest, it indicates that the target file has been tampered or there is error data in the subscription data, and thus, the operator may be required to perform related processing.
S309, under the condition that the first abstract is the same as the second abstract, the block link node sends the target file to the local UDM.
It should be understood that the local UDM is the UDM included in the first private network
S310, the local UDM receives the target file sent by the blockchain node.
To this end, the local UDM may obtain the subscription data corresponding to the first user based on the target file, that is, the subscription data is synchronized.
In the data synchronization method provided by the embodiment of the present invention, the block link node may send a block link account book query request to the data sharing device, that is, request to query a synchronization record of the subscription data corresponding to the first subscriber group; after receiving the query request for the blockchain ledger, the data sharing device may determine the synchronization record based on the identifier of the first subscriber group and send a blockchain ledger query response to the blockchain nodes, where the blockchain ledger query response includes the first abstract, a preset abstract algorithm, and an IP address of the UDM; the block link point can acquire a target file based on the IP address of the UDM and obtain a second abstract by combining the preset abstract algorithm; since the first digest is obtained by the UDM based on the predetermined digest algorithm and the target file, the blockchain node determines whether the first digest is the same as the second digest, that is, whether the target file (specifically, the subscription data) is tampered or has error data, and sends the target file to the local UDM when the first digest is the same as the second digest, that is, the subscription data has no error data. In this manner, the local UDM may obtain subscription data that has not been tampered with or that has no error data. Whether the signing data of the user has errors can be quickly and effectively determined, correct and effective data can be used by equipment in the private network, and user experience is improved.
In an implementation manner of the embodiment of the present invention, if a user group corresponding to a certain private network (a second private network) is the same as the first private network, it may be determined that the second private network is an equivalent network of the first private network. When the UDM in the second private network also needs to synchronize the subscription data corresponding to the first subscriber group, the block link point in the second private network may query the data synchronization information book (specifically, the synchronization record of the subscription data corresponding to the first subscriber group) by running an intelligent contract, and then acquire the subscription data (specifically, acquire the target file, and then acquire the subscription data) when the subscription data exists and is valid.
In this embodiment of the present invention, the data sharing system 20 may be understood as a blockchain platform, and the blockchain platform may further include a management node, configured to issue a shared platform formal and a secret key to each blockchain node, so that each blockchain node may join in a shared federation chain to implement data sharing. Specifically, the data sharing device may include a front-end interface, and the user may log in from the front-end interface and apply for accessing the sharing federation chain. The front-end interface can also display a plurality of block link points on the shared alliance chain, and can display operations such as chain and inquiry.
According to the method, the functional modules of the blockchain node, the data sharing device, the UDM and the like can be divided, for example, the functional modules can be divided corresponding to the functions, or two or more functions can be integrated into one processing module. The integrated module can be realized in a hardware mode, and can also be realized in a software functional module mode. It should be noted that, the division of the modules in the embodiment of the present invention is schematic, and is only a logic function division, and there may be another division manner in actual implementation.
In the case of dividing each functional module by corresponding functions, fig. 5 shows a schematic diagram of a possible structure of the data synchronization apparatus (specifically, the above block chain node) in the above embodiment, as shown in fig. 5, the data synchronization apparatus 30 may include: a sending module 301, a receiving module 302, an obtaining module 303, a processing module 304 and a determining module 305.
A sending module 301, configured to send a block chain ledger query request to a data sharing device, where the block chain ledger query request includes an identifier of a first user group, and the block chain ledger query request is used to request to query a synchronization record of subscription data corresponding to the first user group.
A receiving module 302, configured to receive a block chain ledger query response sent by the data sharing device, where the block chain ledger query response includes a first abstract, a preset abstract algorithm, and an IP address of the UDM, the first abstract is obtained by the UDM based on the preset abstract algorithm and a target file, and the target file is a file generated after the subscription data corresponding to the first user group is packaged.
An obtaining module 303, configured to obtain the target file based on the IP address of the UDM.
The processing module 304 is configured to obtain a second summary based on the preset summary algorithm and the target file.
A determining module 305 for determining whether the first summary and the second summary are the same.
The sending module 301 is further configured to send the target file to the local UDM if the first digest is the same as the second digest.
Optionally, the sending module 301 is further configured to send a data synchronization request to the data sharing device, where the data synchronization request includes an identifier of the first user group, and the data synchronization request is used to request to synchronize subscription data corresponding to the first user group.
The receiving module 302 is further configured to receive a data packing notification message sent by the data sharing device, where the data packing notification message is used to notify a block chain node that the subscription data corresponding to the first user group has been packed.
Optionally, the sending module 301 is further configured to send a file obtaining request to the UDM, where the file obtaining request includes an identifier of the first user group, and the file obtaining request is used to request to obtain the target file.
The receiving module 302 is further configured to receive a file obtaining response sent by the UDM, where the file obtaining response includes the target file.
In the case of an integrated unit, fig. 6 shows a possible structural diagram of the data synchronization apparatus (specifically, the above block chain node) involved in the above embodiment. As shown in fig. 6, the data synchronization device 40 may include: a processing module 401 and a communication module 402. The processing module 401 may be used for controlling and managing the actions of the data synchronization apparatus 40. The communication module 402 may be used to support communication of the data synchronization apparatus 40 with other entities. Optionally, as shown in fig. 6, the data synchronization apparatus 40 may further include a storage module 403 for storing program codes and data of the data synchronization apparatus 40.
The processing module 401 may be a processor or a controller (for example, the processor 201 shown in fig. 2). The communication module 402 may be a transceiver, a transceiver circuit, a communication interface, etc. (e.g., may be the network interface 203 as shown in fig. 2 described above). The storage module 403 may be a memory (e.g., may be the memory 202 described above and shown in fig. 2).
When the processing module 401 is a processor, the communication module 402 is a transceiver, and the storage module 403 is a memory, the processor, the transceiver, and the memory may be connected by a bus. The bus may be a Peripheral Component Interconnect (PCI) bus, an Extended Industry Standard Architecture (EISA) bus, or the like. The bus may be divided into an address bus, a data bus, a control bus, etc.
In the case of dividing each functional module according to each function, fig. 7 shows a schematic diagram of a possible structure of the data synchronization apparatus (specifically, the data sharing device) in the foregoing embodiment, as shown in fig. 7, the data synchronization apparatus 50 may include: a receiving module 501, an obtaining module 502 and a sending module 503.
A receiving module 501, configured to receive a block chain account book query request sent by a block chain node, where the block chain account book query request includes an identifier of a first user group, and the block chain account book query request is used to request to query a synchronization record of subscription data corresponding to the first user group.
An obtaining module 502, configured to obtain, based on the identifier of the first user group, a first abstract, a preset abstract algorithm, and an IP address of the UDM from the data synchronization information book, where the first abstract is obtained by the UDM based on the preset abstract algorithm and a target file, and the target file is a file generated after the subscription data corresponding to the first user group is packaged.
A sending module 503, configured to send a block chain ledger query response to the block chain link point, where the block chain ledger query response includes the first abstract, the preset abstract algorithm, and the IP address of the UDM.
Optionally, the data synchronization apparatus 50 further comprises a storage module 504.
The receiving module 501 is further configured to receive a data synchronization request sent by the blockchain node, where the data synchronization request includes an identifier of the first user group, and the data synchronization request is used to request synchronization of subscription data corresponding to the first user group.
The sending module 503 is further configured to send the data synchronization request to the UDM.
The receiving module 501 is further configured to receive a data synchronization response sent by the UDM, where the data synchronization response includes the first digest, the preset digest algorithm, and the IP address of the UDM.
A storage module 504, configured to store the first abstract, the preset abstract algorithm, and the IP address of the UDM into the data synchronization information book.
The sending module 503 is further configured to send a data packing notification message to the block link point, where the data packing notification message is used to notify that the subscription data corresponding to the first subscriber group has been packed.
Optionally, the storage module 504 is configured to store the query result corresponding to the synchronization record in a data synchronization operation ledger.
In the case of an integrated unit, fig. 8 shows a schematic diagram of a possible structure of the data synchronization apparatus (specifically, the data sharing device) in the above embodiment. As shown in fig. 8, the data synchronization device 60 may include: a processing module 601 and a communication module 602. The processing module 601 may be used for controlling and managing the actions of the data synchronization apparatus 60. The communication module 602 may be used to support communication of the data synchronization apparatus 60 with other entities. Optionally, as shown in fig. 8, the data synchronization apparatus 60 may further include a storage module 603 for storing program codes and data of the data synchronization apparatus 60.
The processing module 601 may be a processor or a controller (e.g., the processor 201 shown in fig. 2). The communication module 602 may be a transceiver, a transceiver circuit, a communication interface, etc. (e.g., may be the network interface 203 as shown in fig. 2 described above). The storage module 603 may be a memory (e.g., may be the memory 202 described above in fig. 2).
When the processing module 601 is a processor, the communication module 602 is a transceiver, and the storage module 603 is a memory, the processor, the transceiver, and the memory may be connected via a bus. The bus may be a PCI bus or an EISA bus, etc. The bus may be divided into an address bus, a data bus, a control bus, etc.
In the case of dividing each functional module according to each function, fig. 9 shows a schematic diagram of a possible structure of the data synchronization apparatus (specifically, the UDM) in the foregoing embodiment, and as shown in fig. 9, the data synchronization apparatus 70 may include: a receiving module 701, an obtaining module 702, a processing module 703 and a sending module 704.
A receiving module 701, configured to receive a data synchronization request sent by a data sharing device, where the data synchronization request includes an identifier of a first user group, and the data synchronization request is used to request to synchronize subscription data corresponding to the first user group.
An obtaining module 702, configured to obtain subscription data corresponding to the first user group based on the identifier of the first user group.
The processing module 703 is configured to package the subscription data to generate a target file.
The processing module 703 is further configured to obtain a first abstract based on a preset abstract algorithm and the target file.
A sending module 704, configured to send a data synchronization response to the data sharing device, where the data synchronization response includes the first digest, the preset digest algorithm, and an IP address of the UDM.
Optionally, the data synchronization apparatus 70 further comprises a determining module 705, and the data synchronization request further comprises an identifier of the first private network.
The determining module 705 is configured to determine whether the first user group is a user group corresponding to the first private network based on the identifier of the first private network and a target correspondence relationship, where the target correspondence relationship includes a plurality of private networks and identifiers of user groups corresponding to the plurality of private networks, and the first private network is one of the plurality of private networks.
The obtaining module 702 is specifically configured to, when the first user group is a user group corresponding to the first private network, obtain subscription data corresponding to the first user group based on the identifier of the first user group.
Optionally, the receiving module 701 is further configured to receive a file obtaining request sent by the blockchain node, where the file obtaining request includes an identifier of the first user group, and the file obtaining request is used to request to obtain the target file.
A determining module 705 for determining the target file based on the identity of the first group of users.
The sending module 704 is further configured to send a file obtaining response to the block link point, where the file obtaining response includes the target file.
In case of using an integrated unit, fig. 10 shows a possible structural schematic diagram of the data synchronization apparatus (specifically, the UDM) involved in the above embodiment. As shown in fig. 10, the data synchronization device 80 may include: a processing module 801 and a communication module 802. The processing module 801 may be used to control and manage the actions of the data synchronization apparatus 80. The communication module 802 may be used to support communication of the data synchronization apparatus 80 with other entities. Optionally, as shown in fig. 10, the data synchronization apparatus 80 may further include a storage module 803 for storing program codes and data of the data synchronization apparatus 80.
The processing module 801 may be a processor or a controller (e.g., the processor 201 shown in fig. 2). The communication module 802 may be a transceiver, a transceiver circuit, or a communication interface, etc. (e.g., may be the network interface 203 as shown in fig. 2 described above). The storage module 803 may be a memory (e.g., may be the memory 202 described above with reference to fig. 2).
When the processing module 801 is a processor, the communication module 802 is a transceiver, and the storage module 803 is a memory, the processor, the transceiver, and the memory may be connected via a bus. The bus may be a PCI bus or an EISA bus, etc. The bus may be divided into an address bus, a data bus, a control bus, etc.
It should be understood that, in various embodiments of the present invention, the sequence numbers of the above-mentioned processes do not mean the execution sequence, and the execution sequence of each process should be determined by its function and inherent logic, and should not constitute any limitation on the implementation process of the embodiments of the present invention.
Those of ordinary skill in the art will appreciate that the various illustrative elements and algorithm steps described in connection with the embodiments disclosed herein may be implemented as electronic hardware or combinations of computer software and electronic hardware. Whether such functionality is implemented as hardware or software depends upon the particular application and design constraints imposed on the implementation. Skilled artisans may implement the described functionality in varying ways for each particular application, but such implementation decisions should not be interpreted as causing a departure from the scope of the present invention.
It is clear to those skilled in the art that, for convenience and brevity of description, the specific working processes of the above-described systems, apparatuses and units may refer to the corresponding processes in the foregoing method embodiments, and are not described herein again.
The units described as separate parts may or may not be physically separate, and parts displayed as units may or may not be physical units, may be located in one place, or may be distributed on a plurality of network units. Some or all of the units can be selected according to actual needs to achieve the purpose of the solution of the embodiment.
In the above embodiments, the implementation may be wholly or partially realized by software, hardware, firmware, or any combination thereof. When implemented using a software program, may be implemented in whole or in part in the form of a computer program product. The computer program product includes one or more computer instructions. The procedures or functions described in accordance with the embodiments of the invention are all or partially effected when the computer program instructions are loaded and executed on a computer. The computer may be a general purpose computer, a special purpose computer, a network of computers, or other programmable device. The computer instructions may be stored on a computer readable storage medium or transmitted from one computer readable storage medium to another, for example, from one website, computer, server, or data center to another website, computer, server, or data center via wire (e.g., coaxial cable, fiber optics, Digital Subscriber Line (DSL)) or wireless (e.g., infrared, wireless, microwave, etc.). The computer-readable storage medium can be any available medium that can be accessed by a computer or can comprise one or more data storage devices, such as a server, a data center, etc., that can be integrated with the medium. The usable medium may be a magnetic medium (e.g., floppy Disk, hard Disk, magnetic tape), an optical medium (e.g., DVD), or a semiconductor medium (e.g., Solid State Disk (SSD)), among others.
The above description is only for the specific embodiments of the present invention, but the scope of the present invention is not limited thereto, and any person skilled in the art can easily conceive of the changes or substitutions within the technical scope of the present invention, and all the changes or substitutions should be covered within the scope of the present invention. Therefore, the protection scope of the present invention shall be subject to the protection scope of the claims.
Claims (21)
1. A method of data synchronization, comprising:
the method comprises the steps that a block chain account book query request is sent to data sharing equipment by a block chain node, the block chain account book query request comprises an identifier of a first user group, and the block chain account book query request is used for requesting to query synchronous records of subscription data corresponding to the first user group;
the block chain node receives a block chain account book query response sent by the data sharing device, wherein the block chain account book query response comprises a first abstract, a preset abstract algorithm and an internet protocol IP address of a unified data management function (UDM), the first abstract is obtained by the UDM based on the preset abstract algorithm and a target file, and the target file is a file generated after signing data corresponding to the first user group is packaged;
the block link point acquires the target file based on the IP address of the UDM;
the block link points obtain a second abstract based on the preset abstract algorithm and the target file;
the blockchain node determining whether the first summary and the second summary are the same;
in the case that the first and second digests are the same, the block link node sends the target file to a local UDM.
2. The data synchronization method of claim 1, wherein before the blockchain node sends a blockchain ledger query request to a data sharing device, the method further comprises:
the block chain node sends a data synchronization request to the data sharing equipment, wherein the data synchronization request comprises the identifier of the first user group, and the data synchronization request is used for requesting to synchronize the subscription data corresponding to the first user group;
and the block chain node receives a data packing notification message sent by the data sharing device, wherein the data packing notification message is used for notifying the block chain node that the signing data corresponding to the first user group is packed completely.
3. The data synchronization method according to claim 1 or 2, wherein the blockchain node acquires the target file based on the IP address of the UDM, including:
the block chain node sends a file acquisition request to the UDM, wherein the file acquisition request comprises an identifier of the first user group, and the file acquisition request is used for requesting to acquire the target file;
and the block chain node receives a file acquisition response sent by the UDM, wherein the file acquisition response comprises the target file.
4. A method of data synchronization, comprising:
the method comprises the steps that a data sharing device receives a block chain account book query request sent by a block chain node, wherein the block chain account book query request comprises an identifier of a first user group, and the block chain account book query request is used for requesting to query a synchronous record of subscription data corresponding to the first user group;
the data sharing device acquires a first abstract, a preset abstract algorithm and an Internet Protocol (IP) address of a unified data management function (UDM) from a data synchronization information book based on the identifier of the first user group, wherein the first abstract is acquired by the UDM based on the preset abstract algorithm and a target file, and the target file is a file generated after signing data corresponding to the first user group is packaged;
and the data sharing equipment sends a block chain account book query response to the block chain link points, wherein the block chain account book query response comprises the first abstract, the preset abstract algorithm and the IP address of the UDM.
5. The data synchronization method according to claim 4, wherein before the data sharing device receives the blockchain ledger query request sent by a blockchain node, the method further comprises:
the data sharing device receives a data synchronization request sent by the blockchain node, wherein the data synchronization request comprises an identifier of the first user group, and the data synchronization request is used for requesting to synchronize subscription data corresponding to the first user group;
the data sharing device sends the data synchronization request to the UDM;
the data sharing equipment receives a data synchronization response sent by the UDM, wherein the data synchronization response comprises the first abstract, the preset abstract algorithm and the IP address of the UDM;
and the data sharing device stores the first abstract, the preset abstract algorithm and the IP address of the UDM into the data synchronization information book, and sends a data packaging notification message to the block chain node, wherein the data packaging notification message is used for notifying the block chain node that the subscription data corresponding to the first user group is packaged completely.
6. The data synchronization method according to claim 4 or 5, wherein the method further comprises:
and the data sharing equipment stores the query result corresponding to the synchronous record into a data synchronous operation book.
7. A method of data synchronization, comprising:
a unified data management function (UDM) receives a data synchronization request sent by a data sharing device, wherein the data synchronization request comprises an identifier of a first user group, and the data synchronization request is used for requesting to synchronize subscription data corresponding to the first user group;
the UDM acquires subscription data corresponding to the first user group based on the identifier of the first user group;
the UDM packs the signing data to generate a target file;
the UDM obtains a first abstract based on a preset abstract algorithm and the target file;
and the UDM sends a data synchronization response to the data sharing equipment, wherein the data synchronization response comprises the first abstract, the preset abstract algorithm and the Internet Protocol (IP) address of the UDM.
8. The data synchronization method of claim 7, wherein the data synchronization request further comprises an identification of the first private network, the method further comprising:
the UDM determines whether the first user group is a user group corresponding to the first private network or not based on the identifier of the first private network and a target corresponding relation, wherein the target corresponding relation comprises a plurality of private networks and identifiers of user groups corresponding to the private networks, and the first private network is one of the private networks;
the UDM obtains subscription data corresponding to the first user group based on the identifier of the first user group, including:
and when the first user group is a user group corresponding to the first private network, the UDM acquires subscription data corresponding to the first user group based on the identifier of the first user group.
9. The data synchronization method according to claim 7 or 8, wherein the method further comprises:
the UDM receives a file acquisition request sent by the blockchain node, wherein the file acquisition request comprises an identifier of the first user group, and the file acquisition request is used for requesting to acquire the target file;
the UDM determines the target file based on the identification of the first user group;
and the UDM sends a file acquisition response to the block link node, wherein the file acquisition response comprises the target file.
10. A data synchronization apparatus, comprising: the device comprises a sending module, a receiving module, an obtaining module, a processing module and a determining module;
the sending module is configured to send a block chain account book query request to the data sharing device, where the block chain account book query request includes an identifier of a first user group, and the block chain account book query request is used to request to query a synchronization record of subscription data corresponding to the first user group;
the receiving module is configured to receive a block chain ledger query response sent by the data sharing device, where the block chain ledger query response includes a first abstract, a preset abstract algorithm, and an internet protocol IP address of a unified data management function UDM, the first abstract is obtained by the UDM based on the preset abstract algorithm and a target file, and the target file is a file generated after signing data corresponding to the first user group is packaged;
the acquisition module is used for acquiring the target file based on the IP address of the UDM;
the processing module is used for obtaining a second abstract based on the preset abstract algorithm and the target file;
the determining module is configured to determine whether the first summary and the second summary are the same;
the sending module is further configured to send the target file to a local UDM when the first digest is the same as the second digest.
11. The data synchronization apparatus according to claim 10,
the sending module is further configured to send a data synchronization request to the data sharing device, where the data synchronization request includes an identifier of the first user group, and the data synchronization request is used to request synchronization of subscription data corresponding to the first user group;
the receiving module is further configured to receive a data packing notification message sent by the data sharing device, where the data packing notification message is used to notify a block chain node that the subscription data corresponding to the first user group has been packed.
12. The data synchronization apparatus according to claim 10 or 11,
the sending module is further configured to send a file acquisition request to the UDM, where the file acquisition request includes an identifier of the first user group, and the file acquisition request is used to request to acquire the target file;
the receiving module is further configured to receive a file acquisition response sent by the UDM, where the file acquisition response includes the target file.
13. A data synchronization apparatus, comprising: the device comprises a receiving module, an obtaining module and a sending module;
the receiving module is configured to receive a block chain account book query request sent by a block chain node, where the block chain account book query request includes an identifier of a first user group, and the block chain account book query request is used to request to query a synchronization record of subscription data corresponding to the first user group;
the acquisition module is configured to acquire a first abstract, a preset abstract algorithm and an internet protocol IP address of a unified data management function UDM from a data synchronization information book based on an identifier of the first user group, where the first abstract is obtained by the UDM based on the preset abstract algorithm and a target file, and the target file is a file generated after signing data corresponding to the first user group is packaged;
the sending module is configured to send a block chain ledger query response to the block chain link point, where the block chain ledger query response includes the first abstract, the preset abstract algorithm, and the IP address of the UDM.
14. The data synchronization apparatus of claim 13, wherein the data synchronization apparatus further comprises a storage module;
the receiving module is further configured to receive a data synchronization request sent by the blockchain node, where the data synchronization request includes an identifier of the first user group, and the data synchronization request is used to request synchronization of subscription data corresponding to the first user group;
the sending module is further configured to send the data synchronization request to the UDM;
the receiving module is further configured to receive a data synchronization response sent by the UDM, where the data synchronization response includes the first digest, the preset digest algorithm, and an IP address of the UDM;
the storage module is configured to store the first abstract, the preset abstract algorithm, and the IP address of the UDM into the data synchronization information book;
the sending module is further configured to send a data packing notification message to the blockchain node, where the data packing notification message is used to notify the blockchain node that the subscription data corresponding to the first user group has been packed.
15. The data synchronization apparatus according to claim 13 or 14, wherein the data synchronization apparatus further comprises a storage module;
and the storage module is used for storing the query result corresponding to the synchronous record into a data synchronous operation book.
16. A data synchronization apparatus, comprising: the device comprises a receiving module, an obtaining module, a processing module and a sending module;
the receiving module is configured to receive a data synchronization request sent by a data sharing device, where the data synchronization request includes an identifier of a first user group, and the data synchronization request is used to request synchronization of subscription data corresponding to the first user group;
the obtaining module is configured to obtain subscription data corresponding to the first user group based on the identifier of the first user group;
the processing module is used for packaging the signing data to generate a target file;
the processing module is further used for obtaining a first abstract based on a preset abstract algorithm and the target file;
the sending module is configured to send a data synchronization response to the data sharing device, where the data synchronization response includes the first digest, the preset digest algorithm, and an internet protocol IP address of a unified data management function UDM.
17. The data synchronization apparatus of claim 16, wherein the data synchronization apparatus further comprises a determination module, and wherein the data synchronization request further comprises an identification of the first private network;
the determining module is configured to determine whether the first user group is a user group corresponding to the first private network based on an identifier of the first private network and a target correspondence relationship, where the target correspondence relationship includes a plurality of private networks and identifiers of user groups corresponding to the plurality of private networks, and the first private network is one of the plurality of private networks;
the obtaining module is specifically configured to, when the first user group is a user group corresponding to the first private network, obtain subscription data corresponding to the first user group based on the identifier of the first user group.
18. The data synchronization apparatus according to claim 16 or 17, wherein the data synchronization apparatus further comprises a determination module;
the receiving module is further configured to receive a file acquisition request sent by the blockchain node, where the file acquisition request includes an identifier of the first user group, and the file acquisition request is used to request to acquire the target file;
the determining module is used for determining the target file based on the identification of the first user group;
the sending module is further configured to send a file acquisition response to the block link node, where the file acquisition response includes the target file.
19. A server, characterized in that the server comprises:
a processor;
a memory configured to store the processor-executable instructions;
wherein the processor is configured to execute the instructions to implement the data synchronization method of any one of claims 1-3, or to implement the data synchronization method of any one of claims 4-6, or to implement the data synchronization method of any one of claims 7-9.
20. A computer-readable storage medium having instructions stored thereon, which when executed by a server, enable the server to perform a data synchronization method as claimed in any one of claims 1 to 3, or perform a data synchronization method as claimed in any one of claims 4 to 6, or perform a data synchronization method as claimed in any one of claims 7 to 9.
21. A computer program product, characterized in that the computer program product comprises computer instructions which, when run on a server, cause the server to perform the data synchronization method of any of claims 1-3, or to perform the data synchronization method of any of claims 4-6, or to perform the data synchronization method of any of claims 7-9.
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202111342917.6A CN114125812B (en) | 2021-11-12 | 2021-11-12 | Data synchronization method, device, server and storage medium |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202111342917.6A CN114125812B (en) | 2021-11-12 | 2021-11-12 | Data synchronization method, device, server and storage medium |
Publications (2)
Publication Number | Publication Date |
---|---|
CN114125812A true CN114125812A (en) | 2022-03-01 |
CN114125812B CN114125812B (en) | 2023-07-18 |
Family
ID=80379405
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN202111342917.6A Active CN114125812B (en) | 2021-11-12 | 2021-11-12 | Data synchronization method, device, server and storage medium |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN114125812B (en) |
Cited By (2)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN114756901A (en) * | 2022-04-11 | 2022-07-15 | 敏于行(北京)科技有限公司 | Operational risk monitoring method and device |
CN115460231A (en) * | 2022-09-06 | 2022-12-09 | 北京信息科技大学 | User data storage method based on block chain in mobile communication core network |
Citations (8)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN109308287A (en) * | 2018-09-26 | 2019-02-05 | 南京荣链科技有限公司 | A kind of partitions of file storage method, terminal and medium based on block chain |
WO2020001336A1 (en) * | 2018-06-26 | 2020-01-02 | 华为技术有限公司 | Information processing method and device |
CN112449350A (en) * | 2019-08-30 | 2021-03-05 | 华为技术有限公司 | Method, device and system for providing service for terminal by using block chain |
CN112584380A (en) * | 2019-09-29 | 2021-03-30 | 中兴通讯股份有限公司 | Verification method, data synchronization method, device, network element and medium |
WO2021062664A1 (en) * | 2019-09-30 | 2021-04-08 | 华为技术有限公司 | Method, device, and system for updating configuration data |
WO2021138822A1 (en) * | 2020-01-07 | 2021-07-15 | 华为技术有限公司 | Subscription information acquisition method and device |
CN113453213A (en) * | 2021-06-02 | 2021-09-28 | 中国联合网络通信集团有限公司 | Authentication data synchronization method and device |
CN113573346A (en) * | 2021-07-12 | 2021-10-29 | 中国联合网络通信集团有限公司 | Data processing method and device |
-
2021
- 2021-11-12 CN CN202111342917.6A patent/CN114125812B/en active Active
Patent Citations (8)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
WO2020001336A1 (en) * | 2018-06-26 | 2020-01-02 | 华为技术有限公司 | Information processing method and device |
CN109308287A (en) * | 2018-09-26 | 2019-02-05 | 南京荣链科技有限公司 | A kind of partitions of file storage method, terminal and medium based on block chain |
CN112449350A (en) * | 2019-08-30 | 2021-03-05 | 华为技术有限公司 | Method, device and system for providing service for terminal by using block chain |
CN112584380A (en) * | 2019-09-29 | 2021-03-30 | 中兴通讯股份有限公司 | Verification method, data synchronization method, device, network element and medium |
WO2021062664A1 (en) * | 2019-09-30 | 2021-04-08 | 华为技术有限公司 | Method, device, and system for updating configuration data |
WO2021138822A1 (en) * | 2020-01-07 | 2021-07-15 | 华为技术有限公司 | Subscription information acquisition method and device |
CN113453213A (en) * | 2021-06-02 | 2021-09-28 | 中国联合网络通信集团有限公司 | Authentication data synchronization method and device |
CN113573346A (en) * | 2021-07-12 | 2021-10-29 | 中国联合网络通信集团有限公司 | Data processing method and device |
Non-Patent Citations (4)
Title |
---|
"\"33501-g30\"", 3GPP TSG_SA\\WG3_SECURITY * |
ERICSSON, KDDI: "C4-195352 \"Discussion on Subscription Data Consistency\"", 3GPP TSG_CT\\WG4_PROTOCOLLARS_EX-CN4, no. 4 * |
ERICSSON: "S3-192046 \"Requirements for credential storage in the UDR\"", 3GPP TSG_SA\\WG3_SECURITY, no. 3 * |
任驰;: "4G与5G融合组网及互操作技术研究", 移动通信, no. 01 * |
Cited By (2)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN114756901A (en) * | 2022-04-11 | 2022-07-15 | 敏于行(北京)科技有限公司 | Operational risk monitoring method and device |
CN115460231A (en) * | 2022-09-06 | 2022-12-09 | 北京信息科技大学 | User data storage method based on block chain in mobile communication core network |
Also Published As
Publication number | Publication date |
---|---|
CN114125812B (en) | 2023-07-18 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
WO2020057163A1 (en) | Mec platform deployment method and device | |
CN110086755B (en) | Method for realizing service of Internet of things, application server, Internet of things equipment and medium | |
CN111460458B (en) | Data processing method, related device and computer storage medium | |
CN111182527B (en) | OTA (over the air) firmware upgrading method and device, terminal equipment and storage medium thereof | |
CN114125812B (en) | Data synchronization method, device, server and storage medium | |
CN110602234B (en) | Block chain network node management method, device, equipment and storage medium | |
CN113271311A (en) | Digital identity management method and system in cross-link network | |
CN111510326A (en) | Master-slave equipment configuration information synchronization method, system, terminal equipment and storage medium | |
CN113221093B (en) | Single sign-on system, method, equipment and product based on block chain | |
CN106571968B (en) | Service switching method and system | |
CN109495362B (en) | Access authentication method and device | |
CN113489689B (en) | Authentication method and device for access request, storage medium and electronic equipment | |
CN112650954B (en) | Block chain data sharing method, device, equipment and storage medium | |
CN116467062A (en) | Block chain-based data processing method, equipment and readable storage medium | |
CN109672756B (en) | Data transmission method and related device, server and storage medium | |
CN111937013B (en) | Electronic device management | |
CN111459899B (en) | Log sharing method and device and terminal equipment | |
CN113765876B (en) | Report processing software access method and device | |
CN115412920A (en) | Internet of things equipment binding system, method and device and electronic equipment | |
US9313272B2 (en) | Information processor and information processing method | |
CN111934928A (en) | Terminal equipment upgrading method, device, management platform, system and equipment | |
CN118175464B (en) | FTTR gateway upgrading method, gateway equipment, system and computer readable storage medium | |
CN113055254A (en) | Address configuration method, device, access server and storage medium | |
CN118316631B (en) | Identity authentication realization method and system | |
CN114513526B (en) | Method, system and first blockchain for accessing data across chains |
Legal Events
Date | Code | Title | Description |
---|---|---|---|
PB01 | Publication | ||
PB01 | Publication | ||
SE01 | Entry into force of request for substantive examination | ||
SE01 | Entry into force of request for substantive examination | ||
GR01 | Patent grant | ||
GR01 | Patent grant |