ZooKeeper源码解析(二)-Java编程API

ZooKeeper还为客户端提供了Java API编程接口的方式。API接口主要是ZooKeeper类中的方法,下面列举几个经常使用的客户端操做的Java代码示例。编程

create

建立ZooKeeper路径节点,参数需提供路径名称和路径关联数据。对应create命令。session

示例代码以下:this

ZooKeeper zk= new ZooKeeper("127.0.0.1",SESSION_TIME,this); zk.create("/test","Hello".getBytes(), null, CreateMode.PERSISTENT);  spa

 

删除

删除路径,对应delete命令。接口

ZooKeeper zk= new ZooKeeper("127.0.0.1",SESSION_TIME,this);事件

zk.delete("/test", -1); ci

 

getData

获取路径关联数据。对应get命令。get

ZooKeeper zk= new ZooKeeper("127.0.0.1",SESSION_TIME,this);io

String data  = zk.getData("/test", false,null); event

 

setData

设置节点关联数据。对应set命令。

ZooKeeper zk= new ZooKeeper("127.0.0.1",SESSION_TIME,this);

zk.setData ("/test", "Welcome".getBytes(), -1);

 

 getChildren

获取子节点路径列表。对应ls命令。

ZooKeeper zk= new ZooKeeper("127.0.0.1",SESSION_TIME,this);

List<String> list = zk.getChildren("/", false); 

 

Watcher

设置观察者:

只要在实例化ZooKeeper类时指定Watcher实现便可实现ZooKeeper事件,Watcher实现只须要实现process接口方法便可。

示例代码:

zk = new ZooKeeper(address, sessionTimeout, new Watcher() { 

     // 监控全部被触发的事件 

     public void process(WatchedEvent event) { 

           System.out.println("触发事件:" + event.getType()); 

    } 

});  

这段代码监听ZooKeeper全部变化,事件处理代码是打印event类型。

相关文章
相关标签/搜索