zookeeper分布式锁

摘要：分享牛原创，zookeeper使用，zookeeper锁在实际项目开发中还是很常用的，在这里我们介绍一下zookeeper分布式锁的使用，以及我们如何zookeeper分布式锁的原理。zookeeper节点理解。

zookeeper分布式锁有什么用呢？首先要明白锁是一个什么东西？举个通俗的例子，把门锁着了，外面的人进不去，里面的人可以随时出来，出来之后，还可以继续加锁。比如我们项目中，主要有供应商系统锁库存这种情况，锁库存的时候不能让其他的人去修改库存信息。这里就需要使用的时候加锁。当然了也可以使用数据库或者redis版本锁的概念，根据版本去区分到底如何锁库。

首先我们看一下zookeeper节点类型。

zookeeper节点类型分为以下四种：

从持久化的层次划分：

1.持久化节点：不删除节点永远存在。

2.非持久节点，换言之就是临时节点，临时节点就是客户端连接的时候创建，客户端挂起的时候，临时节点自动删除。

从排序层次划分：

1.持久有序。

2.持久无序，

3.临时有序。

4.临时无序。

这里需要注意持久化节点可以创建子节点。非持久化节点不能创建子节点。这里可以自己去使用命令去测试。

非持久节点就是创建的时候存在，消失的时候，节点自动删除，所以我们利用这个特性，实现我们的需求，比如，我可以程序启动的时候在指定的持久节点，创建临时节点，当程序挂掉的时候，临时节点消失，我们可以一直监控指定父节点中的子节点集合，就可以监控程序的健康状态。

接下来，在上面理解节点的基础之上，我们可以去实现zookeeper 分布式锁。具体怎么实现呢？思路如下：

我们可以创建一个持久节点，在程序中我们每次创建临时子节点，然后我们遍历持久节点下面的子节点，因为临时节点我们设置的时候是有序的。所以我们可以加锁的时候，创建了一个临时有序节点，当我们加锁完成自己的业务之后，释放锁，然后，这个删除临时节点，所以设计的核心点就是:

1.创建父节点。持久节点

2.创建有序的临时子节点。

3.删除临时节点，当业务完成的时候。

4.每次需要判断自身的临时节点，是否是最小的。为什么要判断是最小的呢？因为不是最小的话，说明前面还有一些节点在加锁执行中，所以我们这个节点不能加锁执行。

5.怎么让自身节点监听执行呢？因为如果自身节点是最小的，可以直接执行，如果不是最小的。要监听前面的节点是否已经删除，如果其他的前面的节点都删除了。则自己就可以加锁执行业务代码了。

下面开始书写我们的代码吧？

程序的输出如下：

打开连接........

【第5个线程】成功连接上ZK服务器

创建临时节点：/shareniuLock/sub0000000001

【第5个线程】自己可以获取锁执行代码了/shareniuLock/sub0000000001

创建临时节点：/shareniuLock/sub0000000002

【第5个线程】获取锁成功....

【第5个线程】前面的节点/shareniuLock/sub0000000001

创建临时节点：/shareniuLock/sub0000000003

创建临时节点：/shareniuLock/sub0000000004

【第5个线程】前面的节点/shareniuLock/sub0000000002

【第5个线程】前面的节点/shareniuLock/sub0000000003

创建临时节点：/shareniuLock/sub0000000005

【第5个线程】前面的节点/shareniuLock/sub0000000004

【第5个线程】删除临时节点：/shareniuLock/sub0000000001

【第5个线程】释放连接

【第5个线程】自己可以获取锁执行代码了/shareniuLock/sub0000000002

【第5个线程】删除临时节点：/shareniuLock/sub0000000002

【第5个线程】自己可以获取锁执行代码了/shareniuLock/sub0000000003

【第5个线程】删除临时节点：/shareniuLock/sub0000000003

【第5个线程】自己可以获取锁执行代码了/shareniuLock/sub0000000004

【第5个线程】删除临时节点：/shareniuLock/sub0000000004

【第5个线程】自己可以获取锁执行代码了/shareniuLock/sub0000000005

【第5个线程】删除临时节点：/shareniuLock/sub0000000005

下面我们看一下zk的节点，

在此证明，节点是有序的，释放锁的时候，会删除临时节点。

分享牛原创(尊重原创 转载对的时候第一行请注明，转载出处来自分享牛http://blog.csdn.net/qq_30739519)