CN111932234B - Transaction data processing method and device - Google Patents

Abstract

The invention provides a transaction data processing method and a device, wherein the method comprises the following steps: responding to the transaction instruction, and acquiring transaction data in the transaction instruction; creating a transaction processing pipeline corresponding to the transaction instruction by using a preset execution engine; the transaction processing pipeline comprises a plurality of service node valves which are sequenced in sequence; inputting transaction data into the transaction processing pipeline, so that each service node valve in the transaction processing pipeline processes the transaction data in sequence to obtain a transaction result corresponding to a transaction instruction; wherein the transaction data is the input of the first service node valve in the transaction processing pipeline, and the output of each service node valve in the transaction processing pipeline is used as the input of the next service node valve. By applying the method provided by the invention, the transaction data is processed through each service node valve in the transaction processing pipeline, so that the transaction result is obtained, the decoupling among the service node valves is realized, and the coding difficulty of the service codes is reduced.

Description

Transaction data processing method and device

Technical Field

The present invention relates to the field of computer technology, and in particular to a transaction data processing method and device.

Background technique

With the development of science and technology, Internet technology has also made great progress, and various Internet application services have emerged in an endless stream, allowing people to carry out various activities through these application services, such as online shopping. Users can buy the goods they need on the e-commerce platform without leaving home, which brings great convenience to users.

In existing e-commerce platforms, businesses are usually divided into different modules, such as shopping cart module, order module, payment module, etc., and then these modules are organized at the business layer, which makes these modules severely coupled together and compiles a large amount of logical judgments into the code, increasing the difficulty of business coding, which is not conducive to the development of business programs and leads to high maintenance costs of the e-commerce platform system.

Summary of the invention

The technical problem to be solved by the present invention is to provide a transaction data processing method to reduce the coupling degree of business codes in an e-commerce platform.

The present invention also provides a transaction data processing device to ensure the implementation and application of the above method in practice.

A transaction data processing method, comprising:

In response to a transaction instruction, acquiring transaction data in the transaction instruction;

Applying a preset execution engine to create a transaction processing pipeline corresponding to the transaction instruction; the transaction processing pipeline includes a plurality of business node valves arranged in sequence;

The transaction data is input into the transaction processing pipeline, so that each of the business node valves in the transaction processing pipeline processes the transaction data in turn to obtain the transaction result corresponding to the transaction instruction; wherein the transaction data is the input of the first business node valve in the transaction processing pipeline, and the output of each business node valve in the transaction processing pipeline serves as the input of the next business node valve.

In the above method, optionally, the application of a preset execution engine to create a transaction processing pipeline corresponding to the transaction instruction includes:

Calling the execution engine to generate an initial transaction processing pipeline;

Determine the transaction process corresponding to the transaction instruction; the transaction process includes multiple transaction links;

Obtaining the business node valve corresponding to each of the transaction links;

Adding each of the business node valves to the initial transaction processing pipeline based on the execution order of each of the transaction links in the transaction process;

The initial transaction processing pipeline to which each of the service node valves has been added is used as the transaction processing pipeline corresponding to the transaction instruction.

In the above method, optionally, the step of inputting the transaction data into the transaction processing pipeline so that each of the service node valves in the transaction processing pipeline processes the transaction data in turn to obtain a transaction result corresponding to the transaction instruction includes:

Creating a pipeline upstream document corresponding to the transaction processing pipeline and assigning a processing identifier to the transaction data;

The transaction data carrying the processing identifier is stored in the pipeline context, and each of the service node valves in the transaction processing pipeline is triggered to perform the data processing operation in the corresponding execution order. The process of each of the service node valves performing the data processing operation includes: obtaining the input of the service node valve in the pipeline context, processing the input, obtaining the output corresponding to the service node valve, and storing the output of the service node valve in the pipeline context;

The transaction data carrying the processing identifier is the input of the first service node valve in the transaction processing pipeline, and the output of each service node valve in the transaction processing pipeline is used as the input of the next service node valve until the output of the last service node valve in the transaction processing pipeline is obtained;

