首先我們需要理解一件事情，雖然大多數人學習ZooKeeper是因為Hadoop和大資料，但實際上ZK只是分散式一致性演算法的實現，和大資料以及Hadoop並無任何關係。

ZK本身是一套樹樁結構的檔案系統，這個系統每個檔案節點可以存放一點兒資料。重點是這個檔案系統十分敏感，一旦任何資料發生變化，ZK就會檢測到並且報告給客戶端。

我們利用這個特性來監管分散式系統的伺服器，配置檔案，名稱空間等。

這裡我給出一個小例子，希望幫助初學者理解，ZK是如何實現上述功能的

準備工作：

1，通過ZK的客戶端視窗，建立一個空的檔案，用來作為分散式檔案系統的跟目錄

create /servergroup ""

現實中每個節點代表一個伺服器，伺服器啟動時候，就會寫入一個節點檔案。伺服器斷開後，節點檔案就會消失。我們可以根據這一點判斷伺服器是否連線。

package com.dynamic.client;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.Stat;
//客戶端監聽服務，監控ZK伺服器指定節點變化資訊
//如果znode（伺服器節點）的子節點發生變化，就會更新客戶端的serverlist
public class AppClient {
	//Application伺服器節點路徑
	private String groupnode = "/servergroup";
	private ZooKeeper zk;//客戶端例項
	private Stat stat= new Stat(); //儲存節點狀態資訊
	//儲存server列表資料
	//volatile多執行緒的情況下保持資料一致性
	private volatile List<String> serverlist;
	
	
	//建立連結伺服器的Client，第三個引數是建立監視器例項
	public void connectZK() throws Exception{
		
		String hosts = "server72:2181,server73:2181,server74:2181";//zookeeper伺服器列表
		final int SESSION_TIMEOUT = 30000;//會話有效時間		
		
		//我們獲得了一個已經連線ZK伺服器的Client,這個Client會話有效時間是30秒，有一個watcher監控該例項
		zk = new ZooKeeper(hosts, SESSION_TIMEOUT, new Watcher(){
			@Override
			public void process(WatchedEvent event) {
				//如果發生子節點發生變化事件，就更新serverlist,並重新繫結watcher
				//子節點發生變化 && 時間的路徑是 "/servergroup"
				if(event.getType()== Watcher.Event.EventType.NodeChildrenChanged && groupnode.equals(event.getPath())){
					
					try {
						//呼叫更新serverlist方法
						updateServerlist();
					} catch (Exception e) {
						e.printStackTrace();
					}				
				}
			}
			
		});
		//建立物件後更新一次server列表
		System.out.println("---客戶端已經連線伺服器---");
		updateServerlist();	
	}
	
	//更新server列表的方法
	public void updateServerlist() throws Exception {
		List<String> newserverlist = new ArrayList<String>();
		//ture表示給groupnode新增watcher(watcher被觸發後就失效了)
		//返回所有子節點的名稱
		List<String> childlist = zk.getChildren(groupnode, true);
		
		for(String childname:childlist){
			//獲取節點的資料
			byte data [] =zk.getData(groupnode+"/"+childname, false,stat);
			String childdata = new String(data,"utf-8");//按照utf-8轉化為字串
			//新增child的全路徑
			newserverlist.add(groupnode+"/"+childname+"/"+childdata);			
		}
		serverlist = newserverlist;
		System.out.println("-----伺服器列表已經更新----"+new Date());
		for(String ss:serverlist){
			System.out.println(ss);
		}
		
	}
	
	public void handle() throws InterruptedException{
		Thread.sleep(Long.MAX_VALUE);		
	}
	
	public static void main(String[] args) throws Exception {
		AppClient ac = new AppClient();
		ac.connectZK();
		ac.handle();//執行緒等待
	}
}
 

測試：

現在我在重新寫一個程式，在eclipse上模擬建立一個臨時的，序列化的節點，並在3秒鐘後斷開連線。臨時節點意味著，斷開客戶端連線後這個節點就自動消失。

根據這個特性，伺服器如果斷開我們就可以迅速感知到，並且列出剩餘可用的伺服器。

package com.dynamic.client;

import java.io.IOException;

import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooDefs.Ids;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.Stat;

public class ServerMissTest {
	private String groupnode = "/servergroup";
	private ZooKeeper zk;
	private Stat stat= new Stat();
	
	void zkConnect() throws IOException{
		String hosts = "server72:2181,server73:2181,server74:2181";//zookeeper伺服器列表
		final int SESSION_TIMEOUT = 30000;//會話有效時間		
		zk = new ZooKeeper(hosts, SESSION_TIMEOUT, new Watcher(){

			@Override
			public void process(WatchedEvent event) {
				// TODO Auto-generated method stub
				System.out.println("--start watching--");
				System.out.println(event.toString());
			}
			
		});
	}
	
	void createNodeServer() throws KeeperException, InterruptedException{
		//建立一個臨時的，序列化的節點，模仿HDFS的namenode
		zk.create(groupnode+"/"+"HDFS-Namenode", "Namenode1".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);
	}
	
	public static void main(String[] args) throws IOException, KeeperException, InterruptedException {
		ServerMissTest smt = new ServerMissTest();
		smt.zkConnect();
		//建立了一個臨時的節點，並在3秒鐘後斷開連線。這個臨時的幾點就會消失。
		smt.createNodeServer();		
		Thread.sleep(3000);		
		
		//我們希望監聽埠能夠檢測到節點消失，並且打印出現在活著的節點。
		
	}
}

在40分56秒，我啟動了程式，客戶端監聽到了

在41分27秒，執行緒3秒接收後了，但整個過程持續了30秒左右，客戶端監聽到了Namenode1消失，並且打印出了可以使用的伺服器列表

以上，今天感覺CSDN不能貼上圖片非常不爽，準備搬家部落格園吧。