02.ZooKeeper读书笔记之入门案例

今天周六，周三请了一天假去学车了，周五上午又去面试了，所以今天加班补假，开发了一些代码后，研究了下zookeeper，说实话，我对它真不了解，但感觉资料不算多，大多讲的很浅，我就一点点的看吧，希望能出个系列教程，感觉一些大公司还是经常用它的。今天来讲一个入门案例，完成以下需求，有3个服务器，让这3个服务器在启动的时候连接zookeeper服务，创建属于该服务的临时结点，客户端通过连接服务器获取结点，选取合适的服务器ip访问。3个服务器我们就模拟了3个main函数，代码都差不多，我们看第一个service1

<span style="font-family: Arial, Helvetica, sans-serif;">public class Service1 {</span>

static String serviceName = "test1";
	static String serviceData = "192.168.11.133:8701";
	public static void main(String[] args) {
		try {
			ZooKeeper zk = new ZooKeeper(Connection.connectString,1000,new Watcher(){
				public void process(WatchedEvent event) {
				}
			});
			
			Stat root = zk.exists("/root/apps",false);
			if(root != null){
				String ok = zk.create("/root/apps/"+serviceName,serviceData.getBytes(),Ids.OPEN_ACL_UNSAFE,CreateMode.EPHEMERAL);
				System.out.println(ok);
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

代码的意思是服务启动的时候，使用Zookeeper连接服务，判断如果/root/apps目录存在的画，就创建属于自身的一个目录结点，这个目录是一个临时结点，即当前session断掉后，这个目录就自动删除了，这个session的超时时间是1000毫秒。其余两个服务也是此类代码，不过我们让第2个服务修改2000毫秒，这样我们在客户端就能清晰的辨认出可用的服务了，客户端代码如下：

public class Client {
	static String serverList = "192.168.11.160:2181,192.168.11.161:2181";
	public static void main(String[] args) {
		try {
			ZooKeeper zk = new ZooKeeper(serverList,10000,new Watcher(){
				public void process(WatchedEvent event) {
				}
			});
			
			List<String> childs = zk.getChildren("/root/apps",false);
			for(String str : childs){
				byte data[] = zk.getData("/root/apps/" + str, false,null);
				System.out.println("可用的服务器地址:"+new String(data));
			}

			Thread.sleep(2000);
			
			System.out.println("--------------------------------");
			

			List<String> childs2 = zk.getChildren("/root/apps",false);
			for(String str : childs2){
				byte data[] = zk.getData("/root/apps/" + str, false,null);
				System.out.println("可用的服务器地址:"+new String(data));
			}
			
			
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

客户端启动后，连接zookeeper，获取/root/apps下的所有子结点，子节点存在，说明服务是可用的，通过遍历可以获取每个结点对应的ip地址信息，然后客户端用过一定的算法得到最优的ip，当然，这个zookpeer是可以得到的应该。然后输出就ok了 过了2000毫秒，再次输出，这次应该少了一个服务，因为第1个服务我们在1000毫秒时就关闭了。

测试结果如下：