zk开源客户端/分布式锁

ZkClient简介

ZkClient是一个开源客户端，在Zookeeper原生API接口的基础上进行了包装，更便于开发人员使用。内部实现了Session超时重连，Watcher反复注册等功能。像dubbo等框架对其也进行了集成使用。
虽然ZkClient对原生API进行了封装，但也有它自身的不足之处：

• 几乎没有参考文档；
• 异常处理简化（抛出RuntimeException）；
• 重试机制比较难用；
• 没有提供各种使用场景的实现；

Curator简介

Curator是Netflix公司开源的一套Zookeeper客户端框架，和ZkClient一样，解决了非常底层的细节开发工作，包括连接重连、反复注册Watcher和NodeExistsException异常等。目前已经成为Apache的顶级项目。另外还提供了一套易用性和可读性更强的Fluent风格的客户端API框架。
除此之外，Curator中还提供了Zookeeper各种应用场景（Recipe，如共享锁服务、Master选举机制和分布式计算器等）的抽象封装。

• zkClient
  • ZkClient在ZooKeeper原生API接口之上进行了包装，是一个更易用的ZooKeeper客户端
  • 与ZooKeeper客户端最大区别提供的API没有了Watcher注册的功能，而是引入了Listener的概念
• Curator
  • Fluent风格的Java编码，流式
  • Curator引入了Cache来替换Watcher实现对ZooKeeper服务端事件的监听
  • 分布式锁/分布式计数器DistributedAtomicInteger/分布式栅栏Barrier
  • 提供一些对数据路径节点操作的ZKPaths和EnsurePath

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.locks.InterProcessMutex;
import org.apache.curator.retry.ExponentialBackoffRetry;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.CountDownLatch;

/**
* curator分布式锁实现
*/
public class Recipes_lock {
    static String lock_path = "/curator_recipes_lock_path";
    static CuratorFramework client = CuratorFrameworkFactory.builder()
            .connectString("127.0.0.1:2181")
            .retryPolicy(new ExponentialBackoffRetry(1000, 3)).build();

    public static void main(String[] args) throws Exception {
        client.start();
        final InterProcessMutex lock = new InterProcessMutex(client, lock_path);
        final CountDownLatch down = new CountDownLatch(1);
        for (int i = 0; i < 30; i++) {
            new Thread(new Runnable() {
                public void run() {
                    try {
                        down.await();
                        lock.acquire();
                    } catch (Exception e) {
                    }
                    SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss|SSS");
                    String orederNo = sdf.format(new Date());
                    System.out.println("生成的订单号为：" + orederNo);
                    try {
                        lock.release();
                    } catch (Exception e) {
                    }
                }
            }).start();
        }
        down.countDown();
    }
}

输出结果：

生成的订单号为：15:32:33|728
生成的订单号为：15:32:33|781
生成的订单号为：15:32:33|849
生成的订单号为：15:32:33|879
生成的订单号为：15:32:33|897
生成的订单号为：15:32:33|972
生成的订单号为：15:32:34|013
生成的订单号为：15:32:34|057
生成的订单号为：15:32:34|130
生成的订单号为：15:32:34|197
生成的订单号为：15:32:34|232
生成的订单号为：15:32:34|282
生成的订单号为：15:32:34|367
生成的订单号为：15:32:34|404
生成的订单号为：15:32:34|425
生成的订单号为：15:32:34|461
生成的订单号为：15:32:34|482
生成的订单号为：15:32:34|515
生成的订单号为：15:32:34|550
生成的订单号为：15:32:34|573
生成的订单号为：15:32:34|600
生成的订单号为：15:32:34|624
生成的订单号为：15:32:34|647
生成的订单号为：15:32:34|670
生成的订单号为：15:32:34|715
生成的订单号为：15:32:34|752
生成的订单号为：15:32:34|774
生成的订单号为：15:32:34|793
生成的订单号为：15:32:34|811
生成的订单号为：15:32:34|836