Redisson分布式锁实现

锁续命逻辑renewExpiration()

true

ttl == null？

加锁成功return;

scheduleExpirationRenewal(threadId)

信号量，唤醒等待线程value.getLatch().release();

return 1

LUA脚本逻辑

业务逻辑

return nil返回null

重设\"lock_key\

解锁lock.unlock();

renewExpirationAsync(threadId)

return null

嵌套调用实现定时任务

LUA脚本实现，保证redis命令原子性

unlockAsync(Thread.currentThread().getId())

当前现在加的\"lock_key\

唤醒

true不存在

获取线程idlong threadId = Thread.currentThread().getId();

new TimerTask().run()

设置\"lock_key\

finally

返回\"lock_key\

true表示不存在

if (counter > 0)

延时任务new TimerTask()，\"lock_key\"span style=\"font-size: inherit;\

RFuture<Boolean> future = unlockInnerAsync(threadId);

false

阻塞线程ttl个时间，如果阻塞过程中锁被释放，可被redischannel消息span style=\"font-size: inherit;\

redis发布订阅实现，当锁被释放时，唤醒等待线程RFuture<RedissonLockEntry> future = subscribe(threadId);

\"lock_key\"font color=\"#323232\

未加锁线程等待，并每隔一段时间进行尝试加锁while (true)

tryAcquireAsync

尝试进行加锁，返回\"lock_key\

redisson

redis中是否存在\"lock_key\

RLock lock = redisson.getLock(\"lock_key\")

redis中是否不存在\"lock_key\

锁续命实现ttlRemainingFuture.onComplete

加锁是否成功  if (ttl == null)

加锁lock.lock();

删除\"lock_key\

return nil返回null

循环尝试加锁

锁续命炒作，重新设置\"lock_key\

加锁成功跳出循环    break;

try

return 0

res 返回为1 时，是true，嵌套调用延时逻辑if (res) {    renewExpiration();}

\"lock_key\