搜尋
首頁資料庫RedisRedis中為什麼需要分散式鎖?如何實現?

這篇文章跟大家介紹一下Redis中的分散式鎖,介紹一下為什麼需要分散式鎖,Redis是如何實現分散式鎖的,希望對大家有幫助!

Redis中為什麼需要分散式鎖?如何實現?

為什麼需要分散式鎖定

#為什麼需要分散式鎖定

使用分散式鎖的目的,無外乎就是保證同一時間只有一個客戶端可以對共享資源進行操作。

我們在分散式應用程式進行邏輯處理時經常會遇到並發問題。 【相關推薦:Redis影片教學

例如一個操作要修改使用者的狀態,修改狀態需要先讀出使用者的狀態,在記憶體裡進行修改,改完了再存回去。如果這樣的操作同時進行了,就會出現並發問題,因為讀取和保存狀態這兩個操作不是原子的。

這個時候就要使用到分散式鎖定來限製程式的並發執行。 redis作為快取中間件系統,就能提供這個分散式鎖定機制,

其本質就是在redis裡面佔一個坑,當別的進程也要來佔坑時,發現已經被佔領了,就只要等待稍後再嘗試

#一般來說,生產環境可用的分散式鎖定需要滿足以下幾點:

  • 互斥性,互斥是鎖的基本特徵,同一時刻只能有一個執行緒持有鎖,執行臨界操作;
  • 逾時釋放,超時釋放是鎖的另一個必備特性,可以比較MySQL InnoDB 引擎中的innodb_lock_wait_timeout配置,透過逾時釋放,防止不必要的執行緒等待和資源浪費;
  • 可重入性,在分散式環境下,在同一個節點上的同一個執行緒如果取得了鎖定之後,再次請求還是可以成功;

實作方式

##使用SETNX實作

SETNX的使用方式為:

SETNX key value,只在鍵key不存在的情況下,將鍵key的值設為value,若鍵key存在,則SETNX不做任何動作。

boolean result = jedis.setnx("lock-key",true)== 1L;
if  (result) {
    try {
        // do something
    } finally {
        jedis.del("lock-key");
    }
 }

這種方案有一個致命問題,就是某個線程在獲取鎖之後由於某些異常因素(比如宕機)而不能正常的執行解鎖操作,那麼這個鎖就永遠釋放不掉了。

為此,我們可以為這個鎖定加上一個逾時時間

執行

SET key value EX seconds 的效果等同於執行SETEX key seconds value

執行

SET key value PX milliseconds 的效果等於執行PSETEX key milliseconds value##<pre class='brush:php;toolbar:false;'>String result = jedis.set(&quot;lock-key&quot;,true, 5); if (&quot;OK&quot;.equals(result)) { try { // do something } finally { jedis.del(&quot;lock-key&quot;); } }</pre>

方案看起來很完美,但實際上還是會有問題

試想一下,某線程A獲取了鎖並且設定了過期時間為10s,然後在執行業務邏輯的時候耗費了15s,此時線程A獲取的鎖早已被Redis的過期機制自動釋放了

在線程A獲取鎖並經過10s之後,改鎖可能已經被其它線程獲取到了。當執行緒A執行完業務邏輯準備解鎖(

DEL key

)的時候,有可能刪除掉的是其它執行緒已經取得到的鎖定。 所以最好的方式是在解鎖時判斷鎖是否是自己的,我們可以在設定

key

#的時候將value設定為一個唯一值uniqueValue(可以是隨機值、UUID、或機器號線程號的組合、簽名等)。 當解鎖時,也就是刪除key的時候先判斷一下key對應的value是否等於先前設定的值,如果相等才能刪除key

String velue= String.valueOf(System.currentTimeMillis())
String result = jedis.set("lock-key",velue, 5);
if ("OK".equals(result)) {
    try {
        // do something
    } finally {
      	//非原子操作
	      if(jedis.get("lock-key")==value){
		        jedis.del("lock-key");
        }    
    }
}

這裡我們一眼就可以看出問題來:

GET

DEL是兩個分開的操作,在GET執行之後且在DEL執行之前的間隙是可能會發生異常的。 如果我們只要保證解鎖的程式碼是原子性的就能解決問題了

這裡我們引入了一種新的方式,就是

Lua腳本

,範例如下:

if redis.call("get",KEYS[1]) == ARGV[1] then
    return redis.call("del",KEYS[1])
else
    return 0
end
其中

ARGV[1]

表示設定key時指定的唯一值。 由於Lua腳本的原子性,在Redis執行該腳本的過程中,其他客戶端的命令都需要等待該Lua腳本執行完才能執行。

確保過期時間大於業務執行時間

為了防止多個執行緒同時執行業務程式碼,需要確保過期時間大於業務執行時間

