zookeeper原生API操作

2021-09-11 21:26:11 字數 1920 閱讀 2527

/**

* zookeeper 學習

* watcher(事件***)

* @author kevin

*/public class zookeeperbase }}

});//進行阻塞

connectedsemaphore.await();

system.out.println("..");

string path = "/testroot";

string data = "測試資料";

//判斷乙個節點是否已經存在

stat stat = nodeexists(path, true);

if (stat == null)

//獲取該節點的內容

system.out.println(readdata(path,false));

//更新該節點的資料

updatedata(path,"更新後的資料");

//獲取該節點更新後的內容

system.out.println(readdata(path,false));

//獲取該節點下的所有子節點

listchildrenlist = getchildren(path,false);

for(string children:childrenlist)

//刪除節點

deletenode(path);

//關閉連線

zk.close();

}/**

* 判斷指定的節點是否已經存在

** @param path

* @param needwatch

* @return

*/public static stat nodeexists(string path, boolean needwatch) catch (exception e)

}/**

* 建立節點

* @param path

* @param data

* @param watcher

* @return

*/public static boolean createnode(string path, string data, boolean watcher) catch (exception e)

return true;

}/**

* 刪除指定節點

* version -1 表示刪除所有的版本

* @param path

*/public static void deletenode(string path) catch (exception e)

}/**

* 更新指定節點的內容

* @param path

* @param data

* @return

*/public static boolean updatedata(string path, string data) catch (exception e)

return true;

}/**

* 獲取所有的子節點

* @param path

* @param needwatch

* @return

*/public static listgetchildren(string path,boolean needwatch) catch (exception e)

}/**

* 讀取指定節點資料內容

* @param path

* @param needwatch

* @return

*/public static string readdata(string path,boolean needwatch) catch (exception e)

}}

zookeeper原生API及Curator的使用

原生api 節點特性 zookeeper節點特性 public class zkdemo countdownlatch.await system.out.println zookeeper.getstate 節點路徑 值 acl 節點的操作許可權 節點的型別,持久化節點 zookeeper.crea...

常用的Xenomai 原生API

常用的xenomai 原生api 1 任務管理 xenomai 本身提供的一系列多任務排程機制,主要有以下一些函式 int rt task create rt task task,const char name,int stksize,int prio,int mode 任務的建立 int rt t...

原生Django常用API 引數

建立虛擬環境 mkvirtualenv django py3 1.11 p python3安裝django pip install django 1.11.111.建立工程 django admin startproject 工程名稱2.建立子應用 3.執行 python manage.py run...