博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
zookeeper学习之zkclient节点增删改查<九>
阅读量:6214 次
发布时间:2019-06-21

本文共 1354 字,大约阅读时间需要 4 分钟。

hot3.png

zkclient提供了一系列接口来创建节点,参数就简单了很多,这边是zkclient 0.1 version

一眼看去,其实感觉原来的zk api 功能更丰富呀,奇怪,不该还有权限控制吗?

214611_lwoe_2277632.png

简单一点就是穿一个参数就可以啦,这边创建一个持久节点

222640_Bukm_2277632.png

path:指定数据节点的节点路径

data:节点的初始数据nei内容

mode:节点类型

createParents:布尔类型,是否需要创建父节点

这边create方法的设计,和构造函数的设计是类似的,一个套一个,这边创建的时候,启动一个线程

223712_lkaM_2277632.png

最后执行的是ZkConnection,这边就用了Ids.OPEN_ACL_UNSAFE,可是我不能加点 其他权限?

224001_g0yH_2277632.png

创建了删除 也是很简单的,就是这样

zkClient.delete(path);

在0.1中目前就看到这样一个delete方法,封装的套路和创建是一样的,和我想象的套路有点不一样啊

public boolean delete(final String path) {    try {        retryUntilConnected(new Callable() {            @Override            public Object call() throws Exception {                _connection.delete(path);                return null;            }        });        return true;    } catch (ZkNoNodeException e) {        return false;    }}
public void delete(String path) throws InterruptedException, KeeperException {    _zk.delete(path, -1);}

改节点的数据,就简单的两个方法,api的实现还是那样的

220951_XLO0_2277632.png

public void writeData(final String path, Object datat, final int expectedVersion) {    final byte[] data = serialize(datat);    retryUntilConnected(new Callable() {        @Override        public Object call() throws Exception {            _connection.writeData(path, data, expectedVersion);            return null;        }    });}

剩下一个查数据,真是让人感觉奇怪,这边又可以用了默认的wather。

221429_gO0M_2277632.png

今天真是奇怪的一天,哎,看着今天的代码也是奇奇怪怪的,难道我看了假的zkclient代码吗?难道原来java api的一些功能没有用?

221929_xXjK_2277632.png

 

 

转载于:https://my.oschina.net/u/2277632/blog/1531546

你可能感兴趣的文章
教你在中国做个有钱途的程序员
查看>>
$.post 返回不了json格式
查看>>
javascript 使用Html5 File Api进行文件读取
查看>>
31.virtualbox安装centos6.4开发环境搭建步骤记录
查看>>
SpringCloud 中文翻译1
查看>>
Ubuntu下无法使用add-apt-repository命令
查看>>
MKNetworkKit引入项目的配置
查看>>
如何管理Spark Streaming消费Kafka的偏移量(一)
查看>>
Elasticsearch如何检索数据
查看>>
mysql在第一次查询的时候很慢,第二次查询就比较快的原因?
查看>>
Android用XmlResourceParser读取XML资源
查看>>
nginx启动报错
查看>>
PPoE 与PPP 协议分析
查看>>
打包war 提示xxx v2不存在解决方法
查看>>
都知道的spring事务那点事(声明式,编程式)
查看>>
商业广告《手》的动画渲染制作
查看>>
Highcharts图表结构分析:详解标题与副标题
查看>>
strongswan ikev2 server on ubuntu 14.04
查看>>
ffmpeg切片命令
查看>>
atom install on ubuntu
查看>>