ZooKeeper使用入門

ZooKeeper線上API

http://zookeeper.apache.org/doc/r3.4.6/api/index.html

ZooKeeper API共包含5個包，分别為：org.apache.zookeeper，org.apache.zookeeper.data，org.apache.zookeeper.server，org.apache.zookeeper.server.quorum和org.apache.zookeeper.server.upgrade。其中org.apache.zookeeper包含ZooKeeper類，它是我們程式設計時最常用的類檔案。

這個ZooKeeper類是ZooKeeper用戶端庫的主要類檔案。如果要使用ZooKeeper服務，應用程式首先必須建立一個Zookeeper執行個體，這時就需要使用此類。一旦用戶端和ZooKeeper服務建立起連接配接，ZooKeeper系統将會配置設定給此連接配接回話一個ID值，并且用戶端将會周期地向伺服器發送心跳來維持會話的連接配接。隻要連接配接有效，用戶端就可以調用ZooKeeper API來做相應的處理。

使用ZooKeeper的Java API來實作簡單的使用zookeeper，并完成一個簡單的經典小需求。

示例：假設有一組伺服器用于為用戶端提供某種服務。我們希望每個用戶端都能找到其中一台伺服器，這樣它們就可以使用這項服務。

有一個挑戰是如何維護這組伺服器的清單。這組伺服器的成員清單顯然不能存儲在網絡中的單個節點上，否則該節點的故障将意味着整個系統的故障，我們希望這個成員清單是高可用的。

我們還希望當其中一台伺服器出現故障時，能夠從這組伺服器成員清單中删除該節點，避免提供不可用的服務。

相應的實作代碼對象以下幾個類：

ConnectionWatcher.java    維護用戶端和ZooKeeper服務之間的連接配接；

CreateGroup.java    建立指定的服務組在ZooKeeper上；

DeleteGroup.java    删除指定的服務組在ZooKeeper上；

JoinGroup.java    添加成員在指定的服務組；

public class ConnectionWatcher implements Watcher{

	private static final int SESSION_TIMEOUT = 5000;
	protected ZooKeeper zk;
	private CountDownLatch connectedSignal = new CountDownLatch(1);
	
	public void connect(String hosts) throws Exception{
		//建立zookeeper執行個體的時候會啟動一個線程連接配接到zookeeper服務。
		zk = new ZooKeeper(hosts, SESSION_TIMEOUT, this);
		connectedSignal.await();
	}

	//當用戶端已經與zookeeper建立連接配接後，Watcher的process方法會被調用。
	public void process(WatchedEvent event) {
		if(event.getState() == KeeperState.SyncConnected){
			connectedSignal.countDown();
		}
	}

	public void close() throws Exception{
		zk.close();
	}
}      

public class CreateGroup extends ConnectionWatcher{

	public void create(String groupName) throws Exception{
		String path = "/"+groupName;
		//建立一個完全開發的ACL（通路控制清單）、持久的znode
		String createdPath = zk.create(path, null, Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
		System.out.println("Created "+createdPath);
	}
	/**
	 * @param args
	 * @throws Exception 
	 */
	public static void main(String[] args) throws Exception {
		// TODO Auto-generated method stub
		CreateGroup createGroup = new CreateGroup();
		createGroup.connect("192.168.44.231");
		createGroup.create("myzoo");
		createGroup.close();
	}
}      

public class DeleteGroup extends ConnectionWatcher{

	public void delete(String groupName) throws Exception{
		String path = "/" + groupName;
		try {
			//ZooKeeper不支援遞歸删除操作，是以在删除父節點之前必須先删除子節點。
			List<String> children = zk.getChildren(path, false);
			for(String child : children){
				zk.delete(path+"/"+child, -1);
			}
			zk.delete(path, -1);
			System.out.printf("Delete Group %s\n", path);
		} catch (KeeperException.NoNodeException e) {
			System.out.printf("Group %s does not exist\n", groupName);
			System.exit(1);
		}
	}
	
	public static void main(String[] args) throws Exception {
		DeleteGroup deleteGroup  = new DeleteGroup();
		deleteGroup.connect("192.168.44.231");
		deleteGroup.delete("myzoo");
		deleteGroup.close();
	}
}      

public class JoinGroup extends ConnectionWatcher{

	public void join(String groupName, String memberName) throws Exception{
		String path = "/" + groupName + "/" + memberName;
		String createdPath = zk.create(path, null, Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
		System.out.println("Created "+ createdPath);
	}
	
	/**
	 * @param args
	 * @throws Exception 
	 */
	public static void main(String[] args) throws Exception {
		// TODO Auto-generated method stub
		JoinGroup joinGroup  = new JoinGroup();
		joinGroup.connect("192.168.44.231");
		joinGroup.join("myzoo", "myservice2");
		
		//stay alive until process is killed or thread is interrupted
		Thread.sleep(Long.MAX_VALUE);
	}
}      

public class ListGroup extends ConnectionWatcher{

	public void list(String groupName) throws Exception{
		String path = "/" + groupName;
		try {
			List<String> children = zk.getChildren(path, false);
			if(children.isEmpty()){
				System.out.printf("No members in group %s\n", groupName);
				System.exit(1);
			}
			for(String child : children){
				System.out.println(child);
			}
		} catch (KeeperException.NoNodeException e) {
			System.out.printf("Group %s does not exist\n", groupName);
			System.exit(1);
		}
	}
	
	/**
	 * @param args
	 * @throws Exception 
	 */
	public static void main(String[] args) throws Exception {
		// TODO Auto-generated method stub
		ListGroup listGroup  = new ListGroup();
		listGroup.connect("192.168.44.231");
		listGroup.list("myzoo");
		listGroup.close();
	}
}