Distributed message consumption method and device with multi-active in different places

A distributed and message technology, applied in the computer field, can solve the problems of reduced satisfaction, repeated messages, and inability to achieve high availability across data centers, and achieve the effect of improving high availability and reducing repeated consumption

Active Publication Date: 2021-06-22
BEIJING QIYI CENTURY SCI & TECH CO LTD
View PDF5 Cites 0 Cited by
  • Summary
  • Abstract
  • Description
  • Claims
  • Application Information

AI Technical Summary

Problems solved by technology

[0004] The technical problem to be solved by the embodiments of the present invention is to provide a multi-active distributed message consumption method in different places, so as to solve the problem that the high availability of services across data centers cannot be realized in the prior art, resulting in a large amount of duplication caused by consumers in the process of switching clusters. Messages, issues that reduce satisfaction

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
  • Distributed message consumption method and device with multi-active in different places
  • Distributed message consumption method and device with multi-active in different places
  • Distributed message consumption method and device with multi-active in different places

Examples

Experimental program
Comparison scheme
Effect test

Embodiment Construction

[0057] In order to make the above objects, features, and advantages of the present invention, the present invention will be further described in detail below with reference to the accompanying drawings and specific embodiments.

[0058] See figure 1 , A flow chart of a consumption method of a differently-lived distributed message provided in the embodiment of the present invention, the method comprising:

[0059] Step 101: Whether at least two business clusters of the consumer side monitoring server are available;

[0060]In this step, each consumption end in the consumer end cluster (or each message receiving end in the message receiving terminal) first monitors all traffic clusters of the server available (ie, whether the business cluster is survived), and then according to the monitoring results Select and mark the main business cluster. The consumer side can only connect to a primary business cluster during each consumption process, and the primary business cluster of this con...

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

An embodiment of the present invention provides a method and device for consumption of distributed multi-active distributed messages in different places. The method includes: monitoring whether at least two service clusters of the server are available; if it is detected that the at least two service clusters are available, Then select any one of the at least two business clusters as the main business cluster; connect to the selected main business cluster for consumption. In the embodiment of the present invention, by monitoring the availability of all business clusters on the server side, a main business cluster is selected from the available business clusters, and then a connection is established with the main business cluster and consumption starts. That is to say, in this embodiment, the consumer side selects the main business cluster from the available business clusters, thereby improving the high availability of the business cluster, and after the consumer side switches to a new business cluster, according to the reset consumption progress Start to consume, greatly reducing the repeated consumption of messages.

Description

Technical field [0001] The present invention relates to the field of computer technology, and more particularly to a distributed message consumption method and apparatus for excessive vending. Background technique [0002] Kafka is a distributed, partitionable, replicable distributed message system, Kafka runs in a cluster, can consist of one or more services. Distributed Message System As an important component in a distributed system, it is mainly to solve problems such as coupling, asynchronous messages, traffic cutting, and high performance, high availability, scalable and final consistency architecture. It is an indispensable middleware that is a large distributed system. Kafka clusters are typical representatives. The existing Kafka cluster is separately deployed operation and maintenance. Because the number of Kafka clusters is numerous, the Kafka cluster is served through the Data Center (DC, DATACENTER) to serve consumers. Once a data center has problems, it will result ...

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): G06F9/50H04L12/58H04L29/08
CPCG06F9/5061G06F9/5083H04L51/00H04L67/10
Inventor 冯浩
Owner BEIJING QIYI CENTURY SCI & TECH 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