CN114900451A - System interaction processing method and device, storage medium and electronic device - Google Patents

Abstract

The embodiment of the invention provides a system interaction processing method and device, a storage medium and an electronic device. The method comprises the following steps: under the condition that the exchange system detects a target interaction request, receiving the target interaction request by using a first type of service, wherein the target interaction request is used for requesting a target business system to process target transaction, and the first type of service is a main control service for receiving the interaction request in the exchange system; controlling a first class of service to forward a target interaction request to an asynchronous frame, and sending the target interaction request to a target service system through the asynchronous frame, wherein the asynchronous frame is a multi-thread service; and under the condition that the switching system detects a target transaction response returned by the target service system, receiving the target transaction response by using a second type of service, wherein the second type of service is a main control service for receiving a response message in the switching system. Therefore, the problem of low system interaction processing efficiency in the related technology can be solved, and the effect of improving the system interaction processing effect is achieved.

Description

A system interaction processing method and device, storage medium, and electronic device

technical field

Embodiments of the present invention relate to the field of computers, and in particular, to a method and device for processing system interaction, a storage medium, and an electronic device.

Background technique

Currently, when each business system needs to interact with a third-party system, it usually needs to perform online processing with a centralized exchange system deployed in the business system, and use transaction middleware to communicate with the third-party system.

Taking a banking system as an example, when online interaction with a third-party business system is required, a centralized exchange system based on deployment is usually required, and the Tuxedo transaction middleware is used to communicate with the third-party business system. The centralized switching system acts as the requester, and the third-party business system acts as the server. The master service of the centralized switching system forwards the interaction request to the third-party business system. After the third-party business system receives the interaction request and processes it, it returns the response message to the centralized exchange. The master service of the switching system.

Because the main control service of the centralized switching system will always be in a state of waiting for a response message after forwarding the interaction request, and cannot process new interaction requests during this period. If the third-party business system takes a long time to process the interaction, the main control service of the centralized switching system needs to wait for a long time to obtain a response from the third-party business system. During this process, the main control of the centralized switching system is always in a waiting state. , other interactions cannot be processed in time, making the interaction processing inefficient. If there is a problem with the interaction processing by the third-party business system, the main control service of the centralized switching system is likely to be stuck in the interaction, further reducing the processing efficiency of the interaction.

SUMMARY OF THE INVENTION

Embodiments of the present invention provide a system interaction processing method and device, a storage medium, and an electronic device, so as to at least solve the problem of low system interaction processing efficiency in the related art.

According to an embodiment of the present invention, a method for processing system interaction is provided, including: when a target interaction request is detected by a switching system, receiving the above-mentioned target interaction request by using a service of the first type, wherein the above-mentioned target interaction request uses a In requesting the target business system to process the target transaction, the above-mentioned first type of service is the main control service in the above-mentioned exchange system for receiving interaction requests; the above-mentioned first type of service is controlled to forward the above-mentioned target interaction request to the asynchronous framework, and the above-mentioned asynchronous framework is sent to the asynchronous framework. The above-mentioned target business system sends the above-mentioned target interaction request, wherein the above-mentioned asynchronous framework is a multi-threaded service; when the above-mentioned exchange system detects the target transaction response returned by the above-mentioned target business system, the second type of service is used to receive the above-mentioned target transaction response, Wherein, the above-mentioned second type of service is the main control service used for receiving the response message in the above-mentioned switching system.

In an exemplary embodiment, using the first type of service to receive the above-mentioned target interaction request includes: determining a first service that is currently in an idle state in the above-mentioned first type of service; using the above-mentioned first service to receive an indication of the above-mentioned target interaction request and save the context data of the above-mentioned target transaction carried in the above-mentioned target request packet.

In an exemplary embodiment, controlling the first type of service to forward the target interaction request to an asynchronous framework, and sending a target processing request to the target business system through the asynchronous framework includes: controlling the first service to report the target request to the asynchronous framework. control the target thread in the asynchronous framework to parse the target request message; and send the target request message to the target service system when the parsing result of the target request message satisfies the interaction conditions.

In an exemplary embodiment, controlling the target thread in the asynchronous framework to parse the target request message includes: controlling the target thread of the asynchronous framework to parse the system identifier indicating the target service system from the target request message and the target transaction time; when the current time does not exceed the above target transaction time, the monitoring information of the above target transaction is added to the monitoring linked list of the monitoring thread, wherein the above monitoring thread is used to monitor each thread running in the above asynchronous framework .

