// 1. 獲取Redisson客戶端（項目里一般是配置好的，直接注入）
RedissonClient redissonClient = Redisson.create();
// 2. 獲取一把分布式鎖（鎖的名字自己定義，比如“order:lock:123”，唯一就行）
RLock lock = redissonClient.getLock("order:lock:123");
try {
    // 3. 加鎖：默認30秒過期，也能自己設(shè)置，比如lock.lock(60, TimeUnit.SECONDS)
    lock.lock();
    // 4. 執(zhí)行業(yè)務(wù)邏輯（比如修改訂單狀態(tài)、扣減庫存，這部分是咱們自己的代碼）
    doBusiness();
} finally {
    // 5. 解鎖：必須放在finally里，防止業(yè)務(wù)報錯，鎖沒釋放
    lock.unlock();
}

// 核心加鎖方法：嘗試獲取鎖，leaseTime是過期時間，unit是時間單位
private <T> RFuture<Long> tryAcquireAsync(long leaseTime, TimeUnit unit, long threadId) {
    // 1. 如果設(shè)置了過期時間，直接調(diào)用tryLockInnerAsync（真正執(zhí)行加鎖的方法）
    if (leaseTime != -1) {
        return tryLockInnerAsync(leaseTime, unit, threadId, RedisCommands.EVAL_LONG);
    }
    // 2. 如果沒設(shè)置過期時間（用默認30秒），先嘗試加鎖
    RFuture<Long> ttlRemainingFuture = tryLockInnerAsync(getLockWatchdogTimeout(), TimeUnit.MILLISECONDS, threadId, RedisCommands.EVAL_LONG);
    // 3. 加鎖成功后，啟動“看門狗”（續(xù)期用的），后面會講
    ttlRemainingFuture.onComplete((ttlRemaining, e) -> {
        if (e == null) {
            if (ttlRemaining == null) {
                scheduleExpirationRenewal(threadId);
            }
        }
    });
    return ttlRemainingFuture;
}

// 真正執(zhí)行加鎖的方法：調(diào)用Lua腳本，和咱們之前講的Lua邏輯一致
private <T> RFuture<T> tryLockInnerAsync(long leaseTime, TimeUnit unit, long threadId, RedisCommand<T> command) {
    // 轉(zhuǎn)換過期時間為毫秒
    long ttl = unit.toMillis(leaseTime);
    // 返回Lua腳本的執(zhí)行結(jié)果，這里就是調(diào)用Redis執(zhí)行Lua腳本
    return evalWriteAsync(getName(), LongCodec.INSTANCE, command,
            "if (redis.call('exists', KEYS[1]) == 0) then " +
                "redis.call('hset', KEYS[1], ARGV[2], 1); " +
                "redis.call('pexpire', KEYS[1], ARGV[1]); " +
                "return nil; " +
            "end; " +
            "if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then " +
                "redis.call('hincrby', KEYS[1], ARGV[2], 1); " +
                "redis.call('pexpire', KEYS[1], ARGV[1]); " +
                "return nil; " +
            "end; " +
            "return redis.call('pttl', KEYS[1]);",
            Collections.singletonList(getName()), ttl, getLockName(threadId));
}

// 啟動看門狗，續(xù)期用的
private void scheduleExpirationRenewal(long threadId) {
    ExpirationEntry entry = new ExpirationEntry();
    // 把當(dāng)前線程的續(xù)期信息，存到本地緩存里
    EXPIRATION_RENEWAL_MAP.put(getEntryName(), entry);
    // 啟動一個定時任務(wù)，每隔10秒執(zhí)行一次，刷新鎖的過期時間
    entry.task = commandExecutor.getConnectionManager().newTimeout(new TimerTask() {
        @Override
        public void run(Timeout timeout) throws Exception {
            // 調(diào)用續(xù)期的Lua腳本，把鎖的過期時間刷新回30秒
            RFuture<Boolean> future = renewExpirationAsync(threadId);
            future.onComplete((res, e) -> {
                if (e != null) {
                    // 續(xù)期失敗，移除本地緩存，停止續(xù)期
                    EXPIRATION_RENEWAL_MAP.remove(getEntryName());
                    return;
                }
                if (res) {
                    // 續(xù)期成功，繼續(xù)啟動下一個定時任務(wù)，循環(huán)續(xù)期
                    scheduleExpirationRenewal(threadId);
                } else {
                    // 續(xù)期失敗，移除本地緩存
                    cancelExpirationRenewal(threadId);
                }
            });
        }
    }, getLockWatchdogTimeout() / 3, TimeUnit.MILLISECONDS);
}

// 續(xù)期的核心方法：調(diào)用Lua腳本，刷新過期時間
private RFuture<Boolean> renewExpirationAsync(long threadId) {
    return evalWriteAsync(getName(), LongCodec.INSTANCE, RedisCommands.EVAL_BOOLEAN,
            "if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then " +
                "redis.call('pexpire', KEYS[1], ARGV[1]); " +
                "return 1; " +
            "end; " +
            "return 0;",
            Collections.singletonList(getName()), getLockWatchdogTimeout(), getLockName(threadId));
}

// 核心解鎖方法
public RFuture<Void> unlockAsync(long threadId) {
    // 調(diào)用解鎖的Lua腳本，返回解鎖結(jié)果
    RFuture<Boolean> future = unlockInnerAsync(threadId);
    future.onComplete((opStatus, e) -> {
        // 解鎖成功后，停止看門狗續(xù)期
        cancelExpirationRenewal(threadId);
        if (e != null) {
            throw new CompletionException(e);
        }
        // 如果返回null，說明解鎖失敗（不是鎖的持有者）
        if (opStatus == null) {
            throw new IllegalMonitorStateException("attempt to unlock lock, not locked by current thread by node id: "
                    + getNodeId() + " thread-id: " + threadId);
        }
    });
    return future;
}

// 真正執(zhí)行解鎖的方法：調(diào)用Lua腳本
private RFuture<Boolean> unlockInnerAsync(long threadId) {
    return evalWriteAsync(getName(), LongCodec.INSTANCE, RedisCommands.EVAL_BOOLEAN,
            "if (redis.call('hexists', KEYS[1], ARGV[2]) == 0) then " +
                "return nil; " +  // 不是鎖的持有者，返回null，解鎖失敗
            "end; " +
            "local counter = redis.call('hincrby', KEYS[1], ARGV[2], -1); " +  // 重入計數(shù)減1
            "if (counter > 0) then " +
                "redis.call('pexpire', KEYS[1], ARGV[1]); " +  // 計數(shù)還大于0，刷新過期時間
                "return 1; " +  // 解鎖成功（只是計數(shù)減1，沒刪除鎖）
            "else " +
                "redis.call('del', KEYS[1]); " +  // 計數(shù)為0，刪除鎖
                "return 1; " +  // 解鎖成功（刪除鎖）
            "end;",
            Collections.singletonList(getName()), getLockWatchdogTimeout(), getLockName(threadId));
}