您好,登錄后才能下訂單哦!
今天就跟大家聊聊有關redis中RedissonLock如何實現等待鎖,可能很多人都不太了解,為了讓大家更加了解,小編給大家總結了以下內容,希望大家根據這篇文章可以有所收獲。
經常會有到這樣的需求,就是在一個查詢接口,第一次查詢的時候,如果沒有查詢到就要執行初始化方法,初始化數據出來,之后的查詢就可以直接查詢庫里的數據了。這樣設計的目的是,如果需要初始化的數據特別大,無法再一次調用方法里處理完,或者說數據并不是每條都需要初始化,這種情況下,優先查詢的數據優先初始化。
這種方案隨之而來就會引發一個問題。查詢接口眾所周知是個自然冪等的,不需要我們額外去做冪等處理。但是在方案中,這個查詢就不單單是個查詢了。沒有查詢到就要執行初始化方法,本質上是個插入邏輯。這就需要我們自己去做冪等了。
單臺服務,我們可以用Java的鎖來實現冪等,每條數據的主鍵id來當鎖。但在現在基本上都是分布式服務,如同上篇文章說的,我們可以用分布式鎖RedissonLock來實現。
并發第一次請求時,競爭RedissonLock,誰獲得了鎖,誰就執行初始化方法,沒有競爭到鎖的請求,可以設置一個等待時間,等待鎖釋放。鎖釋放了,就可以先查詢數據有沒有初始化好,完成了就直接查庫。這里,就要提一下RedissonLock是如何實現等待的?
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; }
這樣,在釋放鎖的時候,同時發布消息出來。所有監聽該鎖的線程都將收到通知,那么,這些線程將再次去競爭加鎖,從而達到我們需要的冪等功能。我們在看看釋放鎖的邏輯,是不是發布消息了?
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如何實現等待鎖有進一步的了解嗎?如果還想了解更多知識或者相關內容,請關注億速云行業資訊頻道,感謝大家的支持。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。