zookeeper c api 安装 & 连接 zookeeper

一、安装c api

　　以此方式下载的zookeeper

wget "http://mirrors.hust.edu.cn/apache/zookeeper/zookeeper-3.4.14/zookeeper-3.4.14.tar.gz"

　　c api源码位于zookeeper-3.4.14/zookeeper-client/zookeeper-client-c

cd zookeeper-3.4.14/zookeeper-client/zookeeper-client-c
./configure
make
sudo make install

　　安装后也可以在/usr/local/include/zookeeper中找到头文件，当然也可以把它拷走至自己的指定目录。

二、使用c api连接zookeeper

zookeeper_test.c

#include <zookeeper.h>
#include <zookeeper_log.h>
#include <zookeeper.jute.h>
#include <stdio.h>

//伪分布式部署 host list最好以配置文件形式，此处为测试程序，暂时写死
const char * host_list = "127.0.0.1:12181,127.0.0.1:12182,127.0.0.1:12183";
void zk_watcher(zhandle_t *zh, int type, int state, const char *path,void *watcherCtx)
{
    printf("zk_watcher: [type=%d] [state=%d] [path=%s] [watcher_ctx=%p]
", type, state, path, watcherCtx);
}

void zk_exists(zhandle_t *zkhandle, const char *path)
{
    struct Stat stat;
    printf("zk_exists: ==========BEGIN============
");
    int ret_code = zoo_exists(zkhandle, path, 0, &stat);
    printf("zk_exists: [ret=%d]
", ret_code);
    if(ZOK == ret_code)
    {
        printf("zk_exists: [path=%s] [czxid=%ld] [mzxid=%ld] [version=%d] [cversion=%d] [child_num=%d]
",
               path, stat.czxid, stat.mzxid, stat.version, stat);
    }
    printf("zk_exists: ==========END============
");
}

int main()
{
    int time_out = 50000;
    zoo_set_debug_level(ZOO_LOG_LEVEL_DEBUG);
    zhandle_t * zkhandle = zookeeper_init(host_list, zk_watcher, time_out, 0, NULL, 0);
    if (NULL == zkhandle)
    {
        printf("main: connect to zk fail.
");
        return -1;
    }
    zk_exists(zkhandle, "/");

    zookeeper_close(zkhandle);

    return 0;
}

Makefile

ZK_CAPI_PATH := /usr/local

INC_PATH := ${ZK_CAPI_PATH}/include/zookeeper
SRC_PATH := ./*.c
LIB_PATH := ${ZK_CAPI_PATH}/lib

LIB_NAME := zookeeper_mt

EXE_NAME := zookeeper_test.exe

main:
        gcc -g -DTHREADED ${SRC_PATH} -I ${INC_PATH} -o ${EXE_NAME} -L ${LIB_PATH} -l ${LIB_NAME}
clean:
        rm ${EXE_NAME}

编译后运行

root@iZwz9hextk0ee6gik32377Z:~/zookeeper/c_test# make
gcc -g -DTHREADED ./*.c -I /usr/local/include/zookeeper -o zookeeper_test.exe -L /usr/local/lib -l zookeeper_mt
root@iZwz9hextk0ee6gik32377Z:~/zookeeper/c_test# ./zookeeper_test.exe 
2020-04-11 11:30:04,628:26341(0x7fd9a61b3740):ZOO_INFO@log_env@753: Client environment:zookeeper.version=zookeeper C client 3.4.14
2020-04-11 11:30:04,628:26341(0x7fd9a61b3740):ZOO_INFO@log_env@757: Client environment:host.name=iZwz9hextk0ee6gik32377Z
2020-04-11 11:30:04,628:26341(0x7fd9a61b3740):ZOO_INFO@log_env@764: Client environment:os.name=Linux
2020-04-11 11:30:04,628:26341(0x7fd9a61b3740):ZOO_INFO@log_env@765: Client environment:os.arch=4.15.0-88-generic
2020-04-11 11:30:04,628:26341(0x7fd9a61b3740):ZOO_INFO@log_env@766: Client environment:os.version=#88-Ubuntu SMP Tue Feb 11 20:11:34 UTC 2020
2020-04-11 11:30:04,628:26341(0x7fd9a61b3740):ZOO_INFO@log_env@774: Client environment:user.name=root
2020-04-11 11:30:04,628:26341(0x7fd9a61b3740):ZOO_INFO@log_env@782: Client environment:user.home=/root
2020-04-11 11:30:04,628:26341(0x7fd9a61b3740):ZOO_INFO@log_env@794: Client environment:user.dir=/root/zookeeper/c_test
2020-04-11 11:30:04,628:26341(0x7fd9a61b3740):ZOO_INFO@zookeeper_init@827: Initiating client connection, host=127.0.0.1:12181,127.0.0.1:12182,127.0.0.1:12183 sessionTimeout=50000 watcher=0x559328a3b86a sessionId=0 sessionPasswd=<null> context=(nil) flags=0
2020-04-11 11:30:04,629:26341(0x7fd9a61b3740):ZOO_DEBUG@start_threads@221: starting threads...
2020-04-11 11:30:04,629:26341(0x7fd9a4f30700):ZOO_DEBUG@do_io@367: started IO thread
zk_exists: ==========BEGIN============
2020-04-11 11:30:04,629:26341(0x7fd9a472f700):ZOO_DEBUG@do_completion@458: started completion thread
2020-04-11 11:30:04,629:26341(0x7fd9a61b3740):ZOO_DEBUG@zoo_awexists@2894: Sending request xid=0x5e9139bd for path [/] to 127.0.0.1:12183
2020-04-11 11:30:04,633:26341(0x7fd9a4f30700):ZOO_INFO@check_events@1764: initiated connection to server [127.0.0.1:12183]
2020-04-11 11:30:04,635:26341(0x7fd9a4f30700):ZOO_INFO@check_events@1811: session establishment complete on server [127.0.0.1:12183], sessionId=0x30000314d590004, negotiated timeout=40000
2020-04-11 11:30:04,635:26341(0x7fd9a4f30700):ZOO_DEBUG@check_events@1817: Calling a watcher for a ZOO_SESSION_EVENT and the state=ZOO_CONNECTED_STATE
2020-04-11 11:30:04,635:26341(0x7fd9a472f700):ZOO_DEBUG@process_completions@2169: Calling a watcher for node [], type = -1 event=ZOO_SESSION_EVENT
zk_watcher: [type=-1] [state=3] [path=] [watcher_ctx=(nil)]
2020-04-11 11:30:04,636:26341(0x7fd9a4f30700):ZOO_DEBUG@process_sync_completion@1929: Processing sync_completion with type=1 xid=0x5e9139bd rc=0
zk_exists: [ret=0]
zk_exists: [path=/] [czxid=0] [mzxid=0] [version=0] [cversion=8] [child_num=2]
zk_exists: ==========END============
2020-04-11 11:30:04,636:26341(0x7fd9a4f30700):ZOO_DEBUG@do_io@445: IO thread terminated
2020-04-11 11:30:04,636:26341(0x7fd9a472f700):ZOO_DEBUG@do_completion@468: completion thread terminated
2020-04-11 11:30:04,636:26341(0x7fd9a61b3740):ZOO_INFO@zookeeper_close@2564: Closing zookeeper sessionId=0x30000314d590004 to [127.0.0.1:12183]

可以看到取到的“/”目录的信息：

zk_exists: [path=/] [czxid=0] [mzxid=0] [version=0] [cversion=8] [child_num=2]

实际从zookeeper client中得到的：

[zk: 127.0.0.1:12181(CONNECTED) 0] get /

cZxid = 0x0
ctime = Thu Jan 01 08:00:00 CST 1970
mZxid = 0x0
mtime = Thu Jan 01 08:00:00 CST 1970
pZxid = 0x400000018
cversion = 8
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 0
numChildren = 2

参考链接：

　　https://www.cnblogs.com/haippy/archive/2013/02/21/2920280.html