基本思路

1 client调用create()方法创建“/locks/_lock_”临时顺序节点,注意节点类型是EPHEMERAL_SEQUENTIAL

2 client调用getChildren("/locks",false)来获取所有已经创建的子节点,这里并不注册任何Watcher,只是为了看自己的是不是最小的节点

如果是,便获得了锁。

3 客户端获取到所有子节点Path后,如果发现自己在步骤1中创建的节点是所有节点中最小的,那么就认为这个客户端获得了锁 执行

4 如果在步骤3中,发现不是最小的,那么找到比自己小的那个节点,然后对其调用exist()方法注册事件监听,通过计数器阻塞

5 之后一旦这个被关注的节点移除,客户端会收到相应的通知,计数器countdown 不在阻塞 继续执行

代码如下

Zookeeper系列3 实现分布式锁-LMLPHP

Zookeeper系列3 实现分布式锁-LMLPHP

Zookeeper系列3 实现分布式锁-LMLPHP

Zookeeper系列3 实现分布式锁-LMLPHP

Zookeeper系列3 实现分布式锁-LMLPHP

Zookeeper系列3 实现分布式锁-LMLPHP

测试代码:

Zookeeper系列3 实现分布式锁-LMLPHPZookeeper系列3 实现分布式锁-LMLPHP

运行结果如下:

Zookeeper系列3 实现分布式锁-LMLPHP

Zookeeper系列3 实现分布式锁-LMLPHP

05-03 21:01