The output of the last service node valve in the transaction processing pipeline is determined as the transaction result corresponding to the transaction instruction.

The above method may optionally further include:

When it is detected that any of the service node valves fails to process data, a data rollback operation is performed to reacquire the input of the service node valve so that the service node valve processes the input again.

In the above method, optionally, the step of obtaining the transaction data in the transaction instruction includes:

Parsing the transaction instruction to obtain instruction information in the transaction instruction;

The transaction data is obtained in the instruction information.

A transaction data processing device, comprising:

an acquisition unit, configured to acquire the transaction data in the transaction instruction in response to the transaction instruction;

A creation unit, configured to apply a preset execution engine to create a transaction processing pipeline corresponding to the transaction instruction; the transaction processing pipeline comprises a plurality of sequentially arranged business node valves;

A processing unit is used to input the transaction data into the transaction processing pipeline, so that each of the business node valves in the transaction processing pipeline processes the transaction data in turn to obtain a transaction result corresponding to the transaction instruction; wherein the transaction data is the input of the first business node valve in the transaction processing pipeline, and the output of each business node valve in the transaction processing pipeline serves as the input of the next business node valve.

In the above device, optionally, the creation unit includes:

A generating subunit, used for calling the execution engine to generate an initial transaction processing pipeline;

A first determining subunit is used to determine a transaction process corresponding to the transaction instruction; the transaction process includes multiple transaction links;

A first acquisition subunit is used to acquire the business node valve corresponding to each of the transaction links;

A first execution subunit, configured to add each of the business node valves to the initial transaction processing pipeline based on the execution order of each of the transaction links in the transaction process;

The second execution subunit is used to use the initial transaction processing pipeline to which each of the service node valves has been added as the transaction processing pipeline corresponding to the transaction instruction.

In the above device, optionally, the processing unit includes:

A creation subunit is used to create a pipeline upstream document corresponding to the transaction processing pipeline and allocate a processing identifier for the transaction data;

A processing subunit is used to store the transaction data carrying the processing identifier into the pipeline context, trigger each of the business node valves in the transaction processing pipeline to perform a data processing operation in a corresponding execution order, wherein the data processing operation includes: obtaining an input of the business node valve in the pipeline context, processing the input, obtaining an output corresponding to the business node valve, and storing the output of the business node valve into the pipeline context;

The transaction data carrying the processing identifier is the input of the first service node valve in the transaction processing pipeline, and the output of each service node valve in the transaction processing pipeline is used as the input of the next service node valve until the output of the last service node valve in the transaction processing pipeline is obtained;

The second determining subunit determines the output of the last service node valve in the transaction processing pipeline as the transaction result corresponding to the transaction instruction.

In the above device, optionally, the processing unit further includes a detection subunit;

The detection subunit is used to perform a data rollback operation when it is detected that data processing of any of the service node valves fails, so as to re-acquire the input of the service node valve so that the service node valve re-processes the input.

In the above device, optionally, the receiving unit includes:

A parsing subunit, used to parse the transaction instruction to obtain transaction parameter information in the transaction instruction;

The second acquisition subunit is used to acquire the transaction data from the transaction parameter information.

Compared with the prior art, the present invention has the following advantages:

The present invention provides a transaction data processing method and device, the method comprising: in response to a transaction instruction, obtaining the transaction data in the transaction instruction; applying a pre-set execution engine to create a transaction processing pipeline corresponding to the transaction instruction; the transaction processing pipeline comprises a plurality of sequentially arranged business node valves; inputting the transaction data into the transaction processing pipeline so that each of the business node valves in the transaction processing pipeline processes the transaction data in turn to obtain a transaction result corresponding to the transaction instruction; wherein the transaction data is the input of the first business node valve in the transaction processing pipeline, and the output of each business node valve in the transaction processing pipeline is used as the input of the next business node valve. By applying the method provided by the present invention, the transaction data is processed by each business node valve in the transaction processing pipeline to obtain a transaction result, thereby achieving decoupling between each business node valve, reducing the coding difficulty of the business code, facilitating the development of business programs, and reducing the maintenance cost of the e-commerce platform system.

