[go: up one dir, main page]

CN113392119A - Data consistency processing method and equipment - Google Patents

Data consistency processing method and equipment Download PDF

Info

Publication number
CN113392119A
CN113392119A CN202110740836.5A CN202110740836A CN113392119A CN 113392119 A CN113392119 A CN 113392119A CN 202110740836 A CN202110740836 A CN 202110740836A CN 113392119 A CN113392119 A CN 113392119A
Authority
CN
China
Prior art keywords
task
target task
executed
retry
target
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
Application number
CN202110740836.5A
Other languages
Chinese (zh)
Inventor
李志华
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Shanghai Wanwu Xinsheng Environmental Technology Group Co
Original Assignee
Shanghai Wanwu Xinsheng Environmental Technology Group Co
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by Shanghai Wanwu Xinsheng Environmental Technology Group Co filed Critical Shanghai Wanwu Xinsheng Environmental Technology Group Co
Priority to CN202110740836.5A priority Critical patent/CN113392119A/en
Publication of CN113392119A publication Critical patent/CN113392119A/en
Pending legal-status Critical Current

Links

Images

Classifications

    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/23Updating
    • G06F16/2365Ensuring data consistency and integrity
    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/27Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F9/00Arrangements for program control, e.g. control units
    • G06F9/06Arrangements 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/46Multiprogramming arrangements
    • G06F9/54Interprogram communication
    • G06F9/546Message passing systems or structures, e.g. queues

Landscapes

  • Engineering & Computer Science (AREA)
  • Theoretical Computer Science (AREA)
  • Physics & Mathematics (AREA)
  • General Engineering & Computer Science (AREA)
  • General Physics & Mathematics (AREA)
  • Databases & Information Systems (AREA)
  • Software Systems (AREA)
  • Data Mining & Analysis (AREA)
  • Computing Systems (AREA)
  • Computer Security & Cryptography (AREA)
  • Retry When Errors Occur (AREA)

Abstract

本申请的目的是提供一种数据一致性处理方法及设备,本申请通过在业务系统内创建一消息组件,所述消息组件包括消息队列和工作线程;通过所述消息组件执行并监测所述业务系统内的目标任务;若所述目标任务执行失败,则通过所述消息队列对所述目标任务进行重试操作并记录重试次数;若所述重试次数达到预设重试次数阈值时,所述目标任务仍执行失败,则通过所述工作线程按照预设重试频率对所述目标任务进行重试,直至所述目标任务执行成功,确保业务系统内的所有的任务最终都能执行成功,不仅达到了对目标任务执行成功的目的,还对执行失败的任务进行快速重试和兜底重试以确保任务能够最终执行成功,达到业务系统中的数据的最终一致性。

Figure 202110740836

The purpose of this application is to provide a data consistency processing method and device. In this application, a message component is created in a business system, and the message component includes a message queue and a worker thread; the business is executed and monitored through the message component. The target task in the system; if the execution of the target task fails, retry the target task through the message queue and record the number of retries; if the number of retries reaches the preset number of retries threshold, If the target task still fails to be executed, the working thread will retry the target task according to the preset retry frequency until the target task is successfully executed, ensuring that all tasks in the business system can be successfully executed in the end , which not only achieves the purpose of successfully executing the target task, but also performs fast retry and bottom-line retry for the failed task to ensure that the task can be successfully executed eventually and achieve the final consistency of the data in the business system.

Figure 202110740836

Description

