(转)Zookeeper的安装配置以及Java的API

jialiguo

　　       最近在大量看有关ZooKeeper的博客，有关Zookeeper配置和Java的Api的博客发现了两篇，特此转载于此。向原作者致敬。
　　       转自：
　　                       http://coolxing.iteye.com/blog/1871009
　　                       http://coolxing.iteye.com/blog/1871347
　　ZK的安装和配置：
    Zookeeper的安装和配置十分简单, 既可以配置成单机模式, 也可以配置成集群模式. 下面将分别进行介绍.
单机模式
点击这里下载zookeeper的安装包之后, 解压到合适目录. 进入zookeeper目录下的conf子目录, 创建zoo.cfg:
 

• tickTime=2000    
  
• dataDir=/Users/apple/zookeeper/data    
  
• dataLogDir=/Users/apple/zookeeper/logs    
  
• clientPort=4180   
  

参数说明:

• tickTime: zookeeper中使用的基本时间单位, 毫秒值.
  
• dataDir: 数据目录. 可以是任意目录.
  
• dataLogDir: log目录, 同样可以是任意目录. 如果没有设置该参数, 将使用和dataDir相同的设置.
  
• clientPort: 监听client连接的端口号.
  

至此, zookeeper的单机模式已经配置好了. 启动server只需运行脚本:
 

• bin/zkServer.sh start  
  

　　 Server启动之后, 就可以启动client连接server了, 执行脚本:
 

• bin/zkCli.sh -server localhost:4180  
  

　　 
伪集群模式
所谓伪集群, 是指在单台机器中启动多个zookeeper进程, 并组成一个集群. 以启动3个zookeeper进程为例.
将zookeeper的目录拷贝2份:
 

• |--zookeeper0  
  
• |--zookeeper1  
  
• |--zookeeper2  
  

 更改zookeeper0/conf/zoo.cfg文件为:
 

• tickTime=2000    
  
• initLimit=5    
  
• syncLimit=2    
  
• dataDir=/Users/apple/zookeeper0/data    
  
• dataLogDir=/Users/apple/zookeeper0/logs    
  
• clientPort=4180  
  
• server.0=127.0.0.1:8880:7770    
  
• server.1=127.0.0.1:8881:7771    
  
• server.2=127.0.0.1:8882:7772  
  

新增了几个参数, 其含义如下:

• initLimit: zookeeper集群中的包含多台server, 其中一台为leader, 集群中其余的server为follower. initLimit参数配置初始化连接时, follower和leader之间的最长心跳时间. 此时该参数设置为5, 说明时间限制为5倍tickTime, 即5*2000=10000ms=10s.
  
• syncLimit: 该参数配置leader和follower之间发送消息, 请求和应答的最大时间长度. 此时该参数设置为2, 说明时间限制为2倍tickTime, 即4000ms.
  
• server.X=A:B:C 其中X是一个数字, 表示这是第几号server. A是该server所在的IP地址. B配置该server和集群中的leader交换消息所使用的端口. C配置选举leader时所使用的端口. 由于配置的是伪集群模式, 所以各个server的B, C参数必须不同.
  

    参照zookeeper0/conf/zoo.cfg, 配置zookeeper1/conf/zoo.cfg, 和zookeeper2/conf/zoo.cfg文件. 只需更改dataDir, dataLogDir, clientPort参数即可.
    在之前设置的dataDir中新建myid文件, 写入一个数字, 该数字表示这是第几号server. 该数字必须和zoo.cfg文件中的server.X中的X一一对应.
/Users/apple/zookeeper0/data/myid文件中写入0, /Users/apple/zookeeper1/data/myid文件中写入1, /Users/apple/zookeeper2/data/myid文件中写入2.
    分别进入/Users/apple/zookeeper0/bin, /Users/apple/zookeeper1/bin, /Users/apple/zookeeper2/bin三个目录, 启动server.
    任意选择一个server目录, 启动客户端:
 

• bin/zkCli.sh -server localhost:4180  
  

 
集群模式
    集群模式的配置和伪集群基本一致.
    由于集群模式下, 各server部署在不同的机器上, 因此各server的conf/zoo.cfg文件可以完全一样.
下面是一个示例:
 

• tickTime=2000    
  
• initLimit=5    
  
• syncLimit=2    
  
• dataDir=/home/zookeeper/data    
  
• dataLogDir=/home/zookeeper/logs    
  
• clientPort=4180  
  
• server.43=10.1.39.43:2888:3888  
  
• server.47=10.1.39.47:2888:3888    
  
• server.48=10.1.39.48:2888:3888  
  

    示例中部署了3台zookeeper server, 分别部署在10.1.39.43, 10.1.39.47, 10.1.39.48上. 需要注意的是, 各server的dataDir目录下的myid文件中的数字必须不同.
    10.1.39.43 server的myid为43, 10.1.39.47 server的myid为47, 10.1.39.48 server的myid为48.
　　Java的API：
    ZooKeeper提供了Java和C的binding. 本文关注Java相关的API.
