Method and device for managing and consuming distributed messages

A distributed and message technology, applied in the computer field, can solve the problems of reducing satisfaction, not being able to achieve high availability of cross-data center services, repeated messages, etc., and achieve the effect of improving high availability

Active Publication Date: 2018-06-22
BEIJING QIYI CENTURY SCI & TECH CO LTD
View PDF14 Cites 4 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 remote multi-active distributed message management method and consumption method, so as to solve the problem that the high availability of cross-data center services cannot be realized in the prior art, causing consumers to switch clusters The process creates a lot of repetitive messages, reducing satisfaction issues

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
  • Method and device for managing and consuming distributed messages
  • Method and device for managing and consuming distributed messages
  • Method and device for managing and consuming distributed messages

Examples

Experimental program
Comparison scheme
Effect test

Embodiment Construction

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

[0077] see also figure 1 , which is a flow chart of a remote multi-active distributed message management method provided by an embodiment of the present invention, the method includes:

[0078] Step 101: the health check center checks whether each business cluster of the server is available;

[0079] In this step, the health check center (HCC, Health Check Center) on the server side is connected to all business clusters separately to check whether each business cluster is available (ie, the survival status). Specifically, HCC usually uses heartbeat (heartbeat) beat) to check whether each cluster is available, and if available, mark the cluster priority for the at least two service clusters available.

[0080] In this embodiment,...

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 method and device for managing and consuming distributed messages . The management method includes the following steps: a health evaluation center checks whether each business cluster of a server is available; and if the health evaluation center checks that at least two business clusters are available, cluster priorities are marked for the available at least two business clusters. In the management method provided by the embodiment of the invention, the health evaluation center checks availability of the business clusters of the server, and marks thecluster priorities of the available business clusters, so that business clusters with the highest cluster priorities are provided for a consumption side to perform connection and consumption, therebyimproving high availability of the business clusters.

Description

technical field [0001] The invention relates to the field of computer technology, in particular to a management method, consumption method and device for multi-active distributed messages in different places. Background technique [0002] Kafka is a distributed, partitionable, and replicable distributed message system. Kafka runs in a cluster and can be composed of one or more services. As an important component in a distributed system, the distributed message system mainly solves problems such as application coupling, asynchronous messages, and traffic cutting, and realizes high performance, high availability, scalability, and eventual consistency architecture. It is an indispensable middleware for large distributed systems. Kafka cluster is a typical representative of them. Existing Kafka clusters are deployed and maintained separately. Due to the large number of Kafka clusters, Kafka clusters provide services to consumers through data centers (DC, datacenter). Once a pr...

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): H04L12/26H04L29/08H04L12/24
CPCH04L41/0668H04L43/0817H04L43/10H04L43/14H04L67/1001
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