分散式锁效劳宕机,ZooKeeper普通因此散群布置,假若呈现ZooKeeper宕机,那末只需以后平常的效劳器超越散群的对折,依旧能够寻常供应效劳持有锁资本效劳器宕机,假设1台效劳器获得锁以后便宕机了, 那末便会致使其余效劳器没法再获得该锁. 便会形成逝世锁题目, 正在Curator中, 锁的疑息皆是保管正在姑且节面上, 倘使持有锁资本的效劳器宕机, 那末ZooKeeper 便会移除它的疑息, 那时其余效劳器便能停止获得锁掌握。

zookeeper安设单机形式

http://www.javacui.com/opensource/445.html

SpringBoot散成Curator杀青Zookeeper基础操纵

http://www.javacui.com/tool/615.html

SpringBoot散成Curator兑现Watch事故监闻

http://www.javacui.com/tool/616.html

Zookeeper告竣分散式锁的体制

应用zk的姑且节面战有序节面，每一个线程获得锁便是正在zk缔造1个姑且有序的节面，例如正在/lock/目次停。

树立节面乐成后，获得/lock目次停的全部姑且节面，再判定以后线程树立的节面能否是全部的节面的序号最小的节面。

假设以后线程创造的节面是全部节面序号最小的节面，则觉得获得锁乐成。

例如以后线程获得到的节面序号为/lock/003,而后全部的节面列表为[/lock/001,/lock/002,/lock/003],则对于/lock/002那个节面加添1个事故监闻器。

假若锁开释了，会叫醒停1个序号的节面，而后从头施行第3步，判定能否本身的节面序号是最小。

譬如/lock/001开释了，/lock/002监闻到时分，此季节面集中为[/lock/002,/lock/003],则/lock/002为最弁言号节面，获得到锁。

锁分类

InterProcessSemaphoreMutex：分散式不行沉进排它锁

InterProcessMutex：分散式可沉进排它锁

InterProcessReadWriteLock：疏散式读写锁

InterProcessMultiLock：多沉同享锁，将多个锁举动单个真体办理的容器

InterProcessSemaphoreV2：同享旌旗灯号量

Shared Lock 分散式非可沉进锁

民网天址：http://curator.apache.org/curator-recipes/shared-lock.html

InterProcessSemaphoreMutex是1种不行沉进的互斥锁，也便表示着便使是统一个线程也没法正在持有锁的环境停再次得到锁，因此须要注重，不行沉进的锁很简单正在少许环境致使逝世锁，例如您写了1个递回。

Shared Reentrant Lockf分散式可沉进锁

民网天址：http://curator.apache.org/curator-recipes/shared-reentrant-lock.html

此锁能够沉进，然则沉进频频须要开释频频。

InterProcessMutex经由过程正在zookeeper的某途径节面停树立姑且序列节面去告终疏散式锁，便每一个线程（跨经过的线程）获得统一把锁前，皆须要正在一样的途径停建树1个节面，节面实字由uuid+递加序列构成。而经由过程比照自己的序列数能否正在全部子节面的第一名，去判定能否乐成获得到了锁。当获得锁朽败时，它会加添watcher去监闻前1个节面的变更环境，而后停止恭候形态。曲到watcher的事故收效将本身叫醒，大概超常常间同常前往。

Shared Reentrant Read Write Lock可沉进读写锁

民网天址：http://curator.apache.org/curator-recipes/shared-reentrant-read-write-lock.html

读写锁庇护1对于相关的锁，1个用于只读掌握，1个用于写操纵。只需不写锁，读锁能够被多个用户共时持有，而写锁是独有的。

读写锁承诺从写锁落级为读锁，办法是先获得写锁，而后便能够获得读锁。然则，没法从读锁晋级到写锁。

Multi Shared Lock 多同享锁

民网天址：http://curator.apache.org/curator-recipes/multi-shared-lock.html

多个锁动作1个锁，能够共时正在多个资本上添锁。1个帮忙多个锁对于象的容器。当挪用acquire()时，获得容器中全部的锁对于象，乞求波折时，开释全部锁对于象。一样挪用release()也会开释全部的锁。

Shared Semaphore同享旌旗灯号量

民网天址：http://curator.apache.org/curator-recipes/shared-semaphore.html

1个计数的旌旗灯号量近似JDK的Semaphore，全部应用相反锁定途径的jvm中全部过程皆将竣工经过间无限的租约。另外，那个旌旗灯号量年夜多是“公道的” - 每一个用户将依照哀求的循序得到租约。

有二种体例决意旌旗灯号号的最年夜租约数。1种是由用户指定的途径去决意最年夜租约数，1种是经由过程SharedCountReader去决意。

若是已应用SharedCountReader，则没有会停止里面查抄例如A显示为有10个租约，经过B显示为有20个。所以，请保证全部历程中的全部真例皆应用相反的numberOfLeases值。

acuquire()办法前往的是Lease对于象，客户端正在应用完后必需要闭关该lease对于象(普通正在finally中停止闭关)，不然该对于象会丧失。倘使过程session丧失（如溃逃），该客户端具有的全部lease会被主动闭关，此时其余端不妨应用那些lease。

