A method and device for triggering delayed tasks based on message queue system

Abstract

The invention provides a message queue system-based delay task triggering method and apparatus. The method comprises the steps of producing messages corresponding to delay tasks by a message queue client as a producer, wherein the messages include task information required for triggering the delay tasks; sending the messages to a message queue by the message queue client as the producer, wherein the messages are arranged in the message queue according to a timeout sequence, and delay time of the delay tasks corresponding to the messages of the same message queue is same; and sending the messages to the message queue client as a consumer according to an arrangement sequence by the message queue, and triggering the corresponding delay tasks in sequence according to the task information by the message queue client of the consumer when the messages are timed out. Therefore, the trigging delay and cost of the delay tasks are shortened and reduced.

Description

technical field [0001] The present disclosure relates to the field of computer technology, in particular to a method and device for triggering delayed tasks based on a message queue system. Background technique [0002] One type of business requirement is as follows: Taking the transfer business as an example, the transfer business is estimated to arrive in three minutes, and each transfer will be checked after three minutes to see if the business has arrived, and an alarm will be issued if it does not arrive. The above query of whether the transfer business has arrived is a delayed task, that is, after the transfer has occurred for a period of time (for example, three minutes), it will be checked whether it has arrived, rather than immediately. In order to trigger the delayed task after the delayed task reaches the timeout time, the current mainstream implementation method can be that every time a transfer occurs, the corresponding information is written into the database (...

AI Technical Summary

Problems solved by technology

[0003] However, the above method of triggering delayed tasks has many disadvantages. First, the implementation cost of the database is relatively high; second, the timer scans the database at fixed intervals. If the interval is too small, higher requirements are placed on the performance of the database. (more queries), and if the interval time is too large, the timing of finding data that meets the conditions will be delayed, resulting in a delay in the triggering of the delayed task

Again, there are too many invalid scans, which wastes machine performance. For example, if the data meets the conditions after 3 minutes and scans once every 10 seconds, the data will be read for 60 seconds*3 / 10 seconds=18 times before the data meets the conditions.

Images