CN109299193A - Method of data synchronization and relevant device - Google Patents
Method of data synchronization and relevant device Download PDFInfo
- Publication number
- CN109299193A CN109299193A CN201811115456.7A CN201811115456A CN109299193A CN 109299193 A CN109299193 A CN 109299193A CN 201811115456 A CN201811115456 A CN 201811115456A CN 109299193 A CN109299193 A CN 109299193A
- Authority
- CN
- China
- Prior art keywords
- data
- sent
- message
- synchronous
- processed result
- 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
- 238000000034 method Methods 0.000 title claims abstract description 67
- 230000001360 synchronised effect Effects 0.000 claims abstract description 206
- 238000012545 processing Methods 0.000 claims abstract description 53
- 238000012795 verification Methods 0.000 claims description 39
- 238000004590 computer program Methods 0.000 claims description 28
- 238000012544 monitoring process Methods 0.000 claims description 19
- 238000003860 storage Methods 0.000 claims description 16
- 230000008569 process Effects 0.000 claims description 15
- 230000005540 biological transmission Effects 0.000 claims description 7
- 238000012360 testing method Methods 0.000 claims description 3
- 239000003999 initiator Substances 0.000 abstract description 14
- 230000003111 delayed effect Effects 0.000 abstract description 10
- 238000010586 diagram Methods 0.000 description 23
- 230000006870 function Effects 0.000 description 19
- 238000004891 communication Methods 0.000 description 5
- 235000013399 edible fruits Nutrition 0.000 description 5
- 238000010168 coupling process Methods 0.000 description 3
- 238000005859 coupling reaction Methods 0.000 description 3
- 238000004422 calculation algorithm Methods 0.000 description 2
- 230000008878 coupling Effects 0.000 description 2
- 230000005611 electricity Effects 0.000 description 2
- 238000009434 installation Methods 0.000 description 2
- 238000004519 manufacturing process Methods 0.000 description 2
- 241001269238 Data Species 0.000 description 1
- 230000009471 action Effects 0.000 description 1
- 230000009286 beneficial effect Effects 0.000 description 1
- 238000004364 calculation method Methods 0.000 description 1
- 210000001072 colon Anatomy 0.000 description 1
- 230000010485 coping Effects 0.000 description 1
- 238000013461 design Methods 0.000 description 1
- 238000011161 development Methods 0.000 description 1
- 238000009826 distribution Methods 0.000 description 1
- 238000005516 engineering process Methods 0.000 description 1
- 230000002452 interceptive effect Effects 0.000 description 1
- 238000012423 maintenance Methods 0.000 description 1
- 230000007246 mechanism Effects 0.000 description 1
- 238000005192 partition Methods 0.000 description 1
- 230000008439 repair process Effects 0.000 description 1
- 238000000926 separation method Methods 0.000 description 1
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/54—Interprogram communication
- G06F9/546—Message passing systems or structures, e.g. queues
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F2209/00—Indexing scheme relating to G06F9/00
- G06F2209/54—Indexing scheme relating to G06F9/54
- G06F2209/548—Queue
Landscapes
- Engineering & Computer Science (AREA)
- Software Systems (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Information Transfer Between Computers (AREA)
Abstract
The present invention is suitable for technical field of data processing, provide a kind of method of data synchronization and relevant device, the described method includes: data message to be sent is pushed to MQ transmit queue, data message to be sent is sent to the synchronous recipient of data by MQ transmit queue, while starting whether the synchronous recipient of MQ receiving queue monitored data returns to the data processed result after receiving data message to be sent；If listening to the synchronous recipient of data by MQ receiving queue returns to the data processed result, subsequent processing is carried out according to data processed result, or terminates or push away again, solve the problems, such as that the synchronous initiator of available data is unable to learn in time whether the synchronous recipient of data receives total data like clockwork, improve the robustness and scalability of system when data synchronize, also avoid the traffic lost because of caused by data difference between operation system, reduce simultaneously because problem is delayed discovery bring baneful influence, is suitble to practical application.
Description
Technical field
The invention belongs to technical field of data processing more particularly to a kind of method of data synchronization and relevant device.
Background technique
With the fast development of each corporate business, there are many mutually independent industry according to the demand of service line in company
Business system, and each system has oneself independent database, all operation system core datas need to be with basic data source core
It is synchronous that library carries out data.The data of big data quantity are synchronized with the MQ mode that generallys use, but there is also a problem, i.e. data are same
Step initiator is unable to learn in time whether the synchronous recipient of data receives total data, and such problems like clockwork
It is difficult to be found, once finding and after several days, a few weeks or even some months, and data repair difficulty, produce corporate business
Raw irremediable loss and influence.
Summary of the invention
In view of this, the embodiment of the invention provides a kind of method of data synchronization and relevant device, to solve available data
Synchronous initiator is unable to learn in time the problem of whether synchronous recipient of data has received total data like clockwork.
The first aspect of the embodiment of the present invention provides a kind of method of data synchronization, comprising:
Data message to be sent is pushed into message queue (Message Queue, MQ) transmit queue, is sent out by the MQ
It send queue that the data message to be sent is sent to the synchronous recipient of data, while starting MQ receiving queue and monitoring the data
Whether synchronous recipient returns to the data processed result after receiving the data message to be sent；
If listening to the synchronous recipient of the data by the MQ receiving queue returns to the data processed result, root
Judge whether that successfully completing data synchronizes according to the data processed result；
If it is synchronous to be not successfully completed data according to data processed result judgement, re-execute it is described will be to be sent
Data message pushes to the step of MQ transmit queue.
Optionally, above-mentioned method of data synchronization, further includes:
If not listening to the synchronous recipient of the data by the MQ receiving queue returns to the data processed result,
Then generate failure of data synchronization prompt.
Optionally, it is described data message to be sent is pushed into MQ transmit queue before, further includes:
According to default message format and information to be sent, the data message to be sent is generated.
The second aspect of the embodiment of the present invention provides a kind of method of data synchronization, comprising:
Whether the synchronous sender of monitored data, which passes through MQ transmit queue, sends data message to be sent；
The data message to be sent is sent by the MQ transmit queue if listening to the synchronous sender of the data,
The data message to be sent is received, and after receiving successfully, data check processing is carried out to the data message to be sent；
After the completion of verification, by described in data processed result return of the MQ receiving queue by the data message to be sent
Data synchronize sender, so that the synchronous sender of the data judges whether to successfully complete data according to the data processed result
It is synchronous, and when determining that being not successfully completed data synchronizes, the data message to be sent is pushed into the MQ again and is sent
Queue is sent.
Optionally, above-mentioned method of data synchronization, further includes:
If the data processed result is data exception, warning message is sent to default personnel, the warning message is taken
With the data processed result.
Optionally, described to include: to the data message progress data check processing to be sent
Even-odd check, CRC check, LRC verification, Gray's code check are carried out to the data message to be sent and verified, different
Or any one or more in verification and MD5 verification.
The third aspect of the embodiment of the present invention provides a kind of data synchronization unit, comprising:
Packet sending unit passes through the MQ transmit queue for data message to be sent to be pushed to MQ transmit queue
The data message to be sent is sent to the synchronous recipient of data；
As a result monitoring unit monitors whether the synchronous recipient of the data returns to reception for starting MQ receiving queue simultaneously
Data processed result after the data message to be sent；
Data synchronize judging unit, if returning for listening to the synchronous recipient of the data by the MQ receiving queue
The data processed result then judges whether that successfully completing data synchronizes according to the data processed result；
Message process unit weighs if synchronizing for being not successfully completed data according to data processed result judgement
Newly execute described the step of data message to be sent is pushed into MQ transmit queue.
The fourth aspect of the embodiment of the present invention provides a kind of data synchronization unit, comprising:
Message monitoring unit sends datagram to be sent for whether the synchronous sender of monitored data to pass through MQ transmit queue
Text；
Message checking unit, if passing through described in MQ transmit queue transmission for listening to the synchronous sender of the data
Data message to be sent then receives the data message to be sent, and after receiving successfully, to the data message to be sent into
Row data checking treatment；
As a result return unit, for after the completion of verification, by MQ receiving queue by the number of the data message to be sent
The synchronous sender of the data is returned to according to processing result, so that the synchronous sender of the data sentences according to the data processed result
The disconnected data that whether successfully complete are synchronous, and when determining that being not successfully completed data synchronizes, again by the datagram to be sent
Text pushes to the MQ transmit queue and is sent.
5th aspect of the embodiment of the present invention provides a kind of terminal device, including memory, processor and is stored in
In the memory and the computer program that can run on the processor, when the processor executes the computer program
It realizes such as the step of the above method.
6th aspect of the embodiment of the present invention provides a kind of computer readable storage medium, the computer-readable storage
Media storage has computer program, realizes when the computer program is executed by processor such as the step of the above method.
Existing beneficial effect is the embodiment of the present invention compared with prior art: the embodiment of the present invention passes through MQ transmit queue
Data message to be sent is sent to the synchronous recipient of data, while whether starting the synchronous recipient of MQ receiving queue monitored data
The data processed result after receiving data message to be sent is returned, if there is listening to, is carried out according to data processed result subsequent
Processing, or terminate or push away again, solve whether the synchronous initiator of available data is unable to learn in time the synchronous recipient of data
The problem of receiving total data like clockwork improves timeliness, robustness and the scalability of system when data synchronize,
The traffic lost because of caused by data difference between operation system is also avoided, while reducing and being disliked because problem is delayed discovery bring
Bad influence is suitble to practical application.
Detailed description of the invention
It to describe the technical solutions in the embodiments of the present invention more clearly, below will be to embodiment or description of the prior art
Needed in attached drawing be briefly described, it should be apparent that, the accompanying drawings in the following description is only of the invention some
Embodiment for those of ordinary skill in the art without any creative labor, can also be according to these
Attached drawing obtains other attached drawings.
Fig. 1 is a kind of schematic flow diagram of method of data synchronization provided in an embodiment of the present invention；
Fig. 2 be another embodiment of the present invention provides a kind of method of data synchronization schematic flow diagram；
Fig. 3 is a kind of schematic flow diagram for method of data synchronization that yet another embodiment of the invention provides；
Fig. 4 is a kind of schematic flow diagram for method of data synchronization that further embodiment of this invention provides；
Fig. 5 is a kind of schematic flow diagram for method of data synchronization that further embodiment of this invention provides；
Fig. 6 is a kind of schematic flow diagram for method of data synchronization that further embodiment of this invention provides；
Fig. 7 is a kind of schematic block diagram of data synchronization unit provided in an embodiment of the present invention；
Fig. 8 be another embodiment of the present invention provides a kind of data synchronization unit schematic block diagram；
Fig. 9 is a kind of data synchronization unit schematic block diagram that yet another embodiment of the invention provides；
Figure 10 is a kind of data synchronization unit schematic block diagram that further embodiment of this invention provides；
Figure 11 is a kind of schematic block diagram of the synchronous sending device of data provided in an embodiment of the present invention；
Figure 12 is a kind of schematic block diagram of data synchronous receiving equipment provided in an embodiment of the present invention.
Specific embodiment
In being described below, for illustration and not for limitation, the tool of such as particular system structure, technology etc is proposed
Body details, to understand thoroughly the embodiment of the present invention.However, it will be clear to one skilled in the art that there is no these specific
The present invention also may be implemented in the other embodiments of details.In other situations, it omits to well-known system, device, electricity
The detailed description of road and method, in case unnecessary details interferes description of the invention.
In order to illustrate technical solutions according to the invention, the following is a description of specific embodiments.
It is a kind of schematic flow diagram of method of data synchronization provided in an embodiment of the present invention referring to Fig. 1, Fig. 1, in the implementation
It in example, is illustrated by taking the angle triggering of the synchronous sender of data as an example, here, the synchronous sender of data is synchronous with data to be received
Fang Jinhang data are synchronous.As shown in Figure 1, in this embodiment, the treatment process of the synchronous sender of data may include following step
It is rapid:
S101: pushing to MQ transmit queue for data message to be sent, will be described to be sent by the MQ transmit queue
Data message is sent to the synchronous recipient of data, while starting MQ receiving queue and monitoring whether the synchronous recipient of the data returns
Data processed result after receiving the data message to be sent.
Here, before data message to be sent is pushed to MQ transmit queue, the synchronous sender of data is synchronous with data
Recipient establishes two MQ queues, i.e. MQ transmit queue according to agreement respectively, and for sending datagram, MQ receiving queue is used
In the processing result for receiving data message.
The synchronous sender of data organizes message according to the message format of agreement, and the data message organized is pushed to
In MQ transmit queue, while starting the data processed result that the synchronous recipient of MQ receiving queue monitored data returns, once there is knot
Fruit returns, and further according to returning the result carry out subsequent processing, or terminates or pushes away again.
Specifically, data message to be sent being pushed to the mode of MQ transmit queue can be push in real time, can also be
Preset time period push, specific push mode can be set according to actual needs.
The synchronous recipient of data after receiving above-mentioned data message to be sent, can to the data message to be sent into
Row data checking treatment, such as even-odd check, CRC check, LRC verification, Gray's code check and verification, exclusive or check and the school MD5
It tests, to judge whether data are correct, sender synchronous to the timely notification data of the data of error guarantees the correct of data transmission
Property.
S102: if listening to the synchronous recipient of the data by the MQ receiving queue returns to the data processing knot
Fruit then judges whether that successfully completing data synchronizes according to the data processed result.
Here, the synchronous recipient of data receives team by MQ after treating and sending datagram and carry out data check processing
Column by the synchronous sender of the data processed result returned data of data message to be sent, the synchronous sender of data according to the data at
Reason result judges whether that completing data synchronizes, wherein above-mentioned data processed result can be normal, data exception of data etc..
S103: if being not successfully completed data synchronization according to data processed result judgement, described incite somebody to action is re-executed
Data message to be sent pushes to the step of MQ transmit queue.
Specifically, it synchronizes, stops operation if successfully completing data according to data processed result judgement, generate data
Synchronously complete prompt.If determining, data synchronous sender weight synchronous without completing data according to the data processed result
Data message is pushed away, above-mentioned the step of data message to be sent is pushed into MQ transmit queue is re-executed, it is same until completing data
Step.
It is evidenced from the above discussion that method of data synchronization of the embodiment of the present invention, by MQ transmit queue by datagram to be sent
Text is sent to the synchronous recipient of data, at the same start the synchronous recipient of MQ receiving queue monitored data whether return receive it is to be sent
Data processed result after data message, if there is listening to, according to data processed result carry out subsequent processing, or terminate or
It pushes away again, solves the synchronous initiator of available data and be unable to learn in time whether the synchronous recipient of data has received like clockwork
The problem of to total data, improve data it is synchronous when system timeliness, robustness and scalability, also avoid because of business
Traffic lost caused by inter-system data difference, while reducing because the problem of data are not inconsistent is delayed the discovery severe shadow of bring
It rings, is suitble to practical application.
Referring to Fig. 2, Fig. 2 be another embodiment of the present invention provides a kind of method of data synchronization schematic flow diagram.This
The difference of embodiment and above-described embodiment is S204, wherein S201~S203 and S101~S103 phase in a upper embodiment
Together, it referring specifically to the associated description of S101~S103 in above-described embodiment, does not repeat herein.Data in the present embodiment are synchronous
Method can also include:
S204: if not listening to the synchronous recipient of the data by the MQ receiving queue returns to the data processing
As a result, then generating failure of data synchronization prompt.
Here, if not listening to the synchronous recipient of data by MQ receiving queue returns to above-mentioned data processed result,
Illustrate that the synchronous recipient of data is possible to be not received by above-mentioned data message, generates failure of data synchronization prompt, can pass through
Data message to be sent is pushed to MQ transmit queue by prefixed time interval again, until listening to data by MQ receiving queue
Synchronous recipient's returned data processing result solves the synchronous initiator of available data and is unable to learn in time the synchronous recipient of data
The problem of whether having received total data like clockwork.
Referring to Fig. 3, Fig. 3 is a kind of schematic flow diagram for method of data synchronization that yet another embodiment of the invention provides.This
The difference of embodiment and above-described embodiment is S304, wherein S301~S303 and S101~S103 phase in a upper embodiment
Together, it referring specifically to the associated description of S101~S103 in above-described embodiment, does not repeat herein.Data in the present embodiment are synchronous
Method can also include:
S304: according to default message format and information to be sent, the data message to be sent is generated.
Here, above-mentioned default message format is the message lattice that the synchronous sender of data recipient synchronous with data makes an appointment
Formula, specifically, the synchronous both sides of data can arrange according to actual needs, meet several scenes application needs.
Referring to Fig. 4, Fig. 4 is a kind of schematic flow diagram for method of data synchronization that further embodiment of this invention provides,
It in the embodiment, is illustrated by taking the angle triggering of the synchronous recipient of data as an example, here, the synchronous sender of data and data are same
It is synchronous to walk recipient's progress data.As shown in figure 4, in this embodiment, the treatment process of the synchronous recipient of data may include
Following steps:
S401: whether the synchronous sender of monitored data, which passes through MQ transmit queue, sends data message to be sent.
Here, the synchronous sender of data recipient synchronous with data establishes two MQ queues according to agreement respectively, and MQ is sent
Queue, for sending datagram, MQ receiving queue, the processing result of message for receiving data.
The synchronous sender of data organizes message according to the message format of agreement, and the synchronous recipient's monitored data of data is synchronous
Whether sender, which passes through MQ transmit queue, sends data message to be sent,
The synchronous sender of data pushes to the data message organized in MQ transmit queue, while starting MQ receiving queue
The data processed result that the synchronous recipient of monitored data returns carries out subsequent place further according to returning the result once there is result return
Reason, or terminate or push away again.
S402: the datagram to be sent is sent by the MQ transmit queue if listening to the synchronous sender of the data
Text then receives the data message to be sent, and after receiving successfully, carries out at data check to the data message to be sent
Reason.
Specifically, if the synchronous recipient of data listen to the synchronous sender of data by MQ transmit queue send it is above-mentioned to
It sends datagram, then receives data message to be sent, and treat to send datagram and carry out data check processing, wherein number
Can be verified according to verification for even-odd check, CRC check, LRC verification, Gray's code check and verification, exclusive or check and MD5 etc., come
Judge whether data are correct, the synchronous sender of data is sent information in data check failure.
Here, even-odd check is carried out according to the number of " 1 " in the one group of binary code transmitted is odd number or even number
A parity check bit is usually specially arranged in verification, and the number for storing " 1 " in code is odd number or even number.If with odd,
Then parity check bit is odd number, indicates that data are correct.If parity check bit is even number with even parity check, indicate that data are correct.
CRC check is most common a kind of debugging check code in data communication field, it is characterized in that the length of information field and check field
Degree can be arbitrarily selected.Cyclical Redundancy Check (CRC) is a kind of data transmission error-detecting function, carries out polynomial computation to data,
And obtained result is attached to behind frame, receiving device also executes similar algorithm, with guarantee data transmission correctness and
Integrality.LRC verification for ModBus agreement ascii mode, it is this verification it is fairly simple, communication speed is slower, it
It is used in ASCII protocol, has detected the content of the new line extra in message field except the colon and end that start.It is only
Add 1 negating after the data byte superposition that each needs transmits.Gray code is a kind of non-weighted code and a kind of circulation
Code.Refer to there was only a difference between any two groups of adjacent codes, remaining is all identical.Be verified as verification one group of data item
And it is whether correct.The form usually indicated using hexadecimal as numeral system.If the numerical value for verifying sum is more than hexadecimal
FF, that is, 255.The verification of exclusive or check, i.e. BCC, is one kind of even-odd check, but is also to be commonly used and efficiency is higher
It is a kind of.So-called BCC check addition, be exactly before sending with after transmission respectively all character step-by-steps for before BCC including ETX character
After exclusive or, obtained character is compared after converting (adding or removing a fixed value) as required.It is equal to think logical
Believe inerrancy, it is unequal, think communication error.The practical application of MD5 is generated to one section of Message (byte serial)
Fingerprint (fingerprint) can prevent from being tampered.
S403: after the completion of verification, the data processed result of the data message to be sent is returned by MQ receiving queue
The synchronous sender of the data is returned, so that the synchronous sender of the data has judged whether successfully according to the data processed result
It is synchronous at data, and when determining that being not successfully completed data synchronizes, the data message to be sent is pushed to again described
MQ transmit queue is sent.
Here, after the completion of verification, the synchronous recipient of data can also be the data message storage by verification.Data are same
Walk recipient can also according to data processed result trigger notice mechanism, i.e., once occur data exception, cannot be normally to data
Completion processing, according to pre-set processing mailbox and contact method, by information through mail such as data synchronous problem, logs
Related system responsible person and operation maintenance personnel are notified with the mode of short message, and related technical personnel is reminded to troubleshoot and handle in time,
And finally solve the problems, such as, it is ensured that data synchronize without exception.
It is evidenced from the above discussion that method of data synchronization of the embodiment of the present invention, whether the synchronous sender of monitored data passes through MQ
Transmit queue sends data message to be sent, if there is listening to, receives above-mentioned data message to be sent, and receiving successfully
Afterwards, it treats to send datagram and carries out data check processing, after the completion of verification, by MQ receiving queue by datagram to be sent
The synchronous sender of the data processed result returned data of text, the synchronous sender of data carry out subsequent place according to data processed result
Reason, or terminate or push away again, it solves the synchronous initiator of available data and is unable to learn in time the synchronous recipient of data whether standard
The problem of really inerrably receiving total data improves timeliness, robustness and the scalability of system when data synchronize,
The traffic lost because of caused by data difference between operation system is avoided, while reducing and finding that bring is severe because problem is delayed
It influences, is suitble to practical application.
Referring to Fig. 5, Fig. 5 is a kind of schematic flow diagram for method of data synchronization that further embodiment of this invention provides.This
The difference of embodiment and above-described embodiment is S504, wherein S501~S503 and S401~S403 phase in a upper embodiment
Together, it referring specifically to the associated description of S401~S403 in above-described embodiment, does not repeat herein.Data in the present embodiment are synchronous
Method can also include:
S504: if the data processed result is data exception, warning message is sent to default personnel, the alarm signal
Breath carries the data processed result.
Here, the synchronous sender of data recipient synchronous with data presets the processing mode of production problem, such as sends out
It send short message to related personnel's mobile phone, transmission mail to related personnel's mailbox etc., can be arranged according to the actual situation.If at data
Reason result is data exception, and the synchronous recipient of data can send warning message to default personnel, which carries data
Processing result is reminded related personnel to troubleshoot and handle in time, is finally solved the problems, such as, it is ensured that data synchronize without exception, wherein
Default personnel can be arranged according to the actual situation, meet plurality of application scenes demand.
In addition, in a specific example, it is described to include: to the data message progress data check processing to be sent
Even-odd check, CRC check, LRC verification, Gray's code check are carried out to the data message to be sent and verified, different
Or any one or more in verification and MD5 verification.
Here, it treats to send datagram and carries out the mode of data check processing and can be arranged according to the actual situation, in school
After testing, corresponding check results are back to the synchronous sender of data by the synchronous recipient of data, and data are synchronous to send root
Subsequent processing is carried out according to data processed result, or terminates or pushes away again, solving the synchronous initiator of available data can not obtain in time
The problem of whether synchronous recipient of primary data has received total data like clockwork, while after verification, can be with
Storage processing will be carried out by the data message to be sent examined, is suitble to application.
The above method in order to better understand, the application example of a method of data synchronization of the present invention detailed below.
In conjunction with above-mentioned each embodiment, in the present embodiment, between the synchronous sender of data and the synchronous recipient of data
Interactive process for be illustrated, it is this explanation not to the present invention program constitute limit.
As shown in fig. 6, this application example may include:
S601: the synchronous sender of data generates the datagram to be sent according to default message format and information to be sent
Text.
Here, the synchronous sender of data recipient synchronous with data establishes two MQ queues according to agreement, i.e. MQ sends team
Column, for sending datagram, MQ receiving queue, the processing result of message for receiving data.And the synchronous sender of data
Recipient synchronous with data also presets the processing mode of production problem.
S602: data message to be sent is pushed to MQ transmit queue by the synchronous sender of data, while being started MQ and being received team
Whether the synchronous recipient of column monitored data returns to the data processed result after receiving data message to be sent.
S603: whether the synchronous sender of the synchronous recipient's monitored data of data, which passes through MQ transmit queue, sends data to be sent
Message.
S604: data message to be sent is sent by MQ transmit queue if listening to the synchronous sender of data, data are same
It walks recipient and receives data message to be sent, and after receiving successfully, treat to send datagram carrying out data check processing.
Specifically, if data processed result is data exception, the synchronous recipient of data sends warning message to default people
Member, the warning message carry above-mentioned data processed result.
S605: the synchronous recipient of data is after the completion of verification, by MQ receiving queue by the data of data message to be sent
Processing result returned data synchronizes sender.
S606: if the synchronous sender of data listens to the synchronous recipient's returned data processing knot of data by MQ receiving queue
Fruit then judges whether that completing data synchronizes according to data processed result.
Here, if the synchronous sender of data is not listened at the synchronous recipient's returned data of data by MQ receiving queue
Reason is as a result, then generate failure of data synchronization prompt.
S607: if determining to synchronize without completing data according to data processed result, the synchronous sender of data is re-executed
Described the step of data message to be sent is pushed into MQ transmit queue.
Specifically, if determining that completing data synchronizes, and stops operation, it is synchronous to generate data according to the data processed result
Complete prompt.
It synchronizes and connects it is evidenced from the above discussion that data message to be sent by MQ transmit queue is sent to data by the present embodiment
Debit, while starting whether the synchronous recipient of MQ receiving queue monitored data returns at the data after receiving data message to be sent
Reason carries out subsequent processing according to data processed result, or terminate or push away again, solves existing number as a result, if there is listening to
It is unable to learn in time the problem of whether synchronous recipient of data has received total data like clockwork according to synchronous initiator, is mentioned
Timeliness, robustness and the scalability of system when high data are synchronous, also avoid because between operation system data it is different due to draw
The traffic lost risen, while reducing because problem is delayed discovery bring baneful influence, it is suitble to practical application.
It should be understood that the size of the serial number of each step is not meant that the order of the execution order in above-described embodiment, each process
Execution sequence should be determined by its function and internal logic, the implementation process without coping with the embodiment of the present invention constitutes any limit
It is fixed.
Corresponding to method of data synchronization described in foregoing embodiments, Fig. 7 shows a kind of number provided in an embodiment of the present invention
According to the schematic block diagram of synchronizing device.The each unit that the data synchronization unit 700 of the present embodiment includes is corresponding for executing Fig. 1
Each step in embodiment does not repeat herein referring specifically to the associated description in the corresponding embodiment of Fig. 1 and Fig. 1.This implementation
The data synchronization unit 700 of example includes packet sending unit 701, result monitoring unit 702, synchronous 703 and of judging unit of data
Message process unit 704.
Wherein, packet sending unit 701 pass through the MQ for data message to be sent to be pushed to MQ transmit queue
The data message to be sent is sent to the synchronous recipient of data by transmit queue.As a result monitoring unit 702, for starting simultaneously
MQ receiving queue monitors whether the synchronous recipient of the data returns to the data processing knot after receiving the data message to be sent
Fruit.Data synchronize judging unit 703, if returning to institute for listening to the synchronous recipient of the data by the MQ receiving queue
Data processed result is stated, then judges whether that successfully completing data synchronizes according to the data processed result.Message process unit
704, if synchronous for being not successfully completed data according to data processed result judgement, re-execute it is described will be to be sent
Data message pushes to the step of MQ transmit queue.
It is evidenced from the above discussion that data synchronization unit of the embodiment of the present invention, by MQ transmit queue by datagram to be sent
Text is sent to the synchronous recipient of data, at the same start the synchronous recipient of MQ receiving queue monitored data whether return receive it is to be sent
Data processed result after data message, if there is listening to, according to data processed result carry out subsequent processing, or terminate or
It pushes away again, solves the synchronous initiator of available data and be unable to learn in time whether the synchronous recipient of data has received like clockwork
The problem of to total data, improve data it is synchronous when system timeliness, robustness and scalability, also avoid because of business
Traffic lost caused by inter-system data difference, while reducing because problem is delayed discovery bring baneful influence, it is suitble to real
Border application.
Referring to Fig. 8, Fig. 8 be another embodiment of the present invention provides another data synchronization unit schematic block diagram.This
The data synchronization unit 800 of embodiment includes packet sending unit 801, result monitoring unit 802, the synchronous judging unit of data
803, message process unit 804, synchronization failure prompt unit 805 and message generation unit 806.
Wherein, the synchronous judging unit 803 of packet sending unit 801, result monitoring unit 802, data and Message processing list
Member 804 is synchronous referring specifically to packet sending unit 701, result monitoring unit 702, data in the corresponding embodiment of Fig. 7 and Fig. 7
The associated description of judging unit 703 and message process unit 704, does not repeat herein.
Further, synchronization failure prompt unit 805, if for not listening to the number by the MQ receiving queue
The data processed result is returned according to synchronous recipient, then generates failure of data synchronization prompt.
Further, message generation unit 806, for pushing away data message to be sent in the packet sending unit 801
It send to before MQ transmit queue, according to default message format and information to be sent, generates the data message to be sent.
It is evidenced from the above discussion that by MQ transmit queue data message to be sent to be sent to data same for the embodiment of the present invention
Recipient is walked, while starting whether the synchronous recipient of MQ receiving queue monitored data returns to the number after receiving data message to be sent
According to processing result, if there is listening to, subsequent processing is carried out according to data processed result, or terminate or push away again, solved existing
There is the synchronous initiator of data to be unable to learn in time whether the synchronous recipient of data receives asking for total data like clockwork
Topic improves timeliness, robustness and the scalability of system when data synchronize, also avoids because data are different between operation system
Caused by traffic lost, while reduce because problem be delayed discovery bring baneful influence, be suitble to practical application.
A kind of schematic block diagram of data synchronization unit of yet another embodiment of the invention offer is provided referring to Fig. 9, Fig. 9.
The each unit that the data synchronization unit 900 of the present embodiment includes is used to execute each step in the corresponding embodiment of Fig. 4, specifically asks
Refering to the associated description in the corresponding embodiment of Fig. 4 and Fig. 4, do not repeat herein.The data synchronization unit 900 of the present embodiment includes
Message monitoring unit 901, message checking unit 902 and result return unit 903.
Wherein, message monitoring unit 901, for the synchronous sender of monitored data whether pass through MQ transmit queue send it is pending
Send data message.Message checking unit 902, if being sent out for listening to the synchronous sender of the data by the MQ transmit queue
The data message to be sent is sent, then receives the data message to be sent, and after receiving successfully, to the data to be sent
Message carries out data check processing.As a result return unit 903, for after the completion of verification, by MQ receiving queue will it is described to
The data processed result to send datagram returns to the synchronous sender of the data, so that the synchronous sender of the data is according to institute
It states data processed result and judges whether that successfully completing data synchronizes, and when determining that being not successfully completed data synchronizes, again will
The data message to be sent pushes to the MQ transmit queue and is sent.
Above description is it is found that whether data synchronization unit of the embodiment of the present invention, the synchronous sender of monitored data are sent out by MQ
Queue is sent to send data message to be sent, if there is listening to, the above-mentioned data message to be sent of reception, and after receiving successfully,
It treats to send datagram and carries out data check processing, after the completion of verification, by MQ receiving queue by data message to be sent
The synchronous sender of data processed result returned data, the synchronous sender of data carries out subsequent processing according to data processed result,
Or terminate or push away again, solve whether accurately the synchronous initiator of available data is unable to learn in time the synchronous recipient of data
The problem of inerrably receiving total data, improve data it is synchronous when system robustness and scalability, also avoid because
Traffic lost caused by data difference between operation system, while reducing because problem is delayed discovery bring baneful influence, it fits
Close practical application.
It is the schematic block diagram for another data synchronization unit that further embodiment of this invention provides referring to Figure 10, Figure 10.
The data synchronization unit 1000 of the present embodiment includes message monitoring unit 1001, message checking unit 1002, result return unit
1003 and alarm unit 1004.
Wherein, message monitoring unit 1001, message checking unit 1002 and result return unit 1003 are referring specifically to Fig. 9
And message monitoring unit 901, message checking unit 902 are related to result return unit 903 retouches in the corresponding embodiment of Fig. 9
It states, does not repeat herein.
Further, alarm unit 1004 send warning message if being data exception for the data processed result
To default personnel, the warning message carries the data processed result.
Further, described to include: to the data message progress data check processing to be sent
Even-odd check, CRC check, LRC verification, Gray's code check are carried out to the data message to be sent and verified, different
Or any one or more in verification and MD5 verification.
It is evidenced from the above discussion that the synchronous sender of monitored data of the embodiment of the present invention whether pass through MQ transmit queue send to
It sends datagram, if there is listening to, above-mentioned data message to be sent is received, and after receiving successfully, to data to be sent
Message carries out data check processing, after the completion of verification, by MQ receiving queue by the data processing knot of data message to be sent
Fruit returned data synchronizes sender, and the synchronous sender of data carries out subsequent processing according to data processed result, or terminates or push away again
Deng solving the synchronous initiator of available data and be unable to learn in time whether the synchronous recipient of data has received entirely like clockwork
The problem of portion's data, improves the robustness and scalability of system when data synchronize, also avoids because of data between operation system
Traffic lost caused by difference, while reducing because problem is delayed discovery bring baneful influence, it is suitble to practical application.
It is a kind of schematic block diagram of the synchronous sending device of data provided by one embodiment of the present invention referring to Figure 11, Figure 11.
As shown in figure 11, the synchronous sending device 110 of the data of the embodiment includes: processor 1100, memory 1101 and is stored in
In the memory 1101 and the computer program 1102 that can be run on the processor 1100, such as data synchronization program.
The processor 1100 realizes the step in above-mentioned each method of data synchronization embodiment when executing the computer program 1102,
Such as step 101 shown in FIG. 1 is to 103.Alternatively, the processor 1100 realized when executing the computer program 1102 it is above-mentioned
The function of each unit in each Installation practice, such as the function of unit 801 to 806 shown in Fig. 8.
The computer program 1102 can be divided into one or more module/units, one or more of moulds
Block/unit is stored in the memory 1101, and is executed by the processor 1100, to complete the present invention.It is one
Or multiple module/units can be the series of computation machine program instruction section that can complete specific function, the instruction segment is for retouching
State implementation procedure of the computer program 1102 in the synchronous sending device 110 of the data.For example, the computer program
1102 can be divided into packet sending unit, result monitoring unit, data synchronous judging unit, message process unit, synchronization
Failure prompt unit and message generation unit, each unit concrete function are as follows:
Data message to be sent is pushed into MQ transmit queue, by the MQ transmit queue by the datagram to be sent
Text is sent to the synchronous recipient of data, while starting MQ receiving queue and monitoring whether the synchronous recipient of the data returns to reception institute
Data processed result after stating data message to be sent；
If listening to the synchronous recipient of the data by the MQ receiving queue returns to the data processed result, root
Judge whether that successfully completing data synchronizes according to the data processed result；
If it is synchronous to be not successfully completed data according to data processed result judgement, re-execute it is described will be to be sent
Data message pushes to the step of MQ transmit queue.
Further, each unit concrete function further include:
If not listening to the synchronous recipient of the data by the MQ receiving queue returns to the data processed result,
Then generate failure of data synchronization prompt.
Further, it is described data message to be sent is pushed into MQ transmit queue before, further includes:
According to default message format and information to be sent, the data message to be sent is generated.
Data message to be sent is sent to the synchronous recipient of data by MQ transmit queue by above scheme, while starting MQ
Whether the synchronous recipient of receiving queue monitored data returns to the data processed result after receiving data message to be sent, if there is prison
Hear, subsequent processing carried out according to data processed result, or terminate or push away again, solve the synchronous initiator of available data without
The problem of whether method timely learning data synchronization recipient has received total data like clockwork, when improving data synchronization
The robustness and scalability of system also avoid the traffic lost because of caused by data difference between operation system, reduce simultaneously
Because problem is delayed discovery bring baneful influence, it is suitble to practical application.
The synchronous sending device 110 of the data can be desktop PC, notebook, palm PC and cloud server
Deng calculating equipment.The mobile unit may include, but be not limited only to, processor 1100, memory 1101.Those skilled in the art
It is appreciated that Figure 11 is only the example of the synchronous sending device 110 of data, structure paired data does not synchronize sending device 110
It limits, may include perhaps combining certain components or different components, such as described than illustrating more or fewer components
Mobile unit can also include input-output equipment, network access equipment, bus etc..
Alleged processor 1100 can be central processing unit (Central Processing Unit, CPU), can be with
It is other general processors, digital signal processor (Digital Signal Processor, DSP), specific integrated circuit
(Application Specific Integrated Circuit, ASIC), ready-made programmable gate array (Field-
Programmable Gate Array, FPGA) either other programmable logic device, discrete gate or transistor logic,
Discrete hardware components etc..General processor can be microprocessor or the processor is also possible to any conventional processor
Deng.
The memory 1101 can be the internal storage unit of the synchronous sending device 110 of the data, such as data are same
Walk the hard disk or memory of sending device 110.The memory 1101 is also possible to the outside of the synchronous sending device 110 of the data
Store the plug-in type hard disk being equipped in equipment, such as the synchronous sending device 110 of the data, intelligent memory card (Smart Media
Card, SMC), secure digital (Secure Digital, SD) card, flash card (Flash Card) etc..Further, described to deposit
Reservoir 1101 can also both include that the data synchronize the internal storage unit of sending device 110 or including External memory equipment.
The memory 1101 is for other programs and data needed for storing the computer program and the mobile unit.It is described
Memory 1101 can be also used for temporarily storing the data that has exported or will export.
It is a kind of schematic block diagram of data synchronous receiving equipment provided by one embodiment of the present invention referring to Figure 12, Figure 12.
As shown in figure 12, the data synchronous receiving equipment 120 of the embodiment includes: processor 1200, memory 1201 and is stored in
In the memory 1201 and the computer program 1202 that can be run on the processor 1200, such as data synchronization program.
The processor 1200 realizes the step in above-mentioned each method of data synchronization embodiment when executing the computer program 1202,
Such as step 401 shown in Fig. 4 is to 403.Alternatively, the processor 1200 realized when executing the computer program 1202 it is above-mentioned
The function of each unit in each Installation practice, such as the function of unit 1001 to 1004 shown in Figure 10.
The computer program 1202 can be divided into one or more module/units, one or more of moulds
Block/unit is stored in the memory 1201, and is executed by the processor 1200, to complete the present invention.It is one
Or multiple module/units can be the series of computation machine program instruction section that can complete specific function, the instruction segment is for retouching
State implementation procedure of the computer program 1202 in the data synchronous receiving equipment 120.For example, the computer program
1202 can be divided into message monitoring unit, message checking unit, result return unit and alarm unit, the specific function of each unit
It can be as follows:
Whether the synchronous sender of monitored data, which passes through MQ transmit queue, sends data message to be sent；
The data message to be sent is sent by the MQ transmit queue if listening to the synchronous sender of the data,
The data message to be sent is received, and after receiving successfully, data check processing is carried out to the data message to be sent；
After the completion of verification, by described in data processed result return of the MQ receiving queue by the data message to be sent
Data synchronize sender, so that the synchronous sender of the data judges whether to successfully complete data according to the data processed result
It is synchronous, and when determining that being not successfully completed data synchronizes, the data message to be sent is pushed into the MQ again and is sent
Queue is sent.
Further, each unit concrete function further include:
If the data processed result is data exception, warning message is sent to default personnel, the warning message is taken
With the data processed result.
Further, described to include: to the data message progress data check processing to be sent
Even-odd check, CRC check, LRC verification, Gray's code check are carried out to the data message to be sent and verified, different
Or any one or more in verification and MD5 verification.
The data synchronous receiving equipment 120 can be desktop PC, notebook, palm PC and cloud server
Deng calculating equipment.The mobile unit may include, but be not limited only to, processor 1200, memory 1201.Those skilled in the art
It is appreciated that Figure 12 is only the example of data synchronous receiving equipment 120, not structure paired data synchronous receiving equipment 120
It limits, may include perhaps combining certain components or different components, such as described than illustrating more or fewer components
Mobile unit can also include input-output equipment, network access equipment, bus etc..
Alleged processor 1200 can be central processing unit (Central Processing Unit, CPU), can be with
It is other general processors, digital signal processor (Digital Signal Processor, DSP), specific integrated circuit
(Application Specific Integrated Circuit, ASIC), ready-made programmable gate array (Field-
Programmable Gate Array, FPGA) either other programmable logic device, discrete gate or transistor logic,
Discrete hardware components etc..General processor can be microprocessor or the processor is also possible to any conventional processor
Deng.
The memory 1201 can be the internal storage unit of the data synchronous receiving equipment 120, such as data are same
Walk the hard disk or memory of receiving device 120.The memory 1201 is also possible to the outside of the data synchronous receiving equipment 120
The plug-in type hard disk being equipped in storage equipment, such as the data synchronous receiving equipment 120, intelligent memory card (Smart Media
Card, SMC), secure digital (Secure Digital, SD) card, flash card (Flash Card) etc..Further, described to deposit
Reservoir 1201 can also both including the data synchronous receiving equipment 120 internal storage unit and also including External memory equipment.
The memory 1201 is for other programs and data needed for storing the computer program and the mobile unit.It is described
Memory 1201 can be also used for temporarily storing the data that has exported or will export.
It is apparent to those skilled in the art that for convenience of description and succinctly, only with above-mentioned each function
Can unit, module division progress for example, in practical application, can according to need and by above-mentioned function distribution by different
Functional unit, module are completed, i.e., the internal structure of described device is divided into different functional unit or module, more than completing
The all or part of function of description.Each functional unit in embodiment, module can integrate in one processing unit, can also
To be that each unit physically exists alone, can also be integrated in one unit with two or more units, it is above-mentioned integrated
Unit both can take the form of hardware realization, can also realize in the form of software functional units.In addition, each function list
Member, the specific name of module are also only for convenience of distinguishing each other, the protection scope being not intended to limit this application.Above system
The specific work process of middle unit, module, can refer to corresponding processes in the foregoing method embodiment, and details are not described herein.
In the above-described embodiments, it all emphasizes particularly on different fields to the description of each embodiment, is not described in detail or remembers in some embodiment
The part of load may refer to the associated description of other embodiments.
Those of ordinary skill in the art may be aware that list described in conjunction with the examples disclosed in the embodiments of the present disclosure
Member and algorithm steps can be realized with the combination of electronic hardware or computer software and electronic hardware.These functions are actually
It is implemented in hardware or software, the specific application and design constraint depending on technical solution.Professional technician
Each specific application can be used different methods to achieve the described function, but this realization is it is not considered that exceed
The scope of the present invention.
In embodiment provided by the present invention, it should be understood that disclosed device/device and method can pass through
Other modes are realized.For example, device/apparatus embodiments described above are only schematical, for example, the module or
The division of unit, only a kind of logical function partition, there may be another division manner in actual implementation, such as multiple units
Or component can be combined or can be integrated into another system, or some features can be ignored or not executed.Another point, institute
Display or the mutual coupling or direct-coupling or communication connection discussed can be through some interfaces, device or unit
INDIRECT COUPLING or communication connection can be electrical property, mechanical or other forms.
The unit as illustrated by the separation member may or may not be physically separated, aobvious as unit
The component shown may or may not be physical unit, it can and it is in one place, or may be distributed over multiple
In network unit.It can select some or all of unit therein according to the actual needs to realize the mesh of this embodiment scheme
's.
It, can also be in addition, the functional units in various embodiments of the present invention may be integrated into one processing unit
It is that each unit physically exists alone, can also be integrated in one unit with two or more units.Above-mentioned integrated list
Member both can take the form of hardware realization, can also realize in the form of software functional units.
If the integrated module/unit be realized in the form of SFU software functional unit and as independent product sale or
In use, can store in a computer readable storage medium.Based on this understanding, the present invention realizes above-mentioned implementation
All or part of the process in example method, can also instruct relevant hardware to complete, the meter by computer program
Calculation machine program can be stored in a computer readable storage medium, the computer program when being executed by processor, it can be achieved that on
The step of stating each embodiment of the method.Wherein, the computer program includes computer program code, the computer program generation
Code can be source code form, object identification code form, executable file or certain intermediate forms etc..The computer-readable medium
It may include: any entity or device, recording medium, USB flash disk, mobile hard disk, magnetic that can carry the computer program code
Dish, CD, computer storage, read-only memory (Read-Only Memory, ROM), random access memory (Random
Access Memory, RAM), electric carrier signal, telecommunication signal and software distribution medium etc..It should be noted that the meter
The content that calculation machine readable medium includes can carry out increase and decrease appropriate according to the requirement made laws in jurisdiction with patent practice,
Such as in certain jurisdictions, according to legislation and patent practice, computer-readable medium do not include be electric carrier signal and electricity
Believe signal.
Embodiment described above is merely illustrative of the technical solution of the present invention, rather than its limitations；Although referring to aforementioned reality
Applying example, invention is explained in detail, those skilled in the art should understand that: it still can be to aforementioned each
Technical solution documented by embodiment is modified or equivalent replacement of some of the technical features；And these are modified
Or replacement, the spirit and scope for technical solution of various embodiments of the present invention that it does not separate the essence of the corresponding technical solution should all
It is included within protection scope of the present invention.
Claims (10)
1. a kind of method of data synchronization characterized by comprising
Data message to be sent is pushed into message queue MQ transmit queue, by the MQ transmit queue by the number to be sent
It is sent to the synchronous recipient of data according to message, while starting MQ receiving queue and monitors the synchronous recipient of the data and whether return and connecing
Data processed result after receiving the data message to be sent；
If listening to the synchronous recipient of the data by the MQ receiving queue returns to the data processed result, according to institute
It states data processed result and judges whether that successfully completing data synchronizes；
If being not successfully completed data according to data processed result judgement to synchronize, re-execute described by data to be sent
Message pushes to the step of MQ transmit queue.
2. method of data synchronization as described in claim 1, which is characterized in that further include:
If not listening to the synchronous recipient of the data by the MQ receiving queue returns to the data processed result, give birth to
It is prompted at failure of data synchronization.
3. method of data synchronization as described in claim 1, which is characterized in that data message to be sent is pushed to MQ described
Before transmit queue, further includes:
According to default message format and information to be sent, the data message to be sent is generated.
4. a kind of method of data synchronization characterized by comprising
Whether the synchronous sender of monitored data, which passes through MQ transmit queue, sends data message to be sent；
The data message to be sent is sent by the MQ transmit queue if listening to the synchronous sender of the data, is received
The data message to be sent, and after receiving successfully, data check processing is carried out to the data message to be sent；
After the completion of verification, the data processed result of the data message to be sent is returned to by the data by MQ receiving queue
Synchronous sender so that the synchronous sender of the data judge whether to successfully complete data according to the data processed result it is same
Step, and when determining that being not successfully completed data synchronizes, the data message to be sent is pushed into the MQ again and sends team
Column are sent.
5. method of data synchronization as claimed in claim 4, which is characterized in that further include:
If the data processed result is data exception, warning message is sent to default personnel, the warning message carries institute
State data processed result.
6. method of data synchronization as claimed in claim 4, which is characterized in that described to be counted to the data message to be sent
Include: according to checking treatment
Even-odd check, CRC check, LRC verification, Gray's code check and verification, exclusive or school are carried out to the data message to be sent
It tests and any one or more in MD5 verification.
7. a kind of data synchronization unit characterized by comprising
Packet sending unit, for data message to be sent to be pushed to MQ transmit queue, by the MQ transmit queue by institute
It states data message to be sent and is sent to the synchronous recipient of data；
As a result monitoring unit monitors whether the synchronous recipient of the data returns described in reception for starting MQ receiving queue simultaneously
Data processed result after data message to be sent；
Data synchronize judging unit, if for being listened to described in the synchronous recipient's return of the data by the MQ receiving queue
Data processed result then judges whether that successfully completing data synchronizes according to the data processed result；
Message process unit is held again if synchronizing for being not successfully completed data according to data processed result judgement
It goes described the step of data message to be sent is pushed into MQ transmit queue.
8. a kind of data synchronization unit characterized by comprising
Message monitoring unit sends data message to be sent for whether the synchronous sender of monitored data to pass through MQ transmit queue；
Message checking unit, if described pending by MQ transmit queue transmission for listening to the synchronous sender of the data
Data message is sent, then receives the data message to be sent, and after receiving successfully, the data message to be sent is counted
According to checking treatment；
As a result return unit is used for after the completion of verification, will be at the data of the data message to be sent by MQ receiving queue
It manages result and returns to the synchronous sender of the data, so that the synchronous sender of the data is according to data processed result judgement
The no data that successfully complete are synchronous, and when determining that being not successfully completed data synchronizes, again push away the data message to be sent
It send to the MQ transmit queue and is sent.
9. a kind of synchronous sending device of data, including memory, processor and storage are in the memory and can be described
The computer program run on processor, which is characterized in that the processor realizes such as right when executing the computer program
It is required that the step of any one of 1 to 3 the method.
10. a kind of computer readable storage medium, the computer-readable recording medium storage has computer program, and feature exists
In when the computer program is executed by processor the step of any one of such as claims 1 to 3 of realization the method.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201811115456.7A CN109299193A (en) | 2018-09-25 | 2018-09-25 | Method of data synchronization and relevant device |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201811115456.7A CN109299193A (en) | 2018-09-25 | 2018-09-25 | Method of data synchronization and relevant device |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN109299193A true CN109299193A (en) | 2019-02-01 |
Family
ID=65164216
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201811115456.7A Pending CN109299193A (en) | 2018-09-25 | 2018-09-25 | Method of data synchronization and relevant device |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN109299193A (en) |
Cited By (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN110825617A (en) * | 2019-09-27 | 2020-02-21 | 福建星云电子股份有限公司 | Method and device for simulating communication interaction between devices |
| CN110941665A (en) * | 2019-10-31 | 2020-03-31 | 北京浪潮数据技术有限公司 | Data synchronization method, data synchronization device and data synchronization equipment between nodes |
| CN111813733A (en) * | 2020-06-30 | 2020-10-23 | 厦门科灿信息技术有限公司 | Synchronous communication method and system based on Modbus protocol and terminal equipment |
| CN113377857A (en) * | 2021-07-02 | 2021-09-10 | 招商局金融科技有限公司 | Data distribution method and device, electronic equipment and readable storage medium |
| CN114422531A (en) * | 2022-03-11 | 2022-04-29 | 深圳市金政软件技术有限公司 | Data synchronization method, system, device and storage medium |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102368700A (en) * | 2011-10-25 | 2012-03-07 | 曙光信息产业(北京)有限公司 | Transmission method of massages in distributed system |
| CN104809202A (en) * | 2015-04-24 | 2015-07-29 | 联动优势科技有限公司 | Database synchronization method and device |
| WO2017141229A1 (en) * | 2016-02-21 | 2017-08-24 | Geir Christian Karlsen | System and method for securely exchanging data between devices |
| CN107332886A (en) * | 2017-06-20 | 2017-11-07 | 福建中金在线信息科技有限公司 | Method of data synchronization, device, system, electronic equipment and readable storage medium storing program for executing |
| CN107682324A (en) * | 2017-09-20 | 2018-02-09 | 华胜信泰信息产业发展有限公司 | Method for message transmission, system, storage medium and computer equipment |
-
2018
- 2018-09-25 CN CN201811115456.7A patent/CN109299193A/en active Pending
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102368700A (en) * | 2011-10-25 | 2012-03-07 | 曙光信息产业(北京)有限公司 | Transmission method of massages in distributed system |
| CN104809202A (en) * | 2015-04-24 | 2015-07-29 | 联动优势科技有限公司 | Database synchronization method and device |
| WO2017141229A1 (en) * | 2016-02-21 | 2017-08-24 | Geir Christian Karlsen | System and method for securely exchanging data between devices |
| CN107332886A (en) * | 2017-06-20 | 2017-11-07 | 福建中金在线信息科技有限公司 | Method of data synchronization, device, system, electronic equipment and readable storage medium storing program for executing |
| CN107682324A (en) * | 2017-09-20 | 2018-02-09 | 华胜信泰信息产业发展有限公司 | Method for message transmission, system, storage medium and computer equipment |
Cited By (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN110825617A (en) * | 2019-09-27 | 2020-02-21 | 福建星云电子股份有限公司 | Method and device for simulating communication interaction between devices |
| CN110825617B (en) * | 2019-09-27 | 2023-09-08 | 福建星云电子股份有限公司 | Method and device for simulating communication interaction between devices |
| CN110941665A (en) * | 2019-10-31 | 2020-03-31 | 北京浪潮数据技术有限公司 | Data synchronization method, data synchronization device and data synchronization equipment between nodes |
| CN111813733A (en) * | 2020-06-30 | 2020-10-23 | 厦门科灿信息技术有限公司 | Synchronous communication method and system based on Modbus protocol and terminal equipment |
| CN113377857A (en) * | 2021-07-02 | 2021-09-10 | 招商局金融科技有限公司 | Data distribution method and device, electronic equipment and readable storage medium |
| CN114422531A (en) * | 2022-03-11 | 2022-04-29 | 深圳市金政软件技术有限公司 | Data synchronization method, system, device and storage medium |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN109299193A (en) | Method of data synchronization and relevant device | |
| US12126732B2 (en) | Blockchain consensus method, device and system | |
| CN109493204B (en) | Service accounting method based on block chain and terminal equipment | |
| EP3859644A1 (en) | Block chain-based data check system and method, computing device, and storage medium | |
| CN112073269B (en) | Block chain network testing method, device, server and storage medium | |
| CN106470133B (en) | System pressure testing method and device | |
| CN109828903A (en) | Automated testing method, device, computer installation and storage medium | |
| CN108848148B (en) | Transaction information confirmation method and device based on block chain | |
| WO2019006654A1 (en) | Financial self-service equipment maintenance dispatch generation method, hand-held terminal and electronic device | |
| CN113645278B (en) | Cross-chain message transmission method, device and storage medium of block chain | |
| CN113505520A (en) | Method, device and system for supporting heterogeneous federated learning | |
| CN110705893B (en) | Service node management method, device, equipment and storage medium | |
| CN113347164A (en) | Block chain-based distributed consensus system, method, device and storage medium | |
| CN110022323A (en) | A kind of method and system of the cross-terminal real-time, interactive based on WebSocket and Redux | |
| CN118584882A (en) | A high-precision integration method and system for distributed control system alarm event signals | |
| CN107451059A (en) | A kind of method for testing software and test device | |
| CN116805912B (en) | A data transmission and storage method for university academic affairs systems based on angle mapping | |
| US20240354878A1 (en) | Method and Apparatus for Data Verification | |
| CN110060163A (en) | Method of commerce, system, medium and the device of podcast chain based on ether mill | |
| CN109600250A (en) | Operation system failure notification method, device, electronic device and storage medium | |
| CN111752642B (en) | Configuration modification method, device, computing device and storage medium | |
| CN112348713A (en) | QLRunner-based data processing method, device, electronic equipment and medium | |
| CN113487041A (en) | Horizontal federal learning method, device and storage medium | |
| CN113328913B (en) | Method, device and system for improving project testing efficiency | |
| CN109471790A (en) | Method and device, computer device and readable storage medium for sending nuclear parameter comparison |
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 | ||
| WD01 | Invention patent application deemed withdrawn after publication | ||
| WD01 | Invention patent application deemed withdrawn after publication |
Application publication date: 20190201 |