续上一篇的 ZooKeeper安装运行 这里采用ZooKeeper的
Java API进行连接。
Java实现
新建一个类实现接口Watcher. 是指：
This interface specifies the public interface an event handler class must implement. A ZooKeeper client will get various events from the ZooKeepr server it connects to. An application using such a client handles these events by registering a callback object with the client. The callback object is expected to be an instance of a class that implements Watcher interface.
[java]
/**
* AbstractZooKeeper.java
* 版权所有(C) 2013
* 创建:cuiran 2013-01-16 14:59:44
*/
package com.zoo.demo;
import java.io.IOException;
import java.util.concurrent.CountDownLatch;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.Watcher.Event.KeeperState;
/**
* TODO
* @author cuiran
* @version TODO
*/
public class AbstractZooKeeper implements Watcher {
private static Log log = LogFactory.getLog(AbstractZooKeeper.class.getName());
//缓存时间
private static final int SESSION_TIME = 2000;
protected ZooKeeper zooKeeper;
protected CountDownLatch countDownLatch=new CountDownLatch(1);
public void connect(String hosts) throws IOException, InterruptedException{
zooKeeper = new ZooKeeper(hosts,SESSION_TIME,this);
countDownLatch.await();
}
/* (non-Javadoc)
* @see org.apache.zookeeper.Watcher#process(org.apache.zookeeper.WatchedEvent)
*/
@Override
public void process(WatchedEvent event) {
// TODO Auto-generated method stub
if(event.getState()==KeeperState.SyncConnected){
countDownLatch.countDown();
}
}
public void close() throws InterruptedException{
zooKeeper.close();
}
}
然后写一些操作和main方法
[java]
/**
* ZooKeeperOperator.java
* 版权所有(C) 2013
* 创建:cuiran 2013-01-16 15:03:40
*/
package com.zoo.demo;
import java.util.Arrays;
import java.util.List;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooDefs.Ids;
/**
* TODO
* @author cuiran
* @version TODO
*/
public class ZooKeeperOperator extends AbstractZooKeeper {
private static Log log = LogFactory.getLog(ZooKeeperOperator.class.getName());
/**
*
*function:创建持久态的znode,比支持多层创建.比如在创建/parent/child的情况下,无/parent.无法通过
*@author cuiran
*@createDate 2013-01-16 15:08:38
*@param path
*@param data
*@throws KeeperException
*@throws InterruptedException
*/
public void create(String path,byte[] data)throws KeeperException, InterruptedException{
/**
* 此处采用的是CreateMode是PERSISTENT 表示The znode will not be automatically deleted upon client's disconnect.
* EPHEMERAL 表示The znode will be deleted