SET lock:order:12345 "client_1" NX EX 10

-- KEYS[1] = lock key
-- ARGV[1] = client_id
if redis.call('get', KEYS[1]) == ARGV[1] then
    return redis.call('del', KEYS[1])
else
    return 0
end

public boolean unlock(String lockKey, String clientId) {
    String script = 
        "if redis.call('get', KEYS[1]) == ARGV[1] then " +
        "   return redis.call('del', KEYS[1]) " +
        " else " +
        "   return 0 " +
        " end";
    DefaultRedisScript<Long> redisScript = new DefaultRedisScript<>();
    redisScript.setScriptText(script);
    redisScript.setResultType(Long.class);
    Long result = redisTemplate.execute(
        redisScript,
        Collections.singletonList(lockKey),
        clientId
    );
    return result != null && result == 1;
}

客戶端A加鎖（EX 30s）
     ↓
啟動(dòng) Watchdog 線程（每10s檢查一次）
     ↓
若鎖仍存在且屬于本客戶端 → 執(zhí)行 EXPIRE lock:xxx 30
     ↓
業(yè)務(wù)執(zhí)行完成 → 取消續(xù)期 + 釋放鎖

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

@Autowired
private RedissonClient redissonClient;
public void doBusiness() {
    RLock lock = redissonClient.getLock("lock:order:12345");
    try {
        // 嘗試加鎖，最多等待10秒，上鎖后30秒自動(dòng)解鎖
        boolean res = lock.tryLock(10, 30, TimeUnit.SECONDS);
        if (res) {
            try {
                // 執(zhí)行業(yè)務(wù)邏輯（可能耗時(shí)較長）
                System.out.println("Locked! Doing business...");
                Thread.sleep(25000); // 模擬長任務(wù)
            } finally {
                lock.unlock(); // 自動(dòng)取消續(xù)期 + 安全釋放
            }
        } else {
            System.out.println("Failed to acquire lock");
        }
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
}

public boolean tryLock(String lockKey, String clientId, int expireSeconds) {
    String result = redisTemplate.opsForValue()
        .setIfAbsent(lockKey, clientId, expireSeconds, TimeUnit.SECONDS);
    return Boolean.TRUE.equals(result);
}

private ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
private volatile boolean isLocked = false;
public void watchDog(String lockKey, String clientId, int expireSeconds) {
    isLocked = true;
    scheduler.scheduleAtFixedRate(() -> {
        if (isLocked) {
            // 只有當(dāng)前客戶端持有鎖時(shí)才續(xù)期
            String current = redisTemplate.opsForValue().get(lockKey);
            if (clientId.equals(current)) {
                redisTemplate.expire(lockKey, expireSeconds, TimeUnit.SECONDS);
            }
        }
    }, expireSeconds / 3, expireSeconds / 3, TimeUnit.SECONDS);
}

String lockKey = "lock:order:12345";
String clientId = "client_" + Thread.currentThread().getId();
if (tryLock(lockKey, clientId, 30)) {
    try {
        watchDog(lockKey, clientId, 30); // 啟動(dòng)續(xù)期
        // 執(zhí)行業(yè)務(wù)
    } finally {
        isLocked = false; // 停止續(xù)期
        unlock(lockKey, clientId); // 安全釋放
    }
}

# 鎖結(jié)構(gòu)
lock:order:12345
  field: client_1
  value: 2   # 重入次數(shù)