Zookeeper搭载kafka分布式消息发布/订阅
二、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是瞬态的，可以发送后关闭，无需直接等待）
关注公众号：程序大视界
觉得对你有帮助，关注博客和公众号。不定期分享最新前沿技术框架和bat大厂常用技术等，加群不定期分享行业内大牛直播讲课以及获得视频课件资料等。
以上是 Zookeeper搭载kafka分布式消息发布/订阅 的全部内容， 来源链接： utcz.com/z/516483.html
