zookeeper如何在java项目中使用

packageorg.zookeeper.demo;importjava.io.IOException;importjava.util.concurrent.CountDownLatch;importorg.apache.zookeeper.CreateMode;importorg.apache.zookeeper.KeeperException;importorg.apache.zookeeper.WatchedEvent;importorg.apache.zookeeper.Watcher;importorg.apache.zookeeper.Watcher.Event.KeeperState;importorg.apache.zookeeper.ZooDefs.Ids;importorg.apache.zookeeper.ZooKeeper;publicclassZookeeperClientimplementsWatcher{//连接超时时间,10sprivatestaticfinalintSESSION_TIMEOUT= 10000;//连接的zookeeperserverprivatestaticfinalStringCONNECTION_STRING = "172.31.25.8:2181";privatestaticfinalStringZK_PATH = "/qyktest";privateZooKeeperzk = null;privateCountDownLatchconnectedSemaphore = newCountDownLatch(1);publicvoidcreateConnection(StringconnectString, intsessionTimeout){this.releaseConnection();try{zk= newZooKeeper(connectString,sessionTimeout, this);connectedSemaphore.await();}catch(InterruptedExceptione) {System.out.println("连接创建失败，发生InterruptedException");e.printStackTrace();}catch(IOExceptione) {System.out.println("连接创建失败，发生IOException");e.printStackTrace();}}publicvoidreleaseConnection(){if(this.zk!= null){try{this.zk.close();}catch(InterruptedExceptione) {e.printStackTrace();}}}publicbooleancreatePath(Stringpath, String data) {try{Stringresult = this.zk.create(path,data.getBytes(), Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);System.out.println("节点创建成功,Path: "+result + ", content: "+data);}catch(KeeperExceptione) {System.out.println("节点创建失败，发生KeeperException");e.printStackTrace();}catch(InterruptedExceptione) {System.out.println("节点创建失败，发生InterruptedException");e.printStackTrace();}returntrue;}publicStringreadData(Stringpath) {try{System.out.println("获取数据成功，path："+path);returnnewString(this.zk.getData(path,false,null));}catch(KeeperExceptione) {System.out.println("读取数据失败，发生KeeperException，path:"+path);e.printStackTrace();return"";}catch(InterruptedExceptione) {System.out.println("读取数据失败，发生InterruptedException，path: "+path);e.printStackTrace();return"";}}publicbooleanwriteData(Stringpath, String data) {try{System.out.println("更新数据成功，path："+path + ", stat: "+this.zk.setData(path,data.getBytes(), -1));}catch(KeeperExceptione) {System.out.println("更新数据失败，发生KeeperException，path:"+path);e.printStackTrace();}catch(InterruptedExceptione) {System.out.println("更新数据失败，发生InterruptedException，path: "+path);e.printStackTrace();}returnfalse;}publicvoiddeleteNode(Stringpath) {try{this.zk.delete(path,-1);System.out.println("删除节点成功，path："+path);}catch(KeeperExceptione) {System.out.println("删除节点失败，发生KeeperException，path:"+path);e.printStackTrace();}catch(InterruptedExceptione) {System.out.println("删除节点失败，发生InterruptedException，path: "+path);e.printStackTrace();}}publicstaticvoidmain(String[]args) {ZookeeperClientsample = newZookeeperClient();//获取连接sample.createConnection(CONNECTION_STRING,SESSION_TIMEOUT);//读数据Stringqyk = sample.readData("/qyktest");System.out.println("qyk:"+qyk);Stringurl = sample.readData("/qyk/db/url");System.out.println("url"+url);Stringdriver = sample.readData("/qyk/db/driver");System.out.println("driver"+driver);StringuserName = sample.readData("/qyk/db/userName");System.out.println("userName"+userName);Stringpassword = sample.readData("/qyk/db/password");System.out.println("password"+password);//创建节点sample.createPath(ZK_PATH,"我是节点初始内容");System.out.println("数据内容:"+sample.readData(ZK_PATH) + "\n");//更新节点sample.writeData(ZK_PATH,"更新后的数据");System.out.println("数据内容:"+sample.readData(ZK_PATH) + "\n");//删除节点sample.deleteNode(ZK_PATH);//释放连接sample.releaseConnection();}@Overridepublicvoidprocess(WatchedEventevent) {System.out.println("收到事件通知："+event.getState() + "\n");if(KeeperState.SyncConnected== event.getState()) {connectedSemaphore.countDown();}}}