【Redis】Redisson入门以及Redisson可重入锁的lua脚本实现

旧城等待， 2023-09-27 22:43 34阅读 0赞

**目录**

一、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类型

![7b29e389613248b89fe77ad7366240e5.png][]

### 3、lua脚本保证原子性 ###

#### 1.获取锁 ####

在获取锁时我们先要判断锁是否存在，不存在则插入数据直接获取锁，如果存在则需要判断这把锁是不是自己持有，如果是则需要使得计数器+1，如果我们在Java中提供代码去一条一条的执行时，这些操作并不是原子性的，会带来线程安全问题（前面有提到）所以我们必须保证这些操作是原子性的，我们可以通过lua脚本来实现

[【Redis】实现及优化分布式锁：实现、解决误删锁问题以及lua脚本确保redis操作原子性\_1373i的博客-CSDN博客![icon-default.png?t=N3I4][icon-default.png_t_N3I4]https://blog.csdn.net/qq\_61903414/article/details/130631441?spm=1001.2014.3001.5501][Redis_lua_redis_1373i_-CSDN_icon-default.png_t_N3I4_icon-default.png_t_N3I4_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

[7b29e389613248b89fe77ad7366240e5.png]: https://img-blog.csdnimg.cn/7b29e389613248b89fe77ad7366240e5.png
[icon-default.png_t_N3I4]: https://csdnimg.cn/release/blog_editor_html/release2.2.5/ckeditor/plugins/CsdnLink/icons/icon-default.png?t=N3I4
[Redis_lua_redis_1373i_-CSDN_icon-default.png_t_N3I4_icon-default.png_t_N3I4_https_blog.csdn.net_qq_61903414_article_details_130631441_spm_1001.2014.3001.5501]: https://blog.csdn.net/qq_61903414/article/details/130631441?spm=1001.2014.3001.5501