zk实现分布式锁基本原理:
因为zk的节点是具有互斥性的,唯一性的,所以一旦一个节点被创建,就不能再被创建,利用这个特性,每次线程进入,都进行节点锁判断,如果锁节点被创建,我们就创建监听,以及等待其他线程执行完业务,释放锁,然后我们再获取锁,执行自己的业务;
具体执行如下:
但是以上的流程有个很大的缺陷,比如有100个线程进入,只可能有1个线程能获取锁,导致其他99个线程创建监听,等待;
创建大量的监听是对zookeeper的资源的浪费,会严重降低zk的性能;当第一个线程执行完业务代码,释放锁,其他98个线程有去抢占资源,重复前面的操作;性能很低下;
也就是所谓的“羊群效应”;
因为实际开发我们用的是顺序临时节点(EPHEMERAL_SEQUENTIAL);
基于前面的大致流程,再细化下:
step01:线程进入,直接再/lock下创建顺序零时节点;
step02:判断自己是不是/lock节点下序号最小的节点;if 是 获取锁 else 否 对前面一个节点进行监听;
step03:获取锁后,执行业务逻辑,执行完,释放锁(delete删除节点),然后后面一个会得到通知,继续重复step02即可;
下一篇:CAS介绍