Zookeeper简单入门

2023年10月23日 204次阅读 来源: hutou

说明

ZooKeeper官方网址
ZooKeeper是一个分布式的，开放源码的分布式应用程序协调服务，是Google的Chubby一个开源的实现，是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件，提供的功能包括：配置维护、域名服务、分布式同步、组服务等。
ZooKeeper的目标就是封装好复杂易出错的关键服务，将简单易用的接口和性能高效、功能稳定的系统提供给用户。
ZooKeeper包含一个简单的原语集，提供Java和C的接口。
ZooKeeper代码版本中，提供了分布式独享锁、选举、队列的接口。其中分布锁和队列有Java和C两个版本，选举只有Java版本。

作用

Zookeeper 从设计模式角度来看，是一个基于观察者模式设计的分布式服务管理框架，它负责存储和管理大家都关心的数据，然后接受观察者的注册，一旦这些数据的状态发生变化，Zookeeper 就将负责通知已经在 Zookeeper 上注册的那些观察者做出相应的反应，从而实现集群中类似 Master/Slave 管理模式，关于 Zookeeper 的详细架构等内部细节可以阅读 Zookeeper 的源码

  1. 统一命名服务（Name Service）
  2. 配置管理（Configuration Management）
  3. 集群管理（Group Membership）
  4. 共享锁（Locks）
  5. 队列管理

特性

  1. 顺序性：
    从同一客户端发出的请求，严格按照发送顺序进入Zookeeper，队列先入先出特性
  2. 原子性：
    所有请求的响应结果在整个分布式集群环境中具有原子性
  3. 单一性：
    无论客户端连接到那个Zookeeper服务器，每个客户端所看到的服务端数据模型是一致的，不可能出现两种不同的数据状态。
  4. 可靠性：
    一旦服务器数据状态发生了变化，就立即存储起来，触发此时有另一个请求对其进行了变更，否则数据一定是可靠的。
  5. 实时性：
    一个请求被成功处理后，客户端立刻获取服务端的最新数据状态。

安装与配置

简单起见，只部署了单机模式。
从官网获取稳定的版本，我这里使用的是zookeeper-3.4.9

  1. 在conf目录下，以生成zoo.cfg文件
# The number of milliseconds of each tick
# 这个时间是作为 Zookeeper 服务器之间或客户端与服务器之间维持心跳的时间间隔，也就是每个 tickTime 时间就会发送一个心跳。
tickTime=2000
# The number of ticks that the initial 
# synchronization phase can take
initLimit=10
# The number of ticks that can pass between 
# sending a request and getting an acknowledgement
syncLimit=5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just 
# example sakes.
dataDir=E:\\data\\zookeeper\\data
dataLogDir=E:\\data\\zookeeper\\log
# the port at which the clients will connect
clientPort=2181
# the maximum number of client connections.
# increase this if you need to handle more clients
#maxClientCnxns=60
#
# Be sure to read the maintenance section of the 
# administrator guide before turning on autopurge.
#
# http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance
#
# The number of snapshots to retain in dataDir
#autopurge.snapRetainCount=3
# Purge task interval in hours
# Set to "0" to disable auto purge feature
#autopurge.purgeInterval=1

主要是设置数据路径，Log路径

  1. 启动
    运行bin/zkServer.cmd

客户端连接

    public static void main(String[] args) throws IOException, KeeperException, InterruptedException {
        // 创建一个与服务器的连接
         ZooKeeper zk = new ZooKeeper("192.168.139.42:2181",3000, 
                 new Watcher() { 
                    // 监控所有被触发的事件
                    public void process(WatchedEvent event) { 
                        System.out.println("已经触发了" + event.getType() + "事件！"); 
                    } 
                }); 
         // 创建一个目录节点
         zk.create("/testRootPath", "我的的测试结果".getBytes(), Ids.OPEN_ACL_UNSAFE,
           CreateMode.PERSISTENT); 
         // 创建一个子目录节点
         zk.create("/testRootPath/testChildPathOne", "这个数据是什么东西".getBytes(),
           Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT); 
         System.out.println(new String(zk.getData("/testRootPath",false,null))); 
         // 取出子目录节点列表
         System.out.println(zk.getChildren("/testRootPath",true)); 
         // 修改子目录节点数据
         zk.setData("/testRootPath/testChildPathOne","modifyChildDataOne".getBytes(),-1); 
         System.out.println("目录节点状态：["+zk.exists("/testRootPath",true)+"]"); 
         // 创建另外一个子目录节点
         zk.create("/testRootPath/testChildPathTwo", "testChildDataTwo".getBytes(), 
           Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT); 
         System.out.println(new String(zk.getData("/testRootPath/testChildPathTwo",true,null))); 
         // 删除子目录节点
         zk.delete("/testRootPath/testChildPathTwo",-1); 
         zk.delete("/testRootPath/testChildPathOne",-1); 
         // 删除父目录节点
         zk.delete("/testRootPath",-1); 
         // 关闭连接
         zk.close();
    }

需要依赖lib目录下的jar包

树状模型

ZooKeeper内部拥有一个树状的内存模型，类似于文件系统，有若干个目录，每个目录下有若干文件。
我们先看看下面几个概念

  1. ZNode：
    在ZooKeeper中目录和文件统称为ZNode，每个ZNode有对应的目录及其包含的数据。
  2. Session
    当客户端与服务端建立连接后，服务端将为客户端创建一个Session，客户端对ZNode的所有操作都在这个Session中完成
  3. 节点类型
    ZNode节点有几种类型，每种类型在会话结束后会有不同的逻辑

Presistent（持久节点）：会话结束后，该节点不会被删除
Persistent Sequential（持久顺序节点）：会话结束后，该节点不会被删除，节点名中带自增后缀
Ephemeral（临时节点）：当会话结束后，该节点将会被删除
Ephemeral Sequential（临时顺序节点）：当会话结束后，该节点将会被删除，节点名中带有自增后缀

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