Curator学习笔记（一）读写锁腾讯云开发者社区

基本涵盖了常用的分布式调度功能。那么这块他们是怎么做的。考虑到好的代码肯定做了很多优化，里边会有很多设计模式。但是作者目前还达不到那种一眼就看出其代码的精髓锁着，因此这块作者还是按照老样子。小了解其大概得轮廓。以后再复习设计模式的时候。再去思考这些能够真正提升自身功力的东西。

publicStringcreatesTheLock(CuratorFrameworkclient,Stringpath,byte[]lockNodeBytes)throwsException{StringourPath;//通过我们注入到springioc中的client操作zk，通过判断是否存在该路径进行加锁if(lockNodeBytes!=null){ourPath=(String)((ACLBackgroundPathAndBytesable)client.create().creatingParentContainersIfNeeded().withProtection().withMode(CreateMode.EPHEMERAL_SEQUENTIAL)).forPath(path,lockNodeBytes);}else{ourPath=(String)((ACLBackgroundPathAndBytesable)client.create().creatingParentContainersIfNeeded().withProtection().withMode(CreateMode.EPHEMERAL_SEQUENTIAL)).forPath(path);}//拿到路径之后，就返回returnourPath;判断是否拿到锁的根据是这里的maxLeasse，写锁这里为1，读锁为2147483647

在锁释放的这个问题上。我们看到也是通过从lackdata中获取重入的次数，然后进行递减的。因为这个lockdata和线程进行绑定。所以在线程轮转中是没有数据消失的问题的。

publicvoidrelease()throwsException{ThreadcurrentThread=Thread.currentThread();//拿到当前线程的重入数据InterProcessMutex.LockDatalockData=(InterProcessMutex.LockData)this.threadData.get(currentThread);if(lockData==null){thrownewIllegalMonitorStateException("Youdonotownthelock:"+this.basePath);}else{//进行锁的重入次数的释放intnewLockCount=lockData.lockCount.decrementAndGet();if(newLockCount<=0){if(newLockCount<0){thrownewIllegalMonitorStateException("Lockcounthasgonenegativeforlock:"+this.basePath);}else{try{//如果锁被释放完毕。那么就开始真正的释放this.internals.releaseLock(lockData.lockPath);}finally{this.threadData.remove(currentThread);}}}}}锁的释放也很简单，直接删除

finalvoidreleaseLock(StringlockPath)throwsException{this.client.removeWatchers();this.revocable.set((Object)null);this.deleteOurPath(lockPath);}总结：通过分析，curator读写锁是通过对zk节点的存在与否进行判断的从而进行加锁的，对于读锁来说只有在不存在的时候线程才能加锁成功。通过将线程和重入次数的绑定，来实现的锁重入机制。当锁被释放之后，通过删除节点来通知其他线程进行加锁。对于读锁来说，单个线程最大或者的读锁数量也是有限制的。通过序列号的方式与写锁进行区别。读锁这块的详细实现作者还没有想明白，以后想明白了再补上。