zookeeper实现分布式锁

本文通过zookeeper实现分布式锁,一共有两个版本,分别是curator框架实现,javaapi实现

实现原理

原理图

实现原理其实很简单,就是利用了zookeeper的临时有序节点实现,其实ID最小的节点获得锁权限,执行完之后,删除节点,其余各点依次获取锁权限,类似于队列FIFO的操作

demo实现:

1、curator实现

CuratorClientUtils工具类

CuratorClientUtils工具类,负责创建客户端

锁事件监听器1
锁事件监听器2

LockWatcher负责监听事件,包括节点的新增,删除,更改

DistributeLock1属性和构造
DistributeLock2属性和构造
DistributeLock3属性和构造

DistributeLock类,分布式锁主要类,实现分布式锁的主要逻辑

测试代码
测试结果数据

2、javaAPI实现:

客户端代码
分布式锁监听事件
DistributeLock1
DistributeLock2
DistributeLock3

测试方法都相同,在这就不贴了,代码只是逻辑的一个体现,不同框架其实实现底层都差不多,只不过封装模式不太一样而已。

当然实现分布式锁还有别的方法,例如数据库实现,redis实现,总的来说原理都差不多,各有利弊吧,多看看可以举一反三吧

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容