Redis分布式锁及看门狗机制

import org.redisson.Redisson;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;

public class RedissonWatchdogExample {
    public static void main(String[] args) {
        // 配置 Redisson
        Config config = new Config();
        config.useSingleServer().setAddress("redis://localhost:6379");

        // 设置看门狗超时时间（单位：毫秒）
        // 默认值为 30000 毫秒（30秒），这里设置为 60秒
        config.setLockWatchdogTimeout(60000);

        // 创建 Redisson 客户端
        RedissonClient redisson = Redisson.create(config);

        // 获取分布式锁
        RLock lock = redisson.getLock("myLock");

        try {
            // 尝试获取锁，看门狗机制会自动续期锁
            boolean isLocked = lock.tryLock();
            if (isLocked) {
                System.out.println("锁获取成功，执行业务逻辑...");

                // 模拟业务逻辑执行时间
                Thread.sleep(100000); // 100秒

                System.out.println("业务逻辑执行完成，释放锁...");
            } else {
                System.out.println("锁获取失败，已有其他线程持有锁...");
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            // 释放锁
            if (lock.isHeldByCurrentThread()) {
                lock.unlock();
                System.out.println("锁已释放");
            }
        }

        // 关闭 Redisson 客户端
        redisson.shutdown();
    }
}