redis中redisson实现锁自动延时

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

import java.util.concurrent.TimeUnit;

public class RedisLockWithAutoRenewal {

    private static final long LEASE_TIME = 30 * 1000L; // 锁的过期时间，默认为 30 秒
    private static final long RENEWAL_INTERVAL = 10 * 1000L; // 自动续期的时间间隔，默认为 10 秒

    public static void main(String[] args) {
        // 创建 Redis 客户端
        Config config = new Config();
        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
        RedissonClient redissonClient = Redisson.create(config);

        // 获取锁并执行任务
        RLock lock = redissonClient.getLock("my-lock");
        try {
            if (lock.tryLock(LEASE_TIME, TimeUnit.MILLISECONDS)) {
                // 执行具体的业务逻辑

                // 启动自动续期任务
                startRenewalTask(lock);
            } else {
                // 获取锁失败，处理锁被其他程序占用的逻辑
            }
        } catch (InterruptedException e) {
            // 处理中断异常
        } finally {
            // 停止自动续期任务
            stopRenewalTask(lock);

            // 释放锁
            if (lock.isHeldByCurrentThread()) {
                lock.unlock();
            }
        }

        // 关闭 Redis 客户端
        redissonClient.shutdown();
    }

    private static void startRenewalTask(RLock lock) {
        Thread renewalThread = new Thread(() -> {
            while (true) {
                try {
                    // 等待续期时间间隔
                    Thread.sleep(RENEWAL_INTERVAL);

                    // 续期
                    lock.expire(LEASE_TIME, TimeUnit.MILLISECONDS);
                } catch (InterruptedException e) {
                    break;
                }
            }
        });
        renewalThread.setDaemon(true);
        renewalThread.start();
    }

    private static void stopRenewalTask(Thread renewalThread) {
        if (renewalThread != null) {
            renewalThread.interrupt();
        }
    }
}