Curator是Netflix开源的一套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上是否存在某个节点路径

核心代码如下：

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<String> 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("上传文件成功！");  
          
          

    }  }