Zookeeper入门看这篇就够了

Zookeeper是什么

官方文档上这么解释zookeeper，它是一个分布式服务框架，是Apache Hadoop 的一个子项目，它主要是用来解决分布式应用中常常遇到的一些数据管理问题，如：统一命名服务、状态同步服务、集群管理、分布式应用配置项的管理等。

上面的解释有点抽象，简单来讲zookeeper=文件系统+监听通知机制。

一、 文件系统

Zookeeper维护一个相似文件系统的数据结构：

每一个子目录项如 NameService 都被称做为 znode(目录节点)，和文件系统同样，咱们可以自由的增长、删除znode，在一个znode下增长、删除子znode，惟一的不一样在于znode是能够存储数据的。

有四种类型的znode：

• PERSISTENT-持久化目录节点

  客户端与zookeeper断开链接后，该节点依旧存在

• PERSISTENT_SEQUENTIAL-持久化顺序编号目录节点

  客户端与zookeeper断开链接后，该节点依旧存在，只是Zookeeper给该节点名称进行顺序编号

• EPHEMERAL-临时目录节点

  客户端与zookeeper断开链接后，该节点被删除

• EPHEMERAL_SEQUENTIAL-临时顺序编号目录节点

  客户端与zookeeper断开链接后，该节点被删除，只是Zookeeper给该节点名称进行顺序编号

二、 监听通知机制

客户端注册监听它关心的目录节点，当目录节点发生变化（数据改变、被删除、子目录节点增长删除）时，zookeeper会通知客户端。

就这么简单，下面咱们看看Zookeeper能作点什么呢？

Zookeeper能作什么

zookeeper功能很是强大，能够实现诸如分布式应用配置管理、统一命名服务、状态同步服务、集群管理等功能，咱们这里拿比较简单的分布式应用配置管理为例来讲明。

假设咱们的程序是分布式部署在多台机器上，若是咱们要改变程序的配置文件，须要逐台机器去修改，很是麻烦，如今把这些配置所有放到zookeeper上去，保存在 zookeeper 的某个目录节点中，而后全部相关应用程序对这个目录节点进行监听，一旦配置信息发生变化，每一个应用程序就会收到 zookeeper 的通知，而后从 zookeeper 获取新的配置信息应用到系统中。

如上，你大体应该了解zookeeper是个什么东西，大概能作些什么了，咱们立刻来学习下zookeeper的安装及使用，并开发一个小程序来实现zookeeper这个分布式配置管理的功能。

Zookeeper单机模式安装

Step1：配置JAVA环境，检验环境：java -version

Step2：下载并解压zookeeper

# cd /usr/local# wget http://mirror.bit.edu.cn/apache/zookeeper/stable/zookeeper-3.4.12.tar.gz# tar -zxvf zookeeper-3.4.12.tar.gz# cd zookeeper-3.4.12

Step3：重命名配置文件zoo_sample.cfg

# cp conf/zoo_sample.cfg conf/zoo.cfg

Step4：启动zookeeper

# bin/zkServer.sh start

Step5：检测是否成功启动，用zookeeper客户端链接下服务端

# bin/zkCli.sh

Zookeeper使用

使用客户端命令操做zookeeper

一、使用 ls 命令来查看当前 ZooKeeper 中所包含的内容

二、建立一个新的 znode ，使用 create /zkPro myData

三、再次使用 ls 命令来查看如今 zookeeper 中所包含的内容：

四、下面咱们运行 get 命令来确认第二步中所建立的 znode 是否包含咱们所建立的字符串：

五、下面咱们经过 set 命令来对 zk 所关联的字符串进行设置：

六、下面咱们将刚才建立的 znode 删除

使用Java API操做zookeeper

使用Java API操做zookeeper须要引用下面的包

下面咱们来实现上面说的分布式配置中心：

一、在zookeeper里增长一个目录节点，而且把配置信息存储在里面

二、启动两个zookeeper客户端程序，代码以下所示

