一、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命令行，如下：

然后，执行ls /可以看到：

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

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

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

最后，我们执行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();
}
}
}

然后，执行可以看到，控制台输出如下：

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

总结

以上所述是小编给大家介绍的java 中 zookeeper简单使用，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对网站的支持！

# zookeeper简单使用  # java使用zookeeper实现的分布式锁示例  # Java zookeeper图形化工具ZooInspector用法详解  # java连接zookeeper的3种方式小结  # 解决java连接zookeeper很慢的问题  # 在Java中操作Zookeeper的示例代码详解  # Java调用Zookeeper的实现步骤  # 如何使用Java操作Zookeeper  # Java中的ZooKeeper使用  # 我们可以  # 都是  # 文件系统  # 客户端  # 可以通过  # 可以看到  # 小编  # 我是  # 几个  # 这一  # 就会  # 都有  # 也有  # 好了  # 还可以  # 第一个  # 在此  # 一是  # 是由  # 还会 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： Laravel用户密码怎么加密_Laravel Hash门面使用教程  如何在香港服务器上快速搭建免备案网站？  韩国网站服务器搭建指南：VPS选购、域名解析与DNS配置推荐  网站设计制作书签怎么做,怎样将网页添加到书签/主页书签/桌面？  Laravel怎么实现软删除SoftDeletes_Laravel模型回收站功能与数据恢复【步骤】  标题：Vue + Vuex 项目中正确使用 JWT 进行身份认证的实践指南  如何快速搭建虚拟主机网站？新手必看指南  php 三元运算符实例详细介绍  用v-html解决Vue.js渲染中html标签不被解析的问题  DeepSeek是免费使用的吗 DeepSeek收费模式与Pro版本功能详解  香港代理服务器配置指南：高匿IP选择、跨境加速与SEO优化技巧  HTML 中动态设置元素 name 属性的正确语法详解  Python文件异常处理策略_健壮性说明【指导】  如何用PHP快速搭建高效网站？分步指南  Laravel如何处理表单验证？（Requests代码示例）  如何在万网自助建站平台快速创建网站？  如何快速配置高效服务器建站软件？  JS中对数组元素进行增删改移的方法总结  车管所网站制作流程,交警当场开简易程序处罚决定书，在交警网站查询不到怎么办？  如何用wdcp快速搭建高效网站？  JS弹性运动实现方法分析  如何在Windows虚拟主机上快速搭建网站？  JavaScript常见的五种数组去重的方式  Laravel如何使用Vite进行前端资源打包？（配置示例）  头像制作网站在线观看,除了站酷，还有哪些比较好的设计网站？  如何挑选高效建站主机与优质域名？  长沙做网站要多少钱,长沙国安网络怎么样？  Laravel项目如何进行性能优化_Laravel应用性能分析与优化技巧大全  在Oracle关闭情况下如何修改spfile的参数  如何快速登录WAP自助建站平台？  Win11怎么关闭资讯和兴趣_Windows11任务栏设置隐藏小组件  Laravel的辅助函数有哪些_Laravel常用Helpers函数提高开发效率  Laravel如何处理异常和错误？（Handler示例）  如何用VPS主机快速搭建个人网站？  如何快速搭建高效香港服务器网站？  网站页面设计需要考虑到这些问题  Bootstrap整体框架之CSS12栅格系统  Laravel如何处理文件下载请求？（Response示例）  香港服务器租用每月最低只需15元？  Zeus浏览器网页版官网入口 宙斯浏览器官网在线通道  昵图网官网入口 昵图网素材平台官方入口  如何制作新型网站程序文件,新型止水鱼鳞网要拆除吗？  Laravel如何使用Eloquent进行子查询  javascript中数组（Array)对象和字符串（String)对象的常用方法总结  如何用PHP快速搭建CMS系统？  Python函数文档自动校验_规范解析【教程】  Python文件流缓冲机制_IO性能解析【教程】  javascript中的try catch异常捕获机制用法分析  JavaScript实现Fly Bird小游戏  php json中文编码为null的解决办法