In an exemplary embodiment, when the current time exceeds the target transaction time, the target thread is released; a target response message indicating an abnormal timeout is generated, and the target response message is sent to the second type of service , so as to respond to the above-mentioned target interaction request by using the above-mentioned second type of service.

In an exemplary embodiment, controlling the monitoring thread to perform linked list processing on the monitoring linked list every time the target time elapses, includes: adjusting the monitoring linked list to a locked state, wherein the monitoring linked list does not respond to the monitoring linked list in the locked state The adjustment operation performed; determine whether the above-mentioned monitoring linked list is an empty linked list; in the case that the above-mentioned monitoring linked list is not an empty linked list, judge in turn whether each monitoring information in the above-mentioned monitoring linked list exceeds the current time; in the case where the above-mentioned monitoring information exceeds the above-mentioned current time In this case, the above-mentioned monitoring thread is instructed to close the thread corresponding to the above-mentioned monitoring information; after the above-mentioned monitoring linked list is an empty linked list or after traversing each of the above-mentioned monitoring information, the above-mentioned monitoring linked list is adjusted to an unlocked state, wherein, the above-mentioned monitoring linked list is in the above-mentioned unlocked state In response to the adjustment operation performed on the above monitoring linked list.

In an exemplary embodiment, when the above-mentioned switching system detects the above-mentioned target transaction response and the above-mentioned target thread is running normally, the above-mentioned target thread is used to obtain a target response message indicating the above-mentioned target transaction response; The context data of the target transaction is added to the target response message, and the target response message to which the context data of the target transaction is added is forwarded to the second type of service; the target thread is released.

In an exemplary embodiment, when the above-mentioned switching system detects the above-mentioned target transaction response and the above-mentioned target thread runs abnormally, the above-mentioned target thread is released, and a target response message indicating that the above-mentioned target thread is abnormal is generated; The message is sent to the above-mentioned second type of service to respond to the above-mentioned target interaction request by using the above-mentioned second type of service.

According to another embodiment of the present invention, a system interaction processing device is provided, comprising: a request receiving unit, configured to receive the above target interaction request by using the first type of service when the switching system detects the target interaction request, The above-mentioned target interaction request is used to request the target business system to process the target transaction, and the above-mentioned first type of service is the main control service in the above-mentioned switching system for receiving interaction requests; the forwarding unit is used to control the above-mentioned first type of service to transfer the above-mentioned target The interaction request is forwarded to the asynchronous framework, and the above-mentioned target interaction request is sent to the above-mentioned target business system through the above-mentioned asynchronous framework, wherein the above-mentioned asynchronous framework is a multi-threaded service; the response receiving unit is used for detecting in the above-mentioned exchange system the response returned by the above-mentioned target business system. In the case of the target transaction response, the second type of service is used to receive the above-mentioned target transaction response, wherein the above-mentioned second type of service is the main control service for receiving the response message in the above-mentioned switching system.

According to yet another embodiment of the present invention, a computer-readable storage medium is also provided, and a computer program is stored in the computer-readable storage medium, wherein the computer program is configured to execute any one of the above methods when running steps in the examples.

According to yet another embodiment of the present invention, there is also provided an electronic device comprising a memory and a processor, wherein the memory stores a computer program, the processor is configured to run the computer program to execute any of the above Steps in Method Examples.

In the present invention, when the target interaction request is detected by the switching system, the first type of service is used to receive the target interaction request, wherein the target interaction request is used to request the target business system to process the target transaction, and the first type of service is the switching system The main control service used to receive interactive requests in the first class of services controls the first type of service to forward the target interactive request to the asynchronous framework, and sends the target interactive request to the target business system through the asynchronous framework. The asynchronous framework is a multi-threaded service, which is detected in the exchange system. In the case of the target transaction response returned by the target business system, the second type of service is used to receive the target transaction response, wherein the second type of service is the main control service used to receive the response message in the switching system, and the The first-class service receives the interactive request that requests the target business system to process the target transaction, and forwards the interactive request to the asynchronous framework. When receiving the transaction response returned by the target business system, the multi-threaded service using the asynchronous framework uses the second-class service to receive the transaction. Response realizes the asynchronous reception of interactive requests and interactive responses through the multi-threaded server of the asynchronous framework, which prevents the thread service from being occupied by the same transaction for a long time after receiving the interactive request until the interactive response is completed, and improves the processing efficiency of system interaction. Therefore, the problem of low processing efficiency of system interaction in the related art can be solved, and the technical effect of improving the processing efficiency of system interaction can be achieved.

Description of drawings

1 is a block diagram of a hardware structure of a computer terminal of a method for processing system interaction according to an embodiment of the present invention;

2 is a network architecture diagram according to an embodiment of the present invention;

3 is a flowchart of a method for processing system interaction according to an embodiment of the present invention;

4 is a flowchart of a method for processing system interaction according to an embodiment of the present invention;

5 is a flowchart of a method for processing system interaction according to an embodiment of the present invention;

6 is a flowchart of a method for processing system interaction according to an embodiment of the present invention;

7 is a flowchart of a method for processing system interaction according to an embodiment of the present invention;

FIG. 8 is a structural block diagram of a processing apparatus for system interaction according to another embodiment of the present invention.

Detailed ways

Hereinafter, embodiments of the present invention will be described in detail with reference to the accompanying drawings and in conjunction with the embodiments.

It should be noted that the terms "first", "second" and the like in the description and claims of the present invention and the above drawings are used to distinguish similar objects, and are not necessarily used to describe a specific sequence or sequence.

In order to facilitate the understanding of the technical solutions provided by the present invention, the technical terms involved in the embodiments of the present invention are explained below.

AP: Application server.

Atomic method: a function that can be configured to be fine-grained in the transaction process

Tuxedo: A client/server middleware product that mediates between client and server to ensure that transactions are processed correctly.

Master: The Tuxedo service used to process transaction packets and configure the transaction processing flow.

The method embodiments provided in the embodiments of this application may be executed in a mobile terminal, a computer terminal, or a similar computing device. Taking running on a computer terminal as an example, FIG. 1 is a hardware structural block diagram of a computer terminal of a method for processing system interaction according to an embodiment of the present invention. As shown in FIG. 1 , the computer terminal may include one or more (only one is shown in FIG. 1 ) processors 102 (the processors 102 may include but are not limited to a microprocessor (Central Processing Unit, MCU) or a programmable logic device) (Field Programmable Gate Array, FPGA) and other processing devices) and a memory 104 for storing data, wherein the computer terminal may further include a transmission device 106 and an input and output device 108 for communication functions. Those of ordinary skill in the art can understand that the structure shown in FIG. 1 is only a schematic diagram, which does not limit the structure of the above-mentioned computer terminal. For example, the computer terminal may also include more or fewer components than shown in FIG. 1 , or have a different configuration than that shown in FIG. 1 .

The memory 104 can be used to store computer programs, for example, software programs and modules of application software, such as the computer programs corresponding to the subject behavior authority control method in the embodiment of the present invention. Executing various functional applications and data processing implements the above-mentioned methods. Memory 104 may include high-speed random access memory, and may also include non-volatile memory, such as one or more magnetic storage devices, flash memory, or other non-volatile solid-state memory. In some instances, memory 104 may further include memory located remotely from processor 102, which may be connected to a computer terminal through a network. Examples of such networks include, but are not limited to, the Internet, an intranet, a local area network, a mobile communication network, and combinations thereof.

Transmission means 106 are used to receive or transmit data via a network. The specific example of the above-mentioned network may include a wireless network provided by the communication provider of the computer terminal. In one example, the transmission device 106 includes a network adapter (Network Interface Controller, NIC for short), which can be connected to other network devices through a base station so as to communicate with the Internet. In one example, the transmission device 106 may be a radio frequency (Radio Frequency, RF for short) module, which is used to communicate with the Internet in a wireless manner.

FIG. 2 is a network architecture diagram of system interaction processing according to an embodiment of the present invention. As shown in FIG. 2 , the network architecture includes a switching system 200 and a service system 210. The switching system 200 is used for processing interaction requests related to transactions in the system. The interaction request is to request the corresponding business system 210 to process the transaction. After the business system 210 processes the transaction, the exchange system 200 receives the transaction response to complete the interaction request. In the case of detecting the interaction request, the switching system 200 uses the first type of service 202 to receive the interaction request, and the first type of service 202 is the main control service in the switching system 200 for receiving the interaction request. The first type of service 202 is controlled to forward the interaction request to the asynchronous framework 206, and the interaction request is sent to the business system 210 through the asynchronous framework 206. The asynchronous framework is a multi-threaded service. When the switching system 200 detects the transaction response returned by the business system 210, the second type of service 204 is used to receive the transaction response, and the second type of service 204 is the main control service in the switching system for receiving the response message.

FIG. 3 is a flowchart of a method for processing system interaction according to an embodiment of the present invention. As shown in FIG. 3 , the flowchart includes the following steps:

