关于zookeeper:zookeeper分布式锁

客户端抉择

zookeeper的Java客户端次要有zkclient和Curator，此篇文章介绍Curator，就冲他官网的简介，zookeeper书的作者Patrick Hunt给了这么高的评估：Guava is to Java what Curator is to Zookeeper。

实际操作下来，Curator的确比zkclient更全面，代码编写也更加优雅。

引入jar包

Curator次要提供了三个包

curator-framework：对zookeeper操作的封装
curator-client：提供了一些客户端的操作
curator-recipes：封装了一些高级个性

咱们能够间接援用curator-recipes，它外面蕴含了其余两个jar包，然而要留神zookeeper的版本，官网中给出了上面提醒：

基本操作

客户端实例的创立

第一种

ExponentialBackoffRetry retry = new ExponentialBackoffRetry(1000, 3);CuratorFramework client = CuratorFrameworkFactory.newClient("127.0.0.1:2181", retry);

retry是重试策略，间隔时间是2的指数增长，比方第一次期待1s，第二次2s，第三次4s。。。

第一个参数是距离根底单位，原始是毫秒；第二个参数是重试次数。

CuratorFrameworkFactory.newClient创立客户端，传入zookeeper的连贯地址和重试策略。

第二种

ExponentialBackoffRetry retry = new ExponentialBackoffRetry(1000, 3);CuratorFramework client = CuratorFrameworkFactory.builder()        .connectString("123.206.212.170:2181")        .connectionTimeoutMs(10000)        .sessionTimeoutMs(10000)        .retryPolicy(retry).build();

重试策略和下面一样，客户端通过CuratorFrameworkFactory.builder()创立，connectionTimeoutMs示意连贯超时工夫，sessionTimeoutMs示意会话超时工夫。

创立节点

CuratorFramework client = client();client.start();String path = "/demo/curd/node-2";client.create()        .creatingParentsIfNeeded()        .withMode(CreateMode.PERSISTENT)        .forPath(path, "world".getBytes("utf-8"));client.close();

curator的操作方法，根本都是链式调用，比起zkclient要优雅很多；

creatingParentsIfNeeded()示意如果父节点没有，就一起创立；

withMode(CreateMode.PERSISTENT)是创立的节点类型，zookeeper的节点有四种类型：

PERSISTENT：长久化节点
PERSISTENT_SEQUENTIAL：长久化程序节点
EPHEMERAL：长期节点
EPHEMERAL_SEQUENTIAL：长期程序节点

最初.forPath设置创立的节点门路和节点携带的内容。创立后果能够通过IDEA的zookeeper插件可视化查看，插件装置办法自行百度。

删除节点

CuratorFramework client = client();client.start();String path = "/demo/curd/node-2";client.delete().forPath(path);client.close();

删除节点调用delete办法即可。

批改节点

CuratorFramework client = client();client.start();String path = "/demo/curd/node-1";client.setData().forPath(path, "hello world".getBytes("utf-8"));client.close();

批改节点调用setData()办法，前面forPath办法传入批改后的内容。

查问节点

CuratorFramework client = client();client.start();String path = "/demo/curd/node-1";byte[] bytes = client.getData().forPath(path);System.out.println(new String(bytes));List<String> list = client.getChildren().forPath("/demo");list.forEach(System.out::println);client.close();

查问以后节点内容应用getData()办法，也能够用过getChildren()获取上面的所有子节点，返回各个节点门路汇合。

异步创立节点

CuratorFramework client = client();client.start();String path = "/demo/curd/node-4";client.create()        .creatingParentsIfNeeded()        .withMode(CreateMode.PERSISTENT)        .inBackground((c,e) ->{            System.out.println("================");            System.out.println(e);        }).forPath(path);Thread.sleep(10000);

节点创立和批改能够异步操作，只有调用inBackground办法，当节点创立胜利当前，会走此办法外面的回调函数。

节点监听

CuratorFramework client = client();client.start();CountDownLatch countDownLatch = new CountDownLatch(1);Watcher w = new Watcher() {    @Override    public void process(WatchedEvent watchedEvent) {        System.out.println("监听到的变动 watchedEvent = " + watchedEvent);        countDownLatch.countDown();    }};client.getData().usingWatcher(w).forPath("/demo/curd/node-1");countDownLatch.await();client.close();

实例化Watcher，并实现process办法，当节点发生变化，会执行process办法，应用usingWatcher办法增加监听办法。