CN116185654A - Method and system for realizing asynchronous data processing based on message queue - Google Patents
Method and system for realizing asynchronous data processing based on message queue Download PDFInfo
- Publication number
- CN116185654A CN116185654A CN202211669978.8A CN202211669978A CN116185654A CN 116185654 A CN116185654 A CN 116185654A CN 202211669978 A CN202211669978 A CN 202211669978A CN 116185654 A CN116185654 A CN 116185654A
- Authority
- CN
- China
- Prior art keywords
- asynchronous
- request
- message queue
- requests
- completion
- 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
- 238000012545 processing Methods 0.000 title claims abstract description 64
- 238000000034 method Methods 0.000 title claims abstract description 38
- 230000004044 response Effects 0.000 claims abstract description 29
- 230000002159 abnormal effect Effects 0.000 claims description 6
- 230000008569 process Effects 0.000 claims description 6
- 238000010586 diagram Methods 0.000 description 8
- 238000004590 computer program Methods 0.000 description 7
- 230000006870 function Effects 0.000 description 4
- 238000012986 modification Methods 0.000 description 4
- 230000004048 modification Effects 0.000 description 4
- 238000003672 processing method Methods 0.000 description 3
- 230000004075 alteration Effects 0.000 description 2
- 238000004364 calculation method Methods 0.000 description 2
- 238000005516 engineering process Methods 0.000 description 2
- 238000013461 design Methods 0.000 description 1
- 230000008030 elimination Effects 0.000 description 1
- 238000003379 elimination reaction Methods 0.000 description 1
- 230000002452 interceptive effect Effects 0.000 description 1
- 238000004519 manufacturing process Methods 0.000 description 1
- 230000003287 optical effect Effects 0.000 description 1
- 238000012827 research and development Methods 0.000 description 1
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/54—Interprogram communication
- G06F9/546—Message passing systems or structures, e.g. queues
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/54—Interprogram communication
- G06F9/547—Remote procedure calls [RPC]; Web services
Landscapes
- Engineering & Computer Science (AREA)
- Software Systems (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
The invention discloses a method and a system for realizing asynchronous data processing based on a message queue, wherein the method comprises the following steps: classifying the asynchronous requests to be processed according to the actual service requirements, wherein the types of the asynchronous requests are classified into the types of the requests which need to be responded immediately after the completion or the types of the asynchronous requests which need not to be responded immediately after the completion; writing the classified asynchronous requests into a message queue, decoupling the asynchronous requests based on the message queue, and respectively processing the asynchronous requests according to the classification; after the asynchronous request is completed, a response result of the asynchronous request which is required to respond to the request type immediately after the asynchronous request is completed is directly sent to the client; or writing the response result of the asynchronous request, which does not need to respond to the request immediately after completion, into the database.
Description
Technical Field
The present invention relates to the field of information technology application technology, and more particularly, to a method and system for implementing asynchronous data processing based on a message queue.
Background
After the software receives various requests of the client, one type of service call request does not need to obtain response information on service logic in real time, but the request still occupies system resources, and the system resources are not released until the response information is received.
In the prior art, at present, a multithreading mode is adopted to process a request which needs to be asynchronous, and a database specified identification record mode is adopted to record a service call state after the execution of a new thread is finished. And simultaneously, the new thread is started, and the database identification state is inquired in a designated time interval in a polling mode. And when the server identification state is inquired to be recorded as the completion of the execution of the asynchronous thread, returning response information to prompt the client to complete the corresponding request operation. This scheme is limited by the system thread increase in multiple concurrent states and the resulting system pressure surge in frequent polling requests. The burden of the server side and the database is greatly increased.
The prior art, application number (US 14287007) provides software and metadata structures for distributed and interactive database architectures for parallel and asynchronous data processing of complex data and real-time query processing, and the prior art provides a data processing system and architecture for distributed processing that can be executed in parallel and asynchronously, providing not only high-speed data processing, but also efficient and valuable decoupling of the provision of output data from the provision of input data.
However, the prior art fails to address requests initiated by clients that require asynchronous processing. The distributed processing method is mostly used in basic data processing in large data items, and a request initiated by a client is not suitable for distributed processing. The aim of decoupling and peak elimination can be achieved by adopting a message queue mode.
Therefore, a technique is needed to implement asynchronous data processing based on message queues.
Disclosure of Invention
The technical scheme of the invention provides a method and a system for realizing asynchronous data processing based on a message queue, which are used for solving the problem of how to realize asynchronous data processing based on the message queue.
In order to solve the above problems, the present invention provides a method for implementing asynchronous data processing based on a message queue, the method comprising:
classifying the asynchronous requests to be processed according to the actual service requirements, wherein the types of the asynchronous requests are classified into the types of the requests which need to be responded immediately after the completion or the types of the asynchronous requests which need not to be responded immediately after the completion;
writing the classified asynchronous requests into a message queue, decoupling the asynchronous requests based on the message queue, and respectively processing the asynchronous requests according to the classification;
after the asynchronous request is completed, a response result of the asynchronous request which is required to respond to the request type immediately after the asynchronous request is completed is directly sent to the client; or alternatively
And writing the response result of the asynchronous request which does not need to respond to the request immediately after completion into the database.
Preferably, the asynchronous request for responding to the request immediately after completion includes: export of large data volumes or issuance of specific transactions;
the asynchronous request that does not require an immediate response to the request after completion includes: after the request is completed, the client executes the program until a certain step, and the system automatically triggers to inquire whether the asynchronous request processing is completed.
Preferably, the writing the classified asynchronous request into a message queue, decoupling the asynchronous request based on the message queue, and processing the asynchronous request according to the category respectively, including:
after receiving an asynchronous request sent by a client, an application system writes the abnormal request into a message queue;
after receiving the push information of the message queue, the consumer of the message queue executes different programs according to service conditions and is decoupled from the application system.
Preferably, the method further comprises:
taking the message queue as a buffer area of the asynchronous request, and accumulating a large amount of asynchronous requests in the message queue;
the asynchronous request is processed based on processing power.
Preferably, the method further comprises: different actual business demands correspond to different message queue middleware.
Based on another aspect of the present invention, the present invention provides a system for implementing asynchronous data processing based on a message queue, the system comprising:
the initial unit is used for classifying the asynchronous requests to be processed according to the actual service requirements, and the types of the asynchronous requests are classified into the types of the requests which need to be responded immediately after the completion or the types of the asynchronous requests which need not to be responded immediately after the completion;
the execution unit is used for writing the classified asynchronous requests into a message queue, decoupling the asynchronous requests based on the message queue, and respectively processing the asynchronous requests according to the classification;
the result unit is used for directly sending a response result of the asynchronous request which is required to be immediately responded to the request type to the client after the asynchronous request is completed; or writing the response result of the asynchronous request, which does not need to respond to the request immediately after completion, into the database.
Preferably, the asynchronous request for responding to the request immediately after completion includes: export of large data volumes or issuance of specific transactions;
the asynchronous request that does not require an immediate response to the request after completion includes: after the request is completed, the client executes the program until a certain step, and the system automatically triggers to inquire whether the asynchronous request processing is completed.
Preferably, the executing unit is configured to write the classified asynchronous requests into a message queue, decouple the asynchronous requests based on the message queue, and process the asynchronous requests according to categories, and includes:
after receiving an asynchronous request sent by a client, an application system writes the abnormal request into a message queue;
after receiving the push information of the message queue, the consumer of the message queue executes different programs according to service conditions and is decoupled from the application system.
Preferably, the execution unit is further configured to:
taking the message queue as a buffer area of the asynchronous request, and accumulating a large amount of asynchronous requests in the message queue;
the asynchronous request is processed based on processing power.
Preferably, the method further comprises: different actual business demands correspond to different message queue middleware.
The technical scheme of the invention provides a method and a system for realizing asynchronous data processing based on a message queue, wherein the method comprises the following steps: classifying the data of the asynchronous request to be processed according to the actual service requirement, wherein the type of the asynchronous request is classified into immediately responding to the request after the completion or not immediately responding to the request after the completion; writing the classified asynchronous requests into a message queue, decoupling the asynchronous requests based on the message queue, and respectively processing the asynchronous requests according to the categories; when the asynchronous request is completed, directly transmitting a response result of the asynchronous request which is required to be immediately responded to the request type to the client; or writing the response result of the asynchronous request, which does not need to respond to the request immediately after completion, into the database. The technical scheme of the invention replaces the traditional multithreading mode by the message queue to realize asynchronous data processing, thereby reducing the system pressure. The asynchronous data processing method and the asynchronous data processing system based on the message queue, provided by the technical scheme of the invention, utilize the property of the message queue, realize decoupling of asynchronous data processing, improve the throughput of the system, reduce the resource consumption of the system and ensure the stability of the software system.
Drawings
Exemplary embodiments of the present invention may be more completely understood in consideration of the following drawings:
FIG. 1 is a flow chart of a method for implementing asynchronous data processing based on message queues in accordance with a preferred embodiment of the present invention; and
FIG. 2 is a flowchart of an asynchronous data request method according to a preferred embodiment of the present invention;
fig. 3 is a system structural diagram for implementing asynchronous data processing based on message queues according to a preferred embodiment of the present invention.
Detailed Description
The exemplary embodiments of the present invention will now be described with reference to the accompanying drawings, however, the present invention may be embodied in many different forms and is not limited to the examples described herein, which are provided to fully and completely disclose the present invention and fully convey the scope of the invention to those skilled in the art. The terminology used in the exemplary embodiments illustrated in the accompanying drawings is not intended to be limiting of the invention. In the drawings, like elements/components are referred to by like reference numerals.
Unless otherwise indicated, terms (including technical and scientific terms) used herein have the same meaning as commonly understood by one of ordinary skill in the art. In addition, it will be understood that terms defined in commonly used dictionaries should be interpreted as having a meaning that is consistent with their meaning in the context of the relevant art and will not be interpreted in an idealized or overly formal sense.
Fig. 1 is a flow chart of a method for implementing asynchronous data processing based on message queues in accordance with a preferred embodiment of the present invention. The invention replaces the traditional multithreading to realize asynchronous data processing by the message queue mode, and lightens the system pressure.
The invention provides a method for realizing asynchronous data processing based on a message queue, which comprises the following steps:
step 101: classifying the data of the asynchronous request to be processed according to the actual service requirement, wherein the type of the asynchronous request is classified into immediately responding to the request after the completion or not immediately responding to the request after the completion; preferably, the asynchronous request to respond to the request immediately after completion includes: export of large data volumes or issuance of specific transactions;
asynchronous requests that do not require immediate response to a request after completion include: after the request is completed, the client executes the program until a certain step, and the system automatically triggers to inquire whether the asynchronous request processing is completed.
The invention classifies the data needing to be asynchronously requested according to the actual service condition.
And immediately feeding back response information to the client after the request is completed. For export of large amounts of data or issuance of certain transactions, etc.
After the request is completed, the client executes the program until a certain step, and the system automatically triggers to inquire whether the asynchronous request processing is completed. The method is mainly used for complex calculation in a flow system, and the initialization operation of the subsequent node is performed after the execution of the node is finished.
The invention sets a classification mark (request type) to the asynchronous data request aiming at the two request cases, and the request is the case of the request 1. The requesttype= "1" as the request is the case described in 2 above. The requesttype= "2".
Step 102: writing the classified asynchronous requests into a message queue, decoupling the asynchronous requests based on the message queue, and respectively processing the asynchronous requests according to the categories;
preferably, writing the classified asynchronous requests into a message queue, decoupling the asynchronous requests based on the message queue, and processing the asynchronous requests according to categories respectively, including:
after receiving an asynchronous request sent by a client, an application system writes the abnormal request into a message queue;
after receiving the push information of the message queue, the consumer of the message queue executes different programs according to the service condition and is decoupled from the application system.
Preferably, the method further comprises:
the message queue is used as a buffer area of the asynchronous request, and a large number of asynchronous requests are backlogged in the message queue;
asynchronous requests are processed based on processing power.
Preferably, the method further comprises: different actual business demands correspond to different message queue middleware.
The producer and the consumer of the message queue of the invention are both back-end services, the application system is used as the producer to write the request information into the message queue after receiving the request from the client, and the consumer executes different programs according to the service condition after receiving the push information from the message queue, so that the consumer can be an independent application or program and can be effectively decoupled from the application system, thereby increasing the stability of the application system. Based on the message queue as buffer, a great amount of requests can be backlogged in the message queue in the peak period of the user use, the processor obtains the request amount according to the maximum processing capacity of the processor, and the processor consumes the request amount after the request period. And huge pressure on the system and the database can be effectively avoided.
Step 103: when the asynchronous request is completed, directly transmitting a response result of the asynchronous request which is required to be immediately responded to the request type to the client; or alternatively
Step 104: and writing the response result of the asynchronous request which does not need to respond to the request immediately after completion into the database.
Finally, after the asynchronous request is processed, if the request is requesttype= "1", the invention can directly send response information to the client. If the requesttype= "2", writing the execution completion status information into the database, waiting for the user to actively inquire the data processing status when executing the corresponding operation, and if not, prompting the user to wait. As shown in fig. 2.
According to the invention, different message queue middleware is selected according to different service scenes, and the system design is completed according to the classification of each service requirement.
The invention utilizes the message queue to decouple the asynchronous request, can distribute the asynchronous processing program to different servers, and can be developed by adopting various research and development modes such as java, python and the like.
The asynchronous data processing method and the asynchronous data processing system based on the message queue provided by the invention utilize the property of the message queue, realize decoupling of asynchronous data processing, improve the throughput of the system, reduce the resource consumption of the system and ensure the stability of the software system.
Fig. 3 is a system structural diagram for implementing asynchronous data processing based on message queues according to a preferred embodiment of the present invention. As shown in fig. 3, the present invention provides a system for implementing asynchronous data processing based on message queues, the system comprising:
an initial unit 301, configured to classify an asynchronous request to be processed according to actual service requirements, where the type of the asynchronous request is classified into a request that needs to be responded immediately after completion, or a request that does not need to be responded immediately after completion; preferably, the asynchronous request to respond to the request immediately after completion includes: export of large data volumes or issuance of specific transactions;
asynchronous requests that do not require immediate response to a request after completion include: after the request is completed, the client executes the program until a certain step, and the system automatically triggers to inquire whether the asynchronous request processing is completed.
The invention classifies the data needing to be asynchronously requested according to the actual service condition.
And immediately feeding back response information to the client after the request is completed. For export of large amounts of data or issuance of certain transactions, etc.
After the request is completed, the client executes the program until a certain step, and the system automatically triggers to inquire whether the asynchronous request processing is completed. The method is mainly used for complex calculation in a flow system, and the initialization operation of the subsequent node is performed after the execution of the node is finished.
The invention sets a classification mark (request type) to the asynchronous data request aiming at the two request cases, and the request is the case of the request 1. The requesttype= "1" as the request is the case described in 2 above. The requesttype= "2".
The execution unit 302 is configured to write the classified asynchronous requests into a message queue, decouple the asynchronous requests based on the message queue, and process the asynchronous requests according to the classification respectively;
preferably, the executing unit 302 is configured to write the classified asynchronous requests into a message queue, decouple the asynchronous requests based on the message queue, and process the asynchronous requests according to the categories, and includes:
after receiving an asynchronous request sent by a client, an application system writes the abnormal request into a message queue;
after receiving the push information of the message queue, the consumer of the message queue executes different programs according to the service condition and is decoupled from the application system.
Preferably, the execution unit 302 is further configured to:
the message queue is used as a buffer area of the asynchronous request, and a large number of asynchronous requests are backlogged in the message queue;
asynchronous requests are processed based on processing power.
Preferably, the method further comprises: different actual business demands correspond to different message queue middleware.
The producer and the consumer of the message queue of the invention are both back-end services, the application system is used as the producer to write the request information into the message queue after receiving the request from the client, and the consumer executes different programs according to the service condition after receiving the push information from the message queue, so that the consumer can be an independent application or program and can be effectively decoupled from the application system, thereby increasing the stability of the application system. Based on the message queue as buffer, a great amount of requests can be backlogged in the message queue in the peak period of the user use, the processor obtains the request amount according to the maximum processing capacity of the processor, and the processor consumes the request amount after the request period. And huge pressure on the system and the database can be effectively avoided.
A result unit 303, configured to send a response result of the asynchronous request that needs to respond to the request type immediately after completion to the client directly after the asynchronous request is completed; or writing the response result of the asynchronous request, which does not need to respond to the request immediately after completion, into the database.
Finally, after the asynchronous request is processed, if the request is requesttype= "1", the invention can directly send response information to the client. If the requesttype= "2", writing the execution completion status information into the database, waiting for the user to actively inquire the data processing status when executing the corresponding operation, and if not, prompting the user to wait.
It will be appreciated by those skilled in the art that embodiments of the present invention may be provided as a method, system, or computer program product. Accordingly, the present invention may take the form of an entirely hardware embodiment, an entirely software embodiment or an embodiment combining software and hardware aspects. Furthermore, the present invention may take the form of a computer program product embodied on one or more computer-usable storage media (including, but not limited to, disk storage, CD-ROM, optical storage, and the like) having computer-usable program code embodied therein. The scheme in the embodiment of the invention can be realized by adopting various computer languages, such as object-oriented programming language Java, an transliteration script language JavaScript and the like.
The present invention is described with reference to flowchart illustrations and/or block diagrams of methods, apparatus (systems) and computer program products according to embodiments of the invention. It will be understood that each flow and/or block of the flowchart illustrations and/or block diagrams, and combinations of flows and/or blocks in the flowchart illustrations and/or block diagrams, can be implemented by computer program instructions. These computer program instructions may be provided to a processor of a general purpose computer, special purpose computer, embedded processor, or other programmable data processing apparatus to produce a machine, such that the instructions, which execute via the processor of the computer or other programmable data processing apparatus, create means for implementing the functions specified in the flowchart flow or flows and/or block diagram block or blocks.
These computer program instructions may also be stored in a computer-readable memory that can direct a computer or other programmable data processing apparatus to function in a particular manner, such that the instructions stored in the computer-readable memory produce an article of manufacture including instruction means which implement the function specified in the flowchart flow or flows and/or block diagram block or blocks.
These computer program instructions may also be loaded onto a computer or other programmable data processing apparatus to cause a series of operational steps to be performed on the computer or other programmable apparatus to produce a computer implemented process such that the instructions which execute on the computer or other programmable apparatus provide steps for implementing the functions specified in the flowchart flow or flows and/or block diagram block or blocks.
While preferred embodiments of the present invention have been described, additional variations and modifications in those embodiments may occur to those skilled in the art once they learn of the basic inventive concepts. It is therefore intended that the following claims be interpreted as including the preferred embodiments and all such alterations and modifications as fall within the scope of the invention.
It will be apparent to those skilled in the art that various modifications and variations can be made to the present invention without departing from the spirit or scope of the invention. Thus, it is intended that the present invention also include such modifications and alterations insofar as they come within the scope of the appended claims or the equivalents thereof.
The invention has been described with reference to a few embodiments. However, as is well known to those skilled in the art, other embodiments than the above disclosed invention are equally possible within the scope of the invention, as defined by the appended patent claims.
Generally, all terms used in the claims are to be interpreted according to their ordinary meaning in the technical field, unless explicitly defined otherwise therein. All references to "a/an/the [ means, component, etc. ]" are to be interpreted openly as referring to at least one instance of said means, component, etc., unless explicitly stated otherwise. The steps of any method disclosed herein do not have to be performed in the exact order disclosed, unless explicitly stated.
Claims (10)
1. A method for implementing asynchronous data processing based on a message queue, the method comprising:
classifying the asynchronous requests to be processed according to the actual service requirements, wherein the types of the asynchronous requests are classified into the types of the requests which need to be responded immediately after the completion or the types of the asynchronous requests which need not to be responded immediately after the completion;
writing the classified asynchronous requests into a message queue, decoupling the asynchronous requests based on the message queue, and respectively processing the asynchronous requests according to the classification;
after the asynchronous request is completed, a response result of the asynchronous request which is required to respond to the request type immediately after the asynchronous request is completed is directly sent to the client; or alternatively
And writing the response result of the asynchronous request which does not need to respond to the request immediately after completion into the database.
2. The method of claim 1, the asynchronous request to respond to a request immediately after completion comprising: export of large data volumes or issuance of specific transactions;
the asynchronous request that does not require an immediate response to the request after completion includes: after the request is completed, the client executes the program until a certain step, and the system automatically triggers to inquire whether the asynchronous request processing is completed.
3. The method of claim 1, wherein writing the classified asynchronous requests into a message queue, decoupling the asynchronous requests based on the message queue, and processing the asynchronous requests by category, respectively, comprises:
after receiving an asynchronous request sent by a client, an application system writes the abnormal request into a message queue;
after receiving the push information of the message queue, the consumer of the message queue executes different programs according to service conditions and is decoupled from the application system.
4. A method according to claim 3, further comprising:
taking the message queue as a buffer area of the asynchronous request, and accumulating a large amount of asynchronous requests in the message queue;
the asynchronous request is processed based on processing power.
5. A method according to claim 3, further comprising: different actual business demands correspond to different message queue middleware.
6. A system for implementing asynchronous data processing based on a message queue, the system comprising:
the initial unit is used for classifying the asynchronous requests to be processed according to the actual service requirements, and the types of the asynchronous requests are classified into the types of the requests which need to be responded immediately after the completion or the types of the asynchronous requests which need not to be responded immediately after the completion;
the execution unit is used for writing the classified asynchronous requests into a message queue, decoupling the asynchronous requests based on the message queue, and respectively processing the asynchronous requests according to the classification;
the result unit is used for directly sending a response result of the asynchronous request which is required to be immediately responded to the request type to the client after the asynchronous request is completed; or writing the response result of the asynchronous request, which does not need to respond to the request immediately after completion, into the database.
7. The system of claim 6, the asynchronous request to respond to a request immediately after completion comprising: export of large data volumes or issuance of specific transactions;
the asynchronous request that does not require an immediate response to the request after completion includes: after the request is completed, the client executes the program until a certain step, and the system automatically triggers to inquire whether the asynchronous request processing is completed.
8. The system of claim 6, the execution unit to write the classified asynchronous requests into a message queue, decouple the asynchronous requests based on the message queue, and process the asynchronous requests by category, respectively, comprising:
after receiving an asynchronous request sent by a client, an application system writes the abnormal request into a message queue;
after receiving the push information of the message queue, the consumer of the message queue executes different programs according to service conditions and is decoupled from the application system.
9. The system of claim 8, the execution unit further to:
taking the message queue as a buffer area of the asynchronous request, and accumulating a large amount of asynchronous requests in the message queue;
the asynchronous request is processed based on processing power.
10. The system of claim 8, further comprising: different actual business demands correspond to different message queue middleware.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202211669978.8A CN116185654A (en) | 2022-12-25 | 2022-12-25 | Method and system for realizing asynchronous data processing based on message queue |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202211669978.8A CN116185654A (en) | 2022-12-25 | 2022-12-25 | Method and system for realizing asynchronous data processing based on message queue |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN116185654A true CN116185654A (en) | 2023-05-30 |
Family
ID=86445311
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202211669978.8A Pending CN116185654A (en) | 2022-12-25 | 2022-12-25 | Method and system for realizing asynchronous data processing based on message queue |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN116185654A (en) |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN118885123A (en) * | 2024-08-05 | 2024-11-01 | 灵岫科技(深圳)有限公司 | A method for asynchronously writing data based on a queue and a database |
-
2022
- 2022-12-25 CN CN202211669978.8A patent/CN116185654A/en active Pending
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN118885123A (en) * | 2024-08-05 | 2024-11-01 | 灵岫科技(深圳)有限公司 | A method for asynchronously writing data based on a queue and a database |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US9917913B2 (en) | Large message support for a publish-subscribe messaging system | |
| US6633954B1 (en) | Method for enhancing host application performance with a DASD using task priorities | |
| US20090064147A1 (en) | Transaction aggregation to increase transaction processing throughout | |
| US9529651B2 (en) | Apparatus and method for executing agent | |
| CN112416960B (en) | Data processing method, device, equipment and storage medium under multiple scenes | |
| CN103310460A (en) | Image characteristic extraction method and system | |
| CN106569896B (en) | A data distribution and parallel processing method and system | |
| US7454478B1 (en) | Business message tracking system using message queues and tracking queue for tracking transaction messages communicated between computers | |
| CN113760242B (en) | Data processing method, device, server and medium | |
| CN116185654A (en) | Method and system for realizing asynchronous data processing based on message queue | |
| CN112689248A (en) | Message processing method and system | |
| US11861425B2 (en) | Runtime mapping of asynchronous application programming interface messaging topics and schemas | |
| CN110019045B (en) | Log floor method and device | |
| US20240265022A1 (en) | Data query request processing method, electronic device, and storage medium | |
| US11157506B2 (en) | Multiform persistence abstraction | |
| CN112541816A (en) | Distributed stream computing processing engine for internet financial consumption credit batch business | |
| CN114500417B (en) | A communication message transmission method, message processing hardware and storage medium | |
| CN110688223A (en) | Data processing methods and related products | |
| CN115237639A (en) | A single-chip data processing system and method for realizing multi-channel data acquisition | |
| US11392433B1 (en) | Generation of asynchronous application programming interface specifications for messaging topics | |
| CN114327939B (en) | Message distribution method, device, electronic device and storage medium | |
| CN112395076B (en) | Network data processing method, device and storage medium | |
| CN113641679B (en) | Data transfer method, data transfer system, computer equipment and medium | |
| EP3791274A1 (en) | Method and node for managing a request for hardware acceleration by means of an accelerator device | |
| CN116755858A (en) | Kafka data management method, device, computer equipment 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 |