Step S302, when the exchange system detects the target interaction request, the first type of service is used to receive the target interaction request, wherein the target interaction request is used to request the target business system to process the target transaction, and the first type of service is used in the exchange system. The master service that receives interactive requests;

Step S304, controlling the first type of service to forward the target interaction request to the asynchronous framework, and sending the target interaction request to the target business system through the asynchronous framework, wherein the asynchronous framework is a multi-threaded service;

Step S306, when the switching system detects the target transaction response returned by the target business system, the second type of service is used to receive the target transaction response, wherein the second type of service is the main control service used to receive the response message in the switching system .

The exchange system is not limited to receiving interaction requests in the system, but interacts with the business system based on the transaction through the exchange system, and receives the transaction response returned by the business system through the exchange system to determine whether the transaction is successfully completed.

The exchange system is not limited to the first type of service for receiving interaction requests and the second type of service for receiving transaction responses, and the interaction requests and transaction responses are respectively received through different types of services, so that in the case of interaction requirements, calling The service is received to avoid the occupation of services and interaction requests in the switching system.

The asynchronous framework is not limited to multi-threaded services that use asynchronous processing, and each thread handles interactive requests independently of each other. Each thread is used to process each interaction request. When the first type of service receives the interaction request, the thread forwards the interaction request to the business system, and receives the transaction response returned by the business system based on the thread.

In the above-mentioned embodiment of the present invention, when the switching system detects the target interaction request, the first type of service is used to receive the target interaction request, wherein the target interaction request is used to request the target business system to process the target transaction, and the first type of service is used to receive the target interaction request. The service is the main control service used to receive interaction requests in the exchange system, and controls the first type of service to forward the target interaction request to the asynchronous framework, and sends the target interaction request to the target business system through the asynchronous framework, wherein the asynchronous framework is a multi-threaded service, When the switching system detects the target transaction response returned by the target business system, the second type of service is used to receive the target transaction response. The system uses the first type of service to receive the interactive request requesting the target business system to process the target transaction, and forwards the interactive request to the asynchronous framework. The class service receives the transaction response, which realizes the asynchronous reception of the interaction request and the interaction response through the multi-threaded server of the asynchronous framework, avoiding the thread service being occupied by the same transaction for a long time after receiving the interaction request and before the interaction response is completed, and improving the processing efficiency of system interaction . Therefore, the problem of low processing efficiency of system interaction in the related art can be solved, and the technical effect of improving the processing efficiency of system interaction can be achieved.

In an optional example, the above step S302 includes: determining a first service currently in an idle state among the first type of services; using the first service to receive a target request message indicating a target interaction request, and saving the target request Context data of the target transaction carried in the message.

In the case that the switching system receives the interaction request, the interaction request is received by using the first service in the first type of service that is currently in an idle state. The first type of service and the second type of service are not limited to include multiple independent master services. , for independent processing of receiving interactive requests or transaction responses. When the first service forwards the interaction request to the asynchronous framework, the first service is adjusted from the occupied state to the idle state, so that other interaction requests can continue to be received.

Similarly, in the case of receiving a transaction response, the second service in the second type of service that is currently in an idle state is used to receive the transaction response, and after the transaction response is processed, the second service is adjusted from the occupied state to the idle state, Thus, other transaction replies can continue to be received.

The interaction request is not limited to an interaction request message, and the context data stored in the first server for identifying the transaction is not limited to saving the context data of the transaction in the header of the interaction request message. Context data is not limited to identifying interaction requests and transaction responses, and is used to indicate the context of the transaction.

Optionally, it is not limited to use the atomic method Data_SaveKeyData to place the context data in the header of the transaction message, so that the transaction message carrying the context data is forwarded to the asynchronous framework, and the context data is used to indicate the associated environment of the transaction, so as to realize the transaction and thread solution. coupled.

The transaction processing flow of the exchange system is not limited to that shown in FIG. 4 . The master A (the first service) executes the request processing flow, and the master B (the second service) executes the response processing flow and the transaction flow. In the case of receiving the interaction request, it is determined that the transaction processing flow starts. The main control A and the little girl's transaction logic processing, and save the context data. Forwards interaction packets carrying context data to the asynchronous framework. In the case of receiving the interactive message, the asynchronous framework sends a request to a third party (business system). The asynchronous framework receives the third-party response and sends the third-party response to master B. After master B restores the context data and performs transaction logic processing, it returns a response to the requester of the system. At this point, the transaction processing flow ends.

The data format of the transaction message is not limited to those shown in Table 1 below:

Table 1

In an optional example, the above step S304 includes: controlling the first service to forward the target request message to the asynchronous framework; controlling the target thread in the asynchronous framework to parse the target request message; In the case of interaction conditions, send the target request message to the target service system.

