System and method for providing message queues for multinode applications in a middleware machine environment
US-9996403-B2 · Jun 12, 2018 · US
US11611634B2 · US · B2
| Field | Value |
|---|---|
| Publication number | US-11611634-B2 |
| Application number | US-201716470206-A |
| Country | US |
| Kind code | B2 |
| Filing date | Dec 21, 2017 |
| Priority date | Dec 26, 2016 |
| Publication date | Mar 21, 2023 |
| Grant date | Mar 21, 2023 |
A practical reading order for non-experts. Skip the full description unless you need deep technical detail.
What the patent document calls the invention.
A short plain-language summary of the technical disclosure.
Who owns or filed the patent and who is credited as inventor.
Filing, priority, publication, and grant dates set the timeline.
The legal scope of protection — read this for what is actually claimed.
Technology tags used to group this patent with similar filings.
Prior art links and similar publications in this corpus.
Official abstract text for this publication.
Disclosed are a method and device for timeout monitoring, comprising: determining key information of a request message, the key information including a sending time of the request message; storing the key information to a first level cache; scanning the first level cache according to a set frequency, if the first level cache includes a first request message, storing the key information of the first request message into a second level cache, the first request message being a request message for which a reply message is not received; scanning the second level cache, and determining by a message log whether a reply message is received for a second request message in the second level cache, if not, the second request message times out, the second request message is a request message in which the difference value between a sending time and a current time is greater than a time-out threshold.
Opening claim text (preview).
The invention claimed is: 1. A method for timeout monitoring, comprising: determining, by a server, key information of a request message, wherein the key information comprises a sending time of the request message; storing, by the server, the key information into a first level cache; scanning, by the server, the first level cache at a preset frequency, and under a condition the first level cache comprises a first request message, storing key information of the first request message into a second level cache, wherein the first request message is not fed back through a response message; and scanning, by the server, the second level cache, determining whether a response message corresponding to a second request message in the second level cache is not received, according to a message log, and under a condition the response message corresponding to the second request message in the second level cache is not received, determining that the second request message is timeout, wherein a difference between a sending time of the second request message and a current time is greater than a time-out threshold. 2. The method according to claim 1 , further comprises: under a condition the server receives the response message, searching in the first level cache for the request message corresponding to the response message; and under a condition the request message corresponding to the response message is found, marking the key information of the request message corresponding to the response message as RESPONDED. 3. The method according to claim 1 , wherein the storing, by the server, the key information into the first level cache comprises: determining, by the server, a writing time for storing the request message into the first level cache; storing, by the server, the key information of the request message into a corresponding memory zone according to a remainder result of dividing the writing time of the request message by N, wherein a memory in the first level cache is divided in advance into N memory zones, and a size of each memory zone is a size of a data segment of the key information multiplied with an estimated number of transactions in a unit of time. 4. The method according to claim 3 , wherein the scanning, by the server, the first level cache at the preset frequency comprises: creating, by the server, N monitoring processes, wherein each of the monitoring process corresponds to one of the memory zones, and scans a corresponding memory zone at the preset frequency. 5. The method according to claim 1 , wherein the scanning, by the server, the second level cache, and determining whether a response message to a second request message in the second level cache is received, according to the message log comprises: storing, by the server, the key information of the first request messages sequentially into a link list acting as the second level cache, from a head of the link list, in a sequential order of the sending time of the first request messages; inquiring, by the server, the key information of the first request message in the link list sequentially from the head of the link list, and determining whether a difference between the sending time of the first request messages and the current time is greater than the time-out threshold; and under a condition the difference between the sending time of the first request messages and the current time is greater than the time-out threshold, determining, by the server, the first request message as the second request message, and determining whether the response message corresponding to the second request message is received, according to the message log of the second request message; and under a condition the difference between the sending time of the first request messages and the current time is not greater than the time-out threshold, performing a timeout processing on the second request message. 6. A timeout monitoring apparatus, comprising: a writing module configured to determine key information of a request message, wherein the key information comprises a sending time of the request message; the writing module further configured to store the key information into a first level cache; a first monitoring module configured to scan the first level cache at a preset frequency, and under a condition the first level cache comprises a first request message, to store key information of the first request message into a second level cache, wherein the first request message is not fed back through a response message; and a second monitoring module configured to scan the second level cache, to determine whether a response message corresponding to a second request message in the second level cache is received, according to a message log, and under a condition the response message corresponding to the second request message in the second level cache is not received, to determine that the second request message is timeout, wherein a difference between a sending time of the second request message and a current time is greater than a time-out threshold. 7. The apparatus according to claim 6 , wherein the writing module is further configured: under a condition the response message is received, to search in the first level cache for the request message corresponding to the response message; and under a condition the request message corresponding to the response message is found, to mark the key information of the request message corresponding to the response message as RESPONDED. 8. The apparatus according to claim 6 , wherein the writing module is configured: to determine a writing time for storing the request message into the first level cache; and to store the key information of the request message into a corresponding memory zone according to a remainder result of dividing the writing time of the request message by N, wherein a memory in the first level cache is divided in advance into N memory zones, and a size of each memory zone is a size of a data segment of the key information multiplied with an estimated number of transactions in a unit of time. 9. The apparatus according to claim 8 , wherein the first monitoring module is configured: to create N monitoring processes, wherein each of the monitoring process corresponds to one of the memory zones, and scans a corresponding memory zone at the preset frequency. 10. The apparatus according to claim 6 , wherein the second monitoring module is configured: to store the key information of the first request messages sequentially into a link list acting as the second level cache, from a head of the link list, in a sequential order of the sending time of the first request messages; to inquiry the key information of the first request message in the link list sequentially from the head of the link list, and determining whether a difference between the sending time of the first request messages and the current time is greater than the time-out threshold; and under a condition the difference between the sending time of the first request messages and the current time is greater than the time-out threshold, to determine the first request message as the second request message, and to determine whether the response message corresponding to the second request message is received, according to the message log of the second request message; and under a condition the difference between the sending time of the first request messages and the current time is not greater than the time-out threshold, to perform a timeout processing on the second request message. 11. A computing device, comprising: a memory configured to store program instructions; and a processor configured to invoke the program instructions stored in th
Storing data temporarily at an intermediate stage, e.g. caching · CPC title
where the computing system is distributed, e.g. networked systems, clusters, multiprocessor systems (multiprogramming arrangements G06F9/46; allocation of resources G06F9/50) · CPC title
Details of the supervisory signal · CPC title
with two or more cache hierarchy levels (with multilevel cache hierarchies G06F12/0811) · CPC title
Establishing a time schedule for servicing the requests · CPC title
Related publications grouped by family.
Answers are generated from the same data shown on this page.