Zookeeper 作为一个分布式的服务框架，主要用来解决分布式集群中应用系统的一致性问题。它能提供基于类似于文件系统的目录节点树方式的数据存储，但是 Zookeeper 并不是用来专门存储数据的，它的作用主要是用来维护和监控你存储的数据的状态变化。通过监控这些数据状态的变化，从而可以达到基于数据的集群管理，在本节实践中，我们将会通过java工程来看Zookeeper 的操作接口和简单使用情况。

一、目标

建立java工程，使用zookeeper的api 对其进行简单操作。

了解接口的分类和情况

二、环境

在虚拟机192.168.136.144上部署了zookeeper，伪分布式方式。

在本机192.168.136.1 eclipse环境下建立 java工程

三、zookeeper java api工程情况

1）依赖库

2） 代码

package com.solostudy.zookeeper.api; import java.io.IOException; import java.util.List; import java.util.concurrent.CountDownLatch; import org.apache.zookeeper.CreateMode; import org.apache.zookeeper.KeeperException; import org.apache.zookeeper.WatchedEvent; import org.apache.zookeeper.Watcher; import org.apache.zookeeper.Watcher.Event.KeeperState; import org.apache.zookeeper.ZooDefs.Ids; import org.apache.zookeeper.ZooKeeper; public class CliApiDemo implements Watcher { public final String CLIENT_PORT = "2181"; public final String ZK_IP = "192.168.136.144"; public final Integer CONNECTION_TIMEOUT = 1000; public ZooKeeper zk = null; private CountDownLatch connectedSemaphore = new CountDownLatch(1); /** * 继承了watcher，需要实现process接口，这个接口类似一个回调函数 收到来自Server的Watcher通知后的处理。 */ @Override public void process(WatchedEvent event) { //System.out.println("收到事件通知：" + event.getState() + "\n"); if (KeeperState.SyncConnected == event.getState()) { connectedSemaphore.countDown(); } } /** * zookeeper连接方法，成功返回true，否则返回false * */ public boolean ZK_con() { String con_string = ZK_IP + ":" + CLIENT_PORT; try { zk = new ZooKeeper(con_string, CONNECTION_TIMEOUT, this); // connectedSemaphore.await(); } catch (InterruptedException e) { System.out.println("连接创建失败，发生 InterruptedException"); e.printStackTrace(); return false; } catch (IOException e) { System.out.println("连接创建失败，发生 IOException"); e.printStackTrace(); return false; } return true; } /** * zookeeper 创建目录或者子目录，成功返回true，否则返回false * */ public boolean ZK_create(String strPath, String strDir) { try { zk.create(strPath, strDir.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); } catch (KeeperException e) { // TODO Auto-generated catch block e.printStackTrace(); return false; } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); return false; } return true; } /** * zookeeper连接方法，成功返回true，否则返回false * */ public String ZK_getNode(String strPath) { String result = ""; try { result = new String(zk.getData(strPath, false, null)); } catch (KeeperException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } return result; } public List ZK_getChild(String strPath) { List<String> resultList = null; try { resultList = zk.getChildren(strPath, true); } catch (KeeperException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } return resultList; } // 设置节点数据 public boolean ZK_setNodeDate(String strPath, String strNewData) { try { zk.setData(strPath, strNewData.getBytes(), -1); } catch (KeeperException e) { // TODO Auto-generated catch block e.printStackTrace(); return false; } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); return false; } return true; } // 判断节点是否存在 public boolean ZK_exists(String strPath) { try { zk.exists(strPath, true); } catch (KeeperException e) { // TODO Auto-generated catch block e.printStackTrace(); return false; } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); return false; } return true; } // 删除节点 public boolean ZK_delete(String strPath) { try { zk.delete(strPath, -1); } catch (KeeperException e) { // TODO Auto-generated catch block e.printStackTrace(); return false; } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); return false; } return true; } // 删除节点 public boolean ZK_close() { try { zk.close(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); return false; } return true; } public static void main(String[] args) { // 创建一个CliApiDemo对象 CliApiDemo myCliApiDemo = new CliApiDemo(); // 创建一个与服务器的连接 if (myCliApiDemo.ZK_con()) { System.out.println("ZK connect succesfully!"); } else { System.out.println("ZK connect failed!"); System.exit(0); } // 创建一个目录节点 if (myCliApiDemo.ZK_create("/MyPath", "MyPath")) System.out.println(myCliApiDemo.ZK_getNode("/MyPath")); else System.out.println("Create Node failed!!!"); // 创建一个子目录节点 if (myCliApiDemo.ZK_create("/MyPath/MyChildPath1", "child-1")) System.out.println(myCliApiDemo.ZK_getChild("/MyPath")); else System.out.println("Create children Node failed!!!"); // 修改子目录节点数据 if (myCliApiDemo.ZK_setNodeDate("/MyPath/MyChildPath1", "child-1")) System.out.println("目录节点状态：[" + myCliApiDemo.ZK_exists("/MyPath") + "]"); else System.out.println("Set New Data failed!!!"); // 创建另外一个子目录节点 if (myCliApiDemo.ZK_create("/MyPath/MyChildPath2", "child-2")) System.out.println(myCliApiDemo .ZK_getChild("/MyPath")); else System.out.println("Create children Node failed!!!"); // 删除子目录节点 myCliApiDemo.ZK_delete("/MyPath/MyChildPath2"); myCliApiDemo.ZK_delete("/MyPath/MyChildPath1"); // 删除父目录节点 myCliApiDemo.ZK_delete("/MyPath"); // 关闭连接 myCliApiDemo.ZK_close(); } } 执行结果如下图：

四、zookeeper常用接口列表

客户端要连接 Zookeeper 服务器可以通过创建 org.apache.zookeeper. ZooKeeper 的一个实例对象，然后调用这个类提供的接口来和服务器交互。 这些接口如下表所示：