BRIEF DESCRIPTION OF THE DRAWINGS

In order to more clearly illustrate the embodiments of the present invention or the technical solutions in the prior art, the drawings required for use in the embodiments or the description of the prior art will be briefly introduced below. Obviously, the drawings described below are only embodiments of the present invention. For ordinary technicians in this field, other drawings can be obtained based on the provided drawings without paying creative work.

FIG1 is a flow chart of a transaction data processing method provided by the present invention;

FIG2 is a flow chart of a process of creating a transaction processing pipeline provided by the present invention;

FIG3 is a flow chart of a process for obtaining a transaction result provided by the present invention;

FIG4 is a schematic diagram of the structure of a transaction data processing device provided by the present invention;

FIG5 is a schematic diagram of the structure of an electronic device provided by the present invention.

Detailed ways

The following will be combined with the drawings in the embodiments of the present invention to clearly and completely describe the technical solutions in the embodiments of the present invention. Obviously, the described embodiments are only part of the embodiments of the present invention, not all of the embodiments. Based on the embodiments of the present invention, all other embodiments obtained by ordinary technicians in this field without creative work are within the scope of protection of the present invention.

The present invention can be used in many general or special computing device environments or configurations, such as personal computers, server computers, handheld or portable devices, tablet devices, multi-processor devices, distributed computing environments including any of the above devices or devices, etc.

The embodiment of the present invention provides a transaction data processing method, which can be applied to various system platforms, and the execution subject can be a processor of a computer terminal or various mobile devices. The method flow chart of the method is shown in FIG1, and specifically includes:

S101: In response to a transaction instruction, acquiring transaction data in the transaction instruction.

In the method provided by the embodiment of the present invention, the transaction instruction may be triggered by the user in a preset visual interface, and the transaction data may be a business parameter of the business corresponding to the transaction instruction.

S102: Apply a preset execution engine to create a transaction processing pipeline corresponding to the transaction instruction; the transaction processing pipeline includes a plurality of business node valves arranged in sequence.

In the method provided by the embodiment of the present invention, each service node valve has its corresponding data processing logic.

Among them, the transaction processing pipeline contains multiple business node valves sorted in order of execution, and the execution order is determined by the transaction process corresponding to the transaction instruction.

S103: Input the transaction data into the transaction processing pipeline, so that each of the business node valves in the transaction processing pipeline processes the transaction data in turn to obtain the transaction result corresponding to the transaction instruction; wherein the transaction data is the input of the first business node valve in the transaction processing pipeline, and the output of each business node valve in the transaction processing pipeline serves as the input of the next business node valve.

In the method provided by an embodiment of the present invention, the output of each business node valve can be stored in the cache area corresponding to the transaction processing pipeline as the input of the next business node valve; the cache area is used for full life cycle context support of the transaction processing pipeline and is used to store the input and output of each business node valve.

A transaction data processing method provided by an embodiment of the present invention comprises: in response to a transaction instruction, obtaining the transaction data in the transaction instruction; applying a pre-set execution engine to create a transaction processing pipeline corresponding to the transaction instruction; the transaction processing pipeline comprises a plurality of sequentially arranged business node valves; inputting the transaction data into the transaction processing pipeline so that each of the business node valves in the transaction processing pipeline processes the transaction data in turn to obtain a transaction result corresponding to the transaction instruction; wherein the transaction data is the input of the first business node valve in the transaction processing pipeline, and the output of each business node valve in the transaction processing pipeline is used as the input of the next business node valve. By applying the method provided by the present invention, the transaction data is processed by each business node valve in the transaction processing pipeline to obtain a transaction result, thereby achieving decoupling between each business node valve, reducing the coding difficulty of the business code, facilitating the development of business programs, and reducing the maintenance cost of the e-commerce platform system.

In the method provided by the embodiment of the present invention, based on the above implementation process, specifically, the application pre-set execution engine creates a transaction processing pipeline corresponding to the transaction instruction, as shown in FIG2, specifically including:

S201: Calling the execution engine to generate an initial transaction processing pipeline.

In the method provided by the embodiment of the present invention, the execution engine is pre-set with logic for generating a transaction pipeline, and the execution engine can be called to generate an initial transaction processing pipeline.

S202: Determine a transaction process corresponding to the transaction instruction; the transaction process includes multiple transaction links.

In the method provided in the embodiment of the present invention, it can be determined that the transaction instruction contains business parameters, and the transaction business corresponding to the transaction instruction can be determined based on the business parameters. In this case, the transaction process corresponding to the transaction business can be determined in a pre-established transaction process set, and the various transaction links required for the transaction business and the execution order of each transaction link can also be determined. The transaction process is composed of the various transaction links required for the transaction business and the execution order of each transaction link.

S203: Obtain the business node valve corresponding to each transaction link.

In the method provided by the embodiment of the present invention, the transaction link can be parsing the shopping cart, obtaining user address information, shipping, splitting orders, combining orders, calculating shipping costs, using coupons, assembling order information, etc.

Among them, each transaction link has its corresponding business node valve, which is pre-configured to execute the processing logic corresponding to the transaction link, wherein each of the business node valves is provided with a trigger, which is used to determine whether to execute the business node valve, and the triggering condition of the trigger is set according to the business requirements of the transaction business.

S204: adding each business node valve to the initial transaction processing pipeline based on the execution order of each transaction link in the transaction process.

In the method provided by the embodiment of the present invention, the transaction process defines the execution order between various transaction links, and each business node valve is added to the initial transaction processing pipeline, so that each business node valve also processes data according to the execution order.

S205: The initial transaction processing pipeline to which each service node valve has been added is used as the transaction processing pipeline corresponding to the transaction instruction.

By applying the method provided in the embodiment of the present invention, the corresponding business node valves can be dynamically combined through configuration to support new transaction processes. At the same time, it supports dynamic addition of business nodes and assembling them into corresponding processes to meet business scalability requirements, deeply decouple business points, and realize a flexible and variable transaction process technical support system.

In the method provided by the embodiment of the present invention, based on the above implementation process, specifically, the transaction data is input into the transaction processing pipeline, so that each of the business node valves in the transaction processing pipeline processes the transaction data in turn to obtain the transaction result corresponding to the transaction instruction, as shown in FIG3, specifically including:

S301: Create a pipeline upstream document corresponding to the transaction processing pipeline and assign a processing identifier to the transaction data.

In the method provided by an embodiment of the present invention, the processing identifier can be used to trigger the transaction processing pipeline to process the transaction data, and can also be used to record the processing flow of the transaction data, so that when the business node valve data processing in the transaction data processing pipeline fails, data can be rolled back based on the processing identifier.

S302: Storing the transaction data carrying the processing identifier into the pipeline context, triggering each business node valve in the transaction processing pipeline to perform data processing operations in its corresponding execution order. The process of each business node valve performing the data processing operation includes: obtaining the input of the business node valve in the pipeline context, processing the input, obtaining the output corresponding to the business node valve, and storing the output of the business node valve in the pipeline context.

Among them, the transaction data carrying the processing identifier is the input of the first business node valve in the transaction processing pipeline, and the output of each business node valve in the transaction processing pipeline is used as the input of the next business node valve until the output of the last business node valve in the transaction processing pipeline is obtained.

In the method provided by the embodiment of the present invention, the pipeline context can be used to store the input and output of each service node valve, and the input and output of each service node valve corresponds to the processing identifier.

Specifically, each service node valve processes the input of the service node valve according to its corresponding processing logic, thereby obtaining the output of the service node valve.

Each service node valve may obtain the input of the service node valve through an input acquisition module.

S303: Determine the output of the last service node valve in the transaction processing pipeline as the transaction result corresponding to the transaction instruction.

By applying the method provided in the embodiment of the present invention, it is possible to organize each service node valve to complete the processing of transaction data based on the order dependency of each service node valve to obtain a transaction result.

