欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

java 中 zookeeper简单使用

程序员文章站 2024-02-27 20:48:33
一、zookeeper的基本原理 数据模型,如下: zookeeper数据模型的结构与unix文件系统很类似,整体上可以看作是一棵树,每个节点称做一个zno...

一、zookeeper的基本原理

数据模型,如下:


java 中 zookeeper简单使用

zookeeper数据模型的结构与unix文件系统很类似,整体上可以看作是一棵树,每个节点称做一个znode。每个znode都可以通过其路径唯一标识,比如上图中第三层的第一个znode,它的路径是/app1/c1。在每个znode上可存储少量数据(默认是1m, 可以通过配置修改,通常不建议在znode上存储大量的数据),这个特性非常有用。另外,每个znode上还存储了其acl信息,这里需要注意,虽说znode的树形结构跟unix文件系统很类似,但是其acl与unix文件系统是完全不同的,每个znode的acl的独立的,子结点不会继承父结点的。

zookeeper特性:

1、读、写(更新)模式

在zookeeper集群中,读可以从任意一个zookeeperserver读,这一点是保证zookeeper比较好的读性能的关键;写的请求会先forwarder到leader,然后由leader来通过zookeeper中的原子广播协议,将请求广播给所有的follower,leader收到一半以上的写成功的ack后,就认为该写成功了,就会将该写进行持久化,并告诉客户端写成功了。

2、wal和snapshot

和大多数分布式系统一样,zookeeper也有wal(write-ahead-log),对于每一个更新操作,zookeeper都会先写wal,然后再对内存中的数据做更新,然后向client通知更新结果。另外,zookeeper还会定期将内存中的目录树进行snapshot,落地到磁盘上,这个跟hdfs中的fsimage是比较类似的。这么做的主要目的,一当然是数据的持久化,二是加快重启之后的恢复速度,如果全部通过replaywal的形式恢复的话,会比较慢。

3、fifo

对于每一个zookeeper客户端而言,所有的操作都是遵循fifo顺序的,这一特性是由下面两个基本特性来保证的:一是zookeeperclient与server之间的网络通信是基于tcp,tcp保证了client/server之间传输包的顺序;二是zookeeperserver执行客户端请求也是严格按照fifo顺序的。

4、linearizability

在zookeeper中,所有的更新操作都有严格的偏序关系,更新操作都是串行执行的,这一点是保证zookeeper功能正确性的关键。

二、zookeeper的常用命令

我们可以执行zookeeper-client或者执行/opt/cloudera/parcels/cdh-5.0.0-1.cdh5.0.0.p0.47/lib/zookeeper/bin/zkcli.sh-server localhost,进入zookeeper命令行,如下:


java 中 zookeeper简单使用

然后,执行ls /可以看到:


java 中 zookeeper简单使用

然后,我们可以执行create /qyktest‘qyktest'创建一个节点,如下:


java 中 zookeeper简单使用

然后,我们执行get /qyktest获取节点值,如下:


java 中 zookeeper简单使用

然后,我们可以执行set /qyktest‘111'修改节点的值,如下:


java 中 zookeeper简单使用

最后,我们执行delete /qyktest便可删除此节点。

另外,我们还可以在qyktest此节点下继续创建子节点。

好了,几个基本命令就讲到这人啦,其它的命令还有很多,大家可以去查阅下资料。

三、zookeeper的javaapi操作

关于javaapi操作zookeeper比较简单,笔者直接贴出代码,如下:

packageorg.zookeeper.demo;
importjava.io.ioexception;
importjava.util.concurrent.countdownlatch;
importorg.apache.zookeeper.createmode;
importorg.apache.zookeeper.keeperexception;
importorg.apache.zookeeper.watchedevent;
importorg.apache.zookeeper.watcher;
importorg.apache.zookeeper.watcher.event.keeperstate;
importorg.apache.zookeeper.zoodefs.ids;
importorg.apache.zookeeper.zookeeper;
publicclasszookeeperclientimplementswatcher{
//连接超时时间,10s
privatestaticfinalintsession_timeout= 10000;
//连接的zookeeperserver
privatestaticfinalstringconnection_string = "172.31.25.8:2181";
privatestaticfinalstringzk_path = "/qyktest";
privatezookeeperzk = null;
privatecountdownlatchconnectedsemaphore = newcountdownlatch(1);
publicvoidcreateconnection(stringconnectstring, intsessiontimeout){
this.releaseconnection();
try{
zk= newzookeeper(connectstring,sessiontimeout, this);
connectedsemaphore.await();
}catch(interruptedexceptione) {
system.out.println("连接创建失败,发生interruptedexception");
e.printstacktrace();
}catch(ioexceptione) {
system.out.println("连接创建失败,发生ioexception");
e.printstacktrace();
}
}
publicvoidreleaseconnection(){
if(this.zk!= null){
try{
this.zk.close();
}catch(interruptedexceptione) {
e.printstacktrace();
}
}
}
publicbooleancreatepath(stringpath, string data) {
try{
stringresult = this.zk.create(path,data.getbytes(), ids.open_acl_unsafe,createmode.persistent);
system.out.println("节点创建成功,path: "+result + ", content: "+data);
}catch(keeperexceptione) {
system.out.println("节点创建失败,发生keeperexception");
e.printstacktrace();
}catch(interruptedexceptione) {
system.out.println("节点创建失败,发生interruptedexception");
e.printstacktrace();
}
returntrue;
}
publicstringreaddata(stringpath) {
try{
system.out.println("获取数据成功,path:"+path);
returnnewstring(this.zk.getdata(path,false,null));
}catch(keeperexceptione) {
system.out.println("读取数据失败,发生keeperexception,path:"+path);
e.printstacktrace();
return"";
}catch(interruptedexceptione) {
system.out.println("读取数据失败,发生interruptedexception,path: "+path);
e.printstacktrace();
return"";
}
}
publicbooleanwritedata(stringpath, string data) {
try{
system.out.println("更新数据成功,path:"+path + ", stat: "+this.zk.setdata(path,data.getbytes(), -1));
}catch(keeperexceptione) {
system.out.println("更新数据失败,发生keeperexception,path:"+path);
e.printstacktrace();
}catch(interruptedexceptione) {
system.out.println("更新数据失败,发生interruptedexception,path: "+path);
e.printstacktrace();
}
returnfalse;
}
publicvoiddeletenode(stringpath) {
try{
this.zk.delete(path,-1);
system.out.println("删除节点成功,path:"+path);
}catch(keeperexceptione) {
system.out.println("删除节点失败,发生keeperexception,path:"+path);
e.printstacktrace();
}catch(interruptedexceptione) {
system.out.println("删除节点失败,发生interruptedexception,path: "+path);
e.printstacktrace();
}
}
publicstaticvoidmain(string[]args) {
zookeeperclientsample = newzookeeperclient();
//获取连接
sample.createconnection(connection_string,session_timeout);
//读数据
stringqyk = sample.readdata("/qyktest");
system.out.println("qyk:"+qyk);
stringurl = sample.readdata("/qyk/db/url");
system.out.println("url"+url);
stringdriver = sample.readdata("/qyk/db/driver");
system.out.println("driver"+driver);
stringusername = sample.readdata("/qyk/db/username");
system.out.println("username"+username);
stringpassword = sample.readdata("/qyk/db/password");
system.out.println("password"+password);
//创建节点
sample.createpath(zk_path,"我是节点初始内容");
system.out.println("数据内容:"+sample.readdata(zk_path) + "\n");
//更新节点
sample.writedata(zk_path,"更新后的数据");
system.out.println("数据内容:"+sample.readdata(zk_path) + "\n");
//删除节点
sample.deletenode(zk_path);
//释放连接
sample.releaseconnection();
}
@override
publicvoidprocess(watchedeventevent) {
system.out.println("收到事件通知:"+event.getstate() + "\n");
if(keeperstate.syncconnected== event.getstate()) {
connectedsemaphore.countdown();
}
}
}

然后,执行可以看到,控制台输出如下:


java 中 zookeeper简单使用

所以,像一些公用的配置,我们可以存到zookeeper里面,之后其它的服务就可以使用了

总结

以上所述是小编给大家介绍的java 中 zookeeper简单使用,希望对大家有所帮助