public class Demo2 {

public static void main(String[] args) {

String connectString = "192.168.168.133:2181";

int sessionTimeout = 500000; // 會(huì)話(huà)時(shí)間。設(shè)置長(zhǎng)一點(diǎn)，如果不夠長(zhǎng)，則會(huì)connect loss

try {

// 建立zookeeper鏈接

ZooKeeper zk = new ZooKeeper(connectString, sessionTimeout, new Watcher(){

public void process(WatchedEvent event) {

// 監(jiān)控所有觸發(fā)的事件

System.out.println("start do something");

EventType type = event.getType(); // 事件類(lèi)型。枚舉

KeeperState state = event.getState(); // 狀態(tài)。 枚舉

// type.getIntValue();

switch (type) {

case None: // int值對(duì)應(yīng) -1

System.out.println("none 事件觸發(fā)");

break;

case NodeCreated: // int值對(duì)應(yīng) 1

System.out.println("創(chuàng)建節(jié)點(diǎn)事件發(fā)生了");

break;

case NodeDeleted: // int值對(duì)應(yīng) 2

System.out.println("刪除節(jié)點(diǎn)事件發(fā)生了");

break;

case NodeDataChanged: // int值對(duì)應(yīng) 3

System.out.println("節(jié)點(diǎn)數(shù)據(jù)改變事件發(fā)生了");

break;

case NodeChildrenChanged: // int值對(duì)應(yīng) 4

System.out.println("子節(jié)點(diǎn)改變事件發(fā)生了");

break;

default:

System.out.println("I do not know what operate you do");

break;

}

// state.getIntValue(); NoSyncConnected 1和Unknown-1

switch (state) {

case Disconnected: // 0

System.out.println("失去連接");

break;

case SyncConnected: // 3

System.out.println("異步鏈接");

break;

case Expired: // -112

System.out.println("超時(shí)過(guò)期");

break;

default:

break;

}

System.out.println("end");

}

});

System.out.println("zk創(chuàng)建成功");

List list = zk.getChildren("/", true); // 獲取所有節(jié)點(diǎn)

if(list != null) {

for(String s : list)

System.out.println(s);

}

// 在/app5節(jié)點(diǎn)下創(chuàng)建child節(jié)點(diǎn)

zk.create("/app7", "/app8的子節(jié)點(diǎn)數(shù)據(jù)".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); // 會(huì)對(duì)數(shù)據(jù)持久化，服務(wù)下次啟動(dòng)任然存在

zk.create("/app8", "/app8的子節(jié)點(diǎn)數(shù)據(jù)".getBytes(), Ids.OPEN_ACL_UNSAFE,

CreateMode.PERSISTENT, new StringCallback(){

public void processResult(int rc, String path, Object ctx, String name) {

System.out.println("rc: " + rc);

System.out.println("path: " + path);

System.out.println("Object:" + ctx);

System.out.println("name: " + name);

}

}, "ctx object");

} catch (IOException e) {

e.printStackTrace();

} catch (KeeperException e) {

e.printStackTrace();

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}

zk每一次操縱都會(huì)被監(jiān)控watcher記錄下來(lái)

出現(xiàn)這種報(bào)錯(cuò)是由于創(chuàng)建節(jié)點(diǎn)的時(shí)候沒(méi)有創(chuàng)建父節(jié)點(diǎn) /app1

總結(jié)

以上是生活随笔為你收集整理的java连接zookeeper_java 学习笔记（四） java连接ZooKeeper的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。