本文通过zookeeper实现分布式锁,一共有两个版本,分别是curator框架实现,javaapi实现
实现原理
原理图实现原理其实很简单,就是利用了zookeeper的临时有序节点实现,其实ID最小的节点获得锁权限,执行完之后,删除节点,其余各点依次获取锁权限,类似于队列FIFO的操作
demo实现:
1、curator实现
CuratorClientUtils工具类CuratorClientUtils工具类,负责创建客户端
锁事件监听器1 锁事件监听器2LockWatcher负责监听事件,包括节点的新增,删除,更改
DistributeLock1属性和构造 DistributeLock2属性和构造 DistributeLock3属性和构造DistributeLock类,分布式锁主要类,实现分布式锁的主要逻辑
测试代码 测试结果数据2、javaAPI实现:
客户端代码 分布式锁监听事件 DistributeLock1 DistributeLock2 DistributeLock3测试方法都相同,在这就不贴了,代码只是逻辑的一个体现,不同框架其实实现底层都差不多,只不过封装模式不太一样而已。
当然实现分布式锁还有别的方法,例如数据库实现,redis实现,总的来说原理都差不多,各有利弊吧,多看看可以举一反三吧
网友评论