CN109871390A - A kind of more copy data synchronous method of distribution, system and server - Google Patents
A kind of more copy data synchronous method of distribution, system and server Download PDFInfo
- Publication number
- CN109871390A CN109871390A CN201910137349.2A CN201910137349A CN109871390A CN 109871390 A CN109871390 A CN 109871390A CN 201910137349 A CN201910137349 A CN 201910137349A CN 109871390 A CN109871390 A CN 109871390A
- Authority
- CN
- China
- Prior art keywords
- version number
- record information
- new version
- server
- destination server
- 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.)
- Pending
Links
Landscapes
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
The present invention provides a kind of more copy data synchronous method of distribution, system and servers, which comprises the Transaction Information of each transactional operation is split as at least one record information；More new version number corresponding with each record information is generated, the record information of at least one transactional operation and corresponding more new version number are transmitted to destination server；On destination server, more new version number is verified to determine whether to update corresponding record information to destination server, distributed more copy data synchronous efficiencies can be improved in the present invention.
Description
Technical field
The present invention relates to distributed system technical field more particularly to a kind of more copy data synchronous method of distribution, it is
System and server.
Background technique
The more copies of distributed data refer to that there are numbers on more than two computer nodes for a data information (original)
According to copy, such as in banking system, there are the account balance data of some client on the host of isomery and open system.
The synchronous final consistency for guaranteeing more copies of data that the more copies of distributed data pass through different computer nodes.Data final one
Cause property refers to that the different copies of same data in distributed system are not real-time holding strongly consistent, but finally guarantees consistency
Characteristic.
The data of different computer nodes synchronize that generally use the data based on transaction journal same in distributed system at present
Step technology.For example, as shown in Figure 1, trade transactions operate successfully in source server, source server when transactional operation occurs
It, will in strict accordance with data manipulation sequence in time sequencing and affairs according to transaction journal by reading the transaction journal of trade transactions
The more new data formed after operation object and transactional operation is sent to destination server, and destination server operates pair based on the received
As more new data is updated in the corresponding operation object of destination server with the time sequencing of more new data and transaction boundaries.This
The defect of the kind data method of synchronization is that synchronization delay is larger, and especially in the case where transactional operation high concurrent, delay may
Reach 1s or more, the reason is that destination server must execute number in strict accordance with the affairs generation timing sequence and transaction boundaries of source server
According to synchronization, follow-up data operation has to wait for continue to synchronize after preceding data synchronously completes, and data is caused to be prolonged synchronization time
Long, synchronous efficiency is low, and distributed system data simultaneous pressure is larger, easily leads to server crash or crash.
Summary of the invention
It is an object of the present invention to provide a kind of more copy data synchronous method of distribution, improve distributed more copies
Data synchronization efficiency.It is another object of the present invention to provide a kind of more copy data synchronization systems of distribution.Of the invention
Further object is to provide a kind of server.Another purpose of the invention is that providing a kind of computer equipment.The present invention
Further an object is that providing a kind of readable medium.
In order to reach the goals above, one aspect of the present invention discloses a kind of more copy data synchronous method of distribution, comprising:
The Transaction Information of each transactional operation is split as at least one record information；
More new version number corresponding with each record information is generated, by the record information and correspondence of at least one transactional operation
More new version number be transmitted to destination server；
On destination server, more new version number is verified to determine whether to update corresponding record information to target
Server.
Preferably, the Transaction Information by each transactional operation be split as at least one record information specifically include:
Obtain the operation pair after at least one operation object and the transactional operation in the Transaction Information of each transactional operation
The more new data of elephant forms at least one record information according at least one described operation object and corresponding more new data.
Preferably, the generation more new version number corresponding with each record information specifically includes:
Time sequencing based at least one the record information sequentially generates and often according to default version number update rule
The corresponding more new version number of a record information.
Preferably, the generation more new version number corresponding with each record information specifically includes:
Determine the operation object of each record information；
Obtain the current version number of the operation object；
Current version number based on the operation object updates the rule generation record information according to version number is preset
More new version number；
The value of the current version number is replaced with to the value of the more new version number.
Preferably, described more new version number to be verified to determine whether to update corresponding record information to destination service
Implement body includes:
A record information obtains the operation object and more new data of the record information based on the received；
The current version number of operation object described in destination server and more new version number are compared, if the more new version
Number it is greater than the current version number, the basic data of operation object described on destination server is replaced with into the more new data,
The value of the current version number of operation object described on destination server is replaced with to the value of the more new version number.
The invention also discloses a kind of more copy data synchronization systems of distribution, including source server and at least one target
Server；
The source server be used for by the Transaction Information of each transactional operation be split as at least one record information, generate with
The corresponding more new version number of each record information, the record information of at least one transactional operation and corresponding more new version number are passed
Transport to destination server；
The destination server is for verifying more new version number to determine whether to update corresponding record information extremely
Destination server.
The invention also discloses a kind of server, it is configured as the Transaction Information of each transactional operation being split as at least one
A record information generates corresponding with each record information more new version number, by the record information of at least one transactional operation with
Corresponding more new version number is transmitted to destination server, so that the destination server verifies with determination more new version number
Whether corresponding record information is updated to destination server.
The invention also discloses a kind of server, be configured as receiving at least one record information of source server transmission and
Corresponding more new version number verifies more new version number to determine whether to update corresponding record information to destination service
Device, wherein at least one described record information is what the source server split the Transaction Information of each transactional operation,
The more new version number source server is correspondingly formed according to each record information.
The invention also discloses a kind of computer equipment, including memory, processor and storage are on a memory and can
The computer program run on a processor, the processor realize method as described above when executing described program.
The invention also discloses a kind of computer-readable mediums, are stored thereon with computer program, and the program is by processor
Method as described above is realized when execution.
The Transaction Information of each transactional operation is split as at least one record by the present invention, and raw for each record information
At more new version number accordingly.And then it can be by the record information of at least one transactional operation and corresponding more new version number without suitable
Sequence is transmitted to destination server without the mode of affairs.Destination server by update checkout of version number with the received record of determination
Whether more current than destination server the version of information version be higher, i.e., whether the basic data of destination server is newest base
Plinth data, and then determine the need for received record information update to destination server.Unirecord can be achieved simultaneously in the present invention
The data of hair are synchronous, multiple record information can with simultaneous transmission with it is synchronous, data synchronization is not depended on independent of transaction boundaries yet
In transaction timing, so that extremely low data synchronization delay and high concurrent handling capacity can be realized.The present invention can be same by data
The average retardation index of step drops below 50ms, compared with tradition is based on the serial data simultaneous techniques of transaction journal, performance
Increase rate reaches 1000%.
Detailed description of the invention
In order to more clearly explain the embodiment of the invention or the technical proposal in the existing technology, to embodiment or will show below
There is attached drawing needed in technical description to be briefly described, it should be apparent that, the accompanying drawings in the following description is only this
Some embodiments of invention for those of ordinary skill in the art without creative efforts, can be with
It obtains other drawings based on these drawings.
Fig. 1 shows the schematic diagram of distributed more copy data synchronization schemes in the prior art；
Fig. 2 shows a kind of one of flow charts of the more copy data synchronous method specific embodiments of distribution of the present invention；
Fig. 3 shows the two of a kind of flow chart of the more copy data synchronous method specific embodiments of distribution of the present invention；
Fig. 4 shows the three of a kind of flow chart of the more copy data synchronous method specific embodiments of distribution of the present invention；
Fig. 5 shows the four of a kind of flow chart of the more copy data synchronous method specific embodiments of distribution of the present invention；
Fig. 6 shows the five of a kind of flow chart of the more copy data synchronous method specific embodiments of distribution of the present invention；
Fig. 7 shows a kind of working principle diagram of more one specific example of copy data synchronous method of distribution of the present invention；
Fig. 8 shows the structural schematic diagram for being suitable for the computer equipment for being used to realize the embodiment of the present invention.
Specific embodiment
Following will be combined with the drawings in the embodiments of the present invention, and technical solution in the embodiment of the present invention carries out clear, complete
Site preparation description, it is clear that described embodiments are only a part of the embodiments of the present invention, instead of all the embodiments.It is based on
Embodiment in the present invention, it is obtained by those of ordinary skill in the art without making creative efforts every other
Embodiment shall fall within the protection scope of the present invention.
According to an aspect of the present invention, present embodiment discloses a kind of more copy data synchronous method of distribution.Such as Fig. 2
It is shown, in the present embodiment, which comprises
S100: the Transaction Information of each transactional operation is split as at least one record information.
S200: more new version number corresponding with each record information is generated, by the record information of at least one transactional operation
Destination server is transmitted to corresponding more new version number.
S300: on destination server, more new version number is verified to determine whether to update corresponding record information
To destination server.
The Transaction Information of each transactional operation is split as at least one record by the present invention, and raw for each record information
At more new version number accordingly.And then it can be by the record information of at least one transactional operation and corresponding more new version number without suitable
Sequence is transmitted to destination server without the mode of affairs.Destination server by update checkout of version number with the received record of determination
Whether more current than destination server the version of information version be higher, i.e., whether the basic data of destination server is newest base
Plinth data, and then determine the need for received record information update to destination server.Unirecord can be achieved simultaneously in the present invention
The data of hair are synchronous, multiple record information can with simultaneous transmission with it is synchronous, data synchronization is not depended on independent of transaction boundaries yet
In transaction timing, so that extremely low data synchronization delay and high concurrent handling capacity can be realized.
In a preferred embodiment, as shown in figure 3, the S100 is specific can include:
S110: the behaviour after at least one operation object and the transactional operation in the Transaction Information of each transactional operation is obtained
The more new data for making object forms at least one record according at least one described operation object and corresponding more new data and believes
Breath.For example, transactional operation occurs on a server of distributed system, then the server source service synchronous as data
Device, other servers are the synchronous destination server of pending data, will form the transaction journal of each transactional operation on source server.
It can extract the Transaction Information of transactional operation according to the transaction journal of each transactional operation, which may include transactional operation
The more new data that each operation object is updated based on basic data after at least one operation object and transactional operation for being related to.Its
In, each server prestores multiple operation objects, the basic data of each operation object and each operation in distributed system
The current version number of object.When system initialization, settable current version number is initial value, such as 0.According to visitor in transactional operation
The transaction request at family end is handled to obtain more new data to the basic data of corresponding operating object, can will be each in transactional operation
Operation object and the more new data being correspondingly formed are as a record information.
Further, source server can form corresponding more new version number for each record information, thus more when generating
When a record information can by multiple record information out-of-order without affairs while be transmitted to destination server, realize and individually to record
Concurrent data is synchronous, and keeps the data between source and target server synchronous independent of transaction boundaries, also not dependent on
Transaction timing.
Since transactional operation causes the basic data of operation object to change to form more new data in source server, in order to
The data final consistency for guaranteeing copy in each server in distributed system, needs to occur the source server of transactional operation
The more new data that at least one operation object is formed in transactional operation is synchronized to other servers in distributed system.Source clothes
Business device splits the Transaction Information of transactional operation to obtain at least one record information, and more new edition is arranged for each record information
This number, destination server can be according to the current version number of operation object on destination server to the more new version number in record information
It is verified, to can determine that more new data and the basic data in destination server in record information form the successive of time
Sequentially, if the more new version number current version number more corresponding than destination server in record information is bigger, then it represents that more new data
Than the basic data in destination server the formation time later, the version of more new data is higher, need to more new data replace base
Plinth data, while current version number is replaced with more new version number, so that record synchronizing information is updated to destination server.
In one embodiment, as shown in figure 4, generating more new version corresponding with each record information in the S200
It is number specific can include:
S211: rule is updated according to default version number according to the time sequencing of at least one the record information and is sequentially generated
More new version number corresponding with each record information.Specifically, sequentially generating each record according to the time sequencing of record information
The more new version number of information, then on destination server, then for every record information in operation object more new version number with
The current version number of operation object is compared in destination server, that is, can be determined whether to take the record information update to target
Business device.Without for the behaviour in each record information when to generate each more new version number for recording information in source server
Make object and generate more new version number respectively, reduces data processing complexity.Wherein, presetting version number's update rule can be used for example
On the basis of current version plus 1 obtain more new version number version number update rule, when system initialization, current version number
Desirable initial value 0.
In other embodiments, as shown in figure 5, generating more new version corresponding with each record information in the S200
It is number specific can include:
S221: the operation object of each record information is determined.
S222: the current version number of the operation object is obtained.
S223: the current version number based on the operation object updates the rule generation record letter according to version number is preset
The more new version number of breath.
S224: the value of the current version number is replaced with to the value of the more new version number.
It is different from the embodiment described above, the behaviour in record information is obtained according to record information first in present embodiment
Make object, the corresponding current version number of the operation object is searched according to operation object in source server, in the operation object
According to the more new version number for presetting version number's update rule formation operation object on the basis of current version number, as the record
The more new version number of information.It is identical as above embodiment, will record information and more after new version number is transmitted to destination server,
Destination server obtains the current version number of the operation object in destination server according to the operation object in record information, will work as
Preceding version number is compared with more new version number, to determine whether the record information update to destination server.
In a preferred embodiment, as shown in fig. 6, being verified more new version number to determine whether in the S300
Corresponding record information to destination server is updated to specifically include:
S310: a record information obtains the operation object and more new data of the record information based on the received.
S320: the current version number of operation object described in destination server and more new version number are compared, if it is described more
New version number is greater than the current version number, and the data of operation object described on destination server are replaced with the update number
According to the value of the current version number of operation object described on destination server to be replaced with to the value of the more new version number.
It should be noted that presetting version number in the present embodiment and updating rule to add 1 shape on the basis of current version
At more new version number.In other embodiments, presetting version number's update rule can also be used other rules, it can be achieved that more new edition
This number verification.
In a preferred embodiment, when destination server receives multiple record information at the same time, each record is believed
Breath is verified, when the more new version number for recording information is greater than the current version of corresponding operation object, with record information
In more new data replacement destination server in operation object basic data.When the more new version number of record information is less than or waits
When the current version of corresponding operation object, destination server is not updated to for the record information, that is, ignores processing.Example
Such as, as shown in fig. 7, source server obtains 4 four affairs 1, affairs 2, affairs 3 and affairs Transaction Informations by transaction journal, into
Four Transaction Informations are split as at least one record information by one step respectively, i.e., the Transaction Information of affairs 1 are divided into including updating
Table A and record 1 and two record information including updating table C and record 1, the Transaction Information of affairs 2 is divided into including updating
Table B and record 1 and two record information including updating table C and record 2, the Transaction Information of affairs 3 is divided into including updating
The Transaction Information of affairs 4 is divided into the record information including update table B and record 2 by the record information of Table A and record 2.Wherein,
Table A, table B and table C are operation object, and record 1 and record 2 are the more new data formed based on basic data.
Source server further forms according to the operation object in each record information corresponding more with each record information
New version number, for example, for include Table A and record 1 record information, obtain source server in Table A current version number (assuming that
The current version number of Table A, table B and table C is that 0), adding 1 to obtain more new version number on the basis of current version is 1, i.e. version
1.Likewise, can obtain including the more new version number of the record information of table C and record 1 being 1, i.e. version 1；Including table B and record 1
The more new version number of record information be 1, i.e. version 1；The more new version number of record information including table C and record 2 is 2, i.e.,
Version 2；The more new version number of record information including Table A and record 2 is 2, i.e. version 2；Record letter including table B and record 2
The more new version number of breath is 2, i.e. version 2.
Multiple record information of formation and corresponding more new version number impunity business out-of-order are transmitted to mesh by source server
Mark server.On destination server, destination server receives multiple record information and corresponding more new version number, to update
Version number is verified to determine whether to update corresponding record information to destination server.Destination server can be simultaneously at least
The more new version number of one record information is verified, and is obtained operation object according to record information, is obtained and grasp in destination server
The current version number for making object, according to current version checksum update version number, if more new version number is greater than current version number,
With the basic data of the more new data replacement destination server operation object in record information.For example, coming for operation object Table A
It says, destination server first processing includes the record information of Table A and record 1.Search the current version number of Table A in destination server
It is (identical as source server, it is assumed that the current version number of Table A, table B and table C is that 0), the more new version number of the record information is 1, greatly
In the corresponding current version number of Table A, then the basic data of 1 substitution table A of record is used, the value of current version number replaces with more new version
Number value 1, by the record information update to destination server.Likewise, destination server is further processed including Table A and record
2 record information, more new version number 2 are greater than current version number 1, then by the record information update to destination server.And work as mesh
When mark server first handles the record information including table C and record 2, the more new version number 2 of the record information is greater than current version
Number 0, then by the record information update to destination server, the current version number of table C becomes 2.Destination server is further processed
When including table C and recording 1 record information, the more new version number 1 of the record information is less than the current version number 2 of table C, then not more
The new record information does the record information to destination server and ignores processing.Based on same principle, destination server can be into
It includes table B and record 2 and the record information including table B and record 1 that one step, which first post-processes,.To basis in 6 record information
The more new data that more new version number can directly be formed newest transactional operation is updated to destination server, without according to the time
Sequence successively synchronized update, improves the synchronous efficiency of more copy datas in distributed system, reduces answering for data synchronization processing
It is miscellaneous to spend the final consistency in turn ensuring more copy datas.
The present invention is synchronous full decoupled with Transaction Information and transaction timing by data, even the same foundation data short time
Interior continuous several times carry out data according to generation timing sequence queuing by the more new data for also not needing to form these modifications is modified one by one
It is synchronous, but synchronized according to concurrent fashion of the single record without affairs out-of-order, every synchronous record information has one
A more new version number dismantles the Transaction Information in source server as label, synchronization mechanism, records the complete of information for every
Data and more new version number are sent to destination server in concurrent mode.Not only data final consistency requirement had been met, but also real
Show than traditional data method of synchronization higher throughput and lower delay, for realizing distributed system number under more copy datas
Efficient process provides more preferable performance when factually.
The present invention is further described below by a specific example.For banking system, friendship of transferring accounts
When easy and two transactional operations of payment transaction, source server can generate two notes record information, behaviour after the affairs success of money transfer transactions
Making object respectively is the side's of producing account and the side's of being transferred to account, and the more new data of formation is respectively the side's of producing account and the side's of being transferred to account
Current balance, for two notes record information be respectively formed more new version number.Also two notes record, behaviour are generated after payment transaction success
It is respectively account of payment and collecting account as object, the more new data of formation is respectively the current remaining of account of payment and collecting account
Volume, for two notes record information be respectively formed more new version number, therefore transfer accounts and pay completion when one meet together generation four notes record
Information, the side's of producing account are corresponding with two notes record information, and two more new version numbers (because produce and payment is same account) turn
The corresponding notes record information in the side of entering and more new version number；The corresponding notes record information of beneficiary and more new version number.Source server
By this four stroke count, single is concurrently sent to destination server without affairs out-of-order mode accordingly, and destination server end will receive
Current version number is had existed in four notes record information and more new version number and destination server itself to compare, and will be greater than current
The record information update of version number into database, abandon updating by the record information equal to or less than current version number.At this
The reception mechanism of destination server does not need to consider the timing and affairs that these transactional operations of source server occur in the case of kind
Boundary, it is only necessary to relatively determined whether to update local basic data according to version number, even if sent out after occurrence record first to or
Message repeats the case where transmitting, and the final consistency of data will not be destroyed.
Based on same principle, the present embodiment also discloses a kind of more copy data synchronization systems of distribution.In the present embodiment,
The system comprises source servers and at least one destination server.Distributed more copy data synchronization systems may include multiple clothes
Business device can also be used as destination server wherein each server can be used as source server.It is handed over when on a server
Easy to operate when needing the record synchronizing information of transactional operation to other servers, the server is as source server, other clothes
Device be engaged in as destination server；It needs when transactional operation occurs for other servers by the record synchronizing information of transactional operation to the clothes
When business device, the server is as destination server, other servers are as source server.
Wherein, the source server is used to for the Transaction Information of each transactional operation being split as at least one record information,
More new version number corresponding with each record information is generated, by the record information of at least one transactional operation and corresponding more new edition
This number is transmitted to destination server；
The destination server is for verifying more new version number to determine whether to update corresponding record information extremely
Destination server.
Since the principle that the system solves the problems, such as is similar with above method, the implementation of this system may refer to method
Implement, details are not described herein.
Based on same principle, the present embodiment also discloses a kind of server (source server).In the present embodiment, the service
Device is configured as the Transaction Information of each transactional operation being split as at least one record information, generates and each record information pair
The record information of at least one transactional operation and corresponding more new version number are transmitted to destination service by the more new version number answered
Device, so that the destination server verifies more new version number to determine whether to update corresponding record information to target and take
Business device.
Since the principle that the server solves the problems, such as is similar with above method, the implementation side of may refer to of book server
The implementation of method, details are not described herein.
Based on same principle, the present embodiment also discloses a kind of server (destination server).In the present embodiment, the mesh
Mark server is configured as receiving at least one the record information and corresponding more new version number of source server transmission, to more new edition
This number is verified to determine whether to update corresponding record information to destination server, wherein at least one described record letter
Breath is what the source server split the Transaction Information of each transactional operation, and the more new version number is source service
Device is correspondingly formed according to each record information.
Since the principle that the server solves the problems, such as is similar with above method, the implementation side of may refer to of book server
The implementation of method, details are not described herein.
System, device, module or the unit that above-described embodiment illustrates can specifically realize by computer chip or entity,
Or it is realized by the product with certain function.It is a kind of typically to realize that equipment is computer equipment, specifically, computer is set
It is standby for example can for personal computer, laptop computer, cellular phone, camera phone, smart phone, personal digital assistant,
Media player, navigation equipment, electronic mail equipment, game console, tablet computer, wearable device or these equipment
In any equipment combination.
Computer equipment specifically includes memory, processor and storage on a memory simultaneously in a typical example
The computer program that can be run on a processor is realized when the processor executes described program and is held as described above by client
Capable method, alternatively, the processor realizes the method executed as described above by server when executing described program.
Below with reference to Fig. 8, it illustrates the structural representations for the computer equipment 600 for being suitable for being used to realize the embodiment of the present application
Figure.
As shown in figure 8, computer equipment 600 includes central processing unit (CPU) 601, it can be read-only according to being stored in
Program in memory (ROM) 602 is loaded into random access storage device (RAM) from storage section 608) program in 603
And execute various work appropriate and processing.In RAM603, also it is stored with system 600 and operates required various program sum numbers
According to.CPU601, ROM602 and RAM603 are connected with each other by bus 604.Input/output (I/O) interface 605 is also connected to
Bus 604.
I/O interface 605 is connected to lower component: the importation 606 including keyboard, mouse etc.；It is penetrated including such as cathode
The output par, c 607 of spool (CRT), liquid crystal ultramagnifier (LCD) etc. and loudspeaker etc.；Storage section 608 including hard disk etc.；
And including such as LAN card, the communications portion 609 of the network interface card of modem etc..Communications portion 609 via such as because
The network of spy's net executes communication process.Driver 610 is also connected to I/O interface 606 as needed.Detachable media 611, such as
Disk, CD, magneto-optic disk, semiconductor memory etc. are mounted on as needed on driver 610, in order to read from thereon
Computer program be mounted as needed such as storage section 608.
Particularly, according to an embodiment of the invention, may be implemented as computer above with reference to the process of flow chart description
Software program.For example, the embodiment of the present invention includes a kind of computer program product comprising be tangibly embodied in machine readable
Computer program on medium, the computer program include the program code for method shown in execution flow chart.At this
In the embodiment of sample, which can be downloaded and installed from network by communications portion 609, and/or from removable
Medium 611 is unloaded to be mounted.
Computer-readable medium includes permanent and non-permanent, removable and non-removable media can be by any method
Or technology come realize information store.Information can be computer readable instructions, data structure, the module of program or other data.
The example of the storage medium of computer includes, but are not limited to phase change memory (PRAM), static random access memory (SRAM), moves
State random access memory (DRAM), other kinds of random access memory (RAM), read-only memory (ROM), electric erasable
Programmable read only memory (EEPROM), flash memory or other memory techniques, read-only disc read only memory (CD-ROM) (CD-ROM),
Digital versatile disc (DVD) or other optical storage, magnetic cassettes, tape magnetic disk storage or other magnetic storage devices
Or any other non-transmission medium, can be used for storage can be accessed by a computing device information.As defined in this article, it calculates
Machine readable medium does not include temporary computer readable media (transitory media), such as the data-signal and carrier wave of modulation.
For convenience of description, it is divided into various units when description apparatus above with function to describe respectively.Certainly, implementing this
The function of each unit can be realized in the same or multiple software and or hardware when application.
The present invention be referring to according to the method for the embodiment of the present invention, the process of equipment (system) and computer program product
Figure and/or block diagram describe.It should be understood that every one stream in flowchart and/or the block diagram can be realized by computer program instructions
The combination of process and/or box in journey and/or box and flowchart and/or the block diagram.It can provide these computer programs
Instruct the processor of general purpose computer, special purpose computer, Embedded Processor or other programmable data processing devices to produce
A raw machine, so that being generated by the instruction that computer or the processor of other programmable data processing devices execute for real
The device for the function of being specified in present one or more flows of the flowchart and/or one or more blocks of the block diagram.
These computer program instructions, which may also be stored in, is able to guide computer or other programmable data processing devices with spy
Determine in the computer-readable memory that mode works, so that it includes referring to that instruction stored in the computer readable memory, which generates,
Enable the manufacture of device, the command device realize in one box of one or more flows of the flowchart and/or block diagram or
The function of being specified in multiple boxes.
These computer program instructions also can be loaded onto a computer or other programmable data processing device, so that counting
Series of operation steps are executed on calculation machine or other programmable devices to generate computer implemented processing, thus in computer or
The instruction executed on other programmable devices is provided for realizing in one or more flows of the flowchart and/or block diagram one
The step of function of being specified in a box or multiple boxes.
It should also be noted that, the terms "include", "comprise" or its any other variant are intended to nonexcludability
It include so that the process, method, commodity or the equipment that include a series of elements not only include those elements, but also to wrap
Include other elements that are not explicitly listed, or further include for this process, method, commodity or equipment intrinsic want
Element.In the absence of more restrictions, the element limited by sentence "including a ...", it is not excluded that including described want
There is also other identical elements in the process, method of element, commodity or equipment.
It will be understood by those skilled in the art that embodiments herein can provide as method, system or computer program product.
Therefore, complete hardware embodiment, complete software embodiment or embodiment combining software and hardware aspects can be used in the application
Form.It is deposited moreover, the application can be used to can be used in the computer that one or more wherein includes computer usable program code
The shape for the computer program product implemented on storage media (including but not limited to magnetic disk storage, CD-ROM, optical memory etc.)
Formula.
The application can describe in the general context of computer-executable instructions executed by a computer, such as program
Module.Generally, program module includes routines performing specific tasks or implementing specific abstract data types, programs, objects, group
Part, data structure etc..The application can also be practiced in a distributed computing environment, in these distributed computing environments, by
Task is executed by the connected remote processing devices of communication network.In a distributed computing environment, program module can be with
In the local and remote computer storage media including storage equipment.
All the embodiments in this specification are described in a progressive manner, same and similar portion between each embodiment
Dividing may refer to each other, and each embodiment focuses on the differences from other embodiments.Especially for system reality
For applying example, since it is substantially similar to the method embodiment, so being described relatively simple, related place is referring to embodiment of the method
Part explanation.
The above description is only an example of the present application, is not intended to limit this application.For those skilled in the art
For, various changes and changes are possible in this application.All any modifications made within the spirit and principles of the present application are equal
Replacement, improvement etc., should be included within the scope of the claims of this application.
Claims (10)
1. a kind of more copy data synchronous method of distribution characterized by comprising
The Transaction Information of each transactional operation is split as at least one record information；
Generate corresponding with each record information more new version number, by the record information of at least one transactional operation and it is corresponding more
New version number is transmitted to destination server；
On destination server, more new version number is verified to determine whether to update corresponding record information to destination service
Device.
2. the more copy data synchronous method of distribution according to claim 1, which is characterized in that described to grasp each transaction
The Transaction Information of work is split as at least one record information and specifically includes:
Obtain the operation object after at least one operation object and the transactional operation in the Transaction Information of each transactional operation
More new data forms at least one record information according at least one described operation object and corresponding more new data.
3. the more copy data synchronous method of distribution according to claim 1, which is characterized in that the generation and each note
The corresponding more new version number of record information specifically includes:
Time sequencing based at least one the record information updates rule according to default version number and sequentially generates and each note
Record the corresponding more new version number of information.
4. the more copy data synchronous method of distribution according to claim 2, which is characterized in that the generation and each note
The corresponding more new version number of record information specifically includes:
Determine the operation object of each record information；
Obtain the current version number of the operation object；
Current version number based on the operation object updates the update that rule generates the record information according to version number is preset
Version number；
The value of the current version number is replaced with to the value of the more new version number.
5. the more copy data synchronous method of distribution according to claim 2, which is characterized in that described to more new version number
It is verified to determine whether to update corresponding record information to destination server and specifically include:
A record information obtains the operation object and more new data of the record information based on the received；
The current version number of operation object described in destination server and more new version number are compared, if the more new version number is big
In the current version number, the basic data of operation object described on destination server is replaced with into the more new data, by mesh
The value of the current version number of the operation object replaces with the value of the more new version number on mark server.
6. a kind of more copy data synchronization systems of distribution, which is characterized in that including source server and at least one destination service
Device；
The source server is used to for the Transaction Information of each transactional operation being split as at least one record information, generates and each
The corresponding more new version number of information is recorded, the record information of at least one transactional operation and corresponding more new version number are transmitted to
Destination server；
The destination server is for verifying more new version number to determine whether to update corresponding record information to target
Server.
7. a kind of server, which is characterized in that be configured as the Transaction Information of each transactional operation being split as at least one note
Information is recorded, more new version number corresponding with each record information is generated, by the record information and correspondence of at least one transactional operation
More new version number be transmitted to destination server so that the destination server verifies to determine whether more new version number
Corresponding record information is updated to destination server.
8. a kind of server, which is characterized in that be configured as receiving at least one record information of source server transmission and correspondence
More new version number, more new version number is verified to determine whether to update corresponding record information to destination server,
In, at least one described record information is what the source server split the Transaction Information of each transactional operation, described
The more new version number source server is correspondingly formed according to each record information.
9. a kind of computer equipment, can run on a memory and on a processor including memory, processor and storage
Computer program, which is characterized in that the processor realizes the side as described in claim any one of 1-5 when executing described program
Method.
10. a kind of computer-readable medium, is stored thereon with computer program, which is characterized in that the program is executed by processor
Any one of Shi Shixian such as claim 1-5 the method.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201910137349.2A CN109871390A (en) | 2019-02-25 | 2019-02-25 | A kind of more copy data synchronous method of distribution, system and server |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201910137349.2A CN109871390A (en) | 2019-02-25 | 2019-02-25 | A kind of more copy data synchronous method of distribution, system and server |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN109871390A true CN109871390A (en) | 2019-06-11 |
Family
ID=66919155
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201910137349.2A Pending CN109871390A (en) | 2019-02-25 | 2019-02-25 | A kind of more copy data synchronous method of distribution, system and server |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN109871390A (en) |
Cited By (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN113067848A (en) * | 2021-02-05 | 2021-07-02 | 厦门亿联网络技术股份有限公司 | Call record synchronization method and system and electronic equipment |
| CN116975076A (en) * | 2023-07-28 | 2023-10-31 | 深圳市丕微科技企业有限公司 | Multi-terminal interactive data transmission control method and system |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101426026A (en) * | 2008-09-17 | 2009-05-06 | 北京六维世纪网络技术有限公司 | Method and system for data synchronization between multiple servers |
| CN101582920A (en) * | 2009-06-09 | 2009-11-18 | 中兴通讯股份有限公司 | Method and device for verifying and synchronizing data blocks in distributed file system |
| US20140131434A1 (en) * | 2012-11-15 | 2014-05-15 | At&T Intellectual Property I, L.P. | Asset Management Service for Distributed Computing Environments |
| CN103997525A (en) * | 2014-05-21 | 2014-08-20 | 北京紫光天禾软件系统技术有限公司 | Distributed data synchronization method and system |
| US20140250074A1 (en) * | 2008-10-21 | 2014-09-04 | Microsoft Corporation | Forgetting items with knowledge based synchronization |
-
2019
- 2019-02-25 CN CN201910137349.2A patent/CN109871390A/en active Pending
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101426026A (en) * | 2008-09-17 | 2009-05-06 | 北京六维世纪网络技术有限公司 | Method and system for data synchronization between multiple servers |
| US20140250074A1 (en) * | 2008-10-21 | 2014-09-04 | Microsoft Corporation | Forgetting items with knowledge based synchronization |
| CN101582920A (en) * | 2009-06-09 | 2009-11-18 | 中兴通讯股份有限公司 | Method and device for verifying and synchronizing data blocks in distributed file system |
| US20140131434A1 (en) * | 2012-11-15 | 2014-05-15 | At&T Intellectual Property I, L.P. | Asset Management Service for Distributed Computing Environments |
| CN103997525A (en) * | 2014-05-21 | 2014-08-20 | 北京紫光天禾软件系统技术有限公司 | Distributed data synchronization method and system |
Cited By (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN113067848A (en) * | 2021-02-05 | 2021-07-02 | 厦门亿联网络技术股份有限公司 | Call record synchronization method and system and electronic equipment |
| CN113067848B (en) * | 2021-02-05 | 2023-09-26 | 厦门亿联网络技术股份有限公司 | Call record synchronization method and system and electronic equipment |
| CN116975076A (en) * | 2023-07-28 | 2023-10-31 | 深圳市丕微科技企业有限公司 | Multi-terminal interactive data transmission control method and system |
| CN116975076B (en) * | 2023-07-28 | 2024-05-07 | 深圳市丕微科技企业有限公司 | Multi-terminal interactive data transmission control method and system |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN110741342B (en) | Blockchain transaction commit ordering | |
| US10255108B2 (en) | Parallel execution of blockchain transactions | |
| CN110609872B (en) | Method and apparatus for synchronizing node data | |
| CN109359222A (en) | Date storage method and system, equipment and storage medium | |
| US6363401B2 (en) | Enhanced two-phase commit protocol | |
| CN109063027A (en) | A kind of method and device for business processing | |
| CN110084601A (en) | Parallel chain main chain stateful transaction synchronous method, equipment and storage medium | |
| US11348072B2 (en) | Techniques for sharing electronic calendars between mailboxes in an online application and collaboration service | |
| CN100442238C (en) | Method and apparatus for asynchronous replication of data | |
| CN110113408A (en) | A kind of block synchronous method, equipment and storage medium | |
| CN109862102B (en) | Distributed data multi-copy concurrency control system, server and method | |
| CN110363663A (en) | Batch data processing method, device, equipment and storage medium based on block chain | |
| CN109871390A (en) | A kind of more copy data synchronous method of distribution, system and server | |
| JPH09505918A (en) | Method and apparatus for extracting data from a group of data | |
| CN110955719B (en) | Data access processing equipment, system and method | |
| CN110457327A (en) | A kind of data processing method, device and storage medium | |
| CN107526838A (en) | The method and apparatus of data-base cluster dilatation | |
| CN109376141A (en) | A kind of data migration method and device | |
| CN109062731A (en) | Idempotent control method and device when a kind of database switches | |
| CN116091218A (en) | Financial transaction data processing device and method | |
| CN109697216A (en) | Exchange information processing method, apparatus and system | |
| CN109918178A (en) | Affairs submit method and relevant apparatus | |
| CN113986923A (en) | Distributed transaction processing method, device and equipment based on only additional file storage | |
| CN114189518A (en) | Communication method and communication device applied to computer cluster | |
| CN107357679A (en) | A kind of backup method and device |
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 | ||
| RJ01 | Rejection of invention patent application after publication |
Application publication date: 20190611 |
|
| RJ01 | Rejection of invention patent application after publication |