CN113222565A - Transaction system, transaction method, apparatus, computer device and storage medium - Google Patents
Transaction system, transaction method, apparatus, computer device and storage medium Download PDFInfo
- Publication number
- CN113222565A CN113222565A CN202110436613.XA CN202110436613A CN113222565A CN 113222565 A CN113222565 A CN 113222565A CN 202110436613 A CN202110436613 A CN 202110436613A CN 113222565 A CN113222565 A CN 113222565A
- Authority
- CN
- China
- Prior art keywords
- account
- transaction
- target
- attribute information
- user
- 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
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q20/00—Payment architectures, schemes or protocols
- G06Q20/02—Payment architectures, schemes or protocols involving a neutral party, e.g. certification authority, notary or trusted third party [TTP]
- G06Q20/027—Payment architectures, schemes or protocols involving a neutral party, e.g. certification authority, notary or trusted third party [TTP] involving a payment switch or gateway
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; 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/50—Allocation of resources, e.g. of the central processing unit [CPU]
- G06F9/5061—Partitioning or combining of resources
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q40/00—Finance; Insurance; Tax strategies; Processing of corporate or income taxes
- G06Q40/04—Trading; Exchange, e.g. stocks, commodities, derivatives or currency exchange
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q40/00—Finance; Insurance; Tax strategies; Processing of corporate or income taxes
- G06Q40/06—Asset management; Financial planning or analysis
Landscapes
- Engineering & Computer Science (AREA)
- Business, Economics & Management (AREA)
- Accounting & Taxation (AREA)
- Theoretical Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Finance (AREA)
- Physics & Mathematics (AREA)
- Development Economics (AREA)
- General Business, Economics & Management (AREA)
- Strategic Management (AREA)
- Software Systems (AREA)
- Economics (AREA)
- Marketing (AREA)
- Technology Law (AREA)
- Entrepreneurship & Innovation (AREA)
- Game Theory and Decision Science (AREA)
- Human Resources & Organizations (AREA)
- Operations Research (AREA)
- Computer Security & Cryptography (AREA)
- General Engineering & Computer Science (AREA)
- Financial Or Insurance-Related Operations Such As Payment And Settlement (AREA)
Abstract
The application relates to a transaction system, a transaction method, a transaction device, a computer device and a storage medium. The system comprises: the system comprises a plurality of transaction gateways and a plurality of transaction engines, wherein each transaction gateway and each transaction engine correspond to a unique partition identifier, the partition identifiers correspond to an account set, and the account set comprises at least one user account under the same account attribute information; the target trading gateways in the trading gateways are used for receiving service processing requests sent by user accounts in an account set corresponding to the target partition identifications, converting the service processing requests into corresponding service processing orders and sending the service processing orders to target trading engines corresponding to the target partition identifications; and the target transaction engine is used for processing the business processing order. By adopting the method, the time delay of service processing can be effectively reduced, and the expandability of the transaction system is improved.
Description
Technical Field
The present application relates to the field of internet technologies, and in particular, to a transaction system, a transaction method, a transaction apparatus, a computer device, and a storage medium.
Background
With the rapid development of the field of securities trading, the number of accounts (e.g., trading accounts, funding accounts, security accounts, etc.) present in trading systems has also rapidly increased.
Conventionally, independent trading systems can be respectively deployed at stock exchange locations (such as shanghai and shenzhen) for processing requests (such as entrusted procurement requests, volume inquiry requests and the like) sent by accounts in terminals which are physically close to each other. Alternatively, a unified transaction system may be deployed for uniformly processing requests sent by all accounts. With the rapid increase in the number of accounts in a trading system, the deployed trading system needs to be expanded to be able to handle the increased requests. However, the transaction system in the conventional technology has a problem of poor expansibility.
Disclosure of Invention
In view of the above, there is a need to provide a transaction system, a transaction method, an apparatus, a computer device and a storage medium, which can provide system scalability and help reduce transaction latency.
In a first aspect, an embodiment of the present application provides a transaction system, including:
the system comprises a plurality of transaction gateways and a plurality of transaction engines, wherein each transaction gateway and each transaction engine correspond to a unique partition identifier, the partition identifiers correspond to an account set, and the account set comprises at least one user account under the same account attribute information;
the target trading gateways in the trading gateways are used for receiving service processing requests sent by user accounts in an account set corresponding to target partition identifications, converting the service processing requests into corresponding service processing orders and sending the service processing orders to target trading engines corresponding to the target partition identifications;
and the target transaction engine is used for processing the business processing order.
In one embodiment, the transaction system further includes:
the account partitioning module is used for acquiring a plurality of user accounts and account attribute information corresponding to each user account, and grouping each user account into an account set corresponding to the account attribute information of each user account according to the corresponding relation between preset account attribute information and the account set.
In one embodiment, the account attribute information includes first account attribute information and second account attribute information, and the account partitioning module is configured to:
according to the corresponding relation between the preset first attribute information and an account set, searching and obtaining the account set corresponding to the first attribute information of each user account, wherein the account set corresponding to the first attribute information comprises a plurality of account subsets;
according to the preset corresponding relation between the second attribute information and the account set, the account subset corresponding to the second attribute information of each user account is searched from the plurality of account subsets, and each user account is grouped into the account subset corresponding to the second attribute information of each user account.
In one embodiment, the user account is a funding account; the account attribute information comprises any one of an order amount, a business department to which the fund account belongs and a geographical position of a terminal where a client of the user account is located;
or, the user account is a security account, and the account attribute information includes any one of an account opening place of the security account and a geographic location of a terminal where the client is located.
In one embodiment, the trading system further comprises a plurality of offer services, each offer service corresponding to a set of trading units;
the target transaction engine is used for determining a target transaction unit to which the business processing order belongs, and after the business processing order is processed, sending the business processing order to a target report service corresponding to a group of transaction units to which the target transaction unit belongs;
the target report service is used for processing the business processing order, receiving a reply message returned by an external system, and sending the reply message to the target transaction engine;
the target transaction engine is further used for sending the reply message to the target transaction gateway;
and the target transaction gateway is also used for sending the reply message to the client.
In a second aspect, the embodiments of the present application provide a transaction method, which is applied to the transaction system of any one of the first aspect; the method comprises the following steps:
receiving a service processing request sent by a user account, wherein the service processing request carries a target partition identifier corresponding to a target account set to which the user account belongs, and the account set comprises at least one user account under the same account attribute information;
converting the service processing request into a corresponding service processing order;
and sending the business processing order to a target trading engine corresponding to the target partition identification, wherein the target trading engine is used for processing the business processing order.
In one embodiment, the generation manner of the account set includes:
acquiring a plurality of user accounts and account attribute information corresponding to each user account;
and grouping each user account into an account set corresponding to the account attribute information of each user account according to the corresponding relation between the preset account attribute information and the account set.
In a third aspect, an embodiment of the present application provides a transaction apparatus, including:
the system comprises a receiving module, a processing module and a processing module, wherein the receiving module is used for receiving a service processing request sent by a user account, the service processing request carries a target partition identifier corresponding to a target account set to which the user account belongs, and the account set comprises at least one user account under the same account attribute information;
the conversion module is used for converting the service processing request into a corresponding service processing order;
and the order processing module is used for sending the business processing order to a target trading engine corresponding to the target partition identification, and the target trading engine is used for processing the business processing order.
In a fourth aspect, an embodiment of the present application provides a computer device, including a memory and a processor, where the memory stores a computer program, and the processor implements the transaction method according to any one of the second aspect when executing the computer program.
In a fifth aspect, the present application provides a computer-readable storage medium, on which a computer program is stored, where the computer program is executed by a processor to implement the transaction method according to any one of the second aspect.
According to the transaction system, the transaction method, the transaction device, the computer equipment and the storage medium, a plurality of account sets are obtained by grouping the user accounts, each account set is served by the independent transaction gateway and the transaction engine, the capacity, the throughput and the like of the transaction system are improved, the transaction system has the capability of parallel processing of service processing requests, and therefore the time delay of service processing is effectively reduced; the corresponding transaction gateway and the transaction engine are deployed for each account set, so that the expandability of the transaction system can be improved, and when the number of user accounts is increased, the effect of horizontal expansion can be conveniently realized by adding a new account set, a new component and the like.
Drawings
In order to more clearly illustrate the embodiments of the present specification or the technical solutions in the prior art, the drawings needed to be used in the description of the embodiments or the prior art will be briefly introduced below, it is obvious that the drawings in the following description are only some embodiments described in the specification, and other drawings can be obtained by those skilled in the art without inventive labor.
FIG. 1 is a block diagram of the architecture of a transaction system in one embodiment;
FIG. 2 is a schematic diagram of processing a business process request by a transaction system in one embodiment;
FIG. 3 is a diagram that illustrates grouping of user accounts in one embodiment;
FIG. 4 is a diagram that illustrates grouping of user accounts in one embodiment;
FIG. 5 is a diagram that illustrates grouping of user accounts in one embodiment;
FIG. 6 is a schematic diagram of processing a business process request by a transaction system in one embodiment;
FIG. 7 is a schematic diagram of processing a business process request by a transaction system in one embodiment;
FIG. 8 is a diagram of an application environment of a transaction method in one embodiment;
FIG. 9 is a schematic flow chart diagram of a transaction method in another embodiment;
FIG. 10 is a block diagram of the structure of a transaction device in one embodiment;
FIG. 11 is a diagram illustrating an internal structure of a computer device in one embodiment.
Detailed Description
In order to make the objects, technical solutions and advantages of the present application more apparent, the present application is described in further detail below with reference to the accompanying drawings and embodiments. It should be understood that the specific embodiments described herein are merely illustrative of the present application and are not intended to limit the present application.
The following explains some of the terms referred to in this application:
the transaction gateway refers to a software and hardware facility which is in communication connection with the client and performs data transmission in real time.
The transaction engine is used for performing interface inspection, front-end inspection, business processing and the like on business processing orders, generating internal entrusts, sending the internal entrusts to the report service, processing transaction returns such as entrustment confirmation, transaction returns and the like of the report service, and maintaining fund taken positions, share taken positions and the like according to transaction prices and transaction amounts. The category of the transaction engine may include one, for example, a cash transaction engine and an option transaction engine according to the service platform.
User accounts (including but not limited to registered accounts, funding accounts, securities accounts, etc. of a trading system) are all information that is authorized by the user or sufficiently authorized by various parties.
The fund account, namely the securities trade settlement fund account, refers to a special account used by an investor for clearing securities trade fund.
The securities account is an account book which is set up by a securities registration and settlement institution for investors and is used for accurately recording the types, names and quantities of securities held by the investors, corresponding rights and interests and change conditions, and is an important certificate for identifying the identity of a shareholder.
The transaction unit is a basic unit for the transaction system to perform message interaction with an external system (which may be a transaction system of a trading exchange). The transaction system may send the commitment to the exchange via a certain transaction unit.
The report service is responsible for the interconnection of the gateways of the external systems, can realize interface protocols accessed with different external systems, and is responsible for establishing connection with the gateways of all exchanges; converting the internal order of the transaction engine into a standard interface format corresponding to an external system, and sending the standard interface format to the external system; and converting reporting messages such as entrustment confirmation, successful transaction reporting and the like reported by an external system into an internal reporting format, and then forwarding the internal reporting format to a transaction engine and the like.
Fig. 1 shows a block diagram of a transaction system provided in an exemplary embodiment of the present application. The transaction system may be deployed in a server. The server can be implemented by an independent server or a server cluster composed of a plurality of servers, for example, a server cluster respectively deployed in a Shanghai node and a Shenzhen node is adopted. As shown in fig. 1, the transaction system includes a plurality of transaction gateways and a plurality of transaction engines. The transaction gateway and the transaction engine can be connected through the internet, a local area network and the like. Each transaction gateway and each transaction engine corresponds to a unique partition identification, i.e. the transaction gateway and the transaction engine generate a link relationship by the unique partition identification. The partition identification is in one-to-one correspondence with an account set, and the account set comprises at least one user account under the same account attribute information. The account attribute information may be used to indicate relevant characteristics of the user account, and may be, for example, location information, a terminal device model, an order amount, and the like.
For example, there is a first partition identification and a second partition identification. The first partition identification corresponds to the first account set, the first transaction gateway and the first transaction engine; the second partition identification corresponds to the second account set, the second transaction gateway and the second transaction engine. The first transaction gateway and the first transaction engine then form an independent link for processing the transaction processing requests sent by the user accounts in the first account set. Similarly, the second transaction gateway and the second transaction engine form an independent link for processing the service processing request sent by the user account in the second account set.
FIG. 2 illustrates a schematic diagram of processing a business process request by a transaction system. As shown in fig. 2, any transaction gateway (hereinafter referred to as a target transaction gateway) in the transaction gateways receives a service processing request sent by a user account in an account set under a corresponding target partition identifier. And converting the service processing request into a corresponding service processing order according to the internal interface protocol. The target trading gateway searches a target trading engine corresponding to the target partition identification according to a preset routing rule (including the corresponding relation between the partition identification and the trading engine), and sends the business processing order to the target trading engine in the trading engines. The business processing order may carry a target partition identifier corresponding to the target trading gateway.
And after receiving the business processing order, the target transaction engine performs interface inspection, front-end inspection, business processing and other processing on the business processing order reported by the target transaction gateway to obtain a corresponding business processing result. And the target transaction engine acquires a target partition identifier carried in the service processing order and sends a service processing result to a target transaction gateway corresponding to the target partition identifier, so that the target transaction gateway sends the service processing result to a client of the user account.
Of course, the number of the transaction gateways corresponding to the same partition identifier and/or the number of the transaction engines may be one or more, and the user may expand the transaction gateways corresponding to the same partition identifier and/or the transaction engines according to the current transaction amount.
In the transaction system, a plurality of account sets are obtained by grouping user accounts, and an independent transaction partition (comprising a transaction gateway and a transaction engine) is deployed for each account set, so that service processing requests of the same user account can be processed and completed in the same transaction partition, the capacity, throughput and the like of the transaction system are improved, the transaction system has parallel processing capacity for the service processing requests, and the time delay of service processing is effectively reduced; the corresponding transaction gateway and the transaction engine are deployed for each account set, so that the expandability of the transaction system can be improved, and when the number of user accounts is increased, the effect of horizontal expansion can be conveniently realized by adding a new account set, a new component and the like.
In one embodiment, the transaction system further comprises: and the account partitioning module is used for acquiring a plurality of user accounts and account attribute information corresponding to each user account, and grouping each user account into an account set corresponding to the account attribute information of each user account according to the corresponding relation between the preset account attribute information and the account set.
The user accounts may refer to some user accounts already existing in the transaction system, for example, new user accounts currently registered in the transaction system; but may also be all user accounts in the transaction system. Of course, several user accounts do not exclude a single number.
Specifically, the user may configure the account grouping rule (including the correspondence between the account attribute information and the account set) through a front-end presentation page of the transaction system. After the configuration is completed, an account partitioning module in the trading system acquires a plurality of user accounts to be grouped. Account attribute information for each user account is obtained. And according to the corresponding relation between the preset account attribute information and the account sets, grouping each user account into the account set corresponding to the account attribute information of each user account to obtain a plurality of account sets.
In an exemplary illustration, the account attribute information includes an order amount, and the account grouping rule is configured to group user accounts with the order amount exceeding a preset value in one month into a first account set; and grouping the user accounts of which the order quantity does not exceed the preset value in one month into a second account set'. Referring to FIG. 3, the account partitioning module obtains the order amount for each user account within a month. The order amount for each user account is compared to a preset value. And if the order quantity is larger than the preset value, grouping the user accounts into a first account set. And if the order quantity is not larger than the preset value, grouping the user accounts into a second account set.
Another exemplary illustration is that the trading system is partitioned into nodes in advance, for example, into a shanghai node and a Shenzhen node. The account attribute information includes a node to which the account belongs. The account grouping rule is configured to be that user accounts of Shanghai nodes are grouped into a first account set; and grouping the user accounts of the Shenzhen node into a second account set ". Referring to fig. 4, the account partitioning module obtains the node to which each user account belongs. And if the node is the Shanghai node, grouping the user accounts into a first account set. And if the node belongs to the Shenzhen node, grouping the user accounts into a second account set.
In this embodiment, the account attribute information may reflect the requirements of one type of user accounts for system resources, and the user accounts are grouped according to the account attribute information to obtain a plurality of account sets, and appropriate components are deployed with the account sets as dimensions, so that the utilization rate of the system resources may be improved, and the delay of transaction service processing may be reduced.
In one embodiment, the account partitioning module in the trading system also supports multi-level grouping of accounts. The following takes two-level grouping as an example. The account attribute information includes first account attribute information and second account attribute information, and a level of the first account attribute information is higher than a level of the second account attribute information. An account partitioning module to: according to the corresponding relation between the preset first attribute information and the account set, searching and obtaining the account set corresponding to the first attribute information of each user account, wherein the account set corresponding to the first attribute information comprises a plurality of account subsets; according to the preset corresponding relation between the second attribute information and the account set, the account subset corresponding to the second attribute information of each user account is searched from the account subsets, and each user account is grouped into the account subset corresponding to the second attribute information of each user account.
For example, the trading system is divided into nodes in advance, for example, into a shanghai node and a Shenzhen node. The account attribute information includes an account belonging node and an account belonging business (e.g., a stock account belonging business). The account grouping rule is formulated into that user accounts of Shanghai nodes are grouped into a first account set, user accounts of a first business department in the Shanghai nodes are grouped into a first account subset, and user accounts of a second business department in the Shanghai nodes are grouped into a second account subset; grouping user accounts of the Shenzhen node into a second account set, grouping user accounts of a first business department in the Shenzhen node into a third account subset, and grouping user accounts of a second business department in the Shenzhen node into a fourth account subset ". Referring to fig. 5, the account partitioning module acquires the affiliated node and the affiliated business department of each user account. If the node is a Shanghai node and the business department is a first business department, grouping the user accounts into a first account subset in a first account set; and if the node is the Shanghai node and the business department is the second business department, grouping the user account into a second account subset in the first account set. Similarly, if the affiliated node is the Shenzhen node and the affiliated business department is the first business department, the user account is grouped into a third account subset in the second account set; and if the affiliated node is the Shenzhen node and the affiliated business department is the second business department, grouping the user account into a third account subset in the second account set.
Further, after obtaining the multi-level account set, a corresponding transaction gateway and transaction engine may be deployed for each lowest level account set (e.g., the subset of accounts in the two-level grouping described above).
In this embodiment, the account attribute information may reflect the requirements of one type of user accounts for system resources, and the user accounts may be grouped in multiple levels according to the account attribute information, so that the accuracy of account grouping may be improved, and a suitable component may be conveniently deployed for each account set, thereby improving the utilization rate of system resources and reducing the time delay of transaction service processing.
In one embodiment, the user account is a funding account. The fund accounts can be used as dimensions, the fund accounts under each registered account are grouped according to the grouping mode of the accounts, and the fund accounts are grouped into corresponding account sets. Generally, only one fund account corresponds to one registered account, so that the fund accounts are grouped by taking the fund accounts as dimensions, and each registered account corresponds to a unique partition identifier.
In another embodiment, the user account is a security account. The security accounts can be used as dimensions, the security accounts under each registered account are grouped according to the grouping mode of the accounts, and the security accounts are grouped into corresponding account sets. Generally, there may be one or more security accounts corresponding to a registered account, for example, at least one of a fund account, a stock account, a financing account, etc. may be included under a registered account. And when the number of the security accounts is one, grouping the security accounts by taking the security accounts as dimensions, wherein each registered account corresponds to a unique partition identifier. And when the number of the security accounts is multiple, the security accounts are grouped by taking the security accounts as dimensions, and each registered account corresponds to a plurality of partition identifications.
Further, if the stock account is grouped according to the dimension of the stock account, the trading system can be divided into nodes in advance, and corresponding trading partitions are deployed at the positions of the nodes, so that the close quotation can be realized, and the trading time delay is reduced. For example, the nodes are divided into Shanghai nodes and Shenzhen nodes, the transaction partition can be deployed in Shanghai, and a user processes a service processing request sent by a user account in an account set corresponding to the Shanghai nodes; and (4) in the Shenzhen deployment transaction partition, processing the service processing request sent by the user account in the account set corresponding to the Shenzhen node by the user.
In the case where the same registered account corresponds to a plurality of security accounts, there may be a case where a certain security account has a small amount of money and money needs to be transferred from another security account. The following description will be made of a process of transferring funds between two security accounts (a first security account and a second security account) corresponding to the same registered account. Wherein, the account set of the first security account corresponds to a first partition mark (Shanghai node) and marks an account for fund; and the account set to which the second security account belongs corresponds to a second partition identifier (Shenzhen node) and is used for transferring funds into the account. Referring to fig. 6, a specific process may be:
(1) and the client sends a fund transfer request to the first transaction gateway corresponding to the first partition identifier. The fund transfer request carries a second security account and a second partition identifier.
(2) After receiving the fund transfer request, the first transaction gateway converts the fund transfer request into a corresponding fund transfer order. And sending the fund transfer order, the first partition identifier and the second partition identifier to a first transaction engine corresponding to the first partition identifier according to the corresponding relation between the partition identifiers and the transaction engines.
(3) And after receiving the fund transfer order, the first transaction engine performs processing such as order verification, interface verification and the like, and performs fund transfer freezing after the processing is completed. And the first trading engine forwards the fund transfer order, the first partition identifier and the second partition identifier to a second trading engine corresponding to the second partition identifier according to the corresponding relation between the partition identifiers and the trading engines.
(4) And after receiving the fund transfer order, the second transaction engine performs processing such as order verification and interface verification, and performs fund transfer freezing after the processing is completed. And returning a successful transfer message to the first transaction engine according to the corresponding relation between the partition identification and the transaction engine.
(5) And after receiving the transfer success message, the first transaction engine finishes the fund transfer.
(6) The first transaction engine sends a fund transfer result to the client.
In addition, referring to fig. 6, a data persistence component may be deployed, and is responsible for persisting data such as pipelining, delegation, and return, and storing order status messages such as pipelining, delegation, and return data generated by the transaction engine.
In the embodiment, the account grouping from multiple dimensions is allowed, so that the diversified requirements of the transaction system can be met, and the use flexibility of the transaction system is improved.
In one embodiment, the trading system further comprises a plurality of offer services, each offer service corresponding to a set of trading units.
Wherein, a plurality of transaction units may be configured inside the transaction system. The transaction engine and the transaction units may be in a one-to-one correspondence relationship, or one transaction engine may correspond to a plurality of transaction units. The partitioning of the listing service may be performed in accordance with a combination of transaction units. That is, one reporting service partition is responsible for the reporting of orders for a group of trading units, and one reporting service may serve multiple trading engines.
Specifically, after the target transaction engine finishes processing the business processing order, the target transaction engine determines a target transaction unit from the corresponding transaction units according to a preset mode. For example, a target trading unit is selected from corresponding trading units in a polling, random or other mode, and then a business processing order is sent to a target report service corresponding to a group of trading units to which the target trading unit belongs. And after receiving the business processing order, the target report service converts the business processing order into a standard interface format of the external system and sends the converted business processing order to the external system. And the target report service receives a reply message returned by the external system, sends the reply message to the target transaction engine, sends the reply message to the target transaction gateway through the target transaction engine, and sends the reply message to the client corresponding to the user account through the target transaction gateway.
Further, after a plurality of business processing orders of the same transaction unit are received by the same report service, the business processing orders can be sequentially processed according to the receiving time sequence.
In this embodiment, each component in the transaction system is partitioned, and a data transmission relationship between the components is established, so that a user account and each component in the transaction system have a corresponding relationship, for example: for a certain fund account, a transaction gateway, a transaction engine, a transaction unit and a report service corresponding to the fund account exist, so that the efficient and orderly processing of business processing orders can be ensured, and the efficiency of concurrent processing is improved.
The transaction method provided by the application can be applied to the application environment shown in fig. 8. Wherein the terminal 810 communicates with the server 820 through a network. A transaction client is deployed in the terminal 810. The server 820 is provided with a transaction system according to any one of the above embodiments, and the transaction system can process the service processing request sent by the terminal 810. Specifically, the server 820 receives a service processing request sent by the terminal 810 through a target transaction gateway corresponding to a transaction client in the terminal 810, where the service processing request carries a target partition identifier corresponding to a target account set to which a user account belongs, and the account set includes at least one user account under the same account attribute information. The server 820 converts the business process request into a corresponding business process order through the target transaction gateway. And sending the service processing order to a target trading engine corresponding to the target partition identification through the target trading gateway according to the target partition identification. And processing the business processing order through the target transaction engine.
The terminal 810 may be, but is not limited to, various personal computers, notebook computers, smart phones, tablet computers, and portable wearable devices, and the server 820 may be implemented by an independent server or a server cluster formed by a plurality of servers.
In one embodiment, as shown in fig. 9, a transaction method is provided, which is described by taking the method as an example applied to the transaction system in fig. 1, and comprises the following steps:
step S910, a service processing request sent by a user account is received, the service processing request carries a target partition identifier corresponding to a target account set to which the user account belongs, and the account set includes at least one user account under the same account attribute information.
Step S920, converting the service processing request into a corresponding service processing order.
Step S930, sending the business processing order to a target trading engine corresponding to the target partition identifier, where the target trading engine is configured to process the business processing order.
The generation manner of the account set and the description of the correspondence relationship among the account set, the transaction gateway, and the transaction engine may refer to the embodiments, which are not specifically set forth herein. Specifically, the client acquires a target partition identifier corresponding to a target account set to which the user account belongs, and sends the service processing request to a target transaction gateway corresponding to the target partition identifier. And after receiving the service processing request, the target transaction gateway converts the service processing request into a corresponding service processing order according to the internal interface protocol. And the target trading gateway searches a target trading engine corresponding to the target partition identification according to a preset routing rule (including the corresponding relation between the partition identification and the trading engine), and sends the business processing order to the target trading engine in the trading engines for processing. And after receiving the business processing order, the target transaction engine performs interface inspection, front-end inspection, business processing and other processing on the business processing order reported by the target transaction gateway to obtain a corresponding business processing result. And the target transaction engine acquires a target partition identifier carried in the service processing order and sends a service processing result to a target transaction gateway corresponding to the target partition identifier, so that the target transaction gateway sends the service processing result to a client of the user account.
In the transaction method, a plurality of account sets are obtained by grouping the user accounts, and each account set is served by an independent transaction gateway and a transaction engine, so that the transaction system has the capability of processing service processing requests in parallel, and the time delay of service processing is effectively reduced; the corresponding transaction gateway and the transaction engine are deployed for each account set, so that the expandability of the transaction system can be improved, and when the number of user accounts is increased, the effect of horizontal expansion can be conveniently realized by adding a new account set, a new component and the like.
It should be understood that, although the steps in the above-described flowcharts are shown in order as indicated by the arrows, the steps are not necessarily performed in order as indicated by the arrows. The steps are not performed in the exact order shown and described, and may be performed in other orders, unless explicitly stated otherwise. Moreover, at least a part of the steps in the above-mentioned flowcharts may include a plurality of steps or a plurality of stages, which are not necessarily performed at the same time, but may be performed at different times, and the order of performing the steps or the stages is not necessarily performed in sequence, but may be performed alternately or alternately with other steps or at least a part of the steps or the stages in other steps.
Based on the description of the embodiment of the transaction method, the disclosure also provides a transaction device. The apparatus may include systems (including distributed systems), software (applications), modules, components, servers, clients, etc. that use the methods described in embodiments of the present specification in conjunction with any necessary apparatus to implement the hardware. Based on the same innovative concept, the embodiments of the present disclosure provide an apparatus in one or more embodiments as described in the following embodiments. Since the implementation scheme of the apparatus for solving the problem is similar to that of the method, the specific implementation of the apparatus in the embodiment of the present specification may refer to the implementation of the foregoing method, and repeated details are not repeated. As used hereinafter, the term "unit" or "module" may be a combination of software and/or hardware that implements a predetermined function. Although the means described in the embodiments below are preferably implemented in software, an implementation in hardware, or a combination of software and hardware is also possible and contemplated.
In one embodiment, as shown in fig. 10, there is provided a transaction device 1000 comprising: a receiving module 1002, a converting module 1004, an order processing module 1006, wherein:
the receiving module 1002 is configured to receive a service processing request sent by a user account, where the service processing request carries a target partition identifier corresponding to a target account set to which the user account belongs, and the account set includes at least one user account under the same account attribute information; a conversion module 1004, configured to convert the service processing request into a corresponding service processing order; the order processing module 1006 is configured to send the business processing order to a target trading engine corresponding to the target partition identifier, where the target trading engine is configured to process the business processing order.
In one embodiment, the apparatus 1000 further comprises: the acquisition module is configured to acquire a plurality of user accounts and account attribute information corresponding to each user account; and the grouping module is configured to group each user account into an account set corresponding to the account attribute information of each user account according to the corresponding relation between the preset account attribute information and the account set.
For the specific definition of the transaction device, reference may be made to the above definition of the transaction method, which is not described herein again. The modules in the above-mentioned transaction apparatus can be implemented wholly or partially by software, hardware and their combination. The modules can be embedded in a hardware form or independent from a processor in the computer device, and can also be stored in a memory in the computer device in a software form, so that the processor can call and execute operations corresponding to the modules.
In one embodiment, a computer device is provided, which may be a server, and its internal structure diagram may be as shown in fig. 11. The computer device includes a processor, a memory, and a network interface connected by a system bus. Wherein the processor of the computer device is configured to provide computing and control capabilities. The memory of the computer device comprises a nonvolatile storage medium and an internal memory. The non-volatile storage medium stores an operating system, a computer program, and a database. The internal memory provides an environment for the operation of an operating system and computer programs in the non-volatile storage medium. The database of the computer device is used to store transaction data. The network interface of the computer device is used for communicating with an external terminal through a network connection. The computer program is executed by a processor to implement a transaction method.
Those skilled in the art will appreciate that the architecture shown in fig. 11 is merely a block diagram of some of the structures associated with the disclosed aspects and is not intended to limit the computing devices to which the disclosed aspects apply, as particular computing devices may include more or less components than those shown, or may combine certain components, or have a different arrangement of components.
In one embodiment, a computer device is provided, comprising a memory and a processor, the memory having a computer program stored therein, the processor implementing the following steps when executing the computer program:
receiving a service processing request sent by a user account, wherein the service processing request carries a target partition identifier corresponding to a target account set to which the user account belongs, and the account set comprises at least one user account under the same account attribute information; converting the service processing request into a corresponding service processing order; and sending the business processing order to a target trading engine corresponding to the target partition identification, wherein the target trading engine is used for processing the business processing order.
In one embodiment, the processor, when executing the computer program, further performs the steps of:
acquiring a plurality of user accounts and account attribute information corresponding to each user account; and grouping each user account into an account set corresponding to the account attribute information of each user account according to the corresponding relation between the preset account attribute information and the account set.
In one embodiment, a computer-readable storage medium is provided, having a computer program stored thereon, which when executed by a processor, performs the steps of:
receiving a service processing request sent by a user account, wherein the service processing request carries a target partition identifier corresponding to a target account set to which the user account belongs, and the account set comprises at least one user account under the same account attribute information; converting the service processing request into a corresponding service processing order; and sending the business processing order to a target trading engine corresponding to the target partition identification, wherein the target trading engine is used for processing the business processing order.
In one embodiment, the computer program when executed by the processor further performs the steps of:
acquiring a plurality of user accounts and account attribute information corresponding to each user account; and grouping each user account into an account set corresponding to the account attribute information of each user account according to the corresponding relation between the preset account attribute information and the account set.
It will be understood by those skilled in the art that all or part of the processes of the methods of the embodiments described above can be implemented by hardware instructions of a computer program, which can be stored in a non-volatile computer-readable storage medium, and when executed, can include the processes of the embodiments of the methods described above. Any reference to memory, storage, database or other medium used in the embodiments provided herein can include at least one of non-volatile and volatile memory. Non-volatile Memory may include Read-Only Memory (ROM), magnetic tape, floppy disk, flash Memory, optical storage, or the like. Volatile Memory can include Random Access Memory (RAM) or external cache Memory. By way of illustration and not limitation, RAM can take many forms, such as Static Random Access Memory (SRAM) or Dynamic Random Access Memory (DRAM), among others.
The technical features of the above embodiments can be arbitrarily combined, and for the sake of brevity, all possible combinations of the technical features in the above embodiments are not described, but should be considered as the scope of the present specification as long as there is no contradiction between the combinations of the technical features.
The above-mentioned embodiments only express several embodiments of the present application, and the description thereof is more specific and detailed, but not construed as limiting the scope of the invention. It should be noted that, for a person skilled in the art, several variations and modifications can be made without departing from the concept of the present application, which falls within the scope of protection of the present application. Therefore, the protection scope of the present patent shall be subject to the appended claims.
Claims (10)
1. A transaction system is characterized by comprising a plurality of transaction gateways and a plurality of transaction engines, wherein each transaction gateway and each transaction engine correspond to a unique partition identifier, the partition identifiers correspond to an account set, and the account set comprises at least one user account under the same account attribute information;
the target trading gateways in the trading gateways are used for receiving service processing requests sent by user accounts in an account set corresponding to target partition identifications, converting the service processing requests into corresponding service processing orders and sending the service processing orders to target trading engines corresponding to the target partition identifications;
and the target transaction engine is used for processing the business processing order.
2. The system of claim 1, wherein the transaction system further comprises:
the account partitioning module is used for acquiring a plurality of user accounts and account attribute information corresponding to each user account, and grouping each user account into an account set corresponding to the account attribute information of each user account according to the corresponding relation between preset account attribute information and the account set.
3. The system of claim 2, wherein the account attribute information comprises first account attribute information and second account attribute information, and wherein the account partitioning module is configured to:
according to the corresponding relation between the preset first attribute information and an account set, searching and obtaining the account set corresponding to the first attribute information of each user account, wherein the account set corresponding to the first attribute information comprises a plurality of account subsets;
according to the preset corresponding relation between the second attribute information and the account set, the account subset corresponding to the second attribute information of each user account is searched from the plurality of account subsets, and each user account is grouped into the account subset corresponding to the second attribute information of each user account.
4. The system of claim 2, wherein the user account is a funding account; the account attribute information comprises any one of an order amount, a business department to which the fund account belongs and a geographical position of a terminal where a client of the user account is located;
or, the user account is a security account, and the account attribute information includes any one of an account opening place of the security account and a geographic location of a terminal where the client is located.
5. The system of claim 1, wherein the trading system further comprises a plurality of offer services, each offer service corresponding to a set of trading units;
the target transaction engine is used for determining a target transaction unit to which the business processing order belongs, and after the business processing order is processed, sending the business processing order to a target report service corresponding to a group of transaction units to which the target transaction unit belongs;
the target report service is used for processing the business processing order, receiving a reply message returned by an external system, and sending the reply message to the target transaction engine;
the target transaction engine is further used for sending the reply message to the target transaction gateway;
the target transaction gateway is further configured to send the reply message to the user account.
6. A transaction method, wherein the method is applied to the transaction system according to any one of claims 1 to 5; the method comprises the following steps:
receiving a service processing request sent by a user account, wherein the service processing request carries a target partition identifier corresponding to a target account set to which the user account belongs, and the account set comprises at least one user account under the same account attribute information;
converting the service processing request into a corresponding service processing order;
and sending the business processing order to a target trading engine corresponding to the target partition identification, wherein the target trading engine is used for processing the business processing order.
7. The method of claim 6, wherein the generating of the account set comprises:
acquiring a plurality of user accounts and account attribute information corresponding to each user account;
and grouping each user account into an account set corresponding to the account attribute information of each user account according to the corresponding relation between the preset account attribute information and the account set.
8. A transaction apparatus, the apparatus comprising:
the system comprises a receiving module, a processing module and a processing module, wherein the receiving module is used for receiving a service processing request sent by a user account, the service processing request carries a target partition identifier corresponding to a target account set to which the user account belongs, and the account set comprises at least one user account under the same account attribute information;
the conversion module is used for converting the service processing request into a corresponding service processing order;
and the order processing module is used for sending the business processing order to a target trading engine corresponding to the target partition identification, and the target trading engine is used for processing the business processing order.
9. A computer device comprising a memory and a processor, the memory storing a computer program, wherein the processor, when executing the computer program, implements the transaction method of claim 6.
10. A computer-readable storage medium, on which a computer program is stored, which, when being executed by a processor, carries out the transaction method according to claim 6.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110436613.XA CN113222565A (en) | 2021-04-22 | 2021-04-22 | Transaction system, transaction method, apparatus, computer device and storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110436613.XA CN113222565A (en) | 2021-04-22 | 2021-04-22 | Transaction system, transaction method, apparatus, computer device and storage medium |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN113222565A true CN113222565A (en) | 2021-08-06 |
Family
ID=77088592
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202110436613.XA Pending CN113222565A (en) | 2021-04-22 | 2021-04-22 | Transaction system, transaction method, apparatus, computer device and storage medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN113222565A (en) |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN114663079A (en) * | 2022-03-23 | 2022-06-24 | 阿里云计算有限公司 | Settlement method, terminal, storage medium and program product |
Citations (9)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20070025351A1 (en) * | 2005-06-27 | 2007-02-01 | Merrill Lynch & Co., Inc., A Delaware Corporation | System and method for low latency market data |
| CN105447734A (en) * | 2014-06-06 | 2016-03-30 | 阿里巴巴集团控股有限公司 | Order information processing method and system |
| CN107527225A (en) * | 2016-06-15 | 2017-12-29 | 维萨国际服务协会 | System and method for wide-scale distribution of the efficient process resource between account |
| CN109656574A (en) * | 2018-11-27 | 2019-04-19 | 深圳华锐金融技术股份有限公司 | Transaction time delay measure, device, computer equipment and storage medium |
| CN110134701A (en) * | 2019-04-30 | 2019-08-16 | 阿里巴巴集团控股有限公司 | A kind of buffering benefit account method and device |
| CN111383022A (en) * | 2018-12-29 | 2020-07-07 | 广州市百果园信息技术有限公司 | Background architecture method, system, computer equipment and storage medium for aggregated payment |
| CN111948952A (en) * | 2020-08-13 | 2020-11-17 | 深圳市信锐网科技术有限公司 | A kind of Internet of things equipment control method, Internet of things platform and related equipment |
| CN112598327A (en) * | 2020-12-31 | 2021-04-02 | 平安银行股份有限公司 | Service processing system, method, device and storage medium |
| CN112600926A (en) * | 2020-12-16 | 2021-04-02 | 平安消费金融有限公司 | Message pushing method and device and computer readable storage medium |
-
2021
- 2021-04-22 CN CN202110436613.XA patent/CN113222565A/en active Pending
Patent Citations (9)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20070025351A1 (en) * | 2005-06-27 | 2007-02-01 | Merrill Lynch & Co., Inc., A Delaware Corporation | System and method for low latency market data |
| CN105447734A (en) * | 2014-06-06 | 2016-03-30 | 阿里巴巴集团控股有限公司 | Order information processing method and system |
| CN107527225A (en) * | 2016-06-15 | 2017-12-29 | 维萨国际服务协会 | System and method for wide-scale distribution of the efficient process resource between account |
| CN109656574A (en) * | 2018-11-27 | 2019-04-19 | 深圳华锐金融技术股份有限公司 | Transaction time delay measure, device, computer equipment and storage medium |
| CN111383022A (en) * | 2018-12-29 | 2020-07-07 | 广州市百果园信息技术有限公司 | Background architecture method, system, computer equipment and storage medium for aggregated payment |
| CN110134701A (en) * | 2019-04-30 | 2019-08-16 | 阿里巴巴集团控股有限公司 | A kind of buffering benefit account method and device |
| CN111948952A (en) * | 2020-08-13 | 2020-11-17 | 深圳市信锐网科技术有限公司 | A kind of Internet of things equipment control method, Internet of things platform and related equipment |
| CN112600926A (en) * | 2020-12-16 | 2021-04-02 | 平安消费金融有限公司 | Message pushing method and device and computer readable storage medium |
| CN112598327A (en) * | 2020-12-31 | 2021-04-02 | 平安银行股份有限公司 | Service processing system, method, device and storage medium |
Non-Patent Citations (1)
| Title |
|---|
| 杜玉巍;王海航;: "证券集中交易系统设计", 计算机应用, no. 02, 15 February 2008 (2008-02-15), pages 243 - 246 * |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN114663079A (en) * | 2022-03-23 | 2022-06-24 | 阿里云计算有限公司 | Settlement method, terminal, storage medium and program product |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN110647559B (en) | Data processing method, related node and system | |
| CN109087024B (en) | Data processing method, device, storage medium and equipment for electronic bill | |
| CN113409045B (en) | Data processing method and device based on block chain and electronic equipment | |
| CN106067858B (en) | Communication method, device and system between containers | |
| CN112906064B (en) | Method and device for generating description information | |
| US20190372825A1 (en) | Communication apparatus, communication method, and recording medium | |
| CN113507475B (en) | Cross-domain access method and device | |
| CN109413202B (en) | System and method for sorting block chain transaction information | |
| CN109413224B (en) | Message forwarding method and device | |
| CN114238397A (en) | User data processing method, apparatus, device, storage medium and program product | |
| WO2024054899A1 (en) | Peer-to-peer selectable digital money system | |
| CN112001796A (en) | Method and device for processing service in block chain system | |
| US12293354B2 (en) | Peer-to-peer selectable digital money system | |
| Georgakopoulos et al. | SenShaMart: a trusted lot marketplace for sensor sharing | |
| CN113222565A (en) | Transaction system, transaction method, apparatus, computer device and storage medium | |
| CN110351362A (en) | Data verification method, equipment and computer readable storage medium | |
| CN113051297A (en) | Transaction data query method and device, computer equipment and storage medium | |
| CN111600929B (en) | Transmission line detection method, routing strategy generation method and proxy server | |
| CN113643032A (en) | Information processing method and device based on block chain and data management system | |
| CN116996519A (en) | De-centralized domain name resolution equipment, system and method | |
| CN117112451A (en) | Test method, test device, electronic equipment and computer readable storage medium | |
| CN112035760B (en) | Task allocation method and computer equipment | |
| CN112001800B (en) | Method and device for processing business in block chain system | |
| CN114443723A (en) | Resource processing method, device and system | |
| CN115529299B (en) | Method, device and system for publishing and discovering privacy computing data resources |
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 | ||
| CB02 | Change of applicant information | ||
| CB02 | Change of applicant information |
Address after: Room 2301, building 5, Shenzhen new generation industrial park, 136 Zhongkang Road, Meidu community, Meilin street, Futian District, Shenzhen City, Guangdong Province Applicant after: Shenzhen Huarui Distributed Technology Co.,Ltd. Applicant after: Huarui distributed technology (Changsha) Co., Ltd Address before: Room 2301, building 5, Shenzhen new generation industrial park, 136 Zhongkang Road, Meidu community, Meilin street, Futian District, Shenzhen City, Guangdong Province Applicant before: SHENZHEN ARCHFORCE FINANCIAL TECHNOLOGY Co.,Ltd. Applicant before: Huarui distributed technology (Changsha) Co., Ltd |