The asynchronous framework is not limited to initializing the service through the tuxedo configuration file at startup, so that it supports multi-threading, in which the transaction thread is supported by the Tuxedo middleware, and the configuration property MINDISPATCHTHREADS is used to monitor the startup of the thread in the startup process of the asynchronous framework. The startup process of the asynchronous framework is not limited to that shown in FIG. 5 . Initialize tpinit, parse the parameters to set the published service name according to the parameters, publish the service after the setting is completed, and create a monitoring thread, the transaction thread is by Tuxedo. The monitoring thread is used to monitor the transaction thread running in the asynchronous framework, and the transaction thread is used to receive and forward interactive requests and receive and forward transaction responses.

In an optional example, the above-mentioned controlling the target thread in the asynchronous framework to parse the target request message includes: controlling the target thread of the asynchronous framework to parse out the system identifier indicating the target business system and the target transaction time from the target request message ; Under the condition that the current time does not exceed the target transaction time, the monitoring information of the target transaction is added to the monitoring linked list of the monitoring thread, where the monitoring thread is used to monitor each thread running in the asynchronous framework.

The request message is received and parsed by the currently idle target thread determined in the asynchronous framework, and the system identifier used to indicate the business system and the transaction time used to judge whether the transaction has timed out are parsed from the request message. Taking the transaction time as the transaction timeout moment as an example, if the current time does not exceed the transaction time, it is determined that the transaction is not currently timed out; if the time exceeds the transaction time, it is determined that the transaction has timed out. If the transaction does not time out, add the monitoring information of the transaction to the monitoring list of the monitoring thread.

The monitoring linked list is not limited to monitoring each transaction thread for the monitoring thread in the asynchronous framework and the linked list that records the relevant information of each transaction thread, and records the current status of each transaction thread, the monitoring information of the received transaction, and the transaction information. The transaction thread is running when processing interactive requests and receiving transaction responses, and is in an idle state when not processing interactive requests and receiving transaction responses.

The monitoring information of the target transaction is not limited to include the identifier of the target thread processing the target transaction and the target transaction time, so as to monitor the transaction thread running in the asynchronous framework through the monitoring linked list.

In an optional example, when the current time exceeds the target transaction time, the target thread is released; a target response message indicating a timeout exception is generated, and the target response message is sent to the second type of service, so as to use the The second type of service responds to the target interaction request.

When the current time exceeds the target transaction time, that is, the target transaction currently times out, the target thread processing the target transaction is released, and a response message indicating the transaction timeout exception is generated, thereby indicating that the target transaction is completed within the indicated target transaction time. .

When the current time does not exceed the target transaction time, that is, the target transaction does not currently time out, while recording the monitoring information of the target transaction in the monitoring linked list, the target thread is used to send the interaction request to the third-party service indicated by the interaction request. system to instruct the business system to process the target transaction.

After sending the interactive request to the third-party business system, the asynchronous framework is not limited to processing the monitoring linked list through the monitoring thread to determine whether the transaction thread currently processing the transaction times out.

In an optional example, the control monitoring thread performs linked list processing on the monitoring linked list every time the target time elapses, including:

S1, adjusting the monitoring linked list to a locked state, wherein the monitoring linked list does not respond to the adjustment operation performed on the monitoring linked list in the locked state;

S2, determine whether the monitoring linked list is an empty linked list;

S3, in the case that the monitoring linked list is not an empty linked list, judge in turn whether each monitoring information in the monitoring linked list exceeds the current time;

S4, in the case that the monitoring information exceeds the current time, instruct the monitoring thread to close the thread corresponding to the monitoring information;

S5 , after the monitoring linked list is an empty linked list or after traversing each monitoring information, adjust the monitoring linked list to an unlocked state, wherein the monitoring linked list responds to an adjustment operation performed on the monitoring linked list in the unlocked state.

The monitoring thread performs the above steps on the monitoring linked list every time the target time elapses, and judges whether each monitoring information in the monitoring linked list exceeds the current time, so as to judge whether the transaction of each currently running thread has timed out. Close the thread corresponding to the timeout transaction in time to release thread resources and avoid the transaction occupying the thread for a long time.

The transaction thread in the running state is recorded in the monitoring list, that is, the thread currently occupied by the transaction. When the transaction thread is in an idle state, it is not recorded in the monitoring list.