准备工作
    拷贝ZooKeeper安装目录下的zookeeper.x.x.x.jar文件到项目的classpath路径下.
创建连接和回调接口
首先需要创建ZooKeeper对象, 后续的一切操作都是基于该对象进行的.
 

• ZooKeeper(String connectString, int sessionTimeout, Watcher watcher) throws IOException  
  

以下为各个参数的详细说明:

• connectString. zookeeper server列表, 以逗号隔开. ZooKeeper对象初始化后, 将从server列表中选择一个server, 并尝试与其建立连接. 如果连接建立失败, 则会从列表的剩余项中选择一个server, 并再次尝试建立连接.
  
• sessionTimeout. 指定连接的超时时间.
  
• watcher. 事件回调接口.
  

注意, 创建ZooKeeper对象时, 只要对象完成初始化便立刻返回. 建立连接是以异步的形式进行的, 当连接成功建立后, 会回调watcher的process方法. 如果想要同步建立与server的连接, 需要自己进一步封装.
 

• public class ZKConnection {  
  
•     /** 
  
•      * server列表, 以逗号分割 
  
•      */  
  
•     protected String hosts = "localhost:4180,localhost:4181,localhost:4182";  
  
•     /** 
  
•      * 连接的超时时间, 毫秒 
  
•      */  
  
•     private static final int SESSION_TIMEOUT = 5000;  
  
•     private CountDownLatch connectedSignal = new CountDownLatch(1);  
  
•     protected ZooKeeper zk;  
  
•   
  
•     /** 
  
•      * 连接zookeeper server 
  
•      */  
  
•     public void connect() throws Exception {  
  
•         zk = new ZooKeeper(hosts, SESSION_TIMEOUT, new ConnWatcher());  
  
•         // 等待连接完成  
  
•         connectedSignal.await();  
  
•     }  
  
•   
  
•     public class ConnWatcher implements Watcher {  
  
•         public void process(WatchedEvent event) {  
  
•             // 连接建立, 回调process接口时, 其event.getState()为KeeperState.SyncConnected  
  
•             if (event.getState() == KeeperState.SyncConnected) {  
  
•                 // 放开闸门, wait在connect方法上的线程将被唤醒  
  
•                 connectedSignal.countDown();  
  
•             }  
  
•         }  
  
•     }  
  
• }  
  

 
创建znode
ZooKeeper对象的create方法用于创建znode.
 

• String create(String path, byte[] data, List acl, CreateMode createMode);  
  

以下为各个参数的详细说明:

• path. znode的路径.
  
• data. 与znode关联的数据.
  
• acl. 指定权限信息, 如果不想指定权限, 可以传入Ids.OPEN_ACL_UNSAFE.
  
• 指定znode类型. CreateMode是一个枚举类, 从中选择一个成员传入即可. 关于znode类型的详细说明, 可参考本人的上一篇博文.
  

 

• /** 
  
•  * 创建临时节点 
  
•  */  
  
• public void create(String nodePath, byte[] data) throws Exception {  
  
•     zk.create(nodePath, data, Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);  
  
• }  
  

 
获取子node列表
ZooKeeper对象的getChildren方法用于获取子node列表.
 

• List getChildren(String path, boolean watch);  
  

  watch参数用于指定是否监听path node的子node的增加和删除事件, 以及path node本身的删除事件.
判断znode是否存在
ZooKeeper对象的exists方法用于判断指定znode是否存在.
 

• Stat exists(String path, boolean watch);  
  

    watch参数用于指定是否监听path node的创建, 删除事件, 以及数据更新事件. 如果该node存在, 则返回该node的状态信息, 否则返回null.
获取node中关联的数据
    ZooKeeper对象的getData方法用于获取node关联的数据.
 

• byte[] getData(String path, boolean watch, Stat stat);  
  

    watch参数用于指定是否监听path node的删除事件, 以及数据更新事件, 注意, 不监听path node的创建事件, 因为如果path node不存在, 该方法将抛出KeeperException.NoNodeException异常.
    stat参数是个传出参数, getData方法会将path node的状态信息设置到该参数中.
更新node中关联的数据
ZooKeeper对象的setData方法用于更新node关联的数据.
 

• Stat setData(final String path, byte data[], int version);  
  

    data为待更新的数据.
     version参数指定要更新的数据的版本, 如果version和真实的版本不同, 更新操作将失败. 指定version为-1则忽略版本检查.
    返回path node的状态信息.
删除znode
ZooKeeper对象的delete方法用于删除znode.
 

• void delete(final String path, int version);  
  

version参数的作用同setData方法.
其余接口
请查看ZooKeeper对象的API文档.
需要注意的几个地方

• znode中关联的数据不能超过1M. zookeeper的使命是分布式协作, 而不是数据存储.
  
• getChildren, getData, exists方法可指定是否监听相应的事件. 而create, delete, setData方法则会触发相应的事件的发生.
  
• 以上介绍的几个方法大多存在其异步的重载方法, 具体请查看API说明.