第一步导入jar包

下面就是Zookeeper，Java常用的API

public class ZookeeperDemo {
    public static void main(String[] args) throws Exception {
        Watcher watcher = new Watcher() {
            @Override
            public void process(WatchedEvent watchedEvent) {
                System.out.println("路径"+watchedEvent.getPath());
                System.out.println("状态"+watchedEvent.getState());
                System.out.println("类型"+watchedEvent.getType());
            }
        };
        ZooKeeper zk = new ZooKeeper("node01:2181,node02:2181,node03:2181", 10000, watcher);
        //创建节点
        zk.create("/zhangsan","zhangsanfeng".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);

        //查看节点数据
        String str = new String(zk.getData("/zhangsan", false, null));
        System.out.println(str);
        //修改节点数据
        zk.setData("/zhangsan","mangfu".getBytes(),-1);
        //删除节点
        zk.delete("/zhangsan",-1);
        //关流
        zk.close();
    }
}