A Distributed Delayed Message Queue Processing System Supporting Update

A message queue and processing system technology, which is applied in the field of distributed delayed message queue processing system, can solve the problems of delayed message queue without a good solution and complex business, and achieve the effect of improving system performance and reducing resource competition

Active Publication Date: 2022-01-14
浙江小泰科技有限公司
View PDF11 Cites 0 Cited by
  • Summary
  • Abstract
  • Description
  • Claims
  • Application Information

AI Technical Summary

Problems solved by technology

[0013] The business that relies on IT technology is becoming more and more complex, which leads to the refinement of problem scenarios. Different scenarios require targeted solutions. Currently, the delayed message queue that supports updates in medium / high concurrency and distributed environments is not a good solution. Program

Method used

the structure of the environmentally friendly knitted fabric provided by the present invention; figure 2 Flow chart of the yarn wrapping machine for environmentally friendly knitted fabrics and storage devices; image 3 Is the parameter map of the yarn covering machine
View more

Image

Smart Image Click on the blue labels to locate them in the text.
Viewing Examples
Smart Image
  • A Distributed Delayed Message Queue Processing System Supporting Update

Examples

Experimental program
Comparison scheme
Effect test

Embodiment Construction

[0049] The present invention will be further described with reference to the accompanying drawings.

[0050] Such as figure 1 Shown: A distributed delayed message queue processing system that supports updates. This system includes a message queue, a message producer, and a message consumer. The message queue is used to store delayed messages, the message producer is used to add delayed messages to the message queue, and the message consumer is used to consume delayed messages in the message queue. The message queue is implemented based on Redis, Ignite, Hazelcast or database, preferably using Redis. The message producer and message consumer implement access to different I / O methods through the I / O adapter, and support the integration of mainstream methods such as Kafka, RabbitMQ, and HTTP.

[0051] Delayed messages include queue name, message body, and timestamp of delayed sending. The queue name carries the name of the message body, each queue name corresponds to multiple ...

the structure of the environmentally friendly knitted fabric provided by the present invention; figure 2 Flow chart of the yarn wrapping machine for environmentally friendly knitted fabrics and storage devices; image 3 Is the parameter map of the yarn covering machine
Login to view more

PUM

No PUM Login to view more

Abstract

The invention relates to the technical field of message queues, and discloses a distributed delay message queue processing system that supports updates, including a message queue, a message producer, and a message consumer. The delayed message includes a queue name, a message body, and a time stamp for delayed sending ;The message producer is used to execute the following modules, the judging module, which is used to obtain the current delayed message and judge whether there is a delayed message in the message queue; if so, delete the delayed sending timestamp in the message queue and add the current delay to the message queue The delayed sending timestamp carried in the message; if not, add the delayed message to the message queue. By adopting the above technical solution, when the judging module judges yes, the delay time update of the delayed message can be completed only by updating the time stamp of the delayed sending, and the update of the delayed message is realized in a medium / high concurrency and distributed environment.

Description

technical field [0001] The invention relates to the technical field of message queues, in particular to a distributed delayed message queue processing system supporting update. Background technique [0002] A message queue is a linked list of messages. Think of a message as a record, with a specific format and a specific priority. A process with write permission to the message queue can add new messages to the message queue according to certain rules; a process with read permission to the message queue can read messages from the message queue, and the message queue is persistent with the kernel. [0003] Delayed message queues are widely used in Internet products. For example, user behavior statistics require page operation events to be sequential: BeforeLoad must precede Unload; for example, the data analysis system will synchronize the data of various business systems, and there are often data dependencies in calculations, namely When obtaining a piece of data from syste...

Claims

the structure of the environmentally friendly knitted fabric provided by the present invention; figure 2 Flow chart of the yarn wrapping machine for environmentally friendly knitted fabrics and storage devices; image 3 Is the parameter map of the yarn covering machine
Login to view more

Application Information

Patent Timeline
no application Login to view more
Patent Type & Authority Patents(China)
IPC IPC(8): H04L1/00H04L47/56
Inventor 蒋震宇葛佳兴付银海贾立锋李正先吕宝林彭勇军王树辉
Owner 浙江小泰科技有限公司
Who we serve
  • R&D Engineer
  • R&D Manager
  • IP Professional
Why Eureka
  • Industry Leading Data Capabilities
  • Powerful AI technology
  • Patent DNA Extraction
Social media
Try Eureka
PatSnap group products

Browse by: Latest US Patents, China's latest patents, Technical Efficacy Thesaurus, Application Domain, Technology Topic.

© 2024 PatSnap. All rights reserved.Legal|Privacy policy|Modern Slavery Act Transparency Statement|Sitemap