#增加一個boolean類型的屬性

isOpenExpirationRenewal

,用來標識是否開啟定時刷新過期時間在增加一個

scheduleExpirationRenewal

#方法用於開啟刷新過期時間的執行緒 加鎖代碼在取得鎖定成功後將isOpenExpirationRenewal置為true,並且呼叫

scheduleExpirationRenewal

方法,開啟刷新過期時間的執行緒解鎖碼增加一行程式碼,將isOpenExpirationRenewal屬性置為false,停止刷新過期時間的線程輪詢

Redisson實現

獲取鎖定成功就會開啟一個定時任務,定時任務會定期檢查去續期

此定時調度每次呼叫的時間差是internalLockLeaseTime / 3,也就10秒

預設情況下,加鎖的時間是30秒.如果加鎖的業務沒有執行完,那麼到30-10 = 20秒的時候,就會進行一次續期,把鎖定重置成30秒

##RedLock

#在叢集中,主節點掛掉時,從節點會取而代之,客戶端上卻並沒有明顯感知。原先第一個客戶端在主節點中申請成功了一把鎖,但這把鎖還沒來得及同步到從節點,主節點突然掛掉了。然後從節點變成了主節點,這個新的節點內部沒有這個鎖,所以當另一個客戶端過來請求加鎖時,立即就批准了。這樣就會導致系統中同樣一把鎖被兩個客戶端同時持有,不安全性由此產生

Redlock演算法就是為了解決這個問題

使用Redlock,需要提供多個

Redis 實例,這些實例之前相互獨立沒有主從關係。同許多分散式演算法一樣,redlock 也使用大多數機制

加鎖時,它會向過半節點發送set指令,只要過半節點

set 成功,那就認為加鎖成功。釋放鎖定時,需要向所有節點發送 del 指令。不過Redlock 演算法還需要考慮出錯重試、時脈漂移等許多細節問題,同時因為Redlock 需要向多個節點進行讀寫,這意味著相較於單一實例Redis 效能會下降一些

Redlock 演算法是在單Redis 節點基礎上引入的高可用模式,Redlock 基於N 個完全獨立的Redis 節點,一般是大於3 的奇數個(通常情況下N 可以設定為5),可以基本保證叢集內各節點不會同時宕機。

假設目前叢集有5 個節點,執行Redlock 演算法的客戶端依序執行下面各個步驟,來完成取得鎖定的操作

    客戶端記錄當前系統時間,以毫秒為單位;
  • 依序嘗試從5 個Redis 實例中,使用相同的key 取得鎖,當向Redis 請求取得鎖定時,客戶端應該設定一個網路連線和回應逾時時間,超時時間應該小於鎖的失效時間,避免因為網路故障出現的問題;
  • 客戶端使用當前時間減去開始獲取鎖定時間就得到了獲取鎖使用的時間,當且僅當從半數以上的Redis 節點取得到鎖,並且當使用的時間小於鎖失效時間時,鎖才算獲取成功;
  • 如果獲取到了鎖,key 的真正有效時間等於有效時間減去獲取鎖所使用的時間,減少超時的幾率;
  • 如果獲取鎖定失敗,客戶端應該在​​所有的Redis 實例上進行解鎖,即使是上一步操作請求失敗的節點,防止因為服務端響應訊息丟失,但是實際數據添加成功導致的不一致。
也就是說,假設鎖定30秒過期,三個節點加鎖花了31秒,自然是加鎖失敗了

在Redis 官方推薦的Java 用戶端

Redisson 中,內建了對RedLock 的實作

#https://redis.io/topics/distlock

https:// github.com/redisson/redisson/wiki

RedLock問題:

RedLock 只是保證了鎖的高可用性,並沒有保證鎖的正確性

RedLock 是一個

嚴重依賴系統時脈的分散式系統

Martin 對RedLock 的批評:

    #對於提升效率的場景下, RedLock 太重。
  • 對於對正確性要求極高的場景下,RedLock 並不能保證正確性。
本文轉載自:https://juejin.cn/post/7018968452136173576

作者:心懷遠方

更多程式相關知識,請訪問:

編程視頻! !

以上是Redis中為什麼需要分散式鎖?如何實現?的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述
本文轉載於:掘金社区。如有侵權,請聯絡admin@php.cn刪除
REDIS:超越SQL- NOSQL的觀點REDIS:超越SQL- NOSQL的觀點May 08, 2025 am 12:25 AM

Redis超越SQL數據庫的原因在於其高性能和靈活性。 1)Redis通過內存存儲實現極快的讀寫速度。 2)它支持多種數據結構,如列表和集合,適用於復雜數據處理。 3)單線程模型簡化開發,但高並發時可能成瓶頸。

