Java API操作ZooKeeper

创建会话
 1 package org.zln.zk;
 2 
 3 import org.apache.zookeeper.WatchedEvent;
 4 import org.apache.zookeeper.Watcher;
 5 import org.apache.zookeeper.ZooKeeper;
 6 
 7 import java.io.IOException;
 8 
 9 /**
10  * Created by sherry on 16/8/27.
11  */
12 public class TestZooKeeperClientApi {
13 
14     private static ZooKeeper zooKeeper;
15 
16     public static void main(String[] args) throws IOException, InterruptedException {
17         createSession();
18     }
19 
20     /**
21      * 创建会话
22      */
23     private static ZooKeeper createSession() throws IOException, InterruptedException {
24         //实例化的过程,同时也是与ZooKeeper建立连接的过程,参数说明:ip:port 超时时间  监听器(实现water接口,监听器用于接收通知)
25         zooKeeper = new ZooKeeper("127.0.0.1:2181", 5000, new Watcher() {
26             @Override
27             public void process(WatchedEvent watchedEvent) {
28                 System.out.println("收到事件:"+watchedEvent);//收到事件:WatchedEvent state:SyncConnected type:None path:null
29 
30 
31                 //TODO
32             }
33         });
34         System.out.println("查看状态:"+zooKeeper.getState());//查看状态:CONNECTING
35 
36         //如果不停一段时间,那么,监听器还没收到监听,方法就已经退出了
37         Thread.sleep(5000);
38 
39         return zooKeeper;
40 
41 
42     }
43 }
创建会话