Zookeeper搭载kafka分布式消息发布/订阅

╰半橙微兮° 2022-03-21 04:44 243阅读 0赞

### 一、Zookeeper简介 ###

ZooKeeper 是一个开源的分布式协调服务，由雅虎创建，是 Google Chubby 的开源实现。
    分布式应用程序可以基于 ZooKeeper 实现诸如数据发布/订阅、负载均衡、命名服务、分布式协调/通知、
    集群管理、Master 选举、配置维护，名字服务、分布式同步、分布式锁和分布式队列等功能。

### 二、zookeeper的角色 ###

在zookeeper中有3个角色

*  Leader           领导/组织角色
 *  Follwer           跟随角色
 *  Observer        观察角色

### 三、zookeeper的特点优势 ###

*  **简单**

Zookeeper的核心是一个精简的文件系统，它支持一些简单的操作和一些抽象操作，例如，排序和通知。

*  **丰富**

Zookeeper的原语操作是很丰富的，可实现一些协调数据结构和协议。例如，分布式队列、分布式锁和一组同级别节点中的“领导者选举”。

*  **高可靠**

Zookeeper支持集群模式，可以很容易的解决单点故障问题。

*  **松耦合交互**

不同进程间的交互不需要了解彼此，甚至可以不必同时存在，某进程在zookeeper中留下消息后，该进程结束后其它进程还可以读这条消息。

*  **资源库**

Zookeeper实现了一个关于通用协调模式的开源共享存储库，能使开发者免于编写这类通用协议。

### 四、zookeeper在分布式系统中的功能 ###

zookeeper在分布式微服务中，可以用来做：

*  分布式协调服务/通知
 *  数据发布与订阅（配置中心）
 *  分布式锁
 *  命名服务
 *  Master选举

在SpringCLoud微服务系统中，zookeeper主要定义用来做分布式协调服务/通知，即与kafka搭配使用做为：分布式消息队列服务。kafka与zookeeper的作用主要定义如下:

1、kafka使用zookeeper来实现动态的集群扩展，不需要更改客户端（producer和consumer）的配置。
    broker会在zookeeper注册并保持相关的元数据（topic，partition信息等）更新。
    
    2、 而客户端会在zookeeper上注册相关的watcher。一旦zookeeper发生变化，客户端能及时感知并作出
    相应调整。这样就保证了添加或去除broker时，各broker间仍能自动实现负载均衡。这里的客户端指的是
    Kafka的消息生产端(Producer)和消息消费端(Consumer)
    
    3、Broker端使用zookeeper来注册broker信息,以及监测partitionleader存活性.
    
    4、Consumer端使用zookeeper用来注册consumer信息,其中包括consumer消费的partition列表等,
    同时也用来发现broker列表,并和partitionleader建立socket连接,并获取消息.
    
     5、Zookeer和Producer没有建立关系，只和Brokers、Consumers建立关系以实现负载均衡，即同一个 
    ConsumerGroup中的Consumers可以实现负载均衡（因为Producer是瞬态的，可以发送后关闭，无需直接等待）

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0ZvbGxvd18yNA_size_16_color_FFFFFF_t_70][] 同名原创公众号： **程序大视界**

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0ZvbGxvd18yNA_size_16_color_FFFFFF_t_70]: /images/20220321/31d3b36c708f4c16b45cc02ead67b1ca.png