Springboot整合Redission及分布式鎖

需要安裝redis
引入依賴

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson-spring-boot-starter</artifactId>
    <version>3.16.4</version>
</dependency>

配置RedissonClient客戶端

@Configuration
public class RedissonConfig {

    @Value("${redisHost}")
    private String redisHost;
    @Value("${redisPassword}")
    private String redisPassword;

    @Bean
    public RedissonClient redissonClient() {
        Config config = new Config();
        //單機模式  依次設置redis地址和密碼
        config.useSingleServer().setAddress(redisHost).setPassword(redisPassword);
        return Redisson.create(config);
    }
}

具有看門狗機制，自動續期，默認續30s 每隔10秒檢查異常，最有一次續期檢查，自動續到30s

    public String redissonLock(){

        ExecutorService fixedThreadPool = Executors.newFixedThreadPool(2);

        long start = System.currentTimeMillis();
        for (int i = 0; i < 2; i++) {
            fixedThreadPool.execute(() -> {
                RLock lock = redissonClient.getLock("lockKey");

                lock.lock();
                System.out.println("獲取鎖");
                try {
                    Thread.sleep(200000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }finally {
                    System.out.println(System.currentTimeMillis() - start);
                    if (lock.isLocked() && lock.isHeldByCurrentThread()) {
                        lock.unlock();
                    }
                }
            });
        }

        return "完成";
    }

嘗試拿鎖5s后停止重試,返回false 具有看門狗機制，自動延期 默認續30s 100秒后自動釋放鎖

  public String redissonTryLock() {

        ExecutorService fixedThreadPool = Executors.newFixedThreadPool(2);

        long start = System.currentTimeMillis();
        for (int i = 0; i < 2; i++) {
            fixedThreadPool.execute(() -> {
                RLock lock = redissonClient.getLock("lockKey");
                try {
                    if (lock.tryLock(5, 10, TimeUnit.SECONDS)) {
                        System.out.println(Thread.currentThread() + "獲取鎖");
                        Thread.sleep(20000);
                        System.out.println(Thread.currentThread() + "執行完成");
                    } else {
                        System.out.println(Thread.currentThread() + "沒有獲取鎖");
                    }
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } finally {
                    if (lock.isLocked() && lock.isHeldByCurrentThread()) {
                        lock.unlock();
                        System.out.println(Thread.currentThread() + "主動釋放鎖" + (System.currentTimeMillis() - start));
                    } else {
                        System.out.println(Thread.currentThread() + "已無鎖狀態" + (System.currentTimeMillis() - start));
                    }
                }
            });
        }

        return "完成";
    }