The method provided in the embodiment of the present invention, based on the above implementation process, specifically, also includes:

When it is detected that any of the service node valves fails to process data, a data rollback operation is performed to reacquire the input of the service node valve so that the service node valve processes the input again.

In the method provided by an embodiment of the present invention, the business node valve may include an abnormal rollback module for detecting whether the business node valve fails to process its input. If the processing fails, data is rolled back to return to the step of obtaining input by the current business node valve, or to the step of obtaining input by the first N business node valves of the business node valve.

In the method provided by the embodiment of the present invention, based on the above implementation process, specifically, obtaining the transaction data in the transaction instruction includes:

Parsing the transaction instruction to obtain instruction information in the transaction instruction;

The transaction data is obtained in the instruction information.

In the method provided by the embodiment of the present invention, the instruction information may include transaction data and a transaction service identifier corresponding to the transaction data, etc. The transaction data may be a service parameter of the transaction service corresponding to the transaction service identifier.

In one embodiment provided by the present invention, in order to achieve the decoupling of the transaction code, the following is a detailed description:

First, the design point - transaction process node business model abstraction scheme - valve; the pipeline valve model can be used to abstract the various complex transaction links of the transaction process, based on the single responsibility abstraction of each transaction link:

(1) An interface of a business node valve corresponding to a transaction link may be set. The interface may be a Valve interface, which is used to define the setter method and getter method of the invoke method and the execution order of the valve.

(2) Determine the valve abstract class, where the valve abstract class is the AbstractValve class, which implements the Valve interface and defines abstract methods: isFilter is used to control whether the valve is executed, bizHandler is the valve core business logic processing function, rollbackAdd is used to append execution failure to the rollback chain, and successAdd is used to append execution success to the success chain.

(3) OrderBasicValve, OrderProdValve, etc. are specific implementation classes of valves, which are actual models of business nodes and each carries a single responsibility.

Second, design line - single transaction scenario process chain organization scheme - pipeline; pipeline can be used to organize a single process scenario of the transaction, set pipeline context, pipeline interface, pipeline implementation three parts:

(1) Setting a pipeline context, wherein the pipeline context may be AbstractPipelineContext, which may be used for context support of the entire life cycle of a transaction process pipeline and store execution requests and corresponding states of valves at each business node.

(2) Setting a pipeline interface, wherein the pipeline interface may be a Pipeline interface, which defines a service call chain and some methods for maintaining the chain, including adding a head, a tail, and intermediate service nodes.

(3) PipelineImpl is the implementation of the Pipeline interface and implements the specific logic.

Third, the design aspect - the full-scenario support solution for the transaction process - pipeline flow; the transaction process starts from the execution engine, enters the corresponding business pipeline, calls the corresponding business node logic according to the configured business node valve, and ends the entire transaction process life cycle. In the event of an abnormal situation, the corresponding rollback chain logic will be triggered, and the execution engine will roll back uniformly. The entire framework supports the dynamic organization of the entire business chain, providing low coupling and high scalability features.

Corresponding to the method described in FIG. 1 , an embodiment of the present invention further provides a transaction data processing device for implementing the method described in FIG. 1 . The transaction data processing device provided in the embodiment of the present invention can be applied to a computer terminal or various mobile devices. The schematic diagram of the structure is shown in FIG. 4 , and specifically includes:

The acquisition unit 401 is used to acquire the transaction data in the transaction instruction in response to the transaction instruction;

A creation unit 402 is used to apply a preset execution engine to create a transaction processing pipeline corresponding to the transaction instruction; the transaction processing pipeline includes a plurality of sequentially arranged business node valves;

The processing unit 403 is used to input the transaction data into the transaction processing pipeline, so that each of the business node valves in the transaction processing pipeline processes the transaction data in turn to obtain the transaction result corresponding to the transaction instruction; wherein the transaction data is the input of the first business node valve in the transaction processing pipeline, and the output of each business node valve in the transaction processing pipeline serves as the input of the next business node valve.