REDIS:與傳統數據庫服務器的比較REDIS:與傳統數據庫服務器的比較May 07, 2025 am 12:09 AM

Redis在高並發和低延遲場景下優於傳統數據庫,但不適合複雜查詢和事務處理。 1.Redis使用內存存儲,讀寫速度快,適合高並發和低延遲需求。 2.傳統數據庫基於磁盤,支持複雜查詢和事務處理,數據一致性和持久性強。 3.Redis適用於作為傳統數據庫的補充或替代,但需根據具體業務需求選擇。

REDIS:功能強大的內存數據存儲的簡介REDIS:功能強大的內存數據存儲的簡介May 06, 2025 am 12:08 AM

Redisisahigh-performancein-memorydatastructurestorethatexcelsinspeedandversatility.1)Itsupportsvariousdatastructureslikestrings,lists,andsets.2)Redisisanin-memorydatabasewithpersistenceoptions,ensuringfastperformanceanddatasafety.3)Itoffersatomicoper

Redis主要是數據庫嗎?Redis主要是數據庫嗎?May 05, 2025 am 12:07 AM

Redis主要是一個數據庫,但它不僅僅是數據庫。 1.作為數據庫,Redis支持持久化,適合高性能需求。 2.作為緩存,Redis提升應用響應速度。 3.作為消息代理,Redis支持發布-訂閱模式,適用於實時通信。

REDIS:數據庫,服務器還是其他?REDIS:數據庫,服務器還是其他?May 04, 2025 am 12:08 AM

redisisamultifaceTedToolThatServesAsAdatabase,server和more.itfunctionsasanin-memorydatastrustore,supportsvariousDataStructures,and CanbeusedAsacache,MessageBroker,sessionStorage,sessionStorage,sessionstorage,andford forderibedibedlocking。

REDIS:揭示其目的和關鍵應用程序REDIS:揭示其目的和關鍵應用程序May 03, 2025 am 12:11 AM

Redisisanopen-Source,內存內部的庫雷斯塔氏菌,卡赫和梅斯吉級,excellingInsPeedAndVersatory.itiswidelysusedforcaching,Real-Timeanalytics,Session Management,Session Managements,and sessighterboarderboarderboardobboardotoitsssupportfortfortfortfortfortfortfortfortorvortfortfortfortfortfortforvortfortforvortforvortforvortfortforvortforvortforvortforvortdatastherctuct anddatataCcessandcessanddataaCces

REDIS:鍵值數據存儲的指南REDIS:鍵值數據存儲的指南May 02, 2025 am 12:10 AM

Redis是一個開源的內存數據結構存儲,用作數據庫、緩存和消息代理,適合需要快速響應和高並發的場景。 1.Redis使用內存存儲數據,提供微秒級的讀寫速度。 2.它支持多種數據結構,如字符串、列表、集合等。 3.Redis通過RDB和AOF機制實現數據持久化。 4.使用單線程模型和多路復用技術高效處理請求。 5.性能優化策略包括LRU算法和集群模式。

REDIS:緩存,會話管理等REDIS:緩存,會話管理等May 01, 2025 am 12:03 AM

Redis的功能主要包括緩存、會話管理和其他功能:1)緩存功能通過內存存儲數據,提高讀取速度,適用於電商網站等高頻訪問場景;2)會話管理功能在分佈式系統中共享會話數據,並通過過期時間機制自動清理;3)其他功能如發布-訂閱模式、分佈式鎖和計數器,適用於實時消息推送和多線程系統等場景。

See all articles

熱AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Clothoff.io

Clothoff.io

AI脫衣器

Video Face Swap

Video Face Swap

使用我們完全免費的人工智慧換臉工具,輕鬆在任何影片中換臉!

熱門文章

熱工具

SecLists

SecLists

SecLists是最終安全測試人員的伙伴。它是一個包含各種類型清單的集合,這些清單在安全評估過程中經常使用,而且都在一個地方。 SecLists透過方便地提供安全測試人員可能需要的所有列表,幫助提高安全測試的效率和生產力。清單類型包括使用者名稱、密碼、URL、模糊測試有效載荷、敏感資料模式、Web shell等等。測試人員只需將此儲存庫拉到新的測試機上,他就可以存取所需的每種類型的清單。

SublimeText3 英文版

SublimeText3 英文版

推薦:為Win版本,支援程式碼提示!

Safe Exam Browser

Safe Exam Browser

Safe Exam Browser是一個安全的瀏覽器環境,安全地進行線上考試。該軟體將任何電腦變成一個安全的工作站。它控制對任何實用工具的訪問,並防止學生使用未經授權的資源。

Dreamweaver CS6

Dreamweaver CS6

視覺化網頁開發工具

Atom編輯器mac版下載

Atom編輯器mac版下載

最受歡迎的的開源編輯器