Redisson可重入鎖解鎖邏輯詳細講解

Posted on by

本篇文章基於redisson-3.17.6版本源碼進行分析

相比較Redisson可重入鎖的加鎖邏輯，釋放鎖的邏輯就相對簡單一些。釋放鎖分為主動釋放和自動釋放兩種方式。

主動釋放

我們查看org.redisson.RedissonLock#unlock()方法：

public void unlock() {
        try {
            get(unlockAsync(Thread.currentThread().getId()));
        } catch (RedisException e) {
            if (e.getCause() instanceof IllegalMonitorStateException) {
                throw (IllegalMonitorStateException) e.getCause();
            } else {
                throw e;
            }
        }
//        Future<Void> future = unlockAsync();
//        future.awaitUninterruptibly();
//        if (future.isSuccess()) {
//            return;
//        }
//        if (future.cause() instanceof IllegalMonitorStateException) {
//            throw (IllegalMonitorStateException)future.cause();
//        }
//        throw commandExecutor.convertException(future);
    }

同樣采用異步的方式釋放鎖，unlockAsync()：

public RFuture<Void> unlockAsync(long threadId) {
    // 異步方式釋放鎖
    RFuture<Boolean> future = unlockInnerAsync(threadId);
    CompletionStage<Void> f = future.handle((opStatus, e) -> {
        // 取消看門狗定時任務
        cancelExpirationRenewal(threadId);
        if (e != null) {
            throw new CompletionException(e);
        }
        if (opStatus == null) {
            IllegalMonitorStateException cause = new IllegalMonitorStateException("attempt to unlock lock, not locked by current thread by node id: "
                    + id + " thread-id: " + threadId);
            throw new CompletionException(cause);
        }
        return null;
    });
    return new CompletableFutureWrapper<>(f);
}

可以看到，首先調用unlockInnerAsync()方法釋放鎖，在釋放鎖之後，執行cancelExpirationRenewal(threadId)取消看門狗自動續期的定時任務。

釋放鎖核心邏輯：

protected RFuture<Boolean> unlockInnerAsync(long threadId) {
    /**
     * Redisson解鎖：通過LUA腳本釋放鎖，保證多個命令之間的原子性
     */
    return evalWriteAsync(getRawName(), LongCodec.INSTANCE, RedisCommands.EVAL_BOOLEAN,
            "if (redis.call('hexists', KEYS[1], ARGV[3]) == 0) then " +
                    "return nil;" +
                    "end; " +
                    "local counter = redis.call('hincrby', KEYS[1], ARGV[3], -1); " +
                    "if (counter > 0) then " +
                    "redis.call('pexpire', KEYS[1], ARGV[2]); " +
                    "return 0; " +
                    "else " +
                    "redis.call('del', KEYS[1]); " +
                    "redis.call('publish', KEYS[2], ARGV[1]); " +
                    "return 1; " +
                    "end; " +
                    "return nil;",
            Arrays.asList(getRawName(), getChannelName()), LockPubSub.UNLOCK_MESSAGE, internalLockLeaseTime, getLockName(threadId));
}

Redisson可重入鎖的釋放還是通過LUA腳本實現，保證多個命令之間的原子性。

基本流程：

1、通過hexists指令判斷鎖是不是自己的，如果不是自己的鎖，說明非法釋放鎖，返回nil，

2、如果是自己的鎖，通過hincrby將鎖的重入次數減1；

3、判斷減1後的數是否大於0，如果減1後的數大於0，說明還沒有完全釋放鎖，則重置鎖的過期時間，並返回0；

4、如果減1後的數已經等於0，說明已經完全釋放鎖，則通過del指令釋放鎖，並通過publish發佈一條消息，告訴其它訂閱瞭這把鎖的線程，我已經釋放鎖瞭，你們可以過來獲取瞭；釋放鎖成功，返回1

5、其它情況，返回nil；

主動釋放鎖這塊考慮的不僅僅是對 key 進行處理，因為可能存在重入鎖，所以會先對 redis key 對應的 hash value 進行遞減，相當於減去重入次數。

自動釋放

當服務宕機時，看門狗不再看門，那麼最多 30s 之後鎖被自動釋放；當設置鎖的超時時間時，鎖到瞭過期時間，自動釋放；

到此這篇關於Redisson可重入鎖解鎖邏輯詳細講解的文章就介紹到這瞭,更多相關Redisson可重入鎖解鎖內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

推薦閱讀：