zookeeper之分布式锁以及分布式计数器(通过curator框架实现)

有人可能会问zookeeper我知道,但是curator是什么呢?

其实curator是apachede针对zookeeper开发的一个api框架是apache的顶级项目 他与zookeeper原生api相比更加简洁方便使用

特别就是注册watcher这方面.再也不用我们手工去重复注册watcher了.我们只需监听一下然后curator全给我们做了.而且支持递归创建节点

和递归删除节点.

更大的优势是实现分布式锁和分布式计数器以及分布式的同步更加方便.

以前我们基于zk原生的api实现分布式锁相当麻烦,但是我们基于curator去实现分布式锁那就是特别简单的事了.

废话不多说直接上代码

一个简单的demo

 * 分布式锁
        url
       count
        args
         iii
                     zk 
                            url
                    zk
                     lock zk
                        lock
                       e 
                        e
                            lock
                           e 
                            e
        count
        outcount

没错就是这么简单,curator为我们提供了InterProcessMutex这个类来实现分布式的锁 

其中.acquire();这个方法就是开始枷锁..release();就是释放锁.

看很简单吧.相比我们用zk原生的api实现起来超级简单

其实底层还是基于临时节点实现的,而且curator支持一个更加强大的功能,就是当你的客户端下线以后再次启动如果再次期间你监听的节点的有变化,

curator的watcher会立马进行回调..

所以使用curator开发相当方便,

我们看下curator的CRUD

         cachezk 
                url
        cachezk
        cachezkPERSISTENT
        cachezk
        cachezk
        cachezk

 下面我们看下curator是怎么实现分布式计数器的 

其实也是很简单,以为复杂的curator都提我们做完了

 * 分布式的计数器
        url
       count
        args   
             zk 
                    url
            zk
             counter zk 
             value  counter
            outvalue
            outvalue
            outvalue

 DistributeAtomicInteger就是curator为我们提供的分布式计数器的类 

关于分布式同步机制我就不给大家介绍了.其实也是很简单的.你们自行去了解吧

能力有限,有错误之处还望指出