目录
一、Redisson介绍
二、Redisson的入门
1、引入依赖
2、配置客户端
3、使用锁
三、Redisson可重入锁的原理
1、原理
2、实现
3、lua脚本保证原子性
1.获取锁
2.释放锁
一、Redisson介绍
在之前的文章里我们通过redis中的setn实现了一个简单的分布式锁以及解决了误删、原子性等问题，但他依旧存在不足。我们在项目中一般使用比较成熟的分布式锁，Redisson是一个在redis基础上实现的Java驻内存数据网格，他不仅提供了一系列分布式的常用Java对象，他还提供了许多分布式服务，就比如分布式锁，Redisson中的分布式锁则不存在上述的问题，我们在项目中完全可使用
二、Redisson的入门
1、引入依赖
首先我们需要在项目的pom文件中引入对应的依赖
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson</artifactId>
<version>3.13.6</version>
</dependency>2、配置客户端
其次我们需要创建一个配置类来进行客户端的配置
package com.example.demo.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class RedisConfig {
@Bean
public RedissonClient redissonClient() {
Config config = new Config();
config.useSingleServer().setAddress("redis://IP:6379").setPassword("密码");
return Reisson.create(config);
}
}
3、使用锁
其次我们就可以在项目中进行使用了
package com.example.demo.config;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.concurrent.TimeUnit;
public class Use {
@Autowired
private RedissonClient redis;
public void test() {
// 获取锁
RLock lock = redis.getLock("name");
// 尝试获取锁： 参数1 最大等待时间 参数2 锁自动释放时间 参数3 时间单位
boolean isLock = lock.tryLock(1,111, TimeUnit.SECONDS);
if (!isLock) {
try {
// 业务代码
} finally {
lock.unlock();
}
}
}
}
三、Redisson可重入锁的原理
1、原理
线程1在方法1中获取到了锁，此时在redis锁中会记录持有这把锁的线程，然后执行方法1，在方法1中调用了方法2，进入方法2后发现方法2也需要获取锁，此时线程在获取锁时发现这个锁已经被获取了，此时就进行判断，如果发现是自己获取了这把锁，这直接进入执行业务，但是方法2执行完释放锁时，此时锁并不是真正的释放还需要去执行完方法1所剩的业务才可以释放，为了解决提前释放锁的问题，在实现时会维护一个计数器，当线程获取到锁后计算器会进行加1，当再次进入时计数器再加1变为2，此时方法2执行完释放锁计数器-1，此时计数器不为0则重置锁的过期时间不删除，当计数器=0时说明锁真正释放，删除锁
2、实现
在redis中实现可重入锁时需要维护一个计数器字段，但是传统的string类型是没有办法做到的，此时我们可以使用redis中的hash类型
3、lua脚本保证原子性
1.获取锁
在获取锁时我们先要判断锁是否存在，不存在则插入数据直接获取锁，如果存在则需要判断这把锁是不是自己持有，如果是则需要使得计数器+1，如果我们在Java中提供代码去一条一条的执行时，这些操作并不是原子性的，会带来线程安全问题（前面有提到）所以我们必须保证这些操作是原子性的，我们可以通过lua脚本来实现
【Redis】实现及优化分布式锁：实现、解决误删锁问题以及lua脚本确保redis操作原子性_1373i的博客-CSDN博客
https://blog.csdn.net/qq_61903414/article/details/130631441?spm=1001.2014.3001.5501
local key = KEYS[1] -- 锁的key
local threadId = ARGV[1] -- 线程标识
local time = ARGV[2] -- 锁的ttl
-- 判断锁是否存在
if (redis.call('exists',key) == 0) then
-- 不存在，获取锁
redis.call('hset',key,1);
-- 设置ttl
redis.call('expire',key,time);
return 1;
end;
-- 锁存在判断是否属于自己
if (redis.call('hexists',key,threadId) == 1) then
-- 属于自己计数器自增
redis.call('hincrby',key,threadId,'1');
-- 重置ttl
redis.call('expire',key,time);
return 1;
end;
return 0; -- 此时说明锁不是自己的 获取失败2.释放锁
释放锁时，我们先要判断锁是不是自己的，如果是自己的则让计数器-1，然后再判断计数器是否为0，如果为0则删除锁，这些操作也需要保证原子性
local key = KEYS[1] -- 锁的key
local threadId = ARGV[1] -- 线程标识
local time = ARGV[2] -- 锁的ttl
-- 判断锁是否是自己的
if (redis.call('hexists',key) == 0) then
-- 不是自己的直接返回
return nil;
end;
-- 说明锁是自己的计数器-1
local count = redis.call('hincrby',key,threadId,-1);
-- 判断计数器是否为0
if (count > 0) then
-- 说明不能释放锁，重置有效期
redis.call('expire',key,time);
return nil;
else -- 说明可以释放
redis.call('del',key); -- 删除
end