编码尝试

packagecom.example.springboot;importcom.example.springboot.tool.ZkConfiguration;importorg.apache.curator.framework.CuratorFramework;importorg.apache.curator.framework.recipes.locks.*;importorg.junit.jupiter.api.Test;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.boot.test.context.SpringBootTest;importjava.util.Arrays;importjava.util.Collection;importjava.util.concurrent.TimeUnit;/***@Auther:Java小强*@Date:2022/2/4-19:33*@Decsription:com.example.springboot*@Version:1.0*/@SpringBootTest(classes=Application.class)publicclassCuratorTest{@AutowiredprivateZkConfigurationzk;//同享旌旗灯号量，多个旌旗灯号量@TestpublicvoidtestInterProcessSemaphoreV22()throwsException{CuratorFrameworkclient=zk.curatorFramework();//成立1个旌旗灯号量,Curator以公道锁的体例停止实行finalInterProcessSemaphoreV2semaphore=newInterProcessSemaphoreV2(client,"/lock",3);newThread(newRunnable(){@Overridepublicvoidrun(){//获得锁对于象try{StringthreadName=Thread.currentThread().getName();//获得2个答应Collection<Lease>acquire=semaphore.acquire(2);System.out.println(threadName+"获得旌旗灯号量>>>>>>>>>>>>>>>>>>>>>");Thread.sleep(2*1000);semaphore.returnAll(acquire);System.out.println(threadName+"开释旌旗灯号量>>>>>>>>>>>>>>>>>>>>>");}catch(Exceptione){e.printStackTrace();}}}).start();newThread(newRunnable(){@Overridepublicvoidrun(){//获得锁对于象try{StringthreadName=Thread.currentThread().getName();//获得1个答应Leaselease=semaphore.acquire();System.out.println(threadName+"获得旌旗灯号量>>>>>>>>>>>>>>>>>>>>>");Thread.sleep(2*1000);semaphore.returnLease(lease);System.out.println(threadName+"开释旌旗灯号量>>>>>>>>>>>>>>>>>>>>>");}catch(Exceptione){e.printStackTrace();}}}).start();while(true){}}//同享旌旗灯号量@TestpublicvoidtestInterProcessSemaphoreV2()throwsException{CuratorFrameworkclient=zk.curatorFramework();//创办1个旌旗灯号量,Curator以公道锁的体例停止实行finalInterProcessSemaphoreV2semaphore=newInterProcessSemaphoreV2(client,"/lock",1);newThread(newRunnable(){@Overridepublicvoidrun(){//获得锁对于象try{StringthreadName=Thread.currentThread().getName();//获得1个答应Leaselease=semaphore.acquire();System.out.println(threadName+"获得旌旗灯号量>>>>>>>>>>>>>>>>>>>>>");Thread.sleep(2*1000);semaphore.returnLease(lease);System.out.println(threadName+"开释旌旗灯号量>>>>>>>>>>>>>>>>>>>>>");}catch(Exceptione){e.printStackTrace();}}}).start();newThread(newRunnable(){@Overridepublicvoidrun(){//获得锁对于象try{StringthreadName=Thread.currentThread().getName();//获得1个答应Leaselease=semaphore.acquire();System.out.println(threadName+"获得旌旗灯号量>>>>>>>>>>>>>>>>>>>>>");Thread.sleep(2*1000);semaphore.returnLease(lease);System.out.println(threadName+"开释旌旗灯号量>>>>>>>>>>>>>>>>>>>>>");}catch(Exceptione){e.printStackTrace();}}}).start();while(true){}}//多沉同享锁@TestpublicvoidtestInterProcessMultiLock()throwsException{CuratorFrameworkclient=zk.curatorFramework();//可沉进锁finalInterProcessLockinterProcessLock1=newInterProcessMutex(client,"/lock");//不行沉进锁finalInterProcessLockinterProcessLock2=newInterProcessSemaphoreMutex(client,"/lock");//创立多沉锁对于象finalInterProcessLocklock=newInterProcessMultiLock(Arrays.asList(interProcessLock1,interProcessLock2));newThread(newRunnable(){@Overridepublicvoidrun(){try{StringthreadName=Thread.currentThread().getName();//获得参数集中中的全部锁lock.acquire();//由于永存1个不行沉进锁,因此全部InterProcessMultiLock不行沉进System.out.println(threadName+"----->"+lock.acquire(2,TimeUnit.SECONDS));//interProcessLock1是可沉进锁,因而能够持续获得锁System.out.println(threadName+"----->"+interProcessLock1.acquire(2,TimeUnit.SECONDS));//interProcessLock2是不行沉进锁,因而获得锁障碍System.out.println(threadName+"----->"+interProcessLock2.acquire(2,TimeUnit.SECONDS));}catch(Exceptione){e.printStackTrace();}}}).start();while(true){}}//分散式读写锁@TestpublicvoidtestReadWriteLock()throwsException{CuratorFrameworkclient=zk.curatorFramework();//建立同享可沉进读写锁finalInterProcessReadWriteLocklocl1=newInterProcessReadWriteLock(client,"/lock");finalInterProcessReadWriteLocklock2=newInterProcessReadWriteLock(client,"/lock");newThread(newRunnable(){@Overridepublicvoidrun(){try{StringthreadName=Thread.currentThread().getName();locl1.writeLock().acquire();//获得锁对于象System.out.println(threadName+"获得写锁>>>>>>>>>>>>>>>>>>>>>");Thread.sleep(1*1000);locl1.readLock().acquire();//获得读锁，锁落级System.out.println(threadName+"获得读锁>>>>>>>>>>>>>>>>>>>>>");Thread.sleep(1*1000);locl1.readLock().release();System.out.println(threadName+"开释读锁<<<<<<<<<<<<<<<<<<<<<");locl1.writeLock().release();System.out.println(threadName+"开释写锁<<<<<<<<<<<<<<<<<<<<<");}catch(Exceptione){e.printStackTrace();}}}).start();newThread(newRunnable(){@Overridepublicvoidrun(){try{StringthreadName=Thread.currentThread().getName();lock2.writeLock().acquire();//获得锁对于象System.out.println(threadName+"获得写锁>>>>>>>>>>>>>>>>>>>>>");Thread.sleep(1*1000);lock2.readLock().acquire();//获得读锁，锁落级System.out.println(threadName+"获得读锁>>>>>>>>>>>>>>>>>>>>>");Thread.sleep(1*1000);lock2.readLock().release();System.out.println(threadName+"开释读锁<<<<<<<<<<<<<<<<<<<<<");lock2.writeLock().release();System.out.println(threadName+"开释写锁<<<<<<<<<<<<<<<<<<<<<");}catch(Exceptione){e.printStackTrace();}}}).start();while(true){}}//分散式可沉进排它锁@TestpublicvoidtestInterProcessMutex()throwsException{CuratorFrameworkclient=zk.curatorFramework();//分散式可沉进排它锁finalInterProcessLocklock=newInterProcessMutex(client,"/lock");finalInterProcessLocklock2=newInterProcessMutex(client,"/lock");newThread(newRunnable(){@Overridepublicvoidrun(){try{StringthreadName=Thread.currentThread().getName();lock.acquire();//获得锁对于象System.out.println(threadName+"获得锁>>>>>>>>>>>>>>>>>>>>>");lock.acquire();//尝试锁沉进System.out.println(threadName+"获得锁>>>>>>>>>>>>>>>>>>>>>");Thread.sleep(1*1000);lock.release();System.out.println(threadName+"开释锁<<<<<<<<<<<<<<<<<<<<<");lock.release();System.out.println(threadName+"开释锁<<<<<<<<<<<<<<<<<<<<<");}catch(Exceptione){e.printStackTrace();}}}).start();newThread(newRunnable(){@Overridepublicvoidrun(){try{StringthreadName=Thread.currentThread().getName();lock.acquire();//获得锁对于象System.out.println(threadName+"获得锁>>>>>>>>>>>>>>>>>>>>>");lock.acquire();//尝试锁沉进System.out.println(threadName+"获得锁>>>>>>>>>>>>>>>>>>>>>");Thread.sleep(1*1000);lock.release();System.out.println(threadName+"开释锁<<<<<<<<<<<<<<<<<<<<<");lock.release();System.out.println(threadName+"开释锁<<<<<<<<<<<<<<<<<<<<<");}catch(Exceptione){e.printStackTrace();}}}).start();while(true){}//程序没有必定，然则统一个线程能够屡次获得，获得频频便必需开释频频，其余线程才干获得到锁}//疏散式不行沉进排它锁@TestvoidtestInterProcessSemaphoreMutex()throwsException{CuratorFrameworkclient=zk.curatorFramework();//疏散式不行沉进排它锁finalInterProcessLocklock=newInterProcessSemaphoreMutex(client,"/lock");finalInterProcessLocklock2=newInterProcessSemaphoreMutex(client,"/lock");newThread(newRunnable(){@Overridepublicvoidrun(){try{StringthreadName=Thread.currentThread().getName();lock.acquire();//获得锁对于象System.out.println(threadName+"获得锁>>>>>>>>>>>>>>>>>>>>>");//尝试锁沉进Thread.sleep(2*1000);lock.release();System.out.println(threadName+"开释锁<<<<<<<<<<<<<<<<<<<<<");}catch(Exceptione){e.printStackTrace();}}}).start();newThread(newRunnable(){@Overridepublicvoidrun(){//获得锁对于象try{StringthreadName=Thread.currentThread().getName();lock2.acquire();System.out.println(threadName+"获得锁>>>>>>>>>>>>>>>>>>>>>");Thread.sleep(2*1000);lock2.release();System.out.println(threadName+"开释锁<<<<<<<<<<<<<<<<<<<<<");}catch(Exceptione){e.printStackTrace();}}}).start();while(true){}//依次没有必定，然则必需是获得后再开释其余线程才干获得到锁}}

END

推举您浏览更多相关于“ 锁分散式Curator排它锁读写锁旌旗灯号量 ”的著作