快速使用 Redisson 实现分布式锁

旧城等待， 2022-11-20 09:35 196阅读 0赞

# 1、Maven依赖 #

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

# 2、application.yml添加配置 #

# 分布式锁
    redisson:
      signle:
        timeout: 30000
        address: redis://127.0.0.1:6379
        password: dev-foo
        database: 10
        connectionPoolSize: 50
        connectionMinimumIdleSize: 10

### 3、RedissonAutoConfiguration 配置类 ###

import lombok.Data;
    import org.apache.commons.lang.StringUtils;
    import org.redisson.Redisson;
    import org.redisson.api.RedissonClient;
    import org.redisson.config.Config;
    import org.redisson.config.SingleServerConfig;
    import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.cache.annotation.EnableCaching;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    
    @Data
    @Configuration
    @ConditionalOnClass(Config.class)
    @EnableCaching
    @ConfigurationProperties(prefix = "redisson.signle")
    public class RedissonAutoConfiguration {
    
        private int timeout;
    
        private String address;
    
        private String password;
    
        private int database;
    
        private int connectionPoolSize;
    
        private int connectionMinimumIdleSize;
    
        /**
         * 单机模式自动装配
         *
         * @return
         */
        @Bean
        public RedissonClient redissonClient() {
            Config config = new Config();
            SingleServerConfig serverConfig = config.useSingleServer()
                    .setDatabase(database)
                    .setAddress(address)
                    .setTimeout(timeout)
                    .setConnectionPoolSize(connectionPoolSize)
                    .setConnectionMinimumIdleSize(connectionMinimumIdleSize);
    
            if (StringUtils.isNotBlank(password)) {
                serverConfig.setPassword(password);
            }
    
            return Redisson.create(config);
        }
    
    }

### 4、业务代码 ###

@Resource
    private RedissonClient redissonClient;
    
    
    
    
    public void method1(){
    
    
        RLock lock = redissonClient.getLock(锁住的对象);
    
        try{
    
            // 第一种，加锁 锁的有效期默认30秒
            lock.lock(); 
    
    
            // 第二种，可重入锁，如果三个线程同时竞争，一个线程执行完会给到下个线程
            lock.lock(5, TimeUnit.SECONDS); //过期锁时间5秒
    
            // 第三种，尝试加锁，最多等待1秒，如果超时还获取不到锁就返回false，上锁以后10秒自动解锁 
            boolean res = lock.tryLock(1, 10, TimeUnit.SECONDS)
        
            // 业务代码
    		
        }catch() {
           log.error();	
        }finally{
           if (lock.isLocked()) {
                    lock.unlock();
                } else {
                    log.debug("已经释放锁了");
           }	
        }
    
    }