Zookeeper 分布式环境中的注册表

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);

[zk: localhost:2181(CONNECTED) 2] ls /wsn/sequence
[no0000000001, no0000000000]

总结

通过zookeeper API练习实验,可以加深理解zookeeper的原理。在zookeeperApi的基础上,可以扩展出更多的业务场景,满足分布式场景高可靠、命名、选举等需求。

    原文作者:白头雁
    原文地址: https://www.jianshu.com/p/bdbc3d35dd29
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。
点赞