Data consistency processing method and equipment
Technical Field
The present application relates to the field of computer technologies, and in particular, to a data consistency processing method and device.
Background
In the existing distributed system, in order to ensure the performance of the system and reduce the service coupling degree, a service flow driven based on a message mode is usually adopted. When the message-based driving is performed, the message middleware is usually used for processing, and once the processing fails, the service retry operation is performed based on the retry mechanism of the message, but the following limitations and problems exist: firstly, it cannot be ensured that the message can normally reach the message middleware, secondly, the message is stored in the message middleware, and the message data and the service data cross transactions, which may bring performance and data consistency problems.
Disclosure of Invention
An object of the present application is to provide a data consistency processing method and device, which not only complete execution of a task, but also perform fast retry and bottom retry on a task that fails to be executed to ensure that the task can be successfully executed, thereby achieving final consistency of data in a service system.
According to an aspect of the present application, a data consistency processing method is provided, wherein the method includes:
creating a message component in a business system, wherein the message component comprises a message queue and a work thread;
executing and monitoring a target task in the business system through the message component;
if the target task fails to be executed, carrying out retry operation on the target task through the message queue and recording retry times;
and if the target task still fails to be executed when the retry times reach a preset retry time threshold value, retrying the target task through the working thread according to a preset retry frequency until the target task is successfully executed.
Further, in the above method, the method further includes:
and if the target task fails to be executed, updating the task state of the target task from non-execution to execution failure.
Further, in the above method, the method further includes:
and if the target task fails to be executed, maintaining the task state of the target task as the execution failure.
Further, in the above method, the method further includes:
and if the target task is successfully executed, updating the task state of the target task from execution failure to execution success.
Further, in the above method, the method further includes:
and if the target task is successfully executed, updating the task state of the target task from non-execution to successful execution.
Further, in the above method, the message component further includes a task table, and the task table is used to store all tasks to be executed and all retried tasks in the service system.
According to another aspect of the present application, there is also provided a non-volatile storage medium having computer readable instructions stored thereon, which, when executed by a processor, cause the processor to implement the data consistency processing method as described above.
According to another aspect of the present application, there is also provided a data consistency processing apparatus, wherein the apparatus includes:
one or more processors;
a computer-readable medium for storing one or more computer-readable instructions,
when executed by the one or more processors, cause the one or more processors to implement the data coherency processing method described above.
Compared with the prior art, the method and the system have the advantages that a message component is created in the business system, and the message component comprises a message queue and a work thread; executing and monitoring a target task in the business system through the message component; if the target task fails to be executed, performing retry operation on the target task through the message queue and recording retry times so as to realize quick retry of the target task through the message queue when the target task fails to be executed; if the retry times reach a preset retry time threshold value, the target task is still executed unsuccessfully, the target task is retried through the working thread according to a preset retry frequency until the target task is executed successfully, so that the target task can be successfully executed through the working thread, all tasks in the business system can be guaranteed to be executed successfully finally, the purpose of successfully executing the target task is achieved, the task which is executed unsuccessfully is quickly retried and retried in a bottom-in-bottom mode, the task can be guaranteed to be executed successfully finally, and the final consistency of data in the business system is achieved.
Drawings
Other features, objects and advantages of the present application will become more apparent upon reading of the following detailed description of non-limiting embodiments thereof, made with reference to the accompanying drawings in which:
FIG. 1 illustrates a practical flow diagram of a data consistency handling method in accordance with an aspect of the subject application;
FIG. 2 is a schematic diagram illustrating an integration relationship between a business system and task components in a data consistency processing method according to an aspect of the present application;
FIG. 3 illustrates a pictorial diagram of the organization of task components in a method of data consistency processing in accordance with an aspect of the subject application;
FIG. 4 illustrates a workflow diagram of task components in a data consistency processing method in an actual application scenario according to an aspect of the present application.
The same or similar reference numbers in the drawings identify the same or similar elements.
Detailed Description
The present application is described in further detail below with reference to the attached figures.
In a typical configuration of the present application, the terminal, the device serving the network, and the trusted party each include one or more processors (CPUs), input/output interfaces, network interfaces, and memory.
The memory may include forms of volatile memory in a computer readable medium, Random Access Memory (RAM) and/or non-volatile memory, such as Read Only Memory (ROM) or flash memory (flash RAM). Memory is an example of a computer-readable medium.
Computer-readable media, including both non-transitory and non-transitory, removable and non-removable media, may implement information storage by any method or technology. The information may be computer readable instructions, data structures, modules of a program, or other data. Examples of computer storage media include, but are not limited to, phase change memory (PRAM), Static Random Access Memory (SRAM), Dynamic Random Access Memory (DRAM), other types of Random Access Memory (RAM), Read Only Memory (ROM), Electrically Erasable Programmable Read Only Memory (EEPROM), flash memory or other memory technology, compact disc read only memory (CD-ROM), Digital Versatile Discs (DVD) or other optical storage, magnetic cassettes, magnetic tape, magnetic disk storage or other magnetic storage devices, or any other non-transmission medium that can be used to store information that can be accessed by a computing device. As defined herein, computer readable media does not include non-transitory computer readable media (transient media), such as modulated data signals and carrier waves.
As shown in fig. 1, one aspect of the present application provides a flow diagram of a data consistency processing method, which may employ a relational database management system MySQL, oracel, and other data stores. The method comprises a step S11, a step S12, a step S13 and a step S14, and specifically comprises the following steps:
step S11, creating a message component in the business system, wherein the message component comprises a message queue and a work thread; here, the message component is used to ensure final consistency of related data such as tasks in the service system, the message component is made in a form of JAR (Java Archive) package, and the message component made in the JAR package is introduced into the service system for integration, as shown in fig. 2.
It should be noted that, as shown in fig. 3, the Message components for ensuring data consistency in the service system include an API (Application Programming Interface), a task table, a Message Queue (MQ), and a Worker thread Worker. The API is used for providing task state in the processes of creating a task, inquiring the task, executing the task, supervising the task execution, updating the task state and the like; the task table is used for storing all tasks to be executed and all retried tasks in the service system; the message queue is used for carrying out retry operation on the task which is failed to be executed when the task is failed to be executed, but the retry operation of the task which is failed to be executed by the message queue MQ is limited retry, and after the retry operation reaches a preset retry number threshold, if the task is still failed to be executed, the task which is failed to be executed is carried out with bottom compensation operation through the working thread Worker, so that the task can be successfully executed. In the embodiment of the application, the message queue MQ can be replaced by other message queues such as a Rabbit MQ and a socket MQ; the Worker thread Worker may use a task scheduling tool xxl-joba or elastic-joba, etc.
Step S12, executing and monitoring target tasks in the service system through the message component;
step S13, if the target task fails to be executed, performing retry operation on the target task through the message queue and recording retry times, so that when the target task in the service system fails to be executed, the target task can be quickly retried through the message queue.
Step S14, if the target task still fails to be executed when the retry number reaches a preset retry number threshold, retrying the target task by the worker thread according to a preset retry frequency until the target task is successfully executed.
Through the steps S11 to S14, when the target task in the business system fails to be executed, the target task is preferentially retried through the message queue, and when the number of retries in the message queue reaches the preset retry number threshold and the execution still fails, the target task is retried through the work thread according to the preset retry frequency until the target task is successfully executed, so that the target task can be successfully executed through the work thread, and all tasks in the business system can be successfully executed finally.
Next to the foregoing embodiments of the present application, a data consistency processing method proposed by the present application further includes:
and if the target task fails to be executed, updating the task state of the target task from non-execution to execution failure.
For example, after the target task in the service system is executed and monitored through the message component in step S12, if the target task fails to be executed, the task state of the target task is updated from non-execution to failed execution, so as to achieve the purpose of monitoring and updating the task state of the target task in real time.
Next to the foregoing embodiments of the present application, a data consistency processing method proposed by the present application further includes:
and if the target task fails to be executed, maintaining the task state of the target task as the execution failure.
For example, in step S13, the message queue MQ performs retry operation on the target task and records retry times, and if the target task still fails to execute during retry of the target task within a preset retry time threshold, the task state of the target task is maintained as execution failure, so as to achieve the purpose of monitoring the task state of the target task in real time during retry of the target task through the message queue.
Next to the foregoing embodiments of the present application, a data consistency processing method proposed by the present application further includes:
and if the target task is successfully executed, updating the task state of the target task from execution failure to execution success.
For example, in step S13, the message queue MQ performs retry operation on the target task and records retry times, and if the target task is successfully executed in a certain retry in the process of performing retry within the preset retry time threshold on the target task, the task state of the target task is updated from execution failure to execution success, so as to achieve the purpose of monitoring and updating the task state in real time when the target task is successfully executed in the process of performing retry on the target task through the message queue.
Next to the foregoing embodiments of the present application, a data consistency processing method proposed by the present application further includes:
and if the target task is successfully executed, updating the task state of the target task from non-execution to successful execution.
For example, after the target task is executed and monitored in the service system through the message component in step S12, if the target task is successfully executed, the task state of the target task is updated from non-execution to successful execution, so as to achieve the purpose of monitoring and updating the task state of the target task in real time.
In an actual application scenario of the present application, as shown in fig. 4, after a task component for data consistency is created in a business system, when a task node in the business system executes a task, a write task is preferably operated first (here, a target task is preferably a write task), at this time, a task state of the write task is not executed, when the write task starts executing, the write task starts executing through the message component, and a task state of the write task in a task table is queried, if the write task is successfully executed, a task state of the write task is updated to be successful, and if the write task fails to execute, the task state of the write task is updated to be failed to be executed, and meanwhile, a retry policy of the task is triggered. For example, a quick retry operation is preferentially performed on the write task through the message queue MQ, if the retry number of the retry through the MQ does not reach the preset retry number threshold and the write task is successfully executed during retry, the task state of the write task is updated from execution failure to execution success, if the retry number of the retry through the MQ reaches the preset retry number threshold and the write task is still failed to be executed, the task state of the write task is continuously maintained as execution failure, and the target task is subjected to retry of bottom compensation through the working thread Worker according to the preset retry frequency until the target task is successfully executed, so that the write task can be successfully executed through the working thread, all tasks in the service system can be successfully executed finally, the purpose of successful execution of the write task is achieved, and the task which is failed to be executed is quickly retried and subjected to bottom retry to ensure that the task can be successfully executed finally, the final consistency of the data in the service system is achieved.
In the embodiment of the application, in a distributed system based on message driving, a task component for ensuring data consistency provides a rapid integration capability, a task node in a business system after integration is initialized in the task component, the task component monitors and processes a task execution step, if the execution fails, rapid retry and bottom-of-pocket compensation are carried out, and the task can be successfully executed to achieve final data consistency.
According to another aspect of the present application, there is also provided a non-volatile storage medium having computer readable instructions stored thereon, which, when executed by a processor, cause the processor to implement the data consistency processing method as described above.
According to another aspect of the present application, there is also provided a data consistency processing apparatus, wherein the apparatus includes:
one or more processors;
a computer-readable medium for storing one or more computer-readable instructions,
when executed by the one or more processors, cause the one or more processors to implement the data coherency processing method described above.
Here, for details of each embodiment in the data consistency processing apparatus, reference may be specifically made to corresponding parts of the embodiments of the data consistency processing method, and details are not described here again.
In summary, the application creates a message component in the service system, where the message component includes a message queue and a work thread; executing and monitoring a target task in the business system through the message component; if the target task fails to be executed, performing retry operation on the target task through the message queue and recording retry times so as to realize quick retry of the target task through the message queue when the target task fails to be executed; if the retry times reach a preset retry time threshold value, the target task is still executed unsuccessfully, the target task is retried through the working thread according to a preset retry frequency until the target task is executed successfully, so that the target task can be successfully executed through the working thread, all tasks in the business system can be guaranteed to be executed successfully finally, the purpose of successfully executing the target task is achieved, the task which is executed unsuccessfully is quickly retried and retried in a bottom-in-bottom mode, the task can be guaranteed to be executed successfully finally, and the final consistency of data in the business system is achieved.
It should be noted that the present application may be implemented in software and/or a combination of software and hardware, for example, implemented using Application Specific Integrated Circuits (ASICs), general purpose computers or any other similar hardware devices. In one embodiment, the software programs of the present application may be executed by a processor to implement the steps or functions described above. Likewise, the software programs (including associated data structures) of the present application may be stored in a computer readable recording medium, such as RAM memory, magnetic or optical drive or diskette and the like. Additionally, some of the steps or functions of the present application may be implemented in hardware, for example, as circuitry that cooperates with the processor to perform various steps or functions.
In addition, some of the present application may be implemented as a computer program product, such as computer program instructions, which when executed by a computer, may invoke or provide methods and/or techniques in accordance with the present application through the operation of the computer. Program instructions which invoke the methods of the present application may be stored on a fixed or removable recording medium and/or transmitted via a data stream on a broadcast or other signal-bearing medium and/or stored within a working memory of a computer device operating in accordance with the program instructions. An embodiment according to the present application comprises an apparatus comprising a memory for storing computer program instructions and a processor for executing the program instructions, wherein the computer program instructions, when executed by the processor, trigger the apparatus to perform a method and/or a solution according to the aforementioned embodiments of the present application.
It will be evident to those skilled in the art that the present application is not limited to the details of the foregoing illustrative embodiments, and that the present application may be embodied in other specific forms without departing from the spirit or essential attributes thereof. The present embodiments are therefore to be considered in all respects as illustrative and not restrictive, the scope of the application being indicated by the appended claims rather than by the foregoing description, and all changes which come within the meaning and range of equivalency of the claims are therefore intended to be embraced therein. Any reference sign in a claim should not be construed as limiting the claim concerned. Furthermore, it is obvious that the word "comprising" does not exclude other elements or steps, and the singular does not exclude the plural. A plurality of units or means recited in the apparatus claims may also be implemented by one unit or means in software or hardware. The terms first, second, etc. are used to denote names, but not any particular order.

