Curator实现分布式锁的基本原理-LockInternals.attemptLock

// 尝试获取锁，并返回锁对应的Zookeeper临时顺序节点的路径
String attemptLock(long time, TimeUnit unit, byte[] lockNodeBytes) throws Exception{ final long startMillis = System.currentTimeMillis(); // 无限等待时，millisToWait为null final Long millisToWait = (unit != null) ? unit.toMillis(time) : null; // 创建ZNode节点时的数据内容，无关紧要，这里为null，采用默认值（IP地址） final byte[] localLockNodeBytes = (revocable.get() != null) ? new byte[0] : lockNodeBytes; // 当前已经重试次数，与CuratorFramework的重试策略有关 int retryCount = 0; // 在Zookeeper中创建的临时顺序节点的路径，相当于一把待激活的分布式锁 // 激活条件：同级目录子节点，名称排序最小（排队，公平锁），后续继续分析 String ourPath = null; // 是否已经持有分布式锁 boolean hasTheLock = false; // 是否已经完成尝试获取分布式锁的操作 boolean isDone = false; while ( !isDone ){ isDone = true; try{ // 从InterProcessMutex的构造函数可知实际driver为StandardLockInternalsDriver的实例 // 在Zookeeper中创建临时顺序节点 ourPath = driver.createsTheLock(client, path, localLockNodeBytes); // 循环等待来激活分布式锁，实现锁的公平性，后续继续分析 hasTheLock = internalLockLoop(startMillis, millisToWait, ourPath); } catch ( KeeperException.NoNodeException e ) {// 容错处理，不影响主逻辑的理解，可跳过 // 因为会话过期等原因，StandardLockInternalsDriver因为无法找到创建的临时顺序节点而抛出NoNodeException异常 if ( client.getZookeeperClient().getRetryPolicy().allowRetry(retryCount++, System.currentTimeMillis() - startMillis, RetryLoop.getDefaultRetrySleeper()) ){ // 满足重试策略尝试重新获取锁 isDone = false; } else { // 不满足重试策略则继续抛出NoNodeException throw e; } } } if ( hasTheLock ){ // 成功获得分布式锁，返回临时顺序节点的路径，上层将其封装成锁信息记录在映射表，方便锁重入 return ourPath; } // 获取分布式锁失败，返回null return null;
}

Curator实现分布式锁的基本原理-LockInternals.attemptLock相关推荐

Curator实现分布式锁的基本原理-LockInternals.internalLockLoop
// 循环等待来激活分布式锁,实现锁的公平性 private boolean internalLockLoop(long startMillis, Long millisToWait, String ...
Curator实现分布式锁的基本原理
curator是Netflix公司开源的一个ZooKeeper客户端封装.curator 对于锁这块做了一些封装,curator 提供了InterProcessMutex 这样一个 api.除了分布式 ...
Curator实现分布式锁的基本原理-InterProcessMutex.internalLock
private boolean internalLock(long time, TimeUnit unit) throws Exception{ Thread currentThread = Thre ...
Curator实现分布式锁的基本原理-构造函数
// 最常用 public InterProcessMutex(CuratorFramework client, String path){// Zookeeper利用path创建临时顺序节点,实现公 ...
Curator实现分布式锁的基本原理-createsTheLock
// From StandardLockInternalsDriver // 在Zookeeper中创建临时顺序节点 public String createsTheLock(CuratorFrame ...
Curator实现分布式锁的基本原理-getTheLock
// From StandardLockInternalsDriver public PredicateResults getsTheLock(CuratorFramework client, Lis ...
Curator实现分布式锁的基本原理-InterProcessMutex.acquire
// 无限等待 public void acquire() throws Exception{ if ( !internalLock(-1, null) ){ throw new IOExceptio ...
分布式架构-ZK客户端工具Curator框架分布式锁及基本使用
分布式架构-基于Curator分布式锁及基本使用一.Curator Curator是Netflix公司开源的一套zookeeper客户端框架,解决了很多Zookeeper客户端非常底层的细节开发工作 ...
Apache Curator之分布式锁原理（二）
本文主要讲解如下内容: 为什么要使用分布式锁? 分布式锁特性! 分布式锁的实现方式有哪些? Curator分布式锁原理 Curator分布式锁实现类UML及相关类的介绍基于Redis,数据库实现分布 ...

Curator实现分布式锁的基本原理-LockInternals.attemptLock

Curator实现分布式锁的基本原理-LockInternals.attemptLock相关推荐

最新文章

热门文章