Message delay consumption method and related product

A message and delay time technology, applied in the field of information processing, can solve problems such as message processing failure, and achieve the effect of improving the success rate

Pending Publication Date: 2022-04-15
PINGAN PUHUI ENTERPRISE MANAGEMENT CO LTD
View PDF0 Cites 0 Cited by
  • Summary
  • Abstract
  • Description
  • Claims
  • Application Information

AI Technical Summary

Problems solved by technology

[0005] The embodiment of the present application provides a message delayed consumption method and related products, which solves the problem of message processing failure caused by the immediacy of Kafka by delaying the consumption of messages in Kafka

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
  • Message delay consumption method and related product
  • Message delay consumption method and related product
  • Message delay consumption method and related product

Examples

Experimental program
Comparison scheme
Effect test

Embodiment Construction

[0025] The following will clearly and completely describe the technical solutions in the embodiments of the present application with reference to the drawings in the embodiments of the present application. Obviously, the described embodiments are part of the embodiments of the present application, not all of them. Based on the embodiments in this application, all other embodiments obtained by persons of ordinary skill in the art without creative efforts fall within the protection scope of this application.

[0026] The terms "first", "second", "third" and "fourth" in the specification and claims of the present application and the drawings are used to distinguish different objects, rather than to describe a specific order . Furthermore, the terms "include" and "have", as well as any variations thereof, are intended to cover a non-exclusive inclusion. For example, a process, method, system, product or device comprising a series of steps or units is not limited to the listed ste...

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 embodiment of the invention discloses a message delay consumption method and a related product. The method comprises the steps that a first server consumes a delay message to be consumed from a preset theme of a message queue, the delay message to be consumed is stored in a preset database, and the delay message to be consumed comprises an original theme of an original message and delay time of the original message which are published to the preset theme of a kafka queue by a second server; the first server periodically scans a preset database and obtains a target delay message from the preset database, and the target delay message is a delay message of which the delay time arrives in all delay messages currently stored in the preset database; and the first server obtains a target theme of the target delay message, and sends an original message in the target delay message back to the target theme in the message queue, so that a third server consumes the original message in the target delay message from the target theme.

Description

technical field [0001] The present application relates to the technical field of information processing, and in particular to a message delayed consumption method and related products. Background technique [0002] Kafka is an open source stream processing platform developed by the Apache Software Foundation, written in Scala and Java, and is a high-throughput distributed publish-subscribe messaging system. This makes it a good solution for large-scale message processing applications due to its better throughput, built-in partitioning, multiple replicas, and fault tolerance. [0003] However, in some business scenarios, the last step in a transaction is to send a Kafka message, but this transaction has not been submitted, and the consumer reads the data and processes it after receiving the notification. However, because Kafka receives the message almost instantly, occasionally "the consumer receives the message and reads the data before the transaction is committed" in the ...

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
IPC IPC(8): H04L47/56G06F16/9535
Inventor 舒司廷
Owner PINGAN PUHUI ENTERPRISE MANAGEMENT CO LTD
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