CN115934378A - Service data processing method and device, electronic equipment and storage medium - Google Patents
Service data processing method and device, electronic equipment and storage medium Download PDFInfo
- Publication number
- CN115934378A CN115934378A CN202211534293.2A CN202211534293A CN115934378A CN 115934378 A CN115934378 A CN 115934378A CN 202211534293 A CN202211534293 A CN 202211534293A CN 115934378 A CN115934378 A CN 115934378A
- Authority
- CN
- China
- Prior art keywords
- target
- message
- batch
- service data
- batch process
- 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
-
- Y—GENERAL TAGGING OF NEW TECHNOLOGICAL DEVELOPMENTS; GENERAL TAGGING OF CROSS-SECTIONAL TECHNOLOGIES SPANNING OVER SEVERAL SECTIONS OF THE IPC; TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
- Y02—TECHNOLOGIES OR APPLICATIONS FOR MITIGATION OR ADAPTATION AGAINST CLIMATE CHANGE
- Y02D—CLIMATE CHANGE MITIGATION TECHNOLOGIES IN INFORMATION AND COMMUNICATION TECHNOLOGIES [ICT], I.E. INFORMATION AND COMMUNICATION TECHNOLOGIES AIMING AT THE REDUCTION OF THEIR OWN ENERGY USE
- Y02D10/00—Energy efficient computing, e.g. low power processors, power management or thermal management
Landscapes
- Computer And Data Communications (AREA)
Abstract
The present disclosure provides a business data processing method, device, electronic device and storage medium, which can be applied to the field of computer technology, the field of intelligent operation and maintenance, the field of finance or other fields. The method comprises the following steps: responding to the starting state of the target batch process, and acquiring a process batch number of the target batch process; calling a target batch process, and determining a target message from the message detail table by using a process batch number, wherein the target message comprises target business data, a target application number and a target batch number, and the target batch number and the process batch number belong to the same batch; filling target service data and a target application number in a target message into a message template to generate a communication message; and sending the communication message to the gateway, wherein the gateway is configured to parse the communication message, obtain the target service data and the target application number, and invoke a long connection communication process associated with the target application number to push the target service data to the platform server.
Description
Technical Field
The present disclosure relates to the field of computer technologies, the field of intelligent operation and maintenance, and the field of finance, and more particularly, to a method and an apparatus for processing business data, an electronic device, and a storage medium.
Background
At present, the traditional banking system adopts a centralized host system, core service transactions run on the host, a notification message platform is an open platform system, and when the service transactions are carried out, the next service processing is carried out only after the success or failure of message sending is confirmed by waiting for the communication result between a communication interface and a platform server. Because the host computer and the platform have certain communication delay, the communication time is prolonged under the condition of network jitter or platform server abnormity, and the overall timeliness of service transaction is reduced, thereby influencing the customer experience.
Disclosure of Invention
In view of the above, the present disclosure provides a business data processing method, an apparatus, an electronic device, a readable storage medium, and a computer program product.
One aspect of the present disclosure provides a business data processing method, including responding to a target batch process being in a starting state, obtaining a process batch number of the target batch process; calling the target batch process, and determining a target message from a message detail table by using the process batch number, wherein the target message comprises target service data, a target application number and a target batch number, and the target batch number and the process batch number belong to the same batch; filling the target service data and the target application number in the target message into a message template to generate a communication message; and sending the communication message to a gateway, wherein the gateway is configured to analyze the communication message, acquire the target service data and the target application number, and invoke a long connection communication process associated with the target application number to push the target service data to a platform server.
According to an embodiment of the present disclosure, the method further includes: receiving service data of transaction service from a host by using a communication interface, wherein the service data has a corresponding application number; determining a batch range corresponding to the application number based on a parameter configuration table; generating a batch number of the service data based on the batch range; recording the service data, the application number and the batch number in the message detail table; and sending feedback information to the host, wherein the feedback information indicates that the transaction service is completed.
According to an embodiment of the present disclosure, the method further includes: acquiring the running states of a plurality of batch processes in a polling check mode, wherein the target batch process belongs to the plurality of batch processes; for each batch process, determining the running stopping time length of the batch process under the condition that the batch process is in a dormant state; and controlling the batch process to enter a starting state under the condition that the running stopping time length is greater than or equal to a preset dormancy time length.
According to an embodiment of the present disclosure, the method further includes: for each batch process, acquiring process processing information of the batch process from a data table under the condition that the batch process is in a starting state; and controlling the batch process to enter a dormant state under the condition that the process processing information meets a first process termination condition.
According to an embodiment of the present disclosure, the first process termination condition includes: the processing duration of the batch process is greater than or equal to a processing duration threshold; or the number of messages processed by the batch process is greater than or equal to a message number threshold.
According to the embodiment of the present disclosure, a message sending status of a message is further recorded in the message detail table; the method further comprises the following steps: and controlling the batch process to enter a dormant state under the condition that the message in the message list meets a second process termination condition.
According to an embodiment of the present disclosure, wherein the second process termination condition includes: the message sending states of all messages in the message list are represented as sent; or the message sending states of the messages belonging to the same batch with the process batch number in the message list are all represented as sent.
According to an embodiment of the present disclosure, the method further includes: receiving a data pushing result returned by the gateway; and modifying the message sending state of the target message in the message list based on the data pushing result.
Another aspect of the present disclosure provides a service data processing apparatus, including: the acquisition module is used for responding to the starting state of the target batch process and acquiring the process batch number of the target batch process; the determining module is used for calling the target batch process and determining a target message from a message detail table by using the process batch number, wherein the target message comprises target business data, a target application number and a target batch number, and the target batch number and the process batch number belong to the same batch; a generating module, configured to fill the target service data and the target application number in the target message into a message template, and generate a communication message; and the sending module is used for sending the communication message to a gateway, wherein the gateway is configured to analyze the communication message, acquire the target service data and the target application number, and call a long connection communication process associated with the target application number to push the target service data to a platform server.
Another aspect of the present disclosure provides an electronic device including: one or more processors; a memory for storing one or more instructions, wherein the one or more instructions, when executed by the one or more processors, cause the one or more processors to implement the method as described above.
Another aspect of the present disclosure provides a computer-readable storage medium storing computer-executable instructions for implementing the method as described above when executed.
Another aspect of the disclosure provides a computer program product comprising computer executable instructions that when executed are for implementing a method as described above.
According to the embodiment of the disclosure, in the process that the target batch process is in the starting state, the process batch number of the message to be sent is obtained from the target batch process of the business transaction, the target message belonging to the same batch as the process batch number is determined from the message detail table according to the process batch number, then the target business data and the target application number in the target message are filled into the message template to generate the communication message, and the communication message is sent to the gateway, and the communication message is analyzed by the gateway to obtain the target business data and the target application number, so that the gateway selects the corresponding long connection communication process to send the target business data according to the target application number.
Drawings
The above and other objects, features and advantages of the present disclosure will become more apparent from the following description of embodiments of the present disclosure with reference to the accompanying drawings, in which:
FIG. 1 schematically illustrates an exemplary system architecture to which the disclosed method and apparatus for presenting click left on a web page may be applied;
fig. 2 schematically shows a flow chart of a business data processing method according to an embodiment of the present disclosure;
fig. 3 schematically shows a flow chart of a traffic data processing method according to another embodiment of the present disclosure;
fig. 4 schematically shows a flowchart of a first process termination condition in which batch processes of a business data processing method sequentially perform polling checks according to an embodiment of the present disclosure;
fig. 5 schematically shows a flowchart of a second process termination condition in which the batch processes of the business data processing method sequentially perform polling checks according to an embodiment of the present disclosure;
fig. 6 schematically shows a block diagram of a traffic data processing apparatus according to an embodiment of the present disclosure; and
fig. 7 schematically shows a block diagram of an electronic device adapted to implement a business data processing method according to an embodiment of the present disclosure.
Detailed Description
Hereinafter, embodiments of the present disclosure will be described with reference to the accompanying drawings. It should be understood that these descriptions are illustrative only and are not intended to limit the scope of the present disclosure. In the following detailed description, for purposes of explanation, numerous specific details are set forth in order to provide a thorough understanding of the embodiments of the disclosure. It may be evident, however, that one or more embodiments may be practiced without these specific details. Moreover, in the following description, descriptions of well-known structures and techniques are omitted so as to not unnecessarily obscure the concepts of the present disclosure.
The terminology used herein is for the purpose of describing particular embodiments only and is not intended to be limiting of the disclosure. The terms "comprises," "comprising," and the like, as used herein, specify the presence of stated features, steps, operations, and/or components, but do not preclude the presence or addition of one or more other features, steps, operations, or components.
All terms (including technical and scientific terms) used herein have the same meaning as commonly understood by one of ordinary skill in the art unless otherwise defined. It is noted that the terms used herein should be interpreted as having a meaning that is consistent with the context of this specification and should not be interpreted in an idealized or overly formal sense.
Where a convention analogous to "at least one of A, B, and C, etc." is used, in general such a construction is intended in the sense one having skill in the art would understand the convention (e.g., "a system having at least one of A, B, and C" would include but not be limited to systems that have A alone, B alone, C alone, A and B together, A and C together, B and C together, and/or A, B, and C together, etc.). Where a convention analogous to "at least one of A, B, or C, etc." is used, in general such a construction is intended in the sense one having skill in the art would understand the convention (e.g., "a system having at least one of A, B, or C" would include but not be limited to systems that have A alone, B alone, C alone, A and B together, A and C together, B and C together, and/or A, B, and C together, etc.).
At present, a traditional banking system adopts a centralized host system to process business data. Specifically, when the centralized host system processes the service data, the communication interface is called to obtain target service data to be sent of the service transaction, then the target service data to be sent is pushed to the platform server by means of the long connection communication channel, and then the next step of service processing is performed after the target service data is confirmed to be sent to the platform server successfully or unsuccessfully. Due to the fact that the sending state of the target service data needs to be confirmed, communication delay is caused, and when network jitter or platform server abnormal conditions occur, the overall timeliness of service data processing is reduced, and therefore customer experience is affected.
In view of this, embodiments of the present disclosure provide a business data processing method, a business data processing apparatus, an electronic device, a readable storage medium, and a computer program product. Responding to the starting state of a target batch process, and acquiring a process batch number of the target batch process; calling a target batch process, and determining a target message from the message detail table by using a process batch number, wherein the target message comprises target business data, a target application number and a target batch number, and the target batch number and the process batch number belong to the same batch; filling target service data and a target application number in a target message into a message template to generate a communication message; and sending the communication message to the gateway, wherein the gateway is configured to parse the communication message, obtain the target service data and the target application number, and invoke a long connection communication process associated with the target application number to push the target service data to the platform server.
It should be noted that the business data processing method and apparatus determined in the embodiments of the present disclosure may be used in the field of computer technology, the field of intelligent operation and maintenance, or the field of finance. The business data processing method and device determined by the embodiment of the disclosure can also be used in any fields except the fields of computer technology, intelligent operation and maintenance and finance. The application fields of the service data processing method and the service data processing device determined by the embodiment of the disclosure are not limited.
In the technical scheme of the disclosure, the acquisition, storage, application and the like of the personal information of the related user all accord with the regulations of related laws and regulations, necessary security measures are taken, and the customs of the public order is not violated.
In the technical scheme of the disclosure, before the personal information of the user is obtained or collected, the authorization or the consent of the user is obtained.
Fig. 1 schematically shows an exemplary system architecture to which the business data processing method and apparatus may be applied, according to an embodiment of the present disclosure. It should be noted that fig. 1 is only an example of a system architecture to which the embodiments of the present disclosure may be applied to help those skilled in the art understand the technical content of the present disclosure, and does not mean that the embodiments of the present disclosure may not be applied to other devices, systems, environments or scenarios.
As shown in fig. 1, a system architecture 100 according to this embodiment may include hosts 101, 102, 103, a network 104, and a platform server 105. Network 104 is used to provide a medium for communication links between hosts 101, 102, 103 and platform server 105. Network 104 may include various connection types, such as wired and/or wireless communication links, and so forth.
The user may use the hosts 101, 102, 103 to interact with the platform server 105 over the network 104 to receive or send messages, etc. The hosts 101, 102, 103 may have installed thereon various messenger client applications such as, for example only, a shopping-like application, a web browser application, a search-like application, an instant messaging tool, a mailbox client, and/or social platform software, among others. The user generates business data by operating various communication client applications on the hosts 101, 102, 103.
The hosts 101, 102, 103 may be various electronic devices having display screens including, but not limited to, smart phones, tablet computers, laptop portable computers, desktop computers, and the like.
The platform server 105 may be a server providing various services, for example, the platform server 105 may process business data generated in the process of using the communication client application in the hosts 101, 102, 103 by a user, and return the processing result to the hosts 101, 102, 103.
It should be noted that the service data processing method provided by the embodiment of the present disclosure may be generally executed by the host 101, 102, or 103. Accordingly, the service data processing device provided by the embodiment of the present disclosure may be generally disposed in the host 101, 102 or 103. Alternatively, the business data processing method provided by the embodiment of the present disclosure may also be executed by a client device, a server or a server cluster different from the hosts 101, 102 and 103 and capable of communicating with the hosts 101, 102 and 103 and/or the platform server 105. Accordingly, the service data processing apparatus provided by the embodiment of the present disclosure may also be disposed in a client device, a server or a server cluster different from the hosts 101, 102 and 103 and capable of communicating with the hosts 101, 102 and 103 and/or the platform server 105. It should be understood that the number of hosts, network and platform servers in FIG. 1 is illustrative only. There may be any number of hosts, network and platform servers, as desired for the implementation.
Fig. 2 schematically shows a flow chart of a traffic data processing method according to an embodiment of the present disclosure.
As shown in fig. 2, the method includes operations S201 to S204.
In operation S201, in response to the target batch process being in the starting state, a process batch number of the target batch process is obtained.
In operation S202, a target batch process is called, and a target message is determined from the message list by using a process batch number, where the target message includes target service data, a target application number, and a target batch number, and the target batch number and the process batch number belong to the same batch.
In operation S203, the message template is filled with the target service data and the target application number in the target message, so as to generate a communication message.
In operation S204, a communication packet is sent to the gateway, where the gateway is configured to parse the communication packet, obtain the target service data and the target application number, and invoke a long connection communication process associated with the target application number to push the target service data to the platform server.
According to the embodiment of the present disclosure, the application number is a number for the platform application, and the application number and the platform application may be in a one-to-one correspondence relationship.
According to embodiments of the present disclosure, the lot number may be supplemented by both a lot code and a range code, for example, one lot number may be denoted as 0001-002. Reference numeral 0001 denotes a lot number, and it is determined whether the target lot number and the process lot number belong to the same lot according to whether the lot numbers are the same. 002 is a range code, that is, when a lot number is generated, it is randomly assigned according to the lot range.
According to the embodiment of the disclosure, the host starts a plurality of processes to push the target message in parallel, the serial number of each process is the batch number, and data processed among the processes have no influence on each other.
According to an embodiment of the present disclosure, the message list stores target message data including target traffic data, a target application number, and a target batch number. Wherein the target batch number and the process batch number belong to the same batch; the target service data is a message body and a sending state of the target message, where the sending state of the target message includes sending, sending success, or sending failure, and is not limited herein.
According to the embodiment of the disclosure, a gateway may refer to a device that implements network interconnection above a network layer, and the gateway may implement functions such as message parsing, communication, resource configuration, and the like.
Specifically, the resource configuration function may refer to locally storing a configuration file in the gateway, where the configuration file may be configured with a plurality of target application numbers corresponding to IP addresses of a plurality of platform servers, respectively, and a number of connections that need to be established with each platform server.
The communication function means that the gateway can establish long connection communication with the platform servers, the gateway can acquire all target application numbers and the number of connections to be established with each platform server from the configuration file, establish a group of long connections between each target application number and each platform server, and store the establishment information of the target application numbers and the long connections.
The message analysis function means that the gateway can analyze a communication message sent by the host, acquire target service data and a target application number, and call a long connection communication process associated with the target application number to push the target service data to the platform server.
According to the embodiment of the disclosure, in the process that the target batch process is in the starting state, the process batch number of the message to be sent is obtained from the target batch process of the business transaction, the target message belonging to the same batch as the process batch number is determined from the message detail table according to the process batch number, then the target business data and the target application number in the target message are filled into the message template to generate the communication message, the communication message is sent to the gateway, the communication message is analyzed by the gateway to obtain the target business data and the target application number, so that the gateway selects the corresponding long connection communication process to send the target business data according to the target application number.
Fig. 3 schematically shows a flow chart of a business data processing method according to another embodiment of the present disclosure.
As shown in FIG. 3, the method 300 may further include operations S301-S305.
In operation S301, the method further includes receiving, by using the communication interface, service data of the transaction service from the host, where the service data has a corresponding application number.
In operation S302, a batch range corresponding to an application number in the traffic data is determined based on the parameter configuration table.
In operation S303, a batch number of the service data is generated based on the batch range.
In operation S304, the service data, the application number, and the lot number are recorded in the message list.
In operation S305, feedback information indicating that the transaction service is completed is transmitted to the host.
According to the embodiment of the disclosure, when the interactive process is carried out with the host computer through the communication interface, the business data of the transaction business from the host computer is received, the corresponding application number in the business data and the generated batch number are recorded in the message detail table, and then the host computer receives the feedback information indicating that the transaction business is completed. The host can continue to process the service without pushing the service data to the platform server, so that the overall processing time of the service data processing is reduced, and the timeliness of the service data processing is improved.
FIG. 4 schematically shows a schematic diagram of a batch process workflow according to an embodiment of the present disclosure.
As shown in FIG. 4, the batch process workflow may include operations S401-S405.
In operation S401, the running state of the lot process is judged. In case that it is determined that the batch process is in the dormant state, operation S402 is performed. In the case where it is determined that the lot process is in the running state, operation S404 is performed. In operation S402, it is determined whether the stop operation duration of the batch process is greater than or equal to a preset dormancy duration. In the case where it is determined that the stop operation time period of the batch process is greater than or equal to the preset sleep time period, operation S403 is performed. In a case that it is determined that the stop operation duration of the batch process is less than the preset sleeping duration, operation S404 is performed.
In operation S403, the control batch process enters a startup state.
In operation S404, it is determined whether the batch process is completed. In the case where it is determined that the lot process is completed, operation S405 is performed. In a case where it is determined that the batch process is not completely processed, a message of the next batch is acquired, and operation S401 is performed in return.
In operation S405, control enters the sleep state for the batch process.
According to the embodiment of the disclosure, the business data processing method further includes acquiring the running states of the plurality of batch processes in a polling check mode, wherein the target batch process belongs to the plurality of batch processes.
According to an embodiment of the present disclosure, the run state of a batch process includes a sleep state and a start state.
According to the embodiment of the disclosure, for each batch process, under the condition that the batch process is in the dormant state, the operation stopping time length of the batch process is determined, and under the condition that the operation stopping time length is greater than or equal to the preset dormant time length, the batch process is controlled to enter the starting state, and the completion condition of the batch process is determined.
According to the embodiment of the disclosure, for each batch process, the operation stopping time length of the batch process is determined under the condition that the batch process is in the dormant state, and the completion condition of the batch process is determined under the condition that the operation stopping time length is less than the preset dormant time length.
According to the embodiment of the disclosure, when the completion condition of the batch process is determined, the batch process is controlled to enter a dormant state under the condition that the batch process is completely completed; and under the condition that the batch process is not completely finished, acquiring the running state of the batch process, and entering polling check.
FIG. 5 schematically shows a schematic diagram of a batch process workflow according to another embodiment of the present disclosure.
As shown in FIG. 5, the batch process workflow may include operations S501-S509.
In operation S501, for each lot process, in the case where the lot process is in the activated state, process processing information of the lot process is acquired from the data table.
In operation S502, it is determined whether the processing time duration of the batch process is greater than or equal to the processing time duration threshold.
In operation S503, it is determined whether the number of messages processed by the batch process is greater than or equal to a message number threshold.
In operation S504, the message transmission status of all messages in the message list is determined.
In operation S505, the message data with processing is obtained from the message list, and the message template is filled with the message to be processed, so as to generate a communication message.
In operation S506, a communication packet sent by the message to be processed is sent to the gateway, and a sending status of the message to be processed is determined.
In operation S507, it is determined whether the number of retries of the transmission of the message to be processed is greater than or equal to a threshold number of retries.
In operation S508, the message sending status in the message list is updated, and the number of messages processed by the batch process is updated.
In operation S509, the run state is saved before the batch process enters the sleep state.
In operation S501, when the batch process is in the starting state, the process processing information of the batch process is obtained from the data table, and in operation S502, it is determined whether the processing time duration of the batch process is greater than or equal to the processing time duration threshold. In the case that the processing duration of the batch process is less than the processing duration threshold, operation S503 is executed to determine whether the number of processed messages of the batch process is greater than or equal to the message number threshold. In the case that the number of messages processed by the batch process is less than the message number threshold, operation S504 is performed to determine the message sending status of all messages in the message list, where the message sending status may be success or failure in sending.
If the message to be processed exists in the message list, operation S505 is performed to obtain the data of the message to be processed from the message list, and the message to be processed is filled in the message template to generate the communication message. Then, operation S506 is executed to send the communication packet sent by the message to be processed to the gateway, and determine a sending status of the message to be processed, where the sending status of the message may be successful sending or failure sending.
In case of a transmission failure of the pending message, operation S507 is performed to determine whether a retry number of the transmission of the pending message is greater than or equal to a retry number threshold. Returning to execute operation S506 if the number of retries of the transmission of the message to be processed is smaller than the threshold value of the number of retries; if the retry number of the transmission of the message to be processed is greater than or equal to the retry number threshold, operation S508 is performed, the message transmission status in the message detail table is updated, the number of messages processed by the batch process is updated, and operation S502 is performed.
After the above operations are performed, if the processing time of the batch process is greater than or equal to the processing time threshold and the number of messages processed by the batch process is greater than or equal to the message number threshold, then operation S509 is performed, the batch process enters a dormant state, an operating state is saved before the batch process enters the dormant state, and finally the batch process is ended.
According to the embodiment of the disclosure, for each batch process, in the case where the batch process is in the startup state, the process processing information of the batch process is acquired from the data table.
According to an embodiment of the present disclosure, the progress processing information includes a processing time length of the lot progress or a number of messages that the lot progress has processed.
According to the embodiment of the disclosure, in the case that the process processing information satisfies the first process termination condition, that is, the processing duration of the batch process is greater than or equal to the processing duration threshold; or the number of the processed messages of the batch process is greater than or equal to the message number threshold, controlling the batch process to enter a dormant state, and storing the running state before dormancy.
According to the embodiment of the disclosure, the message sending status of the message is also recorded in the message list, and the message sending status includes success or failure of sending.
According to the embodiment of the present disclosure, in the case that the messages in the message list satisfy the second process termination condition, that is, the message sending states of all the messages in the message list are all represented as sent; or the message sending states of the messages belonging to the same batch with the process batch number in the message list are all indicated as sent, the batch process is controlled to enter a dormant state, and the running state is saved before dormancy.
According to the embodiment of the disclosure, under the condition that the message in the message detail table does not satisfy the second process termination condition, that is, under the condition that the message to be processed exists in the message detail table, the message to be processed is filled into the message template to generate a communication message, and then the communication message sent by the message to be processed is sent to the gateway to determine the sending state of the message to be processed.
According to the embodiment of the disclosure, under the condition that the message to be processed is successfully sent, the message sending state in the message detail table is updated, the number of the messages processed by the batch process is updated and recorded, and the process processing information of the batch process is acquired again.
According to the embodiment of the disclosure, the number of retries of transmission of the message to be processed is determined in the case where the transmission of the message to be processed has failed.
According to the embodiment of the disclosure, under the condition that the retry number of the sending of the message to be processed is greater than or equal to the threshold value of the retry number, the message sending state in the message detail table is updated, the number of the messages processed by the batch process is updated and recorded, and the process processing information of the batch process is acquired again; and under the condition that the retry number of the transmission of the message to be processed is less than the threshold value of the retry number, sending a communication message sent by the message to be processed to the gateway, and determining the transmission state of the message to be processed.
According to the embodiment of the disclosure, a data pushing result returned by the gateway is received, and the message sending state of the target message in the message list is modified based on the data pushing result.
According to the embodiment of the disclosure, the sending state of the target message comprises successful sending or failed sending, and in case of successful sending, the message sending state in the message detail table is updated to be successful sending. And under the condition of transmission failure, updating information such as a return error code, a message transmission failure state, the number of message transmission failure times and the like to the message detail table.
Fig. 6 schematically shows a block diagram of a traffic data processing apparatus according to an embodiment of the present disclosure.
As shown in fig. 6, the service data processing apparatus includes an obtaining module 601, a determining module 602, a generating module 603, and a sending module 604.
The obtaining module 601 is configured to obtain a process batch of the target batch process in response to the target batch process being in a starting state.
The determining module 602 is configured to invoke a target batch process, and determine a target message from the message detail table by using a process batch number, where the target message includes target service data, a target application number, and a target batch number, and the target batch number and the process batch number belong to the same batch.
The generating module 603 is configured to fill the message template with the target service data and the target application number in the target message, and generate a communication message.
A sending module 604, configured to send the communication packet to a gateway, where the gateway is configured to parse the communication packet, obtain the target service data and the target application number, and invoke a long connection communication process associated with the target application number to push the target service data to the platform server.
According to the embodiment of the disclosure, in the process that the target batch process is in the starting state, the process batch number of the message to be sent is obtained from the target batch process of the business transaction, the target message belonging to the same batch as the process batch number is determined from the message detail table according to the process batch number, then the target business data and the target application number in the target message are filled into the message template to generate the communication message, the communication message is sent to the gateway, the communication message is analyzed by the gateway to obtain the target business data and the target application number, so that the gateway selects the corresponding long connection communication process according to the target application number to send the target business data.
According to the embodiment of the present disclosure, the service data processing apparatus further includes a first processing module, a second processing module, a third processing module, a fourth processing module, and a fifth processing module.
The first processing module is used for receiving the service data of the transaction service from the host by using the communication interface, wherein the service data has a corresponding application number.
And the second processing module is used for determining the batch range corresponding to the application number based on the parameter configuration table.
And the third processing module is used for generating the batch number of the service data based on the batch range.
And the fourth processing module is used for recording the service data, the application number and the batch number in the message detail table.
And the fifth processing module is used for sending feedback information to the host, wherein the feedback information represents that the transaction service is completed.
According to the embodiment of the disclosure, the service data processing device further comprises a first control module, a second control module and a third control module.
The first control module is used for acquiring the running states of the plurality of batch processes in a polling check mode, wherein the target batch process belongs to the plurality of batch processes.
And the second control module is used for determining the running stopping time length of the batch progress under the condition that the batch progress is in a dormant state for each batch progress.
And the third control module is used for controlling the batch process to enter a starting state under the condition that the running stopping time is longer than or equal to the preset dormancy time.
According to the embodiment of the disclosure, the service data processing device further comprises a fourth control module and a fifth control module.
The fourth control module is used for acquiring the process processing information of the batch process from the data table under the condition that the batch process is in a starting state for each batch process; and
a fifth control module, configured to control the batch process to enter a dormant state when the process processing information satisfies the first process termination condition
According to an embodiment of the present disclosure, the fifth manipulation module includes a first manipulation unit and a second manipulation unit.
The first control unit is used for enabling the processing time length of the batch process to be larger than or equal to the processing time length threshold value.
And the second control unit is used for enabling the number of the processed messages in the batch process to be larger than or equal to the message number threshold.
According to the embodiment of the disclosure, the service data processing apparatus further includes a sixth control module, configured to control the batch process to enter the dormant state when the message in the message detail table meets the second process termination condition.
According to an embodiment of the present disclosure, the sixth manipulation module includes a third manipulation unit and a fourth manipulation unit.
And the third control unit is used for indicating the message sending states of all the messages in the message list as sent.
And the fourth control unit is used for indicating the message sending states of the messages which belong to the same batch with the process batch number in the message list as sent.
According to the embodiment of the disclosure, the service data processing device further comprises a first pushing module and a second pushing module.
And the first pushing module is used for receiving a data pushing result returned by the gateway.
And the second pushing module is used for modifying the message sending state of the target message in the message detail table based on the data pushing result.
Any number of modules, sub-modules, units, sub-units, or at least part of the functionality of any number thereof according to embodiments of the present disclosure may be implemented in one module. Any one or more of the modules, sub-modules, units, and sub-units according to the embodiments of the present disclosure may be implemented by being split into a plurality of modules. Any one or more of the modules, sub-modules, units, sub-units according to embodiments of the present disclosure may be implemented at least partially as a hardware circuit, such as a Field Programmable Gate Array (FPGA), a Programmable Logic Array (PLA), a system on a chip, a system on a substrate, a system on a package, an Application Specific Integrated Circuit (ASIC), or by any other reasonable means of hardware or firmware for integrating or packaging a circuit, or by any one of or a suitable combination of any of software, hardware, and firmware. Alternatively, one or more of the modules, sub-modules, units, sub-units according to embodiments of the disclosure may be at least partially implemented as a computer program module, which when executed may perform the corresponding functions.
For example, any plurality of the obtaining module 601, the determining module 602, the generating module 603, and the sending module 604 may be combined and implemented in one module/unit/sub-unit, or any one of the modules/units/sub-units may be split into a plurality of modules/units/sub-units. Alternatively, at least part of the functionality of one or more of these modules/units/sub-units may be combined with at least part of the functionality of other modules/units/sub-units and implemented in one module/unit/sub-unit. According to an embodiment of the present disclosure, at least one of the obtaining module 601, the determining module 602, the generating module 603, and the sending module 604 may be at least partially implemented as a hardware circuit, such as a Field Programmable Gate Array (FPGA), a Programmable Logic Array (PLA), a system on a chip, a system on a substrate, a system on a package, an Application Specific Integrated Circuit (ASIC), or may be implemented by hardware or firmware in any other reasonable manner of integrating or packaging a circuit, or implemented by any one of three implementations of software, hardware, and firmware, or any suitable combination of any of them. Alternatively, at least one of the obtaining module 601, the determining module 602, the generating module 603, and the sending module 604 may be at least partially implemented as a computer program module, which when executed, may perform a corresponding function.
It should be noted that, in the embodiment of the present disclosure, the service data processing apparatus portion corresponds to the service data processing method portion in the embodiment of the present disclosure, and the description of the service data processing apparatus portion specifically refers to the service data processing method portion, which is not described herein again.
Fig. 7 schematically shows a block diagram of an electronic device adapted to implement a business data processing method according to an embodiment of the present disclosure. The electronic device shown in fig. 7 is only an example, and should not bring any limitation to the functions and the scope of use of the embodiments of the present disclosure.
As shown in fig. 7, a computer electronic device 700 according to an embodiment of the present disclosure includes a processor 701, which can perform various appropriate actions and processes according to a program stored in a Read Only Memory (ROM) 702 or a program loaded from a storage section 708 into a Random Access Memory (RAM) 703. The processor 701 may include, for example, a general purpose microprocessor (e.g., a CPU), an instruction set processor and/or associated chipset, and/or a special purpose microprocessor (e.g., an Application Specific Integrated Circuit (ASIC)), among others. The processor 701 may also include on-board memory for caching purposes. The processor 701 may comprise a single processing unit or a plurality of processing units for performing the different actions of the method flows according to embodiments of the present disclosure.
In the RAM 703, various programs and data necessary for the operation of the electronic apparatus 700 are stored. The processor 701, the ROM 702, and the RAM 703 are connected to each other by a bus 704. The processor 701 performs various operations of the method flows according to the embodiments of the present disclosure by executing programs in the ROM 702 and/or the RAM 703. It is noted that the programs may also be stored in one or more memories other than the ROM 702 and RAM 703. The processor 701 may also perform various operations of method flows according to embodiments of the present disclosure by executing programs stored in the one or more memories.
According to embodiments of the present disclosure, method flows according to embodiments of the present disclosure may be implemented as computer software programs. For example, embodiments of the present disclosure include a computer program product comprising a computer program embodied on a computer readable storage medium, the computer program containing program code for performing the method illustrated by the flow chart. In such an embodiment, the computer program can be downloaded and installed from a network through the communication section 709, and/or installed from the removable medium 711. The computer program, when executed by the processor 701, performs the above-described functions defined in the system of the embodiment of the present disclosure. The above described systems, devices, apparatuses, modules, units, etc. may be implemented by computer program modules according to embodiments of the present disclosure.
The present disclosure also provides a computer-readable storage medium, which may be contained in the apparatus/device/system described in the above embodiments; or may exist separately and not be assembled into the device/apparatus/system. The computer-readable storage medium carries one or more programs which, when executed, implement a method according to an embodiment of the disclosure.
According to an embodiment of the present disclosure, the computer readable storage medium may be a non-volatile computer readable storage medium. Examples may include, but are not limited to: a portable computer diskette, a hard disk, a Random Access Memory (RAM), a read-only memory (ROM), an erasable programmable read-only memory (EPROM or flash memory), a portable compact disc read-only memory (CD-ROM), an optical storage device, a magnetic storage device, or any suitable combination of the foregoing. In the present disclosure, a computer readable storage medium may be any tangible medium that can contain, or store a program for use by or in connection with an instruction execution system, apparatus, or device.
For example, according to embodiments of the present disclosure, a computer-readable storage medium may include the ROM 702 and/or the RAM 703 and/or one or more memories other than the ROM 702 and the RAM 703 described above.
Embodiments of the present disclosure also include a computer program product comprising a computer program containing program code for performing the method provided by the embodiments of the present disclosure, when the computer program product is run on an electronic device, the program code being configured to cause the electronic device to implement the business data processing method provided by the embodiments of the present disclosure.
The computer program, when executed by the processor 701, performs the above-described functions defined in the system/apparatus of the embodiments of the present disclosure. The systems, apparatuses, modules, units, etc. described above may be implemented by computer program modules according to embodiments of the present disclosure.
In one embodiment, the computer program may be hosted on a tangible storage medium such as an optical storage device, a magnetic storage device, or the like. In another embodiment, the computer program may also be transmitted in the form of a signal over a network medium, distributed, and downloaded and installed via the communication section 709, and/or installed from the removable medium 711. The computer program containing program code may be transmitted using any suitable network medium, including but not limited to: wireless, wired, etc., or any suitable combination of the foregoing.
In accordance with embodiments of the present disclosure, program code for executing computer programs provided by embodiments of the present disclosure may be written in any combination of one or more programming languages, and in particular, these computer programs may be implemented using high level procedural and/or object oriented programming languages, and/or assembly/machine languages. The programming language includes, but is not limited to, programming languages such as Java, C + +, python, the "C" language, or the like. The program code may execute entirely on the user's computing device, partly on the user's device, partly on a remote computing device, or entirely on the remote computing device or server. In the case of a remote computing device, the remote computing device may be connected to the user computing device through any kind of network, including a Local Area Network (LAN) or a Wide Area Network (WAN), or may be connected to an external computing device (e.g., through the internet using an internet service provider).
The flowchart and block diagrams in the figures illustrate the architecture, functionality, and operation of possible implementations of systems, methods and computer program products according to various embodiments of the present disclosure. In this regard, each block in the flowchart or block diagrams may represent a module, segment, or portion of code, which comprises one or more executable instructions for implementing the specified logical function(s). It should also be noted that, in some alternative implementations, the functions noted in the block may occur out of the order noted in the figures. For example, two blocks shown in succession may, in fact, be executed substantially concurrently, or the blocks may sometimes be executed in the reverse order, depending upon the functionality involved. It will also be noted that each block of the block diagrams or flowchart illustration, and combinations of blocks in the block diagrams or flowchart illustration, can be implemented by special purpose hardware-based systems that perform the specified functions or acts, or combinations of special purpose hardware and computer instructions. It will be appreciated by those skilled in the art that various combinations and/or combinations of the features recited in the various embodiments of the disclosure and/or the claims may be made even if such combinations or combinations are not explicitly recited in the disclosure. In particular, various combinations and/or combinations of the features recited in the various embodiments and/or claims of the present disclosure may be made without departing from the spirit or teaching of the present disclosure. All such combinations and/or associations are within the scope of the present disclosure.
The embodiments of the present disclosure are described above. However, these examples are for illustrative purposes only and are not intended to limit the scope of the present disclosure. Although the embodiments are described separately above, this does not mean that the measures in the embodiments cannot be used in advantageous combination. The scope of the disclosure is defined by the appended claims and equivalents thereof. Various alternatives and modifications can be devised by those skilled in the art without departing from the scope of the present disclosure, and such alternatives and modifications are intended to be within the scope of the present disclosure.
Claims (12)
1. A service data processing method comprises the following steps:
responding to the starting state of the target batch process, and acquiring a process batch number of the target batch process;
calling the target batch process, and determining a target message from a message detail table by using the process batch number, wherein the target message comprises target service data, a target application number and a target batch number, and the target batch number and the process batch number belong to the same batch;
filling the target service data and the target application number in the target message into a message template to generate a communication message; and
and sending the communication message to a gateway, wherein the gateway is configured to analyze the communication message, acquire the target service data and the target application number, and call a long connection communication process associated with the target application number to push the target service data to a platform server.
2. The method of claim 1, further comprising:
receiving service data of transaction service from a host by using a communication interface, wherein the service data has a corresponding application number;
determining a batch range corresponding to the application number based on a parameter configuration table;
generating a batch number of the service data based on the batch range;
recording the service data, the application number and the batch number in the message detail table; and
sending feedback information to the host, wherein the feedback information indicates that the transaction service is completed.
3. The method of claim 1, further comprising:
acquiring the running states of a plurality of batch processes in a polling check mode, wherein the target batch process belongs to the plurality of batch processes;
for each batch process, determining the running stop duration of the batch process under the condition that the batch process is in a dormant state; and
and controlling the batch process to enter a starting state under the condition that the operation stopping time length is greater than or equal to the preset dormancy time length.
4. The method of claim 3, further comprising:
for each batch process, acquiring process processing information of the batch process from a data table under the condition that the batch process is in a starting state; and
and controlling the batch process to enter a dormant state under the condition that the process processing information meets a first process termination condition.
5. The method of claim 4, wherein the first process termination condition comprises:
the processing time length of the batch process is greater than or equal to a processing time length threshold value; or
The number of messages processed by the batch process is greater than or equal to a message number threshold.
6. The method of claim 4, wherein the message detail table further records a message sending status of the message;
the method further comprises the following steps:
and controlling the batch process to enter a dormant state under the condition that the message in the message list meets a second process termination condition.
7. The method of claim 6, wherein the second process termination condition comprises:
the message sending states of all messages in the message list are represented as sent; or
And the message sending states of the messages belonging to the same batch with the process batch number in the message list are all represented as sent.
8. The method of claim 6, further comprising:
receiving a data pushing result returned by the gateway; and
and modifying the message sending state of the target message in the message list based on the data pushing result.
9. A service data processing apparatus, comprising:
the acquisition module is used for responding to the starting state of the target batch process and acquiring the process batch number of the target batch process;
the determining module is used for calling the target batch process and determining a target message from a message detail table by using the process batch number, wherein the target message comprises target business data, a target application number and a target batch number, and the target batch number and the process batch number belong to the same batch;
a generating module, configured to fill the target service data and the target application number in the target message into a message template, and generate a communication message; and
and the sending module is used for sending the communication message to a gateway, wherein the gateway is configured to analyze the communication message, acquire the target service data and the target application number, and call a long connection communication process associated with the target application number to push the target service data to a platform server.
10. An electronic device, comprising:
one or more processors;
a memory to store one or more instructions that,
wherein the one or more instructions, when executed by the one or more processors, cause the one or more processors to implement the method of any one of claims 1-8.
11. A computer readable storage medium having stored thereon executable instructions which, when executed by a processor, cause the processor to carry out the method of any one of claims 1 to 8.
12. A computer program product comprising computer executable instructions for implementing the method of any one of claims 1 to 8 when executed.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202211534293.2A CN115934378A (en) | 2022-11-30 | 2022-11-30 | Service data processing method and device, electronic equipment and storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202211534293.2A CN115934378A (en) | 2022-11-30 | 2022-11-30 | Service data processing method and device, electronic equipment and storage medium |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN115934378A true CN115934378A (en) | 2023-04-07 |
Family
ID=86698607
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202211534293.2A Pending CN115934378A (en) | 2022-11-30 | 2022-11-30 | Service data processing method and device, electronic equipment and storage medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN115934378A (en) |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN116450367A (en) * | 2023-06-19 | 2023-07-18 | 建信金融科技有限责任公司 | Data processing method, device, equipment and storage medium |
-
2022
- 2022-11-30 CN CN202211534293.2A patent/CN115934378A/en active Pending
Cited By (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN116450367A (en) * | 2023-06-19 | 2023-07-18 | 建信金融科技有限责任公司 | Data processing method, device, equipment and storage medium |
| CN116450367B (en) * | 2023-06-19 | 2023-09-12 | 建信金融科技有限责任公司 | Data processing method, device, equipment and storage medium |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN112953769B (en) | Data transmission method, device, computer system and readable storage medium | |
| CN111782988A (en) | Method, device, computer system and storage medium for determining source of application program | |
| CN108900562B (en) | Login state sharing method and device, electronic equipment and medium | |
| CN114328132A (en) | Method, device, equipment and medium for monitoring state of external data source | |
| US20150067139A1 (en) | Agentless monitoring of computer systems | |
| CN115934378A (en) | Service data processing method and device, electronic equipment and storage medium | |
| CN113132400B (en) | Business processing method, device, computer system and storage medium | |
| CN113852610B (en) | Message processing method, device, computer equipment and storage medium | |
| CN113191889A (en) | Wind control configuration method, configuration system, electronic device and readable storage medium | |
| CN113590355A (en) | Method for realizing workflow callback message and message gateway system | |
| CN113362173A (en) | Anti-duplication mechanism verification method, anti-duplication mechanism verification system, electronic equipment and storage medium | |
| CN109933444A (en) | A kind of instant communication method between applying of lodging | |
| CN110932966A (en) | Message processing method and device, computer storage medium and electronic equipment | |
| CN114244700A (en) | Port processing method and device, electronic equipment and computer readable storage medium | |
| CN115801764A (en) | File transmission method, device, equipment and storage medium | |
| CN113781154A (en) | Information rollback method, system, electronic equipment and storage medium | |
| CN115190008A (en) | Fault processing method, fault processing device, electronic device and storage medium | |
| CN113778798A (en) | Server control method, server control device, electronic device, and storage medium | |
| CN114793232A (en) | Service processing method and device, electronic equipment and storage medium | |
| CN113419887A (en) | Method and device for processing abnormal online transaction of host | |
| CN112506781A (en) | Test monitoring method, test monitoring device, electronic device, storage medium, and program product | |
| WO2023230797A1 (en) | Cross-system test method and apparatus | |
| CN118041804B (en) | Communication equipment networking data detection method and device, electronic equipment and readable medium | |
| US11588744B1 (en) | Automatic scaling of resources for message processing | |
| CN110460601B (en) | Dependency package security detection method, dependency package security detection device and storage medium |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination |