ZK Curator框架

客官°小女子只卖身不卖艺 2022-05-26 04:28 134阅读 0赞

一、Curator

1.  为了更好的实现Java操作Zookeeper服务器，后来出现了Curator框架，非常的强大，目前已经是Apache的顶级项目，里面提供了更多丰富的操作，例如session超时重连、主从选举、分布式计数器、分布式锁等等适用于各种复杂的zookeeper场景的API封装。
2.  maven依赖：

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

二、Curator框架使用

1.  框架中使用链式编程风格，易读性更强，使用工程方法创建连接对象。使用CuratorFrameworkFactory的俩个静态工厂方法（参数不同）来实现：
    
    参数1：connectString，连接串；  
    参数2：retryPolicy，重试连接策略。有四种实现分别为：ExponentialBackoffRetry、RetryNTimes、RetryOneTimes、RetryUntilElapsed；  
    参数3：sessionTimeoutMs会话超时时间默认为60000ms；  
    参数4：connectionTimeoutMs连接超时事件，默认为15000ms；
    
    注意：对于retryPolicy策略通过一个接口来让用户自定义实现。
2.  创建节点create方法，可选链式项：`createingParentsIfNeeded(),withMode(),forPath(),withACL()`等；
3.  删除节点delete方法，可选链式项：`deletingChildrenIfNeeded(),guaranateed(),withVersion(),forPath()`等；
4.  读取和修改数据方法，`getData()，setData()`；
5.  异步绑定回调方法。比如创建节点时绑定一个回调函数，该回调函数可以输出服务器的状态码以及服务器事件类型。还可以加入一个线程池进行优化操作。
6.  读取子节点方法，`getChildren()`；
7.  判断节点是否存在方法，`checkExists()`；

三、Curator的监听

1.  如果要使用类似Watcher的监听功能Curator必须依赖一个jar包，Maven依赖：

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

有了这个依赖包，我们使用NodeCache的方式去客户端示例中注册一个监听缓存，然后实现对应的监听方法即可，这里我们主要有两种监听方式：  
1）. 监听节点的新增、修改操作：`NodeCacheListener`  
2）. 监听子节点的新增、修改、删除操作：`PathChildrenCacheListener`