Zookeeper 分布式环境中的注册表

birdskyws

发布于 2018-09-12 15:04:20

5180

发布于 2018-09-12 15:04:20

03年，作者大二买了第一台计算机。记得那时候2种主题的书特别多，注册表和Bios。现在想想《教你21天玩转Bios》这样的书名都像个笑话儿。这么说是因为BOIS和注册表对普通用户，基本用不上。但是注册表其实是Windows系统中非常重要的组件，提供了配置存储、事件监听响应等机制，Windows中很多服务开发都需要依赖注册表。

一、Zookeeper提供了分布式环境的注册表服务

ZooKeeper 典型的应用场景，限于篇幅就不详细展开，百度或https://www.jianshu.com/p/1e052bddba80

命名服务
配置管理
集群管理
分布式锁
队列管理

当你了解了这些应用场景，会不会明白作者将zookeeper和注册表对标的想法？

二、Zookeeper Api

1.pom.xml

写作日期为2018.6.17，zookeeper版本为3.4.9。

        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.9</version>
            <type>pom</type>
        </dependency>

2.创建zookeeper session

new Zookeeper是一个异步函数，调用之后马上返回。注册一个Watch回调函数，通常在这个函数中确认连接成功。用DownLatch.await等待确认连接成功。

CountDownLatch countDownLatch = new CountDownLatch(1);
ZooKeeper zk = new ZooKeeper("172.18.0.71:2181", 20000,
        new Watcher() {
            @Override
            public void process(WatchedEvent watchedEvent) {
                System.out.println("process " + watchedEvent);
                if (watchedEvent.getState() ==
                        Event.KeeperState.SyncConnected) {
                    countDownLatch.countDown();
                }
            }
        });
try {
    countDownLatch.await();
} catch (Exception e) {
    e.printStackTrace();
}

3.创建永久节点

指明节点路径和节点上保存的数据。通常可以用JSON保存更多信息。

/*
  
public String create(final String path, byte data[], List<ACL> acl,
            CreateMode createMode)
*/
try {
    zk.create("/wsn","try creat".getBytes()
    ,ZooDefs.Ids.OPEN_ACL_UNSAFE
    ,CreateMode.PERSISTENT);
} catch (KeeperException e) {
    e.printStackTrace();
} catch (InterruptedException e) {
    e.printStackTrace();
}

4.创建临时节点，在session断开时删除节点

创建临时节点，该节点通常被认为是进程的替身，如果节点被删除，那么原进程已经退出。CreateMode指明节点类型。

try {
    zk.create("/wsn_t","EPHEMERAL".getBytes()
                                ,ZooDefs.Ids.OPEN_ACL_UNSAFE
                                ,CreateMode.EPHEMERAL);
} catch (KeeperException e) {
    e.printStackTrace();
} catch (InterruptedException e) {
    e.printStackTrace();
}

5.获取子节点

List<String> children  = zk.getChildren("/wsn",new MyWatcher());
Iterator<String> iter = children.iterator();
while (iter.hasNext())
{
    System.out.println("path :"+iter.next());
}

6.获取节点信息

ret = zk.getData("/wsn", null,stat);
System.out.println("info:"+new String(ret));
System.out.println(stat);

info:wsn test path 748,748,1534087028795,1534087028795,0,15,0,0,13,5,770

public class Stat implements Record {
  private long czxid;
  private long mzxid;
  private long ctime;
  private long mtime;
  private int version;
  private int cversion;
  private int aversion;
  private long ephemeralOwner;
  private int dataLength;
  private int numChildren;
  private long pzxid;
}

状态属性说明 cZxid 数据节点创建时的事务ID ctime 数据节点创建时的时间 mZxid 数据节点最后一次更新时的事务ID mtime 数据节点最后一次更新时的时间 pZxid 数据节点的子节点列表最后一次被修改（是子节点列表变更，而不是子节点内容变更）时的事务ID cversion 子节点的版本号 dataVersion 数据节点的版本号 aclVersion 数据节点的ACL版本号 ephemeralOwner 如果节点是临时节点，则表示创建该节点的会话的SessionID；如果节点是持久节点，则该属性值为0 dataLength 数据内容的长度 numChildren 数据节点当前的子节点个数

7.创建监听

getData

Sets data on the node, or deletes the node.设置数据和删除节点

getChildren

deletes the node of the given path or creates/delete a child under the node删除节点（通getData），子节点创建和删除；不响应孙子节点，和更改状态。注：监听事件只响应一次。响应后需再次注册监听。

    private static class MyWatcher implements Watcher
    {
        @Override
        public void process(WatchedEvent event) {
            System.out.println("getChildren trigger");
            System.out.println("event tpye:"+event.getType());
            System.out.println("event state:"+event.getState());
            System.out.println("event path"+event.getPath());
            try {
                zk.getChildren("/wsn",new MyWatcher()); //再注册
            } catch (KeeperException e) {
                e.printStackTrace();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

为/wsn目录设置一个监听器。

zk.getChildren("/wsn",new MyWatcher());

实验，通过zkCli为/wsn添加一个临时节点。

[zk: localhost:2181(CONNECTED) 1] create -e /wsn/exam 'test' Created /wsn/exam
getChildren trigger event tpye:NodeChildrenChanged event state:SyncConnected event path/wsn

8.创建序列节点

实验演示，创建序列节点，生成00和01两个节点。

       zk.create("/wsn/seq/no"
                ,"wsn_seq".getBytes()
                ,ZooDefs.Ids.OPEN_ACL_UNSAFE
                ,CreateMode.EPHEMERAL_SEQUENTIAL);
        zk.create("/wsn/seq/no"
                ,"wsn_seq_another".getBytes()
                ,ZooDefs.Ids.OPEN_ACL_UNSAFE
                ,CreateMode.PERSISTENT_SEQUENTIAL);