如何使用Curator操作zookeeper

Curator是Netflix开源的一套ZooKeeper客户端框架，用它来操作zookeeper更加简单方便，按Curator官方所比喻的，guava to JAVA， Curator to Zookeeper，Curator采用了fluent风格的代码，非常简洁。

有关curator的介绍：请参照官方文档：http://curator.apache.org/index.html


本篇主要看下，使用curator操作zookeeper的一些基础例子：
主要的功能：
1，在zk上添加，或更新数据
2，删除zk节点上数据
3，读取某个节点上的数据
4，上传一些本地文件到zk节点上
5，检查zookeeper上是否存在某个节点路径

核心代码如下：
<pre name="code" class="java">package com.qin.curator.zk;

import java.io.File;
import java.util.List;

import org.apache.commons.io.FileUtils;
import org.apache.curator.CuratorZookeeperClient;
import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.CuratorFrameworkFactory.Builder;
import org.apache.curator.framework.api.CreateBuilder;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZKUtil;

import framework.CrudExamples;
/**
* @author qindongliang
* curator操作zookeeper的
* 基本例子
* **/
public class CuratorTools {

static CuratorFramework zkclient=null;
static String nameSpace="php";
static {

  String zkhost="192.168.46.22:2181";//zk的host
  RetryPolicy rp=new ExponentialBackoffRetry(1000, 3);//重试机制
  Builder builder = CuratorFrameworkFactory.builder().connectString(zkhost)
  .connectionTimeoutMs(5000)
  .sessionTimeoutMs(5000)
  .retryPolicy(rp);
  builder.namespace(nameSpace);
  CuratorFramework zclient = builder.build();
  zkclient=zclient;
  zkclient.start();// 放在这前面执行
  zkclient.newNamespaceAwareEnsurePath(nameSpace);
 
}

public static void main(String[] args)throws Exception {
CuratorTools ct=new  CuratorTools();
//ct.getListChildren("/zk/bb");
//ct.upload("/jianli/123.txt", "D:\\123.txt");
//ct.createrOrUpdate("/zk/cc334/zzz","c");
//ct.delete("/qinb/bb");
//ct.checkExist("/zk");
ct.read("/jianli/123.txt");
zkclient.close();


}

/**
* 创建或更新一个节点
*
* @param path 路径
* @param content 内容
* **/
public void createrOrUpdate(String path,String content)throws Exception{

zkclient.newNamespaceAwareEnsurePath(path).ensure(zkclient.getZookeeperClient());
    zkclient.setData().forPath(path,content.getBytes());
    System.out.println("添加成功！！！");

}

/**
* 删除zk节点
* @param path 删除节点的路径
*
* **/
public void delete(String path)throws Exception{
zkclient.delete().guaranteed().deletingChildrenIfNeeded().forPath(path);
System.out.println("删除成功!");
}


/**
* 判断路径是否存在
* @param path
* **/
public void checkExist(String path)throws Exception{

if(zkclient.checkExists().forPath(path)==null){
System.out.println("路径不存在!");
}else{
System.out.println("路径已经存在!");
}

}

/**
* 读取的路径
* @param path
* **/
public void read(String path)throws Exception{


String data=new String(zkclient.getData().forPath(path),"gbk");

System.out.println("读取的数据:"+data);

}


/**
* @param path 路径
* 获取某个节点下的所有子文件
* */
public void getListChildren(String path)throws Exception{

List&lt;String&gt; paths=zkclient.getChildren().forPath(path);
for(String p:paths){
System.out.println(p);
}

}

/**
* @param zkPath zk上的路径
* @param localpath 本地上的文件路径
*
* **/
public void upload(String zkPath,String localpath)throws Exception{

createrOrUpdate(zkPath, "");//创建路径
byte[] bs=FileUtils.readFileToByteArray(new File(localpath));
zkclient.setData().forPath(zkPath, bs);
System.out.println("上传文件成功！");


}





}
</pre>