zookeeper学习笔记：java实现与zookeeper的连接

《zookeeper学习笔记：java实现与zookeeper的连接》由会员上传分享，免费在线阅读，更多相关内容在工程资料-天天文库。

1、Zookeeper学习笔记：Java实现与ZooKeeper的连接Java实现与ZooKeeper的连接zookeeper开发实例教程：Zookeeper从入门到精通（开发详解，案例实战，Web界面监控）zookeeper实例教程学习地址：http://www.ibeifeng.com/goods-380.htmlJava实现新建一个类实现接口Watcher.是指：Thisinterfacespecifiesthepublicinterfaceaneventhandlerclassmustimplement.AZooK

2、eeperclientwillgetvariouseventsfromtheZooKeeprserveritconnectsto.Anapplicationusingsuchaclienthandlestheseeventsbyregisteringacallbackobjectwiththeclient.ThecallbackobjectisexpectedtobeaninstanceofaclassthatimplementsWatcherinterface./***AbstractZooKeeper.java*版

3、权所有(C)2013*创建:cuiran2013-01-1614:59:44*/packagecom.zoo.demo;importjava.io.IOException;importjava.util.concurrent.CountDownLatch;importorg.apache.commons.logging.Log;importorg.apache.commons.logging.LogFactory;importorg.apache.zookeeper.WatchedEvent;importorg.apa

4、che.zookeeper.Watcher;importorg.apache.zookeeper.ZooKeeper;importorg.apache.zookeeper.Watcher.Event.KeeperState;/***TODO*@authorcuiran*@versionTODO*/publicclassAbstractZooKeeperimplementsWatcher{privatestaticLoglog=LogFactory.getLog(AbstractZooKeeper.class.getNa

5、me());//缓存时间privatestaticfinalintSESSION_TIME=2000;protectedZooKeeperzooKeeper;protectedCountDownLatchcountDownLatch=newCountDownLatch(1);publicvoidconnect(Stringhosts)throwsIOException,InterruptedException{zooKeeper=newZooKeeper(hosts,SESSION_TIME,this);countDo

6、wnLatch.await();}/*(non-Javadoc)*@seeorg.apache.zookeeper.Watcher#process(org.apache.zookeeper.WatchedEvent)*/@Overridepublicvoidprocess(WatchedEventevent){//TODOAuto-generatedmethodstubif(event.getState()==KeeperState.SyncConnected){countDownLatch.countDown();}

7、}publicvoidclose()throwsInterruptedException{zooKeeper.close();}}然后写一些操作和main方法/***ZooKeeperOperator.java*版权所有(C)2013*创建:cuiran2013-01-1615:03:40*/packagecom.zoo.demo;importjava.util.Arrays;importjava.util.List;importorg.apache.commons.logging.Log;importorg.apac

8、he.commons.logging.LogFactory;importorg.apache.zookeeper.CreateMode;importorg.apache.zookeeper.KeeperException;importorg.apache.zookeeper.ZooDefs.Ids;/***TODO*@author