redisson实现分布式锁原理

redisson实现分布式锁原理实现分布式锁原理

本文将详细介绍redisson实现分布式锁原理。具有很好的参考价值，下面跟着小编一起来看下吧

Redisson分布式锁分布式锁

之前的基于注解的锁有一种锁是基本redis的分布式锁，锁的实现我是基于redisson组件提供的RLock，这篇来看看redisson是如何实现锁的。

不同版本实现锁的机制并不相同不同版本实现锁的机制并不相同

引用的redisson最近发布的版本3.2.3，不同的版本可能实现锁的机制并不相同，早期版本好像是采用简单的setnx，getset等常规命令来配置完成，而后期由于redis支持了脚本Lua变更了实现原理。

<dependency>

<groupId>org.redisson</groupId>

拥有标准锁接口的所有特性，比如lock,unlock,trylock等等。

扩展标准接口扩展标准接口Lock

扩展了很多方法，常用的主要有：强制锁释放，带有效期的锁,还有一组异步的方法。其中前面两个方法主要是解决标准lock可能造成的死锁问题。比如某个线程获取到锁之后，线程所在机器死机，此时

获取了锁的线程无法正常释放锁导致其余的等待锁的线程一直等待下去。

可重入机制可重入机制

各版本实现有差异，可重入主要考虑的是性能，同一线程在未释放锁时如果再次申请锁资源不需要走申请流程，只需要将已经获取的锁继续返回并且记录上已经重入的次数即可，与jdk里面的

ReentrantLock功能类似。重入次数靠hincrby命令来配合使用，详细的参数下面的代码。

怎么判断是同一线程？怎么判断是同一线程？

redisson的方案是，的方案是，RedissonLock实例的一个实例的一个guid再加当前线程的再加当前线程的id,通过通过getLockName返回返回

public class RedissonLock extends RedissonExpirable implements RLock {

}

String getLockName(long threadId) {

return this.id + ":" + threadId;

}

RLock获取锁的两种场景获取锁的两种场景

这里拿tryLock的源码来看：tryAcquire方法是申请锁并返回锁有效期还剩余的时间，如果为空说明锁未被其它线程申请直接获取并返回，如果获取到时间，则进入等待竞争逻辑。

public boolean tryLock(long waitTime, long leaseTime, TimeUnit unit) throws InterruptedException {

long time = unit.toMillis(waitTime);

long current = System.currentTimeMillis();

final long threadId = Thread.currentThread().getId();

}

}

无竞争，直接获取锁无竞争，直接获取锁

先看下首先获取锁并释放锁背后的redis都在做什么，可以利用redis的monitor来在后台监控redis的执行情况。当我们在方法了增加@RequestLockable之后，其实就是调用lock以及unlock，下面是redis命

令：

加锁加锁

由于高版本的redis支持lua脚本，所以redisson也对其进行了支持，采用了脚本模式，不熟悉lua脚本的可以去查找下。执行lua命令的逻辑如下：

<T> RFuture<T> tryLockInnerAsync(long leaseTime, TimeUnit unit, long threadId, RedisStrictCommand<T> command) {

this.internalLockLeaseTime = unit.toMillis(leaseTime);

return this.commandExecutor.evalWriteAsync(this.getName(), LongCodec.INSTANCE, command, "if (redis.call(\'exists\', KEYS[1]) == 0) then redis.call(\'hset\', KEYS[1], ARGV[2], 1); redis.call(\'pexpire\', KEYS[1], ARGV[1]); return nil; end; if (redis.call(\'hexists\', KEYS[1], ARGV[2]) == 1) then redis.call(\'hincrby\', KEYS[1], ARGV[2], 1); redis.call(\'pexpire\', KEYS[1], ARGV[1]); return nil; end; return redis.call(\'pttl\', KEYS[1]);", Collections.singletonList(this.getName()), new Object[]{Long.valueOf(this.internalLockLeaseTime), this.getLockName(threadId)});

"if (redis.call('exists', KEYS[1]) == 0) then

redis.call('hset', KEYS[1], ARGV[2], 1);

redis.call('pexpire', KEYS[1], ARGV[1]);

return nil; end;

if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then

redis.call('hincrby', KEYS[1], ARGV[2], 1);

redis.call('pexpire', KEYS[1], ARGV[1]);

return nil; end;

return redis.call('pttl', KEYS[1]);"

"1" "lock.com.csp.product.api.service.ProductAppService.searchProductByPage#0"

解锁解锁

解锁的流程解锁的流程看起来复杂些：

1. 如果lock键不存在，发消息说锁已经可用

2. 如果锁不是被当前线程锁定，则返回nil

3. 由于支持可重入，在解锁时将重入次数需要减1

4. 如果计算后的重入次数>0，则重新设置过期时间

5. 如果计算后的重入次数<=0，则发消息说锁已经可用

"EVAL"

"if (redis.call('exists', KEYS[1]) == 0) then

redis.call('publish', KEYS[2], ARGV[1]);