In an embodiment provided by an embodiment of the present invention, based on the above solution, specifically, the creating unit 402 includes:

A generating subunit, used for calling the execution engine to generate an initial transaction processing pipeline;

A first determining subunit is used to determine a transaction process corresponding to the transaction instruction; the transaction process includes multiple transaction links;

A first acquisition subunit is used to acquire the business node valve corresponding to each of the transaction links;

A first execution subunit, configured to add each of the business node valves to the initial transaction processing pipeline based on the execution order of each of the transaction links in the transaction process;

The second execution subunit is used to use the initial transaction processing pipeline to which each of the service node valves has been added as the transaction processing pipeline corresponding to the transaction instruction.

In an embodiment provided by the embodiment of the present invention, based on the above solution, specifically, the processing unit 403 includes:

A creation subunit is used to create a pipeline upstream document corresponding to the transaction processing pipeline and allocate a processing identifier for the transaction data;

A processing subunit is used to store the transaction data carrying the processing identifier into the pipeline context, trigger each of the business node valves in the transaction processing pipeline to perform a data processing operation in a corresponding execution order, wherein the data processing operation includes: obtaining an input of the business node valve in the pipeline context, processing the input, obtaining an output corresponding to the business node valve, and storing the output of the business node valve into the pipeline context;

The transaction data carrying the processing identifier is the input of the first service node valve in the transaction processing pipeline, and the output of each service node valve in the transaction processing pipeline is used as the input of the next service node valve until the output of the last service node valve in the transaction processing pipeline is obtained;

The second determining subunit determines the output of the last service node valve in the transaction processing pipeline as the transaction result corresponding to the transaction instruction.

In an embodiment provided by the embodiment of the present invention, based on the above solution, specifically, the processing unit 403 further includes a detection subunit;

The detection subunit is used to perform a data rollback operation when it is detected that data processing of any of the service node valves fails, so as to re-acquire the input of the service node valve so that the service node valve re-processes the input.

In an embodiment provided by the embodiment of the present invention, based on the above solution, specifically, the receiving unit 401 includes:

A parsing subunit, used to parse the transaction instruction to obtain transaction parameter information in the transaction instruction;

The second acquisition subunit is used to acquire the transaction data from the transaction parameter information.

The specific principles and execution processes of each unit and module in the transaction data processing device disclosed in the above embodiment of the present invention are the same as the transaction data processing method disclosed in the above embodiment of the present invention. Please refer to the corresponding parts of the transaction data processing method provided in the above embodiment of the present invention, and will not be repeated here.

An embodiment of the present invention further provides a storage medium, which includes stored instructions, wherein when the instructions are executed, the device where the storage medium is located is controlled to execute the above-mentioned transaction data processing method.

An embodiment of the present invention further provides an electronic device, the structure diagram of which is shown in FIG5 , which specifically includes a memory 501 and one or more instructions 502, wherein the one or more instructions 502 are stored in the memory 501 and are configured to be executed by one or more processors 503 to perform the following operations:

In response to a transaction instruction, acquiring transaction data in the transaction instruction;

Applying a preset execution engine to create a transaction processing pipeline corresponding to the transaction instruction; the transaction processing pipeline includes a plurality of business node valves arranged in sequence;

The transaction data is input into the transaction processing pipeline, so that each of the business node valves in the transaction processing pipeline processes the transaction data in turn to obtain the transaction result corresponding to the transaction instruction; wherein the transaction data is the input of the first business node valve in the transaction processing pipeline, and the output of each business node valve in the transaction processing pipeline serves as the input of the next business node valve.

It should be noted that each embodiment in this specification is described in a progressive manner, and each embodiment focuses on the differences from other embodiments, and the same or similar parts between the embodiments can be referred to each other. For the device embodiment, since it is basically similar to the method embodiment, the description is relatively simple, and the relevant parts can be referred to the partial description of the method embodiment.

