Remote multi-activity distributed message consumption method and device

A distributed and message technology, applied in the computer field, can solve problems such as repeated messages, reduced satisfaction, and inability to achieve high availability across data centers

Active Publication Date: 2018-06-15
BEIJING QIYI CENTURY SCI & TECH CO LTD
View PDF6 Cites 2 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
  • Remote multi-activity distributed message consumption method and device
  • Remote multi-activity distributed message consumption method and device
  • Remote multi-activity distributed message consumption method and device

Examples

Experimental program
Comparison scheme
Effect test

Embodiment Construction

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

[0058] See figure 1 , Is a flowchart of a method for consuming distributed messages with multiple activities in different places according to an embodiment of the present invention, and the method includes:

[0059] Step 101: The consumer monitors whether at least two business clusters on the server are available;

[0060] In this step, each consumer in the consumer cluster (or each message receiver in the message receiver cluster) first monitors whether all business clusters on the server are available (that is, whether the business cluster is alive), and then proceed according to the monitoring results Select and mark the main business cluster. The consumer end can only connect to one main business cluster during each 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

The embodiment of the invention provides a remote multi-activity distributed message consumption method and device. The method comprises the following steps that: monitoring whether at least two business clusters of a service side are available or not; if a monitoring result shows that at least two business clusters are both available, selecting any one of the at least two business clusters as a main business cluster; and connecting with the selected main business cluster for consumption. In the embodiment of the invention, the availability of all business clusters on the server side can be monitored, a main business cluster is selected from the available business clusters, then, connection is established with the main business cluster, and consumption is carried out. In other words, in the embodiment, a consumption end selects the main business cluster from the available business cluster so as to improve the high availability of the business cluster, in addition, after the consumptionend is switched to the new business cluster, consumption is carried out according to reset consumption schedule, and the repeated consumption of messages can be reduced to a large extent.

Description

Technical field [0001] The present invention relates to the field of computer technology, in particular to a distributed message consumption method and device for multiple activities in different places. Background technique [0002] Kafka is a distributed, partitionable, and replicable distributed messaging system. Kafka runs in a cluster and can be composed of one or more services. As an important component of the distributed system, the distributed messaging system mainly solves the problems of application coupling, asynchronous messaging, traffic cutting, etc., to achieve high performance, high availability, scalability and eventual consistency architecture. It is an indispensable middleware for large distributed systems. Kafka cluster is a typical representative. The existing Kafka clusters are deployed separately for operation and maintenance. Due to the large number of Kafka clusters, the Kafka clusters provide services to consumers through data centers (DC, datacenter)....

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): 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