SpringBoot整合Redisson

Posted 2023-04-17

参考技术A

Redisson的Github地址： https://github.com/redisson/redisson/wiki/Table-of-Content

基于Redis的Redisson分布式可重入锁RLock对象实现了java.util.concurrent.locks.Lock接口。

大家都知道，如果负责储存这个分布式锁的Redisson节点宕机以后，而且这个锁正好处于锁住的状态时，这个锁会出现锁死的状态。为了避免这种情况的发生，Redisson内部提供了一个 监控锁的看门狗 ，它的作用是在Redisson实例被关闭前，不断的延长锁的有效期。默认情况下，看门狗的检查锁的超时时间是30秒钟，也可以通过修改Config.lockWatchdogTimeout来另行指定。

在RedissonLock类的renewExpiration()方法中，会启动一个定时任务每隔30/3=10秒给锁续期。如果业务执行期间，应用挂了，那么不会自动续期，到过期时间之后，锁会自动释放。

另外Redisson还提供了leaseTime的参数来指定加锁的时间。超过这个时间后锁便自动解开了。

如果指定了锁的超时时间，底层直接调用lua脚本，进行占锁。如果超过leaseTime，业务逻辑还没有执行完成，则直接释放锁，所以在指定leaseTime时，要让leaseTime大于业务执行时间。RedissonLock类的tryLockInnerAsync()方法

分布式可重入读写锁允许同时有多个读锁和一个写锁处于加锁状态。在读写锁中，读读共享、读写互斥、写写互斥。

读写锁测试类，当访问write接口时，read接口会被阻塞住。

Redisson的分布式信号量与的用法与java.util.concurrent.Semaphore相似

现在redis中保存semaphore的值为3

然后在TestController中添加测试方法：

当访问acquireSemaphore接口时，redis中的semaphore会减1；访问releaseSemaphore接口时，redis中的semaphore会加1。当redis中的semaphore为0时，继续访问acquireSemaphore接口，会被阻塞，直到访问releaseSemaphore接口，使得semaphore>0，acquireSemaphore才会继续执行。

CountDownLatch作用：某一线程，等待其他线程执行完毕之后，自己再继续执行。

在TestController中添加测试方法，访问close接口时，调用await()方法进入阻塞状态，直到有三次访问release接口时，close接口才会返回。

springboot整合redisson分布式锁

一、通过maven引入redisson的jar包

<dependency>
            <groupId>org.redisson</groupId>
            <artifactId>redisson</artifactId>
            <version>3.6.5</version>
        </dependency>

 

二、在yaml文件中引入redis的相关配置（redis单节点可以读取原有redis配置拼装，如果是主从需另外独立配置，相关属性可以参考org.redisson.config.Config.masterSlaveServersConfig）

spring:
  redis:
    host: 127.0.0.1 
    port: 6379
    password: 111111

三、添加springboot配置

package com.aoxun.config;

import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * redisson配置
 * 目前使用的是腾讯云的单节点redis，所以暂时配置单服务
 * 
 *
 */
@Configuration
public class RedissonConfig {

    @Value("${spring.redis.host}")
    private String host;
    
    @Value("${spring.redis.port}")
    private String port;
    
    @Value("${spring.redis.password}")
    private String password;
    
    
    @Bean
    public RedissonClient getRedisson(){
        
        Config config = new Config();
        config.useSingleServer().setAddress("redis://" + host + ":" + port).setPassword(password);
        //添加主从配置
//        config.useMasterSlaveServers().setMasterAddress("").setPassword("").addSlaveAddress(new String[]{"",""});
        
        return Redisson.create(config);
    }
    
}

四、在需要使用的地方注入RedissonClient即可

package com.aoxun.modular.menjin.service.impl;

import java.util.concurrent.TimeUnit;

import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;


@Service
public class TestRedissonLock{
    
    @Autowired
    private RedissonClient redissonClient;

    public void cameraCallback() {
        
        RLock rlock = redissonClient.getLock("redisson:lock:personId" + 123);

　　　　　//设置锁超时时间，防止异常造成死锁
        rlock.lock(20, TimeUnit.SECONDS);
        
        try{
            //执行业务逻辑
            Thread.sleep(10000);
            System.out.println(123);
            
        } catch(Exception e){
            
        }finally{
            rlock.unlock();
        }
        
    }
    

}

 

到此利用redisson实现分布式锁简单样例已经结束