02.ZooKeeper的Java客户端使用

• 初始化连接的问题: 在client与server之间握手建立连接的过程中,如果握手失败,执行所有的同步方法(比如create,getData等)将抛出异常
  
• 自动恢复(failover)的问题: 当client与一台server的连接丢失,并试图去连接另外一台server时, client将回到初始连接模式
  
• session过期的问题: 在极端情况下,出现ZooKeeper session过期,客户端需要自己去监听该状态并重新创建ZooKeeper实例
  
• 对可恢复异常的处理:当在server端创建一个有序ZNode,而在将节点名返回给客户端时崩溃,此时client端抛出可恢复的异常,用户需要自己捕获这些异常并进行重试
  
• 使用场景的问题:Zookeeper提供了一些标准的使用场景支持,但是ZooKeeper对这些功能的使用说明文档很少,而且很容易用错.在一些极端场景下如何处理,zk并没有给出详细的文档说明.比如共享锁服务,当服务器端创建临时顺序节点成功,但是在客户端接收到节点名之前挂掉了,如果不能很好的处理这种情况,将导致死锁
  

• 内部采用SLF4J 来输出日志
  
• 采用驱动器(driver)机制, 允许扩展和定制日志和跟踪处理
  
• 提供了一个TracerDriver接口, 通过实现addTrace()和addCount()接口来集成用户自己的跟踪框架
  

• 文档几乎没有
  
• 异常处理弱爆了(简单的抛出RuntimeException)
  
• 重试处理太难用了
  
• 没有提供各种使用场景的实现
  

• 只是一个底层实现
  
• 要用需要自己写大量的代码
  
• 很容易误用
  
• 需要自己处理连接丢失, 重试等

public static void main(String[] args) throws IOException, KeeperException, InterruptedException
{
    // 创建一个与服务器的连接 需要(服务端的 ip+端口号)(session过期时间)(Watcher监听注册)
    ZooKeeper zk = new ZooKeeper("192.168.110.100:2181", 3000, new Watcher()
    {
        // 监控所有被触发的事件
        public void process(WatchedEvent event)
        {
            System.out.println(event.toString());
        }
    });
    System.out.println("OK!");
    // 创建一个目录节点
    /**
     * CreateMode:
     *       PERSISTENT (持续的，相对于EPHEMERAL，不会随着client的断开而消失)
     *       PERSISTENT_SEQUENTIAL（持久的且带顺序的）
     *       EPHEMERAL (短暂的，生命周期依赖于client session)
     *       EPHEMERAL_SEQUENTIAL  (短暂的，带顺序的)
     */
    zk.create("/path01", "data01".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
    // 创建一个子目录节点
    zk.create("/path01/path01", "data01/data01".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
    System.out.println(new String(zk.getData("/path01", false, null)));
    // 取出子目录节点列表
    System.out.println(zk.getChildren("/path01", true));
    // 创建另外一个子目录节点
    zk.create("/path01/path02", "data01/data02".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
    System.out.println(zk.getChildren("/path01", true));
    // 修改子目录节点数据
    zk.setData("/path01/path01", "data01/data01-01".getBytes(), -1);
    byte[] datas = zk.getData("/path01/path01", true, null);
    String str = new String(datas, "utf-8");
    System.out.println(str);
    // 删除整个子目录 -1代表version版本号，-1是删除所有版本
    zk.delete("/path01/path01", -1);
    zk.delete("/path01/path02", -1);
    zk.delete("/path01", -1);
    System.out.println(str);
    Thread.sleep(15000);
    zk.close();
    System.out.println("OK");
}

public static void main(String[] args) throws Exception
{
    CuratorFramework client = CuratorFrameworkFactory.newClient("127.0.0.1:2181", new RetryNTimes(10, 5000));
    client.start();// 连接
    // 获取子节点，顺便监控子节点
    List<String> children = client.getChildren().usingWatcher(new CuratorWatcher()
    {
        @Override
        public void process(WatchedEvent event) throws Exception
        {
            System.out.println("监控： " + event);
        }
    }).forPath("/");
    System.out.println(children);
    // 创建节点
    String result = client.create().withMode(CreateMode.PERSISTENT).withACL(Ids.OPEN_ACL_UNSAFE).forPath("/test", "Data".getBytes());
    System.out.println(result);
    // 设置节点数据
    client.setData().forPath("/test", "111".getBytes());
    client.setData().forPath("/test", "222".getBytes());
    // 删除节点
    System.out.println(client.checkExists().forPath("/test"));
    client.delete().withVersion(-1).forPath("/test");
    System.out.println(client.checkExists().forPath("/test"));
    client.close();
    System.out.println("OK！");
}

• CuratorListenable：当使用后台线程操作时，后台线程执行完成就会触发，例如：client.getData().inBackground().forPath("/test");后台获取节点数据，获取完成之后触发。
• ConnectionStateListenable：当连接状态变化时触发。
  
• UnhandledErrorListenable：当后台操作发生异常时触发。

• ExponentialBackoffRetry:重试一定次数，每次重试sleep更多的时间
  
• RetryNTimes:重试N次
  
• RetryOneTime:重试一次
  
• RetryUntilElapsed:重试一定的时间