先看一下自己利用setnx写的简易分布式锁,有四个问题,
1,不可重入
2,不可重试
3,超时自动释放(如果业务阻塞了,就算代码没执行完也会释放锁)
4,集群模式下怎么办?
@Override public boolean tryLock(long timeoutSec) { // 获取线程标示 String threadId = ID_PREFIX + Thread.currentThread().getId(); // 获取锁 Boolean success = stringRedisTemplate.opsForValue() .setIfAbsent(KEY_PREFIX + name, threadId, timeoutSec, TimeUnit.SECONDS); return Boolean.TRUE.equals(success); }
Redisson都能解决!!
锁重入:
利用hash结构记录线程id和重入次数。
锁重试:
redisson在尝试获取锁的时候,如果传了时间参数,就不会在获取锁失败时立即返回失败,而是会进行重试。
三个参数:最大重试时间,锁释放时间(默认为-1,会触发看门狗机制),时间单位
上部分源码
public boolean tryLock(long waitTime, long leaseTime, TimeUnit unit) throws InterruptedException { long time = unit.toMillis(waitTime); long current = System.currentTimeMillis(); long threadId = Thread.currentThread().getId();
//尝试获取锁,返回的ttl为null,表示获取成功, Long ttl = this.tryAcquire(waitTime, leaseTime, unit, threadId);
//获取成功 if (ttl == null) { return true;
//获取失败 } else {
//计算剩余时间 time -= System.currentTimeMillis() - current;
//剩余时间小于等于零,不再重试,返回失败 if (time <= 0L) { this.acquireFailed(waitTime, unit, threadId); return false; } else {
//剩余时间大于零,subscribe订阅拿到锁的线程,该线程释放锁后会发布通知,其余等待的线程可以继续争抢。 current = System.currentTimeMillis(); RFuture<RedissonLockEntry> subscribeFuture = this.subscribe(threadId);
看门狗机制:
在获取锁成功以后,开启一个定时任务,每隔一段时间就会去重置锁的超时时间,以确保锁是在程序执行完unlock手动释放的,不会发生因为业务阻塞,key超时而自动释放的情况。
下面源码
private void renewExpiration() { RedissonLock.ExpirationEntry ee = (RedissonLock.ExpirationEntry)EXPIRATION_RENEWAL_MAP.get(this.getEntryName()); if (ee != null) {
//Timeout定时任务,或者叫周期任务 Timeout task = this.commandExecutor.getConnectionManager().newTimeout(new TimerTask() { public void run(Timeout timeout) throws Exception { RedissonLock.ExpirationEntry ent = (RedissonLock.ExpirationEntry)RedissonLock.EXPIRATION_RENEWAL_MAP.get(RedissonLock.this.getEntryName()); if (ent != null) { Long threadId = ent.getFirstThreadId(); if (threadId != null) { RFuture<Boolean> future = RedissonLock.this.renewExpirationAsync(threadId); future.onComplete((res, e) -> { if (e != null) { RedissonLock.log.error("Can't update lock " + RedissonLock.this.getName() + " expiration", e); } else { if (res) { RedissonLock.this.renewExpiration(); } } }); } } }
//刷新周期, this.internalLockLeaseTime / 3L, 默认释放时间是30秒,除以3就是每10秒更新一次
}, this.internalLockLeaseTime / 3L, TimeUnit.MILLISECONDS); ee.setTimeout(task); } }
可以配合下面流程图来看源码
集群问题:
实际生产过程中,redis都是主从或者集群配置的,如果只在主节点上加锁,之后主节点宕机了,而且锁还没被同步到从节点上,就会出现安全问题。
需要使用multilock()方法。必须在所有的节点都获取锁成功,才算成功。 缺点是运维成本高,实现复杂。
@Resource private RedissonClient redissonClient; @Resource private RedissonClient2 redissonClient2; @Resource private RedissonClient3 redissonClient3; RLock lock = redissonClient.getMultilock(lock1,lock2,lock3)
标签:Redisson,long,看门狗,重试,获取,RedissonLock,threadId,null From: https://www.cnblogs.com/tyleaf/p/17121281.html