Finally, it should be noted that, in this article, relational terms such as first and second, etc. are only used to distinguish one entity or operation from another entity or operation, and do not necessarily require or imply any such actual relationship or order between these entities or operations. Moreover, the terms "include", "comprise" or any other variants thereof are intended to cover non-exclusive inclusion, so that a process, method, article or device including a series of elements includes not only those elements, but also other elements not explicitly listed, or also includes elements inherent to such process, method, article or device. In the absence of further restrictions, the elements defined by the sentence "comprise a ..." do not exclude the presence of other identical elements in the process, method, article or device including the elements.

For the convenience of description, the above device is described as being divided into various units according to their functions. Of course, when implementing the present invention, the functions of each unit can be implemented in the same or multiple software and/or hardware.

It can be known from the description of the above implementation mode that those skilled in the art can clearly understand that the present invention can be implemented by means of software plus a necessary general hardware platform. Based on such an understanding, the technical solution of the present invention can be essentially or partly contributed to the prior art in the form of a software product, which can be stored in a storage medium such as ROM/RAM, a magnetic disk, an optical disk, etc., and includes several instructions for enabling a computer device (which can be a personal computer, a server, or a network device, etc.) to execute the methods described in the various embodiments of the present invention or some parts of the embodiments.

The transaction data processing method provided by the present invention is introduced in detail above. The principle and implementation mode of the present invention are explained in this article by using specific examples. The description of the above embodiments is only used to help understand the method of the present invention and its core idea. At the same time, for those skilled in the art, according to the idea of the present invention, there will be changes in the specific implementation mode and application scope. In summary, the content of this specification should not be understood as limiting the present invention.

Claims (10)

1. A transaction data processing method, comprising:

responding to a transaction instruction, and acquiring transaction data in the transaction instruction;

Creating a transaction processing pipeline corresponding to the transaction instruction by using a preset execution engine; the transaction processing pipeline comprises a plurality of service node valves which are sequentially ordered according to the execution sequence; the execution sequence of each service node valve is determined by a transaction flow corresponding to the transaction data, and the transaction flow comprises a plurality of transaction links; each service node valve is provided with data processing logic corresponding to the transaction link; the transaction link of each transaction flow comprises shopping carts, user address information acquisition, delivery, bill disassembly, bill combination, freight fee calculation, coupon use and order information assembly; each service node valve is provided with a trigger for determining whether to execute the service node valve; the trigger condition of the trigger is set according to the business requirement of the transaction business;

Inputting the transaction data into the transaction processing pipeline, so that each service node valve in the transaction processing pipeline processes the transaction data in sequence to obtain a transaction result corresponding to the transaction instruction; the transaction data is input of a first service node valve in the transaction processing pipeline, output of each service node valve in the transaction processing pipeline is stored in a buffer area corresponding to the transaction processing pipeline and used as input of a next service node valve, and the buffer area is used for supporting the full life cycle context of the transaction processing pipeline.

2. The method of claim 1, wherein the creating, by the execution engine preset by the application, a transaction processing pipeline corresponding to the transaction instruction includes:

Invoking the execution engine to generate an initial transaction processing pipeline;

Determining a transaction flow corresponding to the transaction instruction;

Acquiring service node valves corresponding to each transaction link;

Adding each service node valve to the initial transaction processing pipeline based on the execution sequence of each transaction link in the transaction flow;

and taking the initial transaction processing pipeline added with each service node valve as a transaction processing pipeline corresponding to the transaction instruction.

3. The method of claim 1, wherein the inputting the transaction data into the transaction processing pipeline, such that each service node valve in the transaction processing pipeline processes the transaction data in turn, obtains a transaction result corresponding to the transaction instruction, comprises:

creating a pipeline context corresponding to the transaction processing pipeline, and distributing a processing identifier for the transaction data;

Storing transaction data carrying a processing identifier to the pipeline context, triggering each service node valve in the transaction processing pipeline to execute data processing operation according to the corresponding execution sequence, and executing the data processing operation by each service node valve, wherein the process comprises the following steps: acquiring the input of the service node valve in the pipeline context, processing the input to obtain the output corresponding to the service node valve, and storing the output of the service node valve in the pipeline context;