import java.util.concurrent.CountDownLatch;import org.apache.zookeeper.WatchedEvent;import org.apache.zookeeper.Watcher;import org.apache.zookeeper.Watcher.Event.EventType;import org.apache.zookeeper.Watcher.Event.KeeperState;import org.apache.zookeeper.ZooKeeper;import org.apache.zookeeper.data.Stat; /** * 分布式配置中心demo * @author  * */public class ZooKeeperProSync implements Watcher {     private static CountDownLatch connectedSemaphore = new CountDownLatch(1);    private static ZooKeeper zk = null;    private static Stat stat = new Stat();     public static void main(String[] args) throws Exception {        //zookeeper配置数据存放路径        String path = "/username";        //链接zookeeper而且注册一个默认的监听器        zk = new ZooKeeper("192.168.31.100:2181", 5000, //                new ZooKeeperProSync());        //等待zk链接成功的通知        connectedSemaphore.await();        //获取path目录节点的配置数据，并注册默认的监听器        System.out.println(new String(zk.getData(path, true, stat)));         Thread.sleep(Integer.MAX_VALUE);    }     public void process(WatchedEvent event) {        if (KeeperState.SyncConnected == event.getState()) {  //zk链接成功通知事件            if (EventType.None == event.getType() && null == event.getPath()) {                connectedSemaphore.countDown();            } else if (event.getType() == EventType.NodeDataChanged) {  //zk目录节点数据变化通知事件                try {                    System.out.println("配置已修改，新值为：" + new String(zk.getData(event.getPath(), true, stat)));                } catch (Exception e) {                }            }        }    }}

两个程序启动后都正确的读取到了zookeeper的/username目录节点下的数据'qingfeng'

三、咱们在zookeeper里修改下目录节点/username下的数据

修改完成后，咱们看见两个程序后台都及时收到了他们监听的目录节点数据变动后的值，以下所示

Zookeeper集群模式安装

本例搭建的是伪集群模式，即一台机器上启动三个zookeeper实例组成集群，真正的集群模式无非就是实例IP地址不一样，搭建方法没有区别

Step1：配置JAVA环境，检验环境：java -version

Step2：下载并解压zookeeper

# cd /usr/local# wget http://mirror.bit.edu.cn/apache/zookeeper/stable/zookeeper-3.4.12.tar.gz# tar -zxvf zookeeper-3.4.12.tar.gz# cd zookeeper-3.4.12

Step3：重命名 zoo_sample.cfg文件

# cp conf/zoo_sample.cfg conf/zoo-1.cfg

Step4：修改配置文件zoo-1.cfg，原配置文件里有的，修改为下面的值，没有的则加上

# vim conf/zoo-1.cfgdataDir=/tmp/zookeeper-1clientPort=2181server.1=127.0.0.1:2888:3888server.2=127.0.0.1:2889:3889server.3=127.0.0.1:2890:3890

配置说明

• tickTime：这个时间是做为 Zookeeper 服务器之间或客户端与服务器之间维持心跳的时间间隔，也就是每一个 tickTime 时间就会发送一个心跳。
• initLimit：这个配置项是用来配置 Zookeeper 接受客户端（这里所说的客户端不是用户链接 Zookeeper 服务器的客户端，而是 Zookeeper 服务器集群中链接到 Leader 的 Follower 服务器）初始化链接时最长能忍受多少个心跳时间间隔数。当已经超过 10个心跳的时间（也就是 tickTime）长度后 Zookeeper 服务器尚未收到客户端的返回信息，那么代表这个客户端链接失败。总的时间长度就是 10*2000=20 秒
• syncLimit：这个配置项标识 Leader 与 Follower 之间发送消息，请求和应答时间长度，最长不能超过多少个 tickTime 的时间长度，总的时间长度就是 5*2000=10秒
• dataDir：顾名思义就是 Zookeeper 保存数据的目录，默认状况下，Zookeeper 将写数据的日志文件也保存在这个目录里。
• clientPort：这个端口就是客户端链接 Zookeeper 服务器的端口，Zookeeper 会监听这个端口，接受客户端的访问请求。
• server.A=B：C：D：其中 A 是一个数字，表示这个是第几号服务器；B 是这个服务器的 ip 地址；C 表示的是这个服务器与集群中的 Leader 服务器交换信息的端口；D 表示的是万一集群中的 Leader 服务器挂了，须要一个端口来从新进行选举，选出一个新的 Leader，而这个端口就是用来执行选举时服务器相互通讯的端口。若是是伪集群的配置方式，因为 B 都是同样，因此不一样的 Zookeeper 实例通讯端口号不能同样，因此要给它们分配不一样的端口号。

Step4：再从zoo-1.cfg复制两个配置文件zoo-2.cfg和zoo-3.cfg，只需修改dataDir和clientPort不一样便可

# cp conf/zoo-1.cfg conf/zoo-2.cfg# cp conf/zoo-1.cfg conf/zoo-3.cfg# vim conf/zoo-2.cfgdataDir=/tmp/zookeeper-2clientPort=2182# vim conf/zoo-2.cfgdataDir=/tmp/zookeeper-3clientPort=2183

Step5：标识Server ID

建立三个文件夹/tmp/zookeeper-1，/tmp/zookeeper-2，/tmp/zookeeper-2，在每一个目录中建立文件myid 文件，写入当前实例的server id，即1.2.3

# cd /tmp/zookeeper-1# vim myid1# cd /tmp/zookeeper-2# vim myid2# cd /tmp/zookeeper-3# vim myid3

Step6：启动三个zookeeper实例

# bin/zkServer.sh start conf/zoo-1.cfg# bin/zkServer.sh start conf/zoo-2.cfg# bin/zkServer.sh start conf/zoo-3.cfg

Step7：检测集群状态，也能够直接用命令“zkCli.sh -server IP:PORT”链接zookeeper服务端检测

至此，咱们对zookeeper就算有了一个入门的了解，固然zookeeper远比咱们这里描述的功能多，好比用zookeeper实现集群管理，分布式锁，分布式队列，zookeeper集群leader选举等等