点赞再看，Java进阶一大半
如果大家公司里的消息队列Kafka是2.80版本以下的版本，那说明你们的服务器还在跑着一台提供Kafka核心功能支持的Zookeeper。
当年雅虎工程师在给这个分布式协调服务项目起名时，还发生了一个有趣的故事。像如今大名鼎鼎的Hadoop是大象的名字，用于分析大规模数据集的Pig项目是猪，都是某种可爱的动物。时任研究院的首席科学家Raghu Ramakrishnan就跳出来开玩笑说：“再这样下去，我们这儿就变成动物园了！“。于是，大家都起哄起来：那就叫它动物管理员吧。
现在ZooKeeper在GitHub已有Star数⭐️12.1k、Fork数7.2k
大家好，我是南哥。
一个Java学习与进阶的领路人，相信对你通关面试进入心心念念的公司有所帮助。
本文收录在我开源的《Java学习进阶指南》中，涵盖了在大厂工作的Javaer都不会不懂的核心知识、面试重点。相信能帮助到大家在Java成长路上不迷茫，南哥希望收到大家的 ⭐ Star ⭐支持我完善下去。GitHub地址：https://github.com/hdgaadd/JavaProGuide。
1. ZooKeeper分布式锁
1.1 排他锁实现分布式锁
面试官：知道Zookeeper有什么应用场景吗?
目前地球村里大型公司部署的分布式技术，绝大部分都是由Zookeeper提供底层的技术支持，所以Zookeeper多么重要就不用我多说了吧。
我们可以利用Zookeeper来完成分布式系统涉及的各种核心功能，例如以下4种：
数据发布/订阅。可以用来实现配置中心。
命名服务。类似于UUID，可以生成全局唯一的ID。
集群管理。每一个服务器是一个子节点，可以用来检测到集群中机器的上/下线情况。
分布式锁。
南哥先讲下我们可以怎么利用Zookeeper来实现分布式锁，要实现分布式锁，分为获取锁和释放锁两个步骤。
ZooKeepr获取锁时会在/exclusive_lock节点下创建子节点，如果创建成功则获得锁。如果创建失败，则访问Zookeeper的客户端会在该节点注册一个Watcher监听，用来实时监控子节点的变更从而重新获得锁，这有点类似于线程的循环等待。
当要释放锁时，Zookeeper会删除该子节点，此时/exclusive_lock节点下就有空位了。Watcher监听则通知客户端可以重新创建子节点来获得锁资源。
1.2 共享锁实现分布式锁
面试官：你说的是排他锁，共享锁呢？
大家有没发现，上面分布式锁的实现方式是排他锁，我们也可以使用共享锁的实现方式，来看看两者的区别。
排他锁，又称为写锁或独占锁，是一种基本的锁类型。如果事务T1对数据对象O1加上了排他锁，那么在整个加锁期间，只允许事务T1对O1进行读取和更新操作，其他任何事务都不能再对这个数据对象进行任何类型的操作——直到T1释放了排他锁。
共享锁，又称为读锁，同样是一种基本的锁类型。如果事务T1对数据对象O1加上了共享锁，那么当前事务只能对O1进行读取操作，其他事务也只能对这个数据对象加共享锁——直到该数据对象上的所有共享锁都被释放。
Zookeeper以共享锁方式来实现分布式锁，每次读、写请求都会去创建子节点，这是一个类似于“/shared_lock/[Hostname]-请求类型-序号”的临时顺序节点。
每一个要获得分布式锁的客户端都会去获取子节点列表，同时注册Watcher监听，读、写这两步有不同的步骤。
（1）获取读锁的话，如果前面比自己小的序号没有写请求，则表示可以读。
（2）获取写锁的话，只有在自己是序号最小的情况下，才可以读成功。
另外共享锁的释放锁和排他锁都是一样的，只需要删除所创建的子节点就可以。
1.3 共享锁羊群效应
面试官：有没听说过共享锁的羊群效应？
大家要注意下，共享锁来实现分布式锁，在集群规模比较大的场景下，可能会出现羊群效应。
什么是羊群效应？我们看看百度百科的解释。
羊群效应是个人的观念或行为由于真实的或想象的群体的影响或压力，而向与多数人相一致的方向变化的现象。
其实共享锁的特别之处，在于每次读、写请求都要注册Watcher监听来获取子节点列表，特别是数量更多的读请求，每1分钟可能是上百万次的请求。
以共享锁来实现，子节点列表只要每次一变动，就要通知所有的服务器客户端。这明显造成了短时间大量的事件通知，给Zookeeper带来的性能消耗是巨大的。
1.4 处理羊群效应
面试官：那怎么解决呢？
如何看待共享锁带来的羊群效应，我们从两个方面来看待。如果在集群不大的情况下羊群效应发生带来的影响不会太大，而且这种设计简单实用。
而如果在集群规模大的场景下，我们可以这样改进。客户端的读、写请求首先获取子节点列表，但都不注册Watcher监听。
（1）读请求：只向比自己序号小的最后一个写请求节点注册Watcher监听。
（2）写请求：只向比自己序号小的最后一个节点注册Watcher监听。
这样的设计就可以避免羊群效应，主要是从监听子节点列表，改进为只监听某个子节点。
2. Kafka应用场景
2.1 Kafka应用场景
面试官：Kafka应用场景呢，知道Kafka是怎么利用Zookeeper吗？
南哥了解到的Kafka利用Zookeeper的主要有 4 点，我们来看看。
（1）使用Zookeeper来对所有Broker服务器、Topic进行管理。Broker启动后都会到Zookeeper上创建属于自己的临时节点，其节点路径为/broker/ids/[0…N]，注册Topic节点也是一样。
（2）而在Kafka防止消费重复消费方面，消费者消费消息后，都会在消息分区写入临时节点，代表该消息已消费。
（3）另外在Kafka生产者负载均衡方面，Kafka消息生产者会通过监听Broker节点列表，负载均衡地分发到某一个Broker。
（4）在消费者负载均衡有两方面。一方面，每一个消费者服务器都会在Zookeeper创建消费者节点。当有新消息时，Kafka就可以通过Zookeeper的消费者节点列表负载均衡地通知某个消费者；另一方面，Kafka将一个Topic分成了多个分区，多个分区由不同的Broker处理，这是实现对Broker的负载均衡。
戳这，《JavaProGuide》作为一份涵盖Java程序员所需掌握核心知识、面试重点的Java学习进阶指南。
欢迎关注南哥的公众号：Java进阶指南针，公众号里有南哥珍藏整理的大量优秀pdf书籍！
我是南哥，南就南在Get到你的有趣评论➕点赞➕关注。
创作不易，不妨点赞、收藏、关注支持一下，各位的支持就是我创作的最大动力❤️
