【Zookeeper】基本使用：Curator操作Zookeeper

素颜马尾好姑娘i 2022-12-20 11:11 206阅读 0赞

针对zookeeper，比较常用的Java客户端有zkclient、curator。 由于 Curator 对于 zookeeper 的抽象层次比较高，简化了 zookeeper客户端的开发量。使得curator逐步被广泛应用。

1.  封装zookeeper client与zookeeper server之间的连接处理
2.  提供了一套fluent风格的操作api
3.  提供zookeeper各种应用场景（共享锁、leader选举）的抽象 封装

依赖Jar包

<dependency>
    	<groupId>org.apache.curator</groupId>
    	<artifactId>curator-framework</artifactId>
    	<version>4.0.0</version>
    </dependency>

## 1.建立连接 ##

CuratorFramework curatorFramework = CuratorFrameworkFactory.builder().
            connectString("43.105.136.120:2181").  // 若配置集群则是 ip1:port, ip2:post, ip3:port(,隔开)
            sessionTimeoutMs(5000).  // 超时，也是心跳时间
            retryPolicy(new ExponentialBackoffRetry(1000, 3)). // 重试策略，3次且每次多1s
            build();
    curatorFramework.start(); // 启动  注：服务器防火墙端口要开放

重试策略：Curator内部实现的几种重试策略:

*  ExponentialBackoffRetry：重试指定的次数, 且每一次重试之间停顿的时间逐渐增加
 *  RetryNTimes：指定最大重试次数的重试策略
 *  RetryOneTime：仅重试一次
 *  RetryUntilElapsed：一直重试直到达到规定的时间

## 2.CRUD ##

### 2.1 创建节点 ###

public static void CreateData(CuratorFramework curatorFramework) throws Exception {
        
            curatorFramework.create().  // 创建
                    creatingParentContainersIfNeeded(). // 父节点不存在时递归创建，因为一次本来只能一个节点
                    withMode(CreateMode.PERSISTENT). // 节点类型，7类，注：临时节点不能有子节点
                    forPath("/data/program", "test".getBytes()); // 节点路径 注：节点值要传入byte[]
        }

![在这里插入图片描述][20201111220142784.png_pic_center]

### 2.2 删除节点 ###

public static void deleteData(CuratorFramework curatorFramework) throws Exception {
        
            Stat stat = new Stat(); // 当前节点状态信息，内容同stat命令
            curatorFramework.getData().storingStatIn(stat).forPath("/data/program"); // 填充stat
            curatorFramework.delete(). // 删除
                    withVersion(stat.getVersion()). // 指定删的版本号 注：若版本不一致会保存，因此一般不写死
                    forPath("/data/program");
        }

![在这里插入图片描述][20201111220204501.png_pic_center]

### 2.3 修改节点内容 ###

public static void updateData(CuratorFramework curatorFramework) throws Exception {
        
            curatorFramework.setData(). // 修改
                    forPath("/data/program", "update".getBytes()); // forPath指定节点
        }

![在这里插入图片描述][20201111220340346.png_pic_center]

### 2.4 查询节点内容 ###

public static void getData(CuratorFramework curatorFramework) throws Exception {
        
            byte[] bytes = curatorFramework.getData(). // 查询
                    forPath("/data/program");  // 返回结果是byte[]
            System.out.println(new String(bytes)); 
        }

![在这里插入图片描述][20201111220401770.png_pic_center]

## 3.节点权限设置 ##

Zookeeper 作为一个分布式协调框架，内部存储了一些分布式系统运行时的状态的数据，比如master选举、比如分布式锁。对这些数据的操作会直接影响到分布式系统的运行状态。 因此，为了保证zookeeper中的数据的安全性，避免误操作带来的影响。Zookeeper提供了一套**ACL权限控制机制**来保 证数据的安全。

public static void setAcl(CuratorFramework curatorFramework) throws Exception {
        
        List<ACL> list = new ArrayList<>();
        ACL acl = new ACL(ZooDefs.Perms.READ, // 节点权限
                           new Id("digest",   // 权限模式（Scheme),即如何获取权限
                    DigestAuthenticationProvider.generateDigest("admin:admin"))); // 授权对象 (idPassword)
        list.add(acl);                                                        
        
        // 创建节点时加上权限  注：参数是List<ACL>
        curatorFramework.create().withMode(CreateMode.PERSISTENT).withACL(list). forPath("/auth");
        // 对已存在节点加上权限
        curatorFramework.setACL().withACL(list).forPath("/test");
    }

![在这里插入图片描述][20201111220440965.png_pic_center]

1）节点权限

*  Create：允许对子节点Create 操作
 *  Read：允许对本节点GetChildren 和GetData 操作
 *  Write：允许对本节点SetData 操作
 *  Delete：允许对子节点Delete 操作 Admin 允许对本节点setAcl 操作

2）权限模式

*  IP： 通过ip地址来做权限控制，比如 ip:192.168.1.1 表示权 限控制都是针对这个 ip 地址的。也可以针对网段 ip:192.168.1.1/24
    
        new ACL(ZooDefs.Perms.READ, new Id("ip", "192.168.1.1");
 *  Digest ： 最常用的权限控制模式 ， 类似于 username:password 形式来进行权限控制；
    
        new ACL(ZooDefs.Perms.READ, new Id("digest", 
                        DigestAuthenticationProvider.generateDigest("username:password"))); // 加密
 *  World： 开放的权限控制模式，数据节点的访问权限对所有用户开放，也可以看做world:anyone的Digest模式
    
        new ACL(ZooDefs.Perms.READ, new Id("world", "anyone")); // 只有一个ID，anyone
 *  super： 表示超级用户，可以对任意zookeeper上的数据节点进行操作

## 4.事件监听 ##

首先要引入依赖

<dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-recipes</artifactId>
        <version>4.0.0</version>
    </dependency>

### 4.1 NodeCache ###

监视当前结点的创建、更新、删除，并将 结点的数据缓存在本地；子节点的一切操作都不会监听到

private static void addListenerWithNode(CuratorFramework curatorFramework) throws Exception {
        
        NodeCache nodeCache = new NodeCache(curatorFramework, "/watch", false);  // 事件
        NodeCacheListener nodeCacheListener = () -> {
          // 监听器
            System.out.println("receive Node Changed");
            System.out.println(nodeCache.getCurrentData().getPath() + "----" 
                               + new String(nodeCache.getCurrentData().getData()));
        };
        nodeCache.getListenable().addListener(nodeCacheListener);
        nodeCache.start();
    }

![在这里插入图片描述][20201111220530794.png_pic_center]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkzNTkyNw_size_16_color_FFFFFF_t_70_pic_center]

### 4.2 PathChildrenCache ###

监视一个路径下孩子结点的创建、删 除、更新

private static void addListenerWithChild(CuratorFramework curatorFramework) throws Exception {
        
        PathChildrenCache nodeCache = new PathChildrenCache(curatorFramework, "/watch", true); // 事件
        PathChildrenCacheListener pathChildrenCacheListener = (curatorFramework1, // 监听器
                                                               pathChildrenCacheEvent) -> {
        
            System.out.println(pathChildrenCacheEvent.getType()+"->" 
            					+ new String(pathChildrenCacheEvent.getData().getData()));
        };
        nodeCache.getListenable().addListener(pathChildrenCacheListener);
        nodeCache.start();
    }

![在这里插入图片描述][2020111122185583.png_pic_center]

![在这里插入图片描述][20201111221908700.png_pic_center]

注：在创建新节点时，必须要有value，否则监听不到

### 4.3 TreeCache ###

PathChildCache和NodeCache的“合体”， 监视路径下的创建、更新、删除事件，并缓存路径下所有孩子结点的数据。

[20201111220142784.png_pic_center]: /images/20221120/0660174a7c2e494bbf8ffa5b4ed66371.png
[20201111220204501.png_pic_center]: /images/20221120/ce5074912db94a1594b45245c1d88389.png
[20201111220340346.png_pic_center]: /images/20221120/f608af78247141548634b08b1c9f6a34.png
[20201111220401770.png_pic_center]: /images/20221120/399541046c98437abcb2d317f7f665a3.png
[20201111220440965.png_pic_center]: https://img-blog.csdnimg.cn/20201111220440965.png#pic_center
[20201111220530794.png_pic_center]: https://img-blog.csdnimg.cn/20201111220530794.png#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkzNTkyNw_size_16_color_FFFFFF_t_70_pic_center]: https://img-blog.csdnimg.cn/20201111221828779.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkzNTkyNw==,size_16,color_FFFFFF,t_70#pic_center
[2020111122185583.png_pic_center]: https://img-blog.csdnimg.cn/2020111122185583.png#pic_center
[20201111221908700.png_pic_center]: https://img-blog.csdnimg.cn/20201111221908700.png#pic_center