The processing of the monitoring linked list by the monitoring thread is not limited to that shown in FIG. 6 . Start to obtain the current time, lock the monitoring linked list, make the monitoring linked list in a locked state, and judge whether the linked list is empty. When it is determined that the linked list is empty, that is, there is no running transaction thread and no transaction request being processed, the monitoring linked list is unlocked. When it is determined that the linked list is not empty and there are currently running transaction processes, it is determined in turn whether the transaction times out. For each transaction, it is judged whether the transaction has timed out in turn, and if it is determined that the transaction has timed out, the timeout transaction thread is closed. After judging all transactions in the linked list, lock and monitor the linked list. The duration of the sleep target time, the above steps are re-executed after the sleep, and the next round of processing is performed on the monitoring linked list.

Optionally, a locking operation is also performed on the monitoring linked list when the monitoring information of the target transaction is written into the monitoring linked list, so as to ensure that only the information of one thread is changed in the monitoring linked list in the same time period. When the transaction thread is closed and released, the monitoring information corresponding to the transaction thread is deleted from the monitoring linked list.

In an optional example, when the switching system detects the target transaction response and the target thread is running normally, the target thread is used to obtain a target response message indicating the target transaction response; the target thread is controlled to add the target response message Context data of the target transaction, and forward the target response message added with the context data of the target transaction to the second type of service; release the target thread.

In the case of receiving a transaction response, first determine whether the target thread is running normally. If the target thread is running normally, use the target thread to obtain the response message; if the target thread is running abnormally, it is not limited to reporting an abnormal response. text to respond to interactive requests.

In an optional example, when the switching system detects the target transaction response and the target thread runs abnormally, the target thread is released, and a target response message indicating the abnormality of the target thread is generated; the target response message is sent to the first Class II service to respond to the target interaction request by utilizing the second class service.

In the case that the target thread runs abnormally, the target thread is released and a response message indicating the abnormality of the thread is generated to answer the interaction request.

The processing flow of the interactive request and the transaction response by the target thread in the asynchronous framework is not limited to that shown in FIG. 7 . When receiving a request message, parse the message to obtain context data. Obtaining third-party services from the request message is faster than bridge and timeout. Determine whether the transaction has timed out. In the case of judging that the transaction has timed out, release the thread and generate an exception message indicating that the transaction has timed out. In the case of judging that the transaction has not timed out, add the transaction information to the monitoring list. Forward the transaction request to the third-party service to obtain the transaction response returned by the third-party service. In the case of obtaining the transaction response, it is judged whether the thread is running normally. When it is judged that the thread is running normally, the context data is spliced through the transaction response to obtain a response message. Send the response message to the second service to respond to the interaction request. When it is determined that the thread is running abnormally, the thread is released, and a response message indicating the abnormality of the thread is generated.

From the description of the above embodiments, those skilled in the art can clearly understand that the method according to the above embodiment can be implemented by means of software plus a necessary general hardware platform, and of course can also be implemented by hardware, but in many cases the former is better implementation. Based on this understanding, the technical solutions of the present invention can be embodied in the form of software products that are essentially or contribute to the prior art, and the computer software products are stored in a storage medium (such as read-only memory/random access). The memory (Read-Only Memory/Random Access Memory, ROM/RAM), magnetic disk, CD-ROM) includes several instructions to make a terminal device (which can be a mobile phone, a computer, a server, or a network device, etc.) to execute the present invention The methods described in the various examples.

In this embodiment, a system interaction processing apparatus is also provided, and the apparatus is used to implement the above-mentioned embodiments and preferred implementations, and what has been described will not be repeated. As used below, the term "module" may be a combination of software and/or hardware that implements a predetermined function. Although the apparatus described in the following embodiments is preferably implemented in software, implementations in hardware, or a combination of software and hardware, are also possible and contemplated.

FIG. 8 is a structural block diagram of an apparatus for processing system interaction according to an embodiment of the present invention. As shown in FIG. 8 , the apparatus includes:

The request receiving unit 802 is configured to receive the target interaction request by using the first type of service when the exchange system detects the target interaction request, wherein the target interaction request is used to request the target business system to process the target transaction, and the first type of service is the exchange The main control service in the system for receiving interactive requests;

A forwarding unit 804, configured to control the first type of service to forward the target interaction request to the asynchronous framework, and send the target interaction request to the target business system through the asynchronous framework, wherein the asynchronous framework is a multi-threaded service;

The response receiving unit 806 is configured to receive the target transaction response by using the second type of service when the switching system detects the target transaction response returned by the target service system, wherein the second type of service is used in the switching system to receive the response message the master service.

The above request receiving unit 802 also includes:

a determining module, configured to determine the first service currently in an idle state in the first type of service;

The receiving module is configured to use the first service to receive a target request message indicating a target interaction request, and save the context data of the target transaction carried in the target request message.

The above-mentioned forwarding unit 804 includes:

a forwarding module, configured to control the first service to forward the target request message to the asynchronous framework;

The parsing module is used to control the target thread in the asynchronous framework to parse the target request message;

The sending module is configured to send the target request message to the target service system under the condition that the parsing result of the target request message satisfies the interaction condition.

The above parsing module is also used to control the target thread of the asynchronous framework to parse out the system identifier indicating the target business system and the target transaction time from the target request message; if the current time does not exceed the target transaction time, the monitoring information of the target transaction is parsed. It is added to the monitoring linked list of the monitoring thread, where the monitoring thread is used to monitor each thread running in the asynchronous framework.

In addition to all the modules shown in Figure 8, the device also includes a release unit, which is used to release the target thread when the current time exceeds the target transaction time; generate a target response message indicating an abnormal timeout, and report the target response to the The message is sent to the second type of service to respond to the target interaction request by utilizing the second type of service.

In addition to all the modules shown in FIG. 8, the device also includes a monitoring unit, which is used to control the monitoring thread to perform linked list processing on the monitoring linked list every time the target time passes, including: adjusting the monitoring linked list to a locked state, wherein the monitoring linked list is in the locked state. The lock state does not respond to the adjustment operation performed on the monitoring linked list; judge whether the monitoring linked list is an empty linked list; if the monitoring linked list is not an empty linked list, judge whether each monitoring information in the monitoring linked list exceeds the current time in turn; when the monitoring information exceeds the current time In the case of time, the monitoring thread is instructed to close the thread corresponding to the monitoring information; after the monitoring linked list is an empty linked list or after traversing each monitoring information, the monitoring linked list is adjusted to the unlocked state, wherein the monitoring linked list responds to the monitoring linked list in the unlocked state. adjustment operation.

The above-mentioned response receiving unit 806 also includes:

The acquisition module is used to obtain the target response message indicating the target transaction response by using the target thread when the exchange system detects the target transaction response and the target thread operates normally;

The adding module is used to control the target thread to add the context data of the target transaction in the target response message, and forward the target response message with the context data of the target transaction added to the second type of service;

Release module, used to release the target thread.

In addition to all the modules shown in FIG. 8 , the device also includes an exception unit, which is used to release the target thread and generate a target response indicating that the target thread is abnormal when the switching system detects the target transaction response and the target thread runs abnormally. message; send the target response message to the second type of service to respond to the target interaction request by using the second type of service.

It should be noted that the above modules can be implemented by software or hardware, and the latter can be implemented in the following ways, but not limited to this: the above modules are all located in the same processor; or, the above modules can be combined in any combination The forms are located in different processors.

Embodiments of the present invention further provide a computer-readable storage medium, where a computer program is stored in the computer-readable storage medium, wherein the computer program is configured to execute the steps in any of the above method embodiments when running.

In an exemplary embodiment, the above-mentioned computer-readable storage medium may include, but is not limited to, a USB flash drive, a read-only memory (Read-Only Memory, referred to as ROM for short), and a random access memory (Random Access Memory, referred to as RAM for short) , mobile hard disk, magnetic disk or CD-ROM and other media that can store computer programs.

An embodiment of the present invention also provides an electronic device, comprising a memory and a processor, where a computer program is stored in the memory, and the processor is configured to run the computer program to execute the steps in any of the above method embodiments.

In an exemplary embodiment, the above-mentioned electronic device may further include a transmission device and an input-output device, wherein the transmission device is connected to the above-mentioned processor, and the input-output device is connected to the above-mentioned processor.

For specific examples in this embodiment, reference may be made to the examples described in the foregoing embodiments and exemplary implementation manners, and details are not described herein again in this embodiment.

Obviously, those skilled in the art should understand that the above-mentioned modules or steps of the present invention can be implemented by a general-purpose computing device, which can be centralized on a single computing device, or distributed in a network composed of multiple computing devices On the other hand, they can be implemented in program code executable by a computing device, so that they can be stored in a storage device and executed by the computing device, and in some cases, can be performed in a different order than shown here. Or the described steps, or they are respectively made into individual integrated circuit modules, or a plurality of modules or steps in them are made into a single integrated circuit module to realize. As such, the present invention is not limited to any particular combination of hardware and software.

