基于ZooKeeper实现分布式锁
2015-05-26 19:13
363 查看
ZooKeeper 保证了数据的强一致性, zk集群中任意节点(一个zkServer)上的相同znode下的数据一定是相同的。使用zookeeper可以非常简单的实现分布式锁,
其基本逻辑如下:
客户端调用create()方法创建名为“locknode/lock”的节点,需要注意的是,这里节点的创建类型需要设置为EPHEMERAL_SEQUENTIAL。
客户端调用getChildren(“lock”)方法来获取所有已经创建的lock节点的子节点,同时在这个节点上注册上子节点变更通知的Watcher。
客户端获取到所有子节点path之后,如果发现自己在步骤1中创建的节点是所有节点中序号最小的,那么就认为这个客户端获得了锁。
如果在步骤3中发现自己并非是所有子节点中最小的,说明自己还没有获取到锁,就等待,直到下次子节点变更通知的时候,再进行子节点的获取,判断是否获取锁。
释放锁的过程比较简单,就是删除自己创建的那个子节点即可。
附:分布式锁实现过程中考虑问题的思路:
1.锁何时独占
2.锁何时释放
3.锁占有或者释放的先后次序可能引起的问题(控制时序)
参考:
ZooKeeper典型使用场景一览
分布式
其基本逻辑如下:
客户端调用create()方法创建名为“locknode/lock”的节点,需要注意的是,这里节点的创建类型需要设置为EPHEMERAL_SEQUENTIAL。
客户端调用getChildren(“lock”)方法来获取所有已经创建的lock节点的子节点,同时在这个节点上注册上子节点变更通知的Watcher。
客户端获取到所有子节点path之后,如果发现自己在步骤1中创建的节点是所有节点中序号最小的,那么就认为这个客户端获得了锁。
如果在步骤3中发现自己并非是所有子节点中最小的,说明自己还没有获取到锁,就等待,直到下次子节点变更通知的时候,再进行子节点的获取,判断是否获取锁。
释放锁的过程比较简单,就是删除自己创建的那个子节点即可。
附:分布式锁实现过程中考虑问题的思路:
1.锁何时独占
2.锁何时释放
3.锁占有或者释放的先后次序可能引起的问题(控制时序)
参考:
ZooKeeper典型使用场景一览
分布式
相关文章推荐
- 【Dubbo实战】 Dubbo+Zookeeper+Spring整合应用篇-Dubbo基于Zookeeper实现分布式服务(二)
- 基于zookeeper实现分布式锁
- 【Dubbo实战】 Dubbo+Zookeeper+Spring整合应用篇-Dubbo基于Zookeeper实现分布式服务(二)
- 基于zookeeper简单实现分布式锁
- 基于zookeeper实现的分布式锁
- zookeeper学习(七)基于zookeeper实现分布式锁
- 基于zookeeper简单实现分布式锁
- 基于zookeeper简单实现分布式锁
- 【Dubbo实战】 Dubbo+Zookeeper+Spring整合应用篇-Dubbo基于Zookeeper实现分布式服务
- 基于zookeeper实现分布式锁
- 分布式锁与实现(二)基于ZooKeeper实现
- 基于zookeeper实现高性能分布式锁
- 基于zookeeper的分布式Lock及RLock的实现
- 基于zookeeper实现的分布式锁
- 分布式锁与实现(二)——基于ZooKeeper实现
- 分布式锁实现方式一 基于zookeeper的分布式锁
- 【Dubbo实战】 Dubbo+Zookeeper+Spring整合应用篇-Dubbo基于Zookeeper实现分布式服务(二)
- 2种基于简单定时任务实现分布式定时任务的技术解决方案(zookeeper、redis和内联MQ)
- 基于zookeeper实现分布式锁
- Dubbo基于Zookeeper实现分布式服务