Zookeeper环境搭建及使用

李斯特

1.Zookeeper了解
    Zookeeper有能力实现集中配置的能力，举个例子，应用app1 做集群配置，配置3个节点，把app1的配置统一放置zookeeper server /APP1上，所有的app1应用启动就对节点/APP1进行监控，并实现回调方法Watcher，那么在/APP1上数据发生变化的时候，每个app应用节点就会收到通知，Watcher方法被执行，则app1的应用就可以实时得到修改的配置。
Zookeeper 自身可以做集群配置，可以预防由于单点故障导致的信息崩溃问题。
Zookeeper 数据结构类似标准的文件系统
[img]

[/img]

Zookeeper数据结构有如下这些特点：

[tr][td]1.每个子目录项如 NameService 都被称作为 znode，这个 znode 是被它所在的路径唯一标识，如 Server1 这个 znode 的标识为 /NameService/Server1[tr][td]2.znode 可以有子节点目录，并且每个 znode 可以存储数据，注意 EPHEMERAL 类型的目录节点不能有子节点目录[tr][td]3.znode 是有版本的，每个 znode 中存储的数据可以有多个版本，也就是一个访问路径中可以存储多份数据[tr][td]4.znode 可以是临时节点，一旦创建这个 znode 的客户端与服务器失去联系，这个 znode 也将自动删除，Zookeeper 的客户端和服务器通信采用长连接方式，每个客户端和服务器通过心跳来保持连接，这个连接状态称为 session，如果 znode 是临时节点，这个 session 失效，znode 也就删除了[tr][td]5.znode 的目录名可以自动编号，如 App1 已经存在，再创建的话，将会自动命名为 App2[tr][td]6.znode 可以被监控，包括这个目录节点中存储的数据的修改，子节点目录的变化等，一旦变化可以通知设置监控的客户端，这个是 Zookeeper 的核心特性，Zookeeper 的很多功能都是基于这个特性实现的。

2.Zookeeper与redis比较
Zookeeper 不是一个通用的数据库或大型数据存储，而是管理协调数据，
结合软创系统的配置信息，配置信息量不会非常大，完全在可控范围内，同时需要稳定运行，消除单点宕机故障，读取速度不是太大的影响点，综上考虑采用zookeeper作为配置管理中心比较合适。

基于上面描述，使用zookeeper实现我们的配置中心是可行的

3.Zookeeper 安装及使用
3.1安装（单机）
单机安装非常简单，具体步骤如下：
1.使用zookeeper3.3.6版本，解压zookeeper-3.3.6.tar.gz至本地目录
2.配置zoo.cfg(将自带的zoo_sample.cfg copy并改名为zoo.cfg)
# The number of milliseconds of each tick
#心跳时间，客户端与zookeeper server之间的心跳时间
tickTime=2000
# The number of ticks that the initial
# synchronization phase can take 集群配置时，配置zookeeper接受客户端(客户端是指follower服务器，而不是client连接server的客户端) 初始化连接最长能接受的多少个心跳时间间隔数
initLimit=10
# The number of ticks that can pass between
# sending a request and getting an acknowledgement  这个是集群配置时 follower与leader之间的请求应答时间
syncLimit=5
# the directory where the snapshot is stored. zookeeper保存数据目录
dataDir=D:/workspace/config-cache/zookeeper/zookeeper-3.3.6/data/zookeeper
# the port at which the clients will connect  客户端连接zookeeper server的端口
clientPort=2181

3.启动zookeeper server
执行bin目录下zkServer.cmd
3.2安装(集群)
配置zookeeper集群(或者在单机上配置伪集群)
本机设置集群，copy zookeeper-3.3.6 到另外一个目录
1.设置hosts文件，设置server对应的ip
127.0.0.1   zkserver01
127.0.0.1    zkserver02

2.修改配置文件zoo.cfg
#cluster config
server.1=zkserver01:2000:2001
server.2=zkserver02:2002:2003
解释一下上面的配置 server.1=zkserver01:2000:2001
1：表示第几号服务器，与myid中内容一致
zkserver01： 是server01 的ip地址，或者使用hosts中设置的主机名
2000：表示的是这个服务器与集群中的 Leader 服务器交换信息的端口
2001：表示的是万一集群中的 Leader 服务器挂了，需要一个端口来重新进行选举，选出一个新的 Leader，而这个端口就是用来执行选举时服务器相互通信的端口

另外，在zoo.cfg文件中，如果在同一台机器上设置集群，clientPort需要设置不同的端口号
3.添加myid文件
在zoo.cfg 配置的dataDir路径下添加文件myid(文件名)，文件内容就是上面的第几号服务器的值
4.启动集群
执行server01 的zkServer.cmd
执行server02的zkServer.cmd
先执行的server01 在server02启动之前会抛出异常，随着server02启动之后趋于正常，异常可以忽略
3.3使用demo
Demo中包含两个类Executor 和 DataMonitor 负责监听zookeeper某个节点，如果该节点数据发生变化，则dataMonitor会有所反应，然后把最新的data写入文件，并调用执行本地命令。
Zookeeper的watcher是单次有效，如果需要每次变化都能通知client，需要在client接受到变化之后再次注册watcher
if (path != null && path.equals(znode)) {
                // Something has changed on the node, let's find out
                zk.exists(znode, true, this, null);
            }

Zookeeper中watcher概念及特性可以查阅zookeeperProgrammers.pdf文档

单机zkserver执行Executor 的时候设置args： zkserver01:2181 / F:/app/log.txt hostname
集群执行的时候设置的hostPort 略有不同，zkserver01:2181, zkserver02:3181 / F:/app/log.txt hostname
zookeeper-client.zip为java project ，解压后import 到workspace即可