Redisson实现redis分布式锁

蔚落 2023-09-27 20:12 10阅读 0赞

#### Redisson中的分布式锁 ####

Redisson把这些工作都封装好了

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

package com.msb.redis.config;
    
    import org.redisson.Redisson;
    import org.redisson.api.RedissonClient;
    import org.redisson.config.Config;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    @Configuration
    public class MyRedissonConfig {
        
        /**
         * 所有对Redisson的使用都是通过RedissonClient
         */
        @Bean(destroyMethod="shutdown")
        public RedissonClient redisson(){
        
            //1、创建配置
            Config config = new Config();
            config.useSingleServer().setAddress("redis://127.0.0.1:6379");
    
            //2、根据Config创建出RedissonClient实例
            RedissonClient redisson = Redisson.create(config);
            return redisson;
        }
    }

package com.msb.redis.redisbase.adv;
    
    
    import com.msb.redis.lock.rdl.RedisDistLockWithDog;
    import org.junit.jupiter.api.Test;
    import org.redisson.Redisson;
    import org.redisson.api.RLock;
    import org.redisson.api.RedissonClient;
    import org.redisson.config.Config;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.TimeUnit;
    
    @SpringBootTest
    public class TestRedissionLock {
        
    
        private int count = 0;
        @Autowired
        private RedissonClient redisson;
    
        @Test
        public void testLockWithDog() throws InterruptedException {
        
            int clientCount =3;
            RLock lock = redisson.getLock("RD-lock");
            CountDownLatch countDownLatch = new CountDownLatch(clientCount);
            ExecutorService executorService = Executors.newFixedThreadPool(clientCount);
            for (int i = 0;i<clientCount;i++){
        
                executorService.execute(() -> {
        
                    try {
        
                        lock.lock(10, TimeUnit.SECONDS);
                        System.out.println(Thread.currentThread().getName()+"准备进行累加。");
                        Thread.sleep(2000);
                        count++;
                    } catch (InterruptedException e) {
        
                        e.printStackTrace();
                    } finally {
        
                        lock.unlock();
                    }
                    countDownLatch.countDown();
                });
            }
            countDownLatch.await();
            System.out.println(count);
        }
    }

https://github.com/redisson/redisson/

[https://redisson.org/][https_redisson.org]

锁过期时间不好评估怎么办？

[https_redisson.org]: https://redisson.org/