开发者社区> 白头雁> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

Zookeeper 分布式环境中的注册表

简介: 03年,作者大二买了第一台计算机。记得那时候2种主题的书特别多,注册表和Bios。现在想想《教你21天玩转Bios》这样的书名都像个笑话儿。 这么说是因为BOIS和注册表对普通用户,基本用不上。
+关注继续查看

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的基础上,可以扩展出更多的业务场景,满足分布式场景高可靠、命名、选举等需求。

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
zookeeper分布式锁
摘要:分享牛原创,zookeeper使用,zookeeper锁在实际项目开发中还是很常用的,在这里我们介绍一下zookeeper分布式锁的使用,以及我们如何zookeeper分布式锁的原理。
474 0
蚂蚁消息中间件 (MsgBroker) 在 YGC 优化上的探索
GC 一直是 Java 应用中被讨论得最多的话题之一,尤其对于消息中间件这样的基础应用,GC 停顿产生的延迟会严重影响其在线服务能力,是开发和运维人员关注的重点。
755 0
漫画:如何用Zookeeper实现分布式锁?
1.持久节点 (PERSISTENT) 默认的节点类型。创建节点的客户端与zookeeper断开连接后,该节点依旧存在 。 2.持久节点顺序节点(PERSISTENT_SEQUENTIAL) 所谓顺序节点,就是在创建节点时,Zookeeper根据创建的时间顺序给该节点名称进行编号:
0 0
【分布式】Zookeeper使用--命令行
 在学习了Zookeeper相关的理论知识后,下面接着学习对Zookeeper的相关操作。
0 0
【分布式】Zookeeper客户端
前篇博客分析了Zookeeper的序列化和通信协议,接着继续学习客户端,客户端是开发人员使用Zookeeper最主要的途径,很有必要弄懂客户端是如何与服务端通信的。
0 0
ZK(ZooKeeper)分布式锁实现(2)
ZK(ZooKeeper)分布式锁实现
0 0
Dubbo——使用Zookeeper注册中心实现Dubbo
Dubbo——使用Zookeeper注册中心实现Dubbo
0 0
zookeeper实现分布式锁实战
zookeeper实现分布式锁实战
0 0
集群环境下zookeeper和kafka详细安装教程
集群环境下zookeeper和kafka详细安装教程
0 0
+关注
文章
问答
文章排行榜
最热
最新
相关电子书
更多
在多租户环境中提高HBase可用性
立即下载
Redis&MongoDB的同步、迁移以及混合云场景构建
立即下载
Codis 集群演化与 Redis 异步迁移
立即下载