zookeeper是什么

目前，在分布式协调技术方面做得比较好的就是Google的Chubby还有Apache的ZooKeeper他们都是分布式锁的实现者。有人会问 既然有了Chubby为什么还要弄一个ZooKeeper，难道Chubby做得不够好吗？不是这样的，主要是Chbby是非开源的，Google自家 用。后来雅虎模仿Chubby开发出了ZooKeeper，也实现了类似的分布式锁的功能，并且将ZooKeeper作为一种开源的程序捐献给了 Apache，那么这样就可以使用ZooKeeper所提供锁服务。zookeeper，它是一个分布式服务框架，它主要是用来解决分布式应用中经常遇到的一些数据管理问题，如：统一命名服务、状态同步服务、集群管理、分布式应用配置项的管理等。ZooKeeper在一致性、可用性、容错性的保证，也是ZooKeeper的成功之处，它获得的一切成功都与它采用的协议——Zab协议是密不可分的。

zookeeper数据

1.文件系统

每目录项如 NameService,myserver1 都被称作为 znode(目录节点)，和文件系统一样，我们可以增加、 删除znode，在一个znode下增加、删除子znode，其区别在于znode是可以存储数据的，这里可以理解为kv数据结构，k就是我们的文件目录，v就是我们存的数据。

2.数据类型

PERSISTENT-持久化目录节点
客户端与zookeeper断开连接后，该节点依旧存在

PERSISTENT_SEQUENTIAL-持久化顺序编号目录节点
客户端与zookeeper断开连接后，该节点依旧存在，只是Zookeeper给该节点名称进行顺序编号

EPHEMERAL-临时目录节点
客户端与zookeeper断开连接后，该节点被删除

EPHEMERAL_SEQUENTIAL-临时顺序编号目录节点
客户端与zookeeper断开连接后，该节点被删除，只是Zookeeper给该节点名称进行顺序编号

3.监听和通知

1.client会监听节点目录，当目录节点发生变化（数据改变、被删除、子目录节点增加删除）时，zookeeper会通知客户端。

zookeeper单机模式安装

1.验证java环境

java -version

2.下载zookeeper并解压

wget http://mirror.bit.edu.cn/apache/zookeeper/stable/apache-zookeeper-3.5.8.tar.gz
tar -xvf zookeeper-3.4.14.tar.gz

3.重命名配置文件zoo_sample.cfg，zookeeper默认配置文件名zoo.cfg

cp conf/zoo_sample.cfg conf/zoo.cfg

4.启动zookeeper

bin/zkServer.sh start 或者 bin/zkServer.sh start conf/zoo.cfg

5.连接zookeeper客户端

bin/zkCli.sh

zookeep 使用

1.help 查看zookeep的命令

2. ls 查看zookeeper的内容

3. 创建一个新的 znode ，使用 create /myzkNode myzkData
.
4.get 查看我们创建的node

4.set 对值进行修改

5.watch监听znode的值

如果执行了 set /myzkNode 123,则会被监听到

6.delete删除znode

java连接zookeeper

1.maven包

<dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.4.14</version>
</dependency>

2.zookeeper异步监听，当znode的值被修改后这里会被回调。

package com.yicong.boke.test;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;/*** @Description:* @Author yicong* @Date 2020年5月26日*/public class ZooKeeperProSync implements Watcher {private static ZooKeeper zk = null;private static Stat stat = new Stat();public static void main(String[] args) throws Exception {// zookeeper配置数据存放路径String path = "/myzk";// 连接zookeeper并且注册一个默认的监听器zk = new ZooKeeper("10.101.36.176:2181", 5000, //new ZooKeeperProSync());// 获取path目录节点的配置数据，并注册默认的监听器System.out.println(new String(zk.getData(path, true, stat)));for (;;);}public void process(WatchedEvent event) {if (KeeperState.SyncConnected == event.getState()) { // zk连接成功通知事件if (EventType.None == event.getType() && null == event.getPath()) {} else if (event.getType() == EventType.NodeDataChanged) { // zk目录节点数据变化通知事件try {System.out.println("配置已修改，新值为：" + new String(zk.getData(event.getPath(), true, stat)));} catch (Exception e) {}}}}
}

zookeeper 集群模式安装

这里只用了一台机器部署，只是端口不一样。

1.重命名 zoo_sample.cfg文件

cp conf/zoo_sample.cfg conf/zoo1.cfg
cp conf/zoo_sample.cfg conf/zoo2.cfg
cp conf/zoo_sample.cfg conf/zoo3.cfg

2.修改配置文件zoo1.cfg,zoo2.cfg,zoo3.cfg的配置文件,修改dataDir和clientPort，后面三个server在每个zoo.cfg中都加上

dataDir=/tmp/zookeeper1
clientPort=2181
server.1=127.0.0.1:2888:3888
server.2=127.0.0.1:2889:3889
server.3=127.0.0.1:2890:3890

3.zoo.cfg配置说明

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

4.serverId 的设置

在刚才的三个zoo.cfg文件中的dataDir所对应的目录中，分别创建myid文件，依次对应写入1,2,3

5.启动三个zookeeper实例

bin/zkServer.sh start conf/zoo1.cfg
bin/zkServer.sh start conf/zoo2.cfg
bin/zkServer.sh start conf/zoo3.cfg

6.查看启动状态

./bin/zkServer.sh status ./conf/zoo1.cfg

7.连接某台zookeeper

./bin/zkCli.sh -server 127.0.0.1:2181

当然，这只是一个zookeeper入门了解，zookeeper功能还有很多，比如用zookeeper，分布式锁，zookeeper集群leader选举等等