zookeeper的c的客户端编程实例

      2.1  进入刚刚安装的的zookeeper目录&＃xff0c;然后进入src/c目录

      2.2  ./configure –-prefix&＃61;/home/zookeeper/

       2.3 make

       2.4 make install

        然后进入/home/zookeeper下面&＃xff0c;可以看到&＃xff1a;

    然后还可以看得到各个目录下面的东西&＃xff1a;

可以看得到&＃xff0c;生成的库里面既有共享库&＃xff0c;又有静态库。

   建立目录如下&＃xff1a;

    将刚才生成的所有头文件拷贝到common/include下面&＃xff0c;将改成lib下面的libzookeeper_mt.a库拷贝到common/lib下面。

   然后在client目录下面编写client.c&＃xff0c;代码如下&＃xff1a;

#include 
#include 
#include 
#include 
#include 
#include 
void zktest_watcher_g(zhandle_t* zh, int type, int state,const char* path, void* watcherCtx)
{printf("Something happened.\n");printf("type: %d\n", type);printf("state: %d\n", state);printf("path: %s\n", path);printf("watcherCtx: %s\n", (char *)watcherCtx);
}
void zktest_dump_stat(const struct Stat *stat)
{char tctimes[40];char tmtimes[40];time_t tctime;time_t tmtime;if (!stat) {fprintf(stderr,"null\n");return;}tctime &＃61; stat->ctime/1000;tmtime &＃61; stat->mtime/1000;ctime_r(&tmtime, tmtimes);ctime_r(&tctime, tctimes);fprintf(stderr, "\tctime &＃61; %s\tczxid&＃61;%llx\n""\tmtime&＃61;%s\tmzxid&＃61;%llx\n""\tversion&＃61;%x\taversion&＃61;%x\n""\tephemeralOwner &＃61; %llx\n",tctimes, stat->czxid,tmtimes, stat->mzxid,(unsigned int)stat->version, (unsigned int)stat->aversion,stat->ephemeralOwner);
}
//当 zoo_aexists 请求完成时会调用该函数
//rc参数为: ZOK 操作完成&＃xff1b;ZNONODE 节点不存在&＃xff1b;ZNOAUTH 客户端没有权限删除节点。
void zktest_stat_completion(int rc, const struct Stat *stat, const void *data)
{fprintf(stderr, "%s: rc &＃61; %d Stat:\n", (char*)data, rc);zktest_dump_stat(stat);
}
void zktest_void_completion(int rc, const void *data)
{fprintf(stderr, "[%s]: rc &＃61; %d\n", (char*)(data&＃61;&＃61;0?"null":data), rc);
}
//当创建节点请求完成时会调用该函数
//rc 参数为: ZOK 操作完成&＃xff1b;ZNONODE 父节点不存在&＃xff1b;ZNODEEXISTS 节点已存在&＃xff1b;ZNOAUTH 客户端没有权限创建节点。ZNOCHILDRENFOREPHEMERALS 临时节点不能创建子节点
//value 参数即新节点的路径名
//string_completion_t completion 中 const void *data 参数即为 zoo_acreate 中的 const void *data。
void zktest_string_completion(int rc, const char *name, const void *data)
{fprintf(stderr, "[%s]: rc &＃61; %d\n", (char*)(data&＃61;&＃61;0?"null":data), rc);if (!rc) {fprintf(stderr, "\tname &＃61; %s\n", name);}
}
int main(int argc, const char *argv[])
{const char* host &＃61; "172.16.186.71:2191";//如果 30 秒内客户端没有连接上 Zookeeper 服务则表示连接超时。int timeout &＃61; 30000;//设置日志等级。zoo_set_debug_level(ZOO_LOG_LEVEL_WARN);
//初始化zookeeper句柄&＃xff08;zhandle_t&＃xff09;
//第四个参数为客户端会话id,客户端尝试重连的先前会话的ID&＃xff0c;如果不需要重连先前的会话&＃xff0c;则设置为 0
//第五个参数为当前zk的上下文对象&＃xff0c;最后一个参数是预留参数zhandle_t* zkhandle &＃61; zookeeper_init(host,zktest_watcher_g, timeout, 0, "hello zookeeper.", 0);if (zkhandle &＃61;&＃61; NULL) {fprintf(stderr, "Error when connecting to zookeeper servers...\n");exit(EXIT_FAILURE);}// struct ACL ALL_ACL[] &＃61; {{ZOO_PERM_ALL, ZOO_ANYONE_ID_UNSAFE}};// struct ACL_vector ALL_PERMS &＃61; {1, ALL_ACL};
//创建一个znode节点&＃xff0c;节点路径为"/xyz",保存一个长度为5&＃xff0c;内容为hello的数据&＃xff0c;任何人都可以访问
//这个一个异步函数&＃xff0c;调用之后&＃xff0c;直接往下执行&＃xff0c;但是此时节点并没有真正的创建成功。节点创建成功之后会调用zktest_string_compeltion函数
//最后一个参数是该回调函数&＃xff0c;要传入的参数int ret &＃61; zoo_acreate(zkhandle, "/xyz", "hello", 5,&ZOO_OPEN_ACL_UNSAFE, 0 /* ZOO_SEQUENCE */,zktest_string_completion, "acreate");if (ret) {fprintf(stderr, "Error %d for %s\n", ret, "acreate");exit(EXIT_FAILURE);}ret &＃61; 0;//第三个参数是监视&＃xff0c;如果非 0&＃xff0c;则在服务器端设置监视&＃xff0c;当节点发生变化时客户端会得到通知&＃xff0c;即使当前指定的节点不存在也会设置监视&＃xff0c;这样该节点被创建时&＃xff0c;客户端也可以得到通知。ret &＃61; zoo_aexists(zkhandle, "/xyz", 1, zktest_stat_completion, "aexists");if (ret) {fprintf(stderr, "Error %d for %s\n", ret, "aexists");exit(EXIT_FAILURE);}ret &＃61; 0;// Wait for asynchronous zookeeper call done.getchar();
//第三个参数:期望的节点版本号&＃xff0c;如果真实的版本号与期望的版本号不同则 zoo_delete() 调用失败&＃xff0c;-1 表示不不检查版本号。ret &＃61; zoo_adelete(zkhandle, "/xyz", -1, zktest_void_completion, "adelete");if (ret) {fprintf(stderr, "Error %d for %s\n", ret, "adelete");exit(EXIT_FAILURE);}// Wait for asynchronous zookeeper call done.getchar();zookeeper_close(zkhandle);return 0;
}

   然后编写makefile 如下

LIB_DIR&＃61;../common/lib
CC&＃61;gcc
RM&＃61;rm -rf
CFLAGS&＃61;-c  -Wall -DTHREAD  -I../common/include
client:client.o$(CC) $^  -lzookeeper_mt -lpthread -lm -L${LIB_DIR} -o $&＃64;
client.o:./client.c$(CC) $(CFLAGS) $^
clean:$(RM) client *.o

最后的运行结果如下&＃xff1a;

至此&＃xff0c;该程序写完了&＃xff0c;祝玩的愉快&＃xff01;