ZooKeeper使用入門

ZooKeeperオンラインAPI
http://zookeeper.apache.org/doc/r3.4.6/api/index.html
ZooKeeper APIには、org.apache.zookeeper,org.apache.zookeeper.data,org.apache.zookeeper.server,org.apache.zookeeper.server.quorumおよびorg.apache.zookeeper.server.upgradeの5つのパッケージが含まれています.ここでorg.apache.zookeeperにはZooKeeperクラスが含まれています.これは私たちがプログラミングするときに最もよく使われるクラスファイルです.
このZooKeeperクラスはZooKeeperクライアントライブラリの主なクラスファイルです.ZooKeeperサービスを使用する場合は、アプリケーションがまずZookeeperインスタンスを作成する必要があります.この場合、このような使用が必要です.クライアントとZooKeeperサービスが接続を確立すると、ZooKeeperシステムは、この接続に返信するID値を割り当て、クライアントは周期的にサーバにハートビートを送信してセッションの接続を維持する.接続が有効であれば、クライアントはZooKeeper APIを呼び出して対応する処理を行うことができる.
ZooKeeperのJava APIを使用してzookeeperの簡単な使用を実現し、簡単な古典的な小さなニーズを達成します.
例:クライアントにサービスを提供するサーバのセットがあると仮定します.各クライアントが1台のサーバを見つけて、このサービスを使用できるようにしたいと考えています.
このサーバのリストをどのように維持するかという課題があります.このサーバのメンバーリストは、ネットワーク内の単一のノードに格納できないことは明らかです.そうしないと、ノードの障害はシステム全体の障害を意味し、このメンバーリストが高可用性であることを望んでいます.
また、1台のサーバに障害が発生した場合、このサーバメンバーのリストからノードを削除して、使用できないサービスを提供しないようにしたいと考えています.
対応するインプリメンテーション・コード・オブジェクトには、次のクラスがあります.
ConnectionWatcher.java    クライアントとZooKeeperサービス間の接続を維持します.
CreateGroup.java    指定したサービスグループをZooKeeperに作成します.
DeleteGroup.java    指定したサービスグループをZooKeeperに削除します.
JoinGroup.java    指定したサービスグループにメンバーを追加します.
ListGroup.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
", path);
		} catch (KeeperException.NoNodeException e) {
			System.out.printf("Group %s does not exist
", 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
", groupName);
				System.exit(1);
			}
			for(String child : children){
				System.out.println(child);
			}
		} catch (KeeperException.NoNodeException e) {
			System.out.printf("Group %s does not exist
", 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();
	}
}