Claims (8)

1.一种数据一致性处理方法,其中,所述方法包括:1. A data consistency processing method, wherein the method comprises: 在业务系统内创建一消息组件,所述消息组件包括消息队列和工作线程;Create a message component in the business system, the message component includes a message queue and a worker thread; 通过所述消息组件执行并监测所述业务系统内的目标任务;Execute and monitor target tasks in the business system through the message component; 若所述目标任务执行失败,则通过所述消息队列对所述目标任务进行重试操作并记录重试次数;If the execution of the target task fails, perform a retry operation on the target task through the message queue and record the number of retries; 若所述重试次数达到预设重试次数阈值时,所述目标任务仍执行失败,则通过所述工作线程按照预设重试频率对所述目标任务进行重试,直至所述目标任务执行成功。If the target task still fails to execute when the number of retries reaches the preset number of retries threshold, the working thread will retry the target task according to the preset retry frequency until the target task is executed success. 2.根据权利要求1所述的方法,其中,所述方法还包括:2. The method of claim 1, wherein the method further comprises: 若所述目标任务执行失败,则将所述目标任务的任务状态由未执行更新为执行失败。If the execution of the target task fails, the task status of the target task is updated from not executed to execution failure. 3.根据权利要求2所述的方法,其中,所述方法还包括:3. The method of claim 2, wherein the method further comprises: 若所述目标任务执行失败,则维持所述目标任务的任务状态为执行失败。If the execution of the target task fails, the task state of the target task is maintained as execution failure. 4.根据权利要求2所述的方法,其中,所述方法还包括:4. The method of claim 2, wherein the method further comprises: 若所述目标任务执行成功,则将所述目标任务的任务状态由执行失败更新为执行成功。If the target task is successfully executed, the task status of the target task is updated from execution failure to execution success. 5.根据权利要求1所述的方法,其中,所述方法还包括:5. The method of claim 1, wherein the method further comprises: 若所述目标任务执行成功,则将所述目标任务的任务状态由未执行更新为执行成功。If the target task is successfully executed, the task status of the target task is updated from not executed to successfully executed. 6.根据权利要求1所述的方法,其中,所述消息组件还包括任务表,所述任务表用于存储所述业务系统中的所有待执行的任务和所有重试的任务。6. The method according to claim 1, wherein the message component further comprises a task table for storing all tasks to be executed and all retried tasks in the business system. 7.一种非易失性存储介质,其上存储有计算机可读指令,所述计算机可读指令可被处理器执行时,使所述处理器实现如权利要求1至6中任一项所述的方法。7. A non-volatile storage medium having computer-readable instructions stored thereon which, when executable by a processor, cause the processor to implement the invention as claimed in any one of claims 1 to 6 method described. 8.一种数据一致性处理设备,其中,该设备包括:8. A data consistency processing device, wherein the device comprises: 一个或多个处理器;one or more processors; 计算机可读介质,用于存储一个或多个计算机可读指令,a computer-readable medium for storing one or more computer-readable instructions, 当所述一个或多个计算机可读指令被所述一个或多个处理器执行,使得所述一个或多个处理器实现如权利要求1至6中任一项所述的方法。The one or more computer readable instructions, when executed by the one or more processors, cause the one or more processors to implement the method of any one of claims 1 to 6.
CN202110740836.5A 2021-06-30 2021-06-30 Data consistency processing method and equipment Pending CN113392119A (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202110740836.5A CN113392119A (en) 2021-06-30 2021-06-30 Data consistency processing method and equipment

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202110740836.5A CN113392119A (en) 2021-06-30 2021-06-30 Data consistency processing method and equipment

Publications (1)

Publication Number Publication Date
CN113392119A true CN113392119A (en) 2021-09-14

Family

ID=77624795

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202110740836.5A Pending CN113392119A (en) 2021-06-30 2021-06-30 Data consistency processing method and equipment

Country Status (1)

Country Link
CN (1) CN113392119A (en)

Cited By (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN114003611A (en) * 2021-10-27 2022-02-01 土巴兔集团股份有限公司 Data consistency processing method and related device among multiple systems
CN119512823A (en) * 2024-11-29 2025-02-25 湖南长银五八消费金融股份有限公司 Batch task retry method, device, equipment and storage medium

Citations (10)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN103995691A (en) * 2014-05-21 2014-08-20 中国人民解放军国防科学技术大学 Service state consistency maintenance method based on transactions
CN107133302A (en) * 2017-04-28 2017-09-05 努比亚技术有限公司 Realize method, system, terminal and the computer-readable recording medium of data consistency
CN107341062A (en) * 2017-06-28 2017-11-10 百度在线网络技术(北京)有限公司 A kind of data push method, device, equipment and storage medium
US20180375783A1 (en) * 2017-06-27 2018-12-27 Atlassian Pty Ltd Retry handling in messaging queues
CN109542639A (en) * 2018-11-06 2019-03-29 用友网络科技股份有限公司 A kind of processing method, processing unit for ensureing micro services and calling data consistency
CN110995851A (en) * 2019-12-11 2020-04-10 贝壳技术有限公司 Message processing method, device, storage medium and equipment
CN112099935A (en) * 2020-09-25 2020-12-18 北京奇艺世纪科技有限公司 Task processing method and device
CN112667439A (en) * 2020-12-26 2021-04-16 北京奇艺世纪科技有限公司 Data processing method and device and electronic equipment
CN112948174A (en) * 2021-02-03 2021-06-11 江苏苏宁物流有限公司 Message processing method and device, computer equipment and storage medium
CN112991022A (en) * 2021-04-21 2021-06-18 福建天晴在线互动科技有限公司 Method and system for realizing final consistency of distributed order system data by using MQ

Patent Citations (10)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN103995691A (en) * 2014-05-21 2014-08-20 中国人民解放军国防科学技术大学 Service state consistency maintenance method based on transactions
CN107133302A (en) * 2017-04-28 2017-09-05 努比亚技术有限公司 Realize method, system, terminal and the computer-readable recording medium of data consistency
US20180375783A1 (en) * 2017-06-27 2018-12-27 Atlassian Pty Ltd Retry handling in messaging queues
CN107341062A (en) * 2017-06-28 2017-11-10 百度在线网络技术(北京)有限公司 A kind of data push method, device, equipment and storage medium
CN109542639A (en) * 2018-11-06 2019-03-29 用友网络科技股份有限公司 A kind of processing method, processing unit for ensureing micro services and calling data consistency
CN110995851A (en) * 2019-12-11 2020-04-10 贝壳技术有限公司 Message processing method, device, storage medium and equipment
CN112099935A (en) * 2020-09-25 2020-12-18 北京奇艺世纪科技有限公司 Task processing method and device
CN112667439A (en) * 2020-12-26 2021-04-16 北京奇艺世纪科技有限公司 Data processing method and device and electronic equipment
CN112948174A (en) * 2021-02-03 2021-06-11 江苏苏宁物流有限公司 Message processing method and device, computer equipment and storage medium
CN112991022A (en) * 2021-04-21 2021-06-18 福建天晴在线互动科技有限公司 Method and system for realizing final consistency of distributed order system data by using MQ

Non-Patent Citations (1)

* Cited by examiner, † Cited by third party
Title
无名: "系统分布式情况下最终一致性方案梳理", 《微信公众平台》 *

Cited By (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN114003611A (en) * 2021-10-27 2022-02-01 土巴兔集团股份有限公司 Data consistency processing method and related device among multiple systems
CN119512823A (en) * 2024-11-29 2025-02-25 湖南长银五八消费金融股份有限公司 Batch task retry method, device, equipment and storage medium
CN119512823B (en) * 2024-11-29 2025-09-26 湖南长银五八消费金融股份有限公司 Batch task retry method, device, equipment and storage medium

Similar Documents

Publication Publication Date Title
CN111813791B (en) Distributed transaction compensation method and equipment
US7698602B2 (en) Systems, methods and computer products for trace capability per work unit
US8341125B2 (en) Transaction log management
JP5756394B2 (en) Computer program, system, and method for restoring a restore set of files from backup objects stored in a sequential backup device
US10133618B2 (en) Diagnostic data set component
US8001091B2 (en) Apparatus, system, and method for hierarchical rollback of business operations
US20080168472A1 (en) Recording execution information
US9311170B2 (en) System, method and program tool to reset an application
US20090240742A1 (en) Transaction Log Management
CN109426550B (en) Resource scheduling method and equipment
CN112486719B (en) Method and equipment for RPC interface call failure processing
CN113392119A (en) Data consistency processing method and equipment
CN108170552A (en) A kind of method, apparatus and equipment for capturing Dump files
CN111679892A (en) Distributed transaction processing method, device, equipment and medium
CN114327816A (en) Method and equipment for processing batch tasks
CN112231403A (en) Consistency checking method, device, equipment and storage medium for data synchronization
US10228879B1 (en) System and method for backup and restore of offline disks in mainframe computers
CN114510459A (en) Distributed lock management method and system based on Redis cache system
US11163651B1 (en) Automated data restore
CN110096358A (en) Chain drive remote center distributed storage and distributed computing method
CN111552618B (en) Method and equipment for collecting logs
US7882508B1 (en) Tracing information flow using a signature
CN107491363A (en) A kind of Snapshot Method and device of the storage volume based on linux kernel
CN114860505B (en) A method and system for asynchronous backup of object storage data
CN118151857A (en) Data synchronization method, system, device, computer equipment and storage medium

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
RJ01 Rejection of invention patent application after publication

Application publication date: 20210914