Message processing method and device, and electronic device

Abstract

An embodiment of the present invention provides a message processing method and device, and an electronic device. A plurality of timing queues are provided, and the plurality of timing queues correspond to a plurality of preset delay levels respectively. The message processing method includes: receiving a timing message, and writing the timing message into a data file; storing index information ofthe timing message in the corresponding timing queue according to the delay level of the timing message; separately monitoring the plurality of timing queues to determine whether there is a timing message that satisfies a preset delivery condition; delivering the index information of the timing message that satisfies the preset delivery condition to a target queue if there is a timing message that satisfies the preset delivery condition so as to allow the user to acquire the timing message that satisfies the preset delivery condition through the index information. The invention improves the timing message stacking capability, and when the number of timing messages is large, the timing message delay errors can be reduced, and the timing messages are guaranteed to be delivered on time to agreater extent.

Description

technical field [0001] The embodiments of the present invention are in the field of computer technology, and in particular, relate to a message processing method, device, and equipment. Background technique [0002] Most message middleware, such as Alibaba Cloud MQ (Message Queue) and MetaQ (Metamorphosis), can support scheduled messages or delayed messages. At present, timed messages or delayed messages have been applied to many business scenarios. Here is a simple example: when an order is created on a shopping platform (for example, Tmall), it is assumed that the order will be closed if it is not paid within 45 minutes. Just generate a delayed message (or timing message). In our real life, especially in the process of network interaction, scheduled messages or delayed messages can be seen everywhere. [0003] In the related art, the implementation of timing messages (or delayed messages) mainly adopts the following method: after the storage engine receives the timing me...

AI Technical Summary

Problems solved by technology

[0004] In the process of realizing the present invention, the inventor found that the prior art has the following defects: the accumulation ability of timing messages is weak. When the number of timing messages is large, the scheduling pressure on the server side is high and the scheduling ability is insufficient, resulting in a large number of timing messages piling up, causing serious problems. delayed delivery of

Images