Sequential calling method and device based on two-stage transaction messages in distributed environment

Abstract

The invention provides a sequential calling method based on two-stage transaction messages in a distributed environment. The method comprises the steps of obtaining a message type of a to-be-processedtransaction; when the message type of the transaction is a sequence sensitive type, obtaining a sequence key of a processing time sequence of transaction messages processed by each node; receiving apreparation message output by each node, caching the preparation message to the local, and feeding back a preparation message response to the corresponding node; receiving a confirmation message output by the node, and obtaining a transaction message in the preparation message cached in the local according to the confirmation message; comparing the transaction message with the transaction messagecorresponding to the sequence key; and outputting a processing result in the confirmation message to a downstream node of a distributed transaction processing chain when the position of the transaction message in the sequence key meets a preset rule.

Description

technical field [0001] The invention relates to the field of data processing, in particular to a sequential call method and device based on two-stage transaction messages in a distributed environment. Background technique [0002] With the development of society and economy, IT software systems inevitably need to be modularized in order to meet the growing business needs while ensuring maintainability. Each module has supporting data sources for its reading and writing. Regardless of whether a distributed architecture is adopted, there are often multiple data sources for different functional modules. The completion of any business function almost requires multiple modules to work together. For business scenarios with high consistency requirements such as financial payment, in order to ensure the consistency of business execution results, multiple data sources need to be read and written at the same time, and the read and write results must succeed or fail at the same time,...

AI Technical Summary

Problems solved by technology

[0004] In a distributed environment, due to the clock difference of each application node and the instability of network transmission, the sent messages cannot be guaranteed to arrive at the message queue in the order in which they were sent. For downstream applications that need to calculate based on messages, the calculation results correctness is not guaranteed

Images