import org.apache.zookeeper.*;
import org.apache.zookeeper.ZooDefs.Ids;
import org.apache.zookeeper.data.Stat;

import java.util.concurrent.CountDownLatch;

class DataMonitor implements Watcher, AsyncCallback.StatCallback{
    public ZooKeeper zk = null;
    private int i = 0;
    public int iexistcheck = 0;
    public DataMonitor(){

    }

    public void process(WatchedEvent event) {
        String path = event.getPath();
        System.out.println("process: iexistcheck="+iexistcheck+" - "+"i:="+i+",path:"+path+" - state:" + event.getState());
        i++;
    }

    public void processResult(int rc, String path, Object ctx, Stat stat) {
        System.out.println("processResult.1:iexistcheck="+iexistcheck+" - "+"i:="+i+",rc:" + rc + " - path:"+path+" - state:" + stat);
        try {
            System.out.println("processResult.2.getData:iexistcheck="+iexistcheck+" - "+"i:="+i+" - "+new String(zk.getData("/test", false, null)));
        }catch (Exception e){
            System.out.print("processResult.3:exception.....iexistcheck="+iexistcheck+" - "+"i:="+i);
        }finally {
            System.out.println("processResult.4:iexistcheck="+iexistcheck+" - "+"i:="+i+",end......end......end..");
        }
    }
}

public class ZooKeeperTest {

    private static CountDownLatch downLatch = new CountDownLatch(1);
    private static final int TIME_OUT = 300000;
    private static final String HOST = "localhost:2181";
    public static void main(String[] args) throws Exception{
        DataMonitor dm = new DataMonitor();
        ZooKeeper zookeeper = new ZooKeeper(HOST, TIME_OUT, dm);
        dm.zk = zookeeper;
        zookeeper.exists("/test", true, dm, dm);
        Stat stat =  null;
        for(int i = 0; i < 30; i++){
            String buf = "value="+i;
            System.out.println("loop i="+i);
            if(zookeeper.exists("/test", false) == null)
            {
                //PERSISTENT_SEQUENTIAL模式情况下，真正路径是从返回值获取。其格式为/test0000000028。
                //EPHEMERAL模式下，该节点是临时节点，当超时或session断开时，它也跟随着消失。适合检验机器岩机与否等状态。防单点或执备切换等。
                String node_real = zookeeper.create("/test", "znode1".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
                System.out.println("nodename:"+node_real);
            }
            //第三个参数为版本号，当前输入的版本号与目标版本的版本号是相同的情况，才能更新到数据。否则会更新失败。
            if(stat == null){
                stat = zookeeper.setData(node_real, buf.getBytes() , -1);
            }else{
                stat = zookeeper.setData(node_real, buf.getBytes() , stat.getVersion());
            }
            System.out.println("Czxid:" + stat.getCzxid() + " - Mzxid:" + stat.getMzxid() + " - Version:" + stat.getVersion());
            if(i > 5){
                if(i % 3 == 0){
                    dm.iexistcheck = i;
                    zookeeper.exists("/test", true, dm, dm);
                }
            }
            Thread.sleep(1000);
        }
        zookeeper.delete("/test", -1);
        Thread.sleep(5000);
        zookeeper.close();
    }
}

			org.apache.zookeeper
        		zookeeper
        		3.4.8
        		
            			
                			com.sun.jmx
                			jmxri
            			
            			
					com.sun.jdmk
                			jmxtools
            			
            			
                			javax.jms
                			jms
            			
        		
        	

loop i=0
process: iexistcheck=0 - i:=0,path:null - state:SyncConnected
processResult.1:iexistcheck=0 - i:=1,rc:-101 - path:/test - state:null
processResult.3:exception.....iexistcheck=0 - i:=1processResult.4:iexistcheck=0 - i:=1,end......end......end..
process: iexistcheck=0 - i:=1,path:/test - state:SyncConnected
Czxid:1055 - Mzxid:1056 - Version:1
loop i=1
Czxid:1055 - Mzxid:1057 - Version:2
loop i=2
Czxid:1055 - Mzxid:1058 - Version:3
loop i=3
Czxid:1055 - Mzxid:1059 - Version:4
loop i=4
Czxid:1055 - Mzxid:1060 - Version:5
loop i=5
Czxid:1055 - Mzxid:1061 - Version:6
loop i=6
Czxid:1055 - Mzxid:1062 - Version:7
processResult.1:iexistcheck=6 - i:=1,rc:0 - path:/test0000000029 - state:1055,1062,1480343483194,1480343489294,7,0,0,0,7,0,1055

processResult.2.getData:iexistcheck=6 - i:=1 - value=6
processResult.4:iexistcheck=6 - i:=1,end......end......end..
loop i=7
process: iexistcheck=6 - i:=1,path:/test0000000029 - state:SyncConnected
Czxid:1055 - Mzxid:1063 - Version:8
loop i=8
Czxid:1055 - Mzxid:1064 - Version:9
loop i=9
Czxid:1055 - Mzxid:1065 - Version:10
processResult.1:iexistcheck=9 - i:=2,rc:0 - path:/test0000000029 - state:1055,1065,1480343483194,1480343492344,10,0,0,0,7,0,1055

processResult.2.getData:iexistcheck=9 - i:=2 - value=9
processResult.4:iexistcheck=9 - i:=2,end......end......end..