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; // 鎖的過期時(shí)間，默認(rèn)為 30 秒
    private static final long RENEWAL_INTERVAL = 10 * 1000L; // 自動(dòng)續(xù)期的時(shí)間間隔，默認(rèn)為 10 秒

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

        // 獲取鎖并執(zhí)行任務(wù)
        RLock lock = redissonClient.getLock("my-lock");
        try {
            if (lock.tryLock(LEASE_TIME, TimeUnit.MILLISECONDS)) {
                // 執(zhí)行具體的業(yè)務(wù)邏輯

                // 啟動(dòng)自動(dòng)續(xù)期任務(wù)
                startRenewalTask(lock);
            } else {
                // 獲取鎖失敗，處理鎖被其他程序占用的邏輯
            }
        } catch (InterruptedException e) {
            // 處理中斷異常
        } finally {
            // 停止自動(dòng)續(xù)期任務(wù)
            stopRenewalTask(lock);

            // 釋放鎖
            if (lock.isHeldByCurrentThread()) {
                lock.unlock();
            }
        }

        // 關(guān)閉 Redis 客戶端
        redissonClient.shutdown();
    }

    private static void startRenewalTask(RLock lock) {
        Thread renewalThread = new Thread(() -> {
            while (true) {
                try {
                    // 等待續(xù)期時(shí)間間隔
                    Thread.sleep(RENEWAL_INTERVAL);

                    // 續(xù)期
                    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();
        }
    }
}