前段时间项目中用到Zookeeper，前人已经搭建好环境、封装好业务逻辑、只须要配置一下就能够用。简单但不够深刻，有点‘纸上得来终觉浅，绝知此事要躬行’的感受。
Zookeeper环境很是容易搭建，只须要注意下配置文件，在myid文件中写上配置文件中的编号便可，参考：http://attend.iteye.com/blog/1454212
查看ZK源代码，发现网络通讯用的是NIO实现的，创建客户端链接时，必定要等到状态为已链接时才能够进行下一步操做，代码实现借助锁的逻辑来实现。如：
final CountDownLatch countDownLatch = new CountDownLatch(1);
ZK 很大的用处是ZK集群上的每个变化均可以通知到自定义的Watchcer实现。利用ZK集群的高可用性（2X+1台机器，容忍X台机器挂掉）。而且ZK有一套如文件系统通常的能够增删改查的数据模型（Znode）。运用这套模型来实现自定义服务。有点抽象，画个图，以下：
客户端链接到ZK的物理集群中，集群中维护了Znode模型，客户端对znode进行操做，由Zk维护Znode模型的一致性和高可用性，而且能够对Znode节点增删改查数据。也能够用给Znode模型上添加新的节点。添加节点若是须要监控这个节点须要调用
zooKeeper.exists(path, true);方法，这个方法做用是：若是存在path并设置watch为true，监控起来，这样就能够把针对这个path的变化 通知到watcher.(明白这点很是重要，初学者常犯并无watcher这个path,就想获取到针对这个path的事件)。
来段测试代码:
package com.jcloud.zk.taokepper.reader;
import java.io.IOException;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.atomic.AtomicInteger;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.Watcher.Event.KeeperState;
import org.apache.zookeeper.ZooDefs.Ids;
public class ZkReader {
public static void main(String args[]) throws IOException, KeeperException,
InterruptedException {
//借助于该方法实现刚开始链接等待，链接好后，才容许下一步的逻辑。
final CountDownLatch countDownLatch = new CountDownLatch(1);
final ZooKeeper zooKeeper = new ZooKeeper("10.28.174.199:2181；10.28.174.79:2181", 10000,
new Watcher() {
@Override
public void process(WatchedEvent event) {
System.out.println("event." +event);
if (null != event) {
if (event.getState() == KeeperState.SyncConnected) {
//若是链接好了，能够下一步操做
countDownLatch.countDown();
System.out.println("---> created...");
}
}
}
});
countDownLatch.await();
//等到链接完成后后，开始下一步。
System.out.println("--->");
AtomicInteger increInt = new AtomicInteger();
String path="/2testnode0";
while (true) {
Thread.sleep(1000L);
//zooKeeper.create(path, "ttttt".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
//要在这个Path上作watcher
zooKeeper.exists(path, true);
//修改节点数据，触发watcher
zooKeeper.setData(path, (path+increInt.getAndAdd(1)).getBytes(), -1);
zooKeeper.setData(path, (path+increInt.getAndAdd(1)).getBytes(), -1);
System.out.println((path+increInt.getAndAdd(1)));
}
}
}
Zk有些经典使用场景，好比配置项推送，作法是，多个客户端链接到ZK集群中，监控同一个Znode，只要一个客户端改变了这个Znode，其余监控的客户端均可以收到相应的消息。
还能够用来作服务高可用性，最经典的用法是服务器起来的话，建立一个临时Znode,服务挂掉后删除这个Znode，其余监控到这个Znode的客户端也能够收到服务是否可用的消息。
还能够用来作选举场景，多个客户端建立同一个Znode,谁建立成功了谁就是老大。关于这个Znode的一致性就让ZK集群完成吧。
整体感受ZK确实提供是一款不错的一致性、高可用性工具。试着去用好它。