博客

zookeeper的原理及API学习

Stat结构体
1）czxid-创建节点的事务zxid
每次修改ZooKeeper状态都会收到一个zxid形式的时间戳，也就是ZooKeeper事务ID;
事务ID是ZooKeeper中所有修改总的次序。每个修改都有唯一的zxid，如果zxid1小于zxid2，那么zxid1在zxid2之前发生。
2）ctime – znode被创建的毫秒数(从1970年开始)
3）mzxid – znode最后更新的事务zxid
4）mtime – znode最后修改的毫秒数(从1970年开始)
5）pZxid-znode最后更新的子节点zxid
6）cversion – znode子节点变化号，znode子节点修改次数
7）dataversion – znode数据变化号
8）aclVersion – znode访问控制列表的变化号
9）ephemeralOwner- 如果是临时节点，这个是znode拥有者的session id。如果不是临时节点则是0

如图

APi:
//初始化

private static String connectString = "192.168.221.132:2181";
    private static int sessionTimeout = 2000;
    private ZooKeeper zkClient = null;
    @Before
    public void init() throws Exception {
        zkClient = new ZooKeeper(connectString, sessionTimeout, new Watcher() {
            public void process(WatchedEvent event) {
                // 收到事件通知后的回调函数（用户的业务逻辑）
                System.out.println(event.getType() + "--" + event.getPath());
                try {
                    zkClient.getChildren("/", true);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        });
    }


 // 参数1：要创建的节点的路径； 参数2：节点数据 ； 参数3：节点权限 ；参数4：节点的类型
        zkClient.create("/ls0406", "hello".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
        //获取子节点
 List<String> children = zkClient.getChildren("/", true);
 //判断节点是否存在
  Stat exists = zkClient.exists("/idea", true);

更多API参考：https://www.aboutyun.com//forum.php/forum.php?mod=viewthread&tid=9311
https://zookeeper.apache.org/doc/r3.6.0/apidocs/zookeeper-server/index.html