redis中RedissonLock如何實現等待鎖

今天就跟大家聊聊有關redis中RedissonLock如何實現等待鎖，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結了以下內容，希望大家根據這篇文章可以有所收獲。

前言

經常會有到這樣的需求，就是在一個查詢接口，第一次查詢的時候，如果沒有查詢到就要執行初始化方法，初始化數據出來，之后的查詢就可以直接查詢庫里的數據了。這樣設計的目的是，如果需要初始化的數據特別大，無法再一次調用方法里處理完，或者說數據并不是每條都需要初始化，這種情況下，優先查詢的數據優先初始化。

問題

這種方案隨之而來就會引發一個問題。查詢接口眾所周知是個自然冪等的，不需要我們額外去做冪等處理。但是在方案中，這個查詢就不單單是個查詢了。沒有查詢到就要執行初始化方法，本質上是個插入邏輯。這就需要我們自己去做冪等了。

方案

單臺服務，我們可以用Java的鎖來實現冪等，每條數據的主鍵id來當鎖。但在現在基本上都是分布式服務，如同上篇文章說的，我們可以用分布式鎖RedissonLock來實現。
并發第一次請求時，競爭RedissonLock，誰獲得了鎖，誰就執行初始化方法，沒有競爭到鎖的請求，可以設置一個等待時間，等待鎖釋放。鎖釋放了，就可以先查詢數據有沒有初始化好，完成了就直接查庫。這里，就要提一下RedissonLock是如何實現等待的？

tryLock

RedissonLock在加鎖方法提供了一個api，提供了一個參數waitTime即等待時間。

public boolean tryLock(long waitTime, long leaseTime, TimeUnit unit)

在waitTime時間內會訂閱消息，這里用的是redis本身的發布訂閱功能。

RFuture<RedissonLockEntry> subscribeFuture = subscribe(threadId);
if (!subscribeFuture.await(time, TimeUnit.MILLISECONDS)) {
    if (!subscribeFuture.cancel(false)) {
        subscribeFuture.onComplete((res, e) -> {
            if (e == null) {
                unsubscribe(subscribeFuture, threadId);
            }
        });
    }
    acquireFailed(threadId);
    return false;
}

這樣，在釋放鎖的時候，同時發布消息出來。所有監聽該鎖的線程都將收到通知，那么，這些線程將再次去競爭加鎖，從而達到我們需要的冪等功能。我們在看看釋放鎖的邏輯，是不是發布消息了？

unlockInnerAsync

protected RFuture<Boolean> unlockInnerAsync(long threadId) {
    return commandExecutor.evalWriteAsync(getName(), 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.<Object>asList(getName(), getChannelName()), LockPubSub.UNLOCK_MESSAGE, internalLockLeaseTime, getLockName(threadId));

}

可以看出在unlockInnerAsync方法里，執行了lua腳本，在腳本里，我們很容易能看到執行了publish命令。

Redisson巧妙的用了redis的發布訂閱功能，實現了分布式鎖的等待功能。

看完上述內容，你們對redis中RedissonLock如何實現等待鎖有進一步的了解嗎？如果還想了解更多知識或者相關內容，請關注億速云行業資訊頻道，感謝大家的支持。