The above descriptions are only preferred embodiments of the present invention, and are not intended to limit the present invention. For those skilled in the art, the present invention may have various modifications and changes. Any modification, equivalent replacement, improvement, etc. made within the principle of the present invention shall be included within the protection scope of the present invention.

Claims (11)

1. A method for processing system interaction is characterized by comprising the following steps:

under the condition that a target interaction request is detected by an exchange system, receiving the target interaction request by utilizing a first type of service, wherein the target interaction request is used for requesting a target business system to process a target transaction, and the first type of service is a main control service for receiving the interaction request in the exchange system;

controlling the first class of service to forward the target interaction request to an asynchronous framework, and sending the target interaction request to the target business system through the asynchronous framework, wherein the asynchronous framework is a multi-thread service;

and under the condition that the switching system detects a target transaction response returned by the target service system, receiving the target transaction response by using a second type of service, wherein the second type of service is a main control service for receiving a response message in the switching system.

2. The method of claim 1, wherein receiving the target interaction request using a first class of service comprises:

determining a first service currently in an idle state in the first class of services;

and receiving a target request message indicating the target interaction request by using the first service, and storing the context data of the target transaction carried in the target request message.

3. The method of claim 2, wherein controlling the first class of service to forward the target interactive request to an asynchronous framework, and sending a target processing request to the target business system through the asynchronous framework comprises:

controlling the first service to forward the target request packet to the asynchronous frame;

controlling a target thread in the asynchronous frame to analyze the target request message;

and sending the target request message to the target service system under the condition that the analysis result of the target request message meets the interaction condition.

4. The method according to claim 3, wherein controlling the target thread in the asynchronous framework to parse the target request packet comprises:

controlling the target thread of the asynchronous frame to analyze a system identifier indicating the target service system and target transaction time from the target request message;

and under the condition that the current time does not exceed the target transaction time, adding the monitoring information of the target transaction into a monitoring linked list of a monitoring thread, wherein the monitoring thread is used for monitoring each thread running in the asynchronous frame.

5. The method of claim 4, wherein:

releasing the target thread if the current time exceeds the target transaction time;

and generating a target response message indicating timeout abnormity, and sending the target response message to the second type of service so as to respond to the target interaction request by utilizing the second type of service.

6. The method of claim 4, wherein controlling the monitor thread to perform linked list processing on the monitor linked list each time a target time elapses comprises:

adjusting the monitoring linked list to be in a locking state, wherein the monitoring linked list does not respond to the adjustment operation executed on the monitoring linked list in the locking state;

judging whether the monitoring linked list is an empty linked list or not;

under the condition that the monitoring linked list is not an empty linked list, sequentially judging whether each piece of monitoring information in the monitoring linked list exceeds the current time;

when the monitoring information exceeds the current time, indicating the monitoring thread to close the thread corresponding to the monitoring information;

and adjusting the monitoring linked list to be in an unlocking state when the monitoring linked list is an empty linked list or after traversing each piece of monitoring information, wherein the monitoring linked list responds to the adjustment operation executed on the monitoring linked list in the unlocking state.

7. The method of claim 3, wherein:

under the condition that the exchange system detects the target transaction response and the target thread runs normally, acquiring a target response message indicating the target transaction response by using the target thread;

controlling the target thread to add the context data of the target transaction in the target response message, and forwarding the target response message added with the context data of the target transaction to the second type of service;

and releasing the target thread.

8. The method of claim 3, wherein:

when the exchange system detects the target transaction response and the target thread runs abnormally, releasing the target thread and generating a target response message indicating that the target thread is abnormal;

and sending the target response message to the second type of service so as to respond to the target interaction request by utilizing the second type of service.

9. A system interaction processing apparatus, comprising:

a request receiving unit, configured to receive a target interaction request by using a first type of service when a switching system detects the target interaction request, where the target interaction request is used to request a target service system to process a target transaction, and the first type of service is a master control service used in the switching system to receive the interaction request;

the forwarding unit is used for controlling the first class of service to forward the target interaction request to an asynchronous frame and sending the target interaction request to the target service system through the asynchronous frame, wherein the asynchronous frame is a multi-thread service;

and the response receiving unit is used for receiving the target transaction response by using a second type of service under the condition that the switching system detects the target transaction response returned by the target service system, wherein the second type of service is a main control service for receiving a response message in the switching system.

10. A computer-readable storage medium, in which a computer program is stored, wherein the computer program is arranged to perform the method of any of claims 1 to 8 when executed.

11. An electronic device comprising a memory and a processor, wherein the memory has stored therein a computer program, and wherein the processor is arranged to execute the computer program to perform the method of any of claims 1 to 8.

Images