中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

redis中RedissonLock如何實現等待鎖

發布時間:2021-11-11 21:06:45 來源:億速云 閱讀:250 作者:柒染 欄目:開發技術

今天就跟大家聊聊有關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如何實現等待鎖有進一步的了解嗎?如果還想了解更多知識或者相關內容,請關注億速云行業資訊頻道,感謝大家的支持。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

湾仔区| 吴桥县| 桂阳县| 贵港市| 台南县| 明溪县| 平湖市| 新建县| 福海县| 蛟河市| 铜山县| 吕梁市| 钟祥市| 舒城县| 德兴市| 秭归县| 沂水县| 长春市| 宜州市| 城固县| 慈溪市| 马边| 永丰县| 古蔺县| 明星| 博湖县| 黎川县| 邵东县| 博客| 仁寿县| 顺平县| 东乌珠穆沁旗| 汾阳市| 长治县| 巨野县| 玉树县| 安吉县| 徐州市| 格尔木市| 郑州市| 米泉市|