The transaction data carrying the processing identifier is input of a first service node valve in the transaction processing pipeline, and output of each service node valve in the transaction processing pipeline is used as input of a next service node valve until output of a last service node valve in the transaction processing pipeline is obtained;

and determining the output of the last service node valve in the transaction processing pipeline as a transaction result corresponding to the transaction instruction.

4. A method according to claim 3, further comprising:

and when any service node valve is detected to fail in data processing, executing data rollback operation to reacquire the input of the service node valve, so that the service node valve can process the input again.

5. The method of claim 1, wherein the obtaining transaction data in the transaction instructions comprises:

analyzing the transaction instruction to obtain instruction information in the transaction instruction;

and acquiring the transaction data from the instruction information.

6. A transaction data processing device, comprising:

The acquisition unit is used for responding to the transaction instruction and acquiring transaction data in the transaction instruction;

The creation unit is used for creating a transaction processing pipeline corresponding to the transaction instruction by applying a preset execution engine; the transaction processing pipeline comprises a plurality of service node valves which are sequentially ordered according to the execution sequence; the execution sequence of each service node valve is determined by a transaction flow corresponding to the transaction data, and the transaction flow comprises a plurality of transaction links; each service node valve is provided with data processing logic corresponding to the transaction link; the transaction link of each transaction flow comprises shopping carts, user address information acquisition, delivery, bill disassembly, bill combination, freight fee calculation, coupon use and order information assembly; each service node valve is provided with a trigger for determining whether to execute the service node valve; the trigger condition of the trigger is set according to the business requirement of the transaction business;

The processing unit is used for inputting the transaction data into the transaction processing pipeline, so that each service node valve in the transaction processing pipeline sequentially processes the transaction data to obtain a transaction result corresponding to the transaction instruction; the transaction data is input of a first service node valve in the transaction processing pipeline, output of each service node valve in the transaction processing pipeline is stored in a buffer area corresponding to the transaction processing pipeline and used as input of a next service node valve, and the buffer area is used for supporting the full life cycle context of the transaction processing pipeline.

7. The apparatus of claim 6, wherein the creation unit comprises:

a generating subunit, configured to invoke the execution engine to generate an initial transaction processing pipeline;

The first determining subunit is used for determining a transaction flow corresponding to the transaction instruction;

the first acquisition subunit is used for acquiring the service node valve corresponding to each transaction link;

a first execution subunit, configured to add each service node valve to the initial transaction processing pipeline based on an execution order of each transaction link in the transaction flow;

And the second execution subunit is used for taking the initial transaction processing pipeline added with each service node valve as the transaction processing pipeline corresponding to the transaction instruction.

8. The apparatus of claim 6, wherein the processing unit comprises:

A creation subunit, configured to create a pipeline context corresponding to the transaction processing pipeline, and allocate a processing identifier to the transaction data;

the processing subunit is configured to store transaction data carrying a processing identifier into the pipeline context, and trigger each service node valve in the transaction processing pipeline to execute a data processing operation according to a corresponding execution sequence, where the data processing operation includes: acquiring the input of the service node valve in the pipeline context, processing the input to obtain the output corresponding to the service node valve, and storing the output of the service node valve in the pipeline context;

The transaction data carrying the processing identifier is input of a first service node valve in the transaction processing pipeline, and output of each service node valve in the transaction processing pipeline is used as input of a next service node valve until output of a last service node valve in the transaction processing pipeline is obtained;

And the second determining subunit determines the output of the last service node valve in the transaction processing pipeline as a transaction result corresponding to the transaction instruction.

9. The apparatus of claim 8, wherein the processing unit further comprises a detection subunit;

And the detection subunit is used for executing data rollback operation when detecting that any service node valve fails to process data so as to reacquire the input of the service node valve, so that the service node valve can process the input again.

10. The apparatus of claim 6, wherein the acquisition unit comprises:

the analysis subunit is used for analyzing the transaction instruction to obtain transaction parameter information in the transaction instruction;

and the second acquisition subunit is used for acquiring the transaction data in the transaction parameter information.