ZooKeeper安装及配置（Windows系统下）

# The number of milliseconds of each tick
tickTime=2000
# The number of ticks that the initial 
# synchronization phase can take
initLimit=10
# The number of ticks that can pass between 
# sending a request and getting an acknowledgement
syncLimit=5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just 
# example sakes.
dataDir=D:\Program Files (x86)\zookeeper-3.4.12\data  
dataLogDir=D:\Program Files (x86)\zookeeper-3.4.12\log 
# the port at which the clients will connect
clientPort=2181
# the maximum number of client connections.
# increase this if you need to handle more clients
#maxClientCnxns=60
#
# Be sure to read the maintenance section of the 
# administrator guide before turning on autopurge.
#
# http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance
#
# The number of snapshots to retain in dataDir
#autopurge.snapRetainCount=3
# Purge task interval in hours
# Set to "0" to disable auto purge feature
#autopurge.purgeInterval=1

initLimit=10 
syncLimit=5 
server.1=192.168.211.1:2888:3888 
server.2=192.168.211.2:2888:3888

import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;

public class WatcherTest implements Watcher{
    public void process(WatchedEvent arg0){
        System.out.println("========================");
        System.out.println("path:"+arg0.getPath());
        System.out.println("type:"+arg0.getType());
        System.out.println("state:"+arg0.getState());
    }
}

import java.io.IOException;

import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.Stat;

import com.zang.WatcherTest;

public class App 
{
    
    public static void main( String[] args ) throws IOException, KeeperException, InterruptedException {
        //创建一个Zookeeper实例，第一个参数为目标服务器地址和端口，第二个参数为Session超时时间，第三个为节点变化时的回调方法
       ZooKeeper zk = new ZooKeeper("127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183", 30000, new WatcherTest());
       
       String node = "/node2";
       Stat stat = zk.exists(node, false);
       if(null == stat){
           //创建一个节点，数据为test,不进行ACL权限控制，节点为永久性的 
           String createResult = zk.create(node, "test".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
           System.out.println(createResult);
       }
       
       //取得/node2/test节点下的数据,返回byte[] 
       byte[] b = zk.getData(node, false, stat);
       System.out.println(new String(b));
       zk.close();
    }
}