ZooKeeper实战【Windows集群环境搭建】

概述

ZooKeeper是Hadoop的开源子项目（Google Chubby的开源实现），它是一个针对大型分布式系统的可靠协调系统，提供的功能包括：配置管理、命名服务、分布式锁、集群管理等。

本文主要讲述如何在Windows环境上搭建ZooKeeper集群环境，注意是在一台Windows机器上部署3个ZooKeeper实例。
本文介绍的 Zookeeper 是以 3.4.8 稳定版本为基础，下载连接：http://zookeeper.apache.org/releases.html

配置

我在本地Windows机器上部署3个ZooKeeper实例，目录结构以下：

其中，Server_A，Server_B，Server_C各自都拥有一个ZooKeeper实例；ZK_data用来存储ZooKeeper数据信息；ZK_log用来存储ZooKeeper日志信息。
解压缩

将下载下来的zookeeper-3.4.8.tar.gz解压缩到F:\ZooKeeper\ZK_Cluster\Server_A目录下，以下图所示：

修改zoo.cfg

将conf/zoo_sample.cfg 复制一份命名为zoo.cfg，以下图所示：

而后编辑，以下：

# The number of milliseconds of each tick
tickTime=2000
# The number of ticks that the initial 
# synchronization phase can take
initLimit=10
# The number of ticks that can pass between 
# sending a request and getting an acknowledgement
syncLimit=5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just 
# example sakes.
dataDir=F:/ZooKeeper/ZK_Cluster/ZK_data/ServerA/data/
# the port at which the clients will connect
clientPort=2181
# the maximum number of client connections.
# increase this if you need to handle more clients
#maxClientCnxns=60

server.1=localhost:2887:3887
server.2=localhost:2888:3888
server.3=localhost:2889:3889

注意事项

1. 因为部署在同一台机器上，clientPort不能重复，建议Server_A的clientPort=2181，Server_B的clientPort=2182，依次递增。
2. server.A=B：C：D：其中 A 是一个数字，表示这个是第几号服务器；B 是这个服务器的 ip 地址；C表示的是这个服务器与集群中的 Leader 服务器交换信息的端口；D 表示的是万一集群中的 Leader服务器挂了，须要一个端口来从新进行选举，选出一个新的Leader，而这个端口就是用来执行选举时服务器相互通讯的端口。若是是伪集群的配置方式，因为 B 都是同样，因此不一样的ZooKeeper实例通讯端口号不能同样，因此要给它们分配不一样的端口号。
3. 集群模式下还要配置一个文件 myid，这个文件在 dataDir 目录下，这个文件里面只有一个数据就是A的值，ZooKeeper启动时会读取这个文件，拿到里面的数据与 zoo.cfg 里面的配置信息比较从而判断究竟是那个 server。
4. 
   至此，Server_A已经配置完毕了，同理依次配置Server_B、Server_C。

启动

配置完成后，咱们进入${ZooKeeper}/bin目录，双击zkServer.cmd脚本便可启动，以下图所示：

刚开始启动ZooKeeper时出现Java.NET.ConnectException: Connection refused: connect错误：

2016-05-08 22:53:37,188 [myid:1] - WARN  [QuorumPeer[myid=1]/0:0:0:0:0:0:0:0:2181:QuorumCnxManager@400] - Cannot open channel to 3 at election address /192.168.1.100:3889
java.net.ConnectException: Connection refused: connect
        at java.net.DualStackPlainSocketImpl.waitForConnect(Native Method)
        at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:85)
        at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
        at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
        at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
        at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172)
        at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
        at java.net.Socket.connect(Socket.java:589)
        at org.apache.zookeeper.server.quorum.QuorumCnxManager.connectOne(QuorumCnxManager.java:381)
        at org.apache.zookeeper.server.quorum.QuorumCnxManager.connectAll(QuorumCnxManager.java:426)
        at org.apache.zookeeper.server.quorum.FastLeaderElection.lookForLeader(FastLeaderElection.java:843)
        at org.apache.zookeeper.server.quorum.QuorumPeer.run(QuorumPeer.java:822)

这个是正常现象，由于此时其它的ZooKeeper实例还未启动，等全部的ZooKeeper实例都启动后集群就正常了。

验证

使用 zkCli.cmd -server 127.0.0.1:2181验证

bin> zkCli.cmd -server 127.0.0.1:2181