cppzk

c++ 封裝的zookeeper庫

特點：

1. c++封裝，介面簡單易用；
2. 檔案少，一個頭檔案和一個原始檔，無論是編譯成庫還是直接原始檔編譯都很方便；
3. 支援節點的create、set、get；支援watch；
4. 暫時只支援linux。

編譯

需要boost標頭檔案，因為使用了boost::function作為回撥函式。

linux下：

cd src
make -f Makefile.mk

生成libcppzk.a

如何使用

#include "ZooKeeper.h" // 包含標頭檔案

ZooKeeper zk; // 定義物件
zk.init("127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183")； // 初始化，引數為zookeeper伺服器地址列表，格式為:ip:port,ip:port,...
zk.exists(path)； // 判斷節點是否存在
zk.createNode(path, data, recursive); // 遞迴建立節點（recursivce=false時不遞迴建立，當父節點不存在時直接返回錯誤 ）
zk.createEphemeralNode(path, data, recursive); // 遞迴建立ephemeral節點
zk.createSequenceNode(path, data, rpath, recursive); // 遞迴建立sequence節點， rpath為返回的實際路徑
// watch
zk.watchData(path, dataCallback); // watch節點資料，當資料變化時，觸發回撥函式
zk.watchChildren(path, childrenCallback); // watch子節點，當增加或刪除子節點時，觸發回撥函式
// 日誌
zk.setLogStream(stderr); // 設定日誌流
zk.setDebugLogLevel(true); // 開啟debug日誌
 

watch的callback的定義：

// 兩種callback，資料回撥和子節點回調
// DataWatchCallback返回路徑和該路徑的值
// ChildrenWatchCallback返回路徑和該路徑下的子節點名
typedef boost::function<void (const std::string &path, const std::string &value)> DataWatchCallback;
typedef boost::function<void (const std::string &path, const std::vector<std::string> &value)> ChildrenWatchCallback;
 

以上程式碼為清晰起見，省略了錯誤處理和一些變數的定義，完整程式碼可參見src/test.cc