zookeeper学习之zkclient节点增删改查<九>
博客专区 > woshixin 的博客 > 博客详情
zookeeper学习之zkclient节点增删改查<九>
woshixin 发表于6个月前
zookeeper学习之zkclient节点增删改查<九>
  • 发表于 6个月前
  • 阅读 8
  • 收藏 0
  • 点赞 0
  • 评论 0

新睿云服务器60天免费使用,快来体验!>>>   

摘要: zookeeper zkclient创建节点

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

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

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

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

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

mode:节点类型

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

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

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

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

zkClient.delete(path);

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

public boolean delete(final String path) {
    try {
        retryUntilConnected(new Callable<Object>() {

            @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的实现还是那样的

public void writeData(final String path, Object datat, final int expectedVersion) {
    final byte[] data = serialize(datat);
    retryUntilConnected(new Callable<Object>() {

        @Override
        public Object call() throws Exception {
            _connection.writeData(path, data, expectedVersion);
            return null;
        }
    });
}

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

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

 

 

标签: ZooKeeper
  • 打赏
  • 点赞
  • 收藏
  • 分享
共有 人打赏支持
粉丝 11
博文 115
码字总数 80015
×
woshixin
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: