国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 數(shù)據(jù)庫 > Redis > 正文

Redis實現(xiàn)分布式鎖的方法示例

2020-10-28 21:35:13
字體:
供稿:網(wǎng)友

之前我們使用的定時任務(wù)都是只部署在了單臺機器上,為了解決單點的問題,為了保證一個任務(wù),只被一臺機器執(zhí)行,就需要考慮鎖的問題,于是就花時間研究了這個問題。到底怎樣實現(xiàn)一個分布式鎖呢?

鎖的本質(zhì)就是互斥,保證任何時候能有一個客戶端持有同一個鎖,如果考慮使用redis來實現(xiàn)一個分布式鎖,最簡單的方案就是在實例里面創(chuàng)建一個鍵值,釋放鎖的時候,將鍵值刪除。但是一個可靠完善的分布式鎖需要考慮的細節(jié)比較多,我們就來看看如何寫一個正確的分布式鎖。

單機版分布式鎖 SETNX

所以我們直接基于 redis 的 setNX (SET if Not eXists)命令,實現(xiàn)一個簡單的鎖。直接上偽碼

鎖的獲取:

SET resource_name my_random_value NX PX 30000

鎖的釋放:

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

幾個細節(jié)需要注意:

首先在獲取鎖的時候我們需要設(shè)置設(shè)置超時時間。設(shè)置超時時間是為了,防止客戶端崩潰,或者網(wǎng)絡(luò)出現(xiàn)問題以后鎖一直被持有。真?zhèn)€系統(tǒng)就死鎖了。

使用 setNX 命令,保證查詢和寫入兩個步驟是原子的

在鎖釋放的時候我們判斷了KEYS[1]) == ARGV[1],在這里 KEYS[1]是從redis里面取出來的value,ARGV[1]是上文生成的my_random_value。之所以進行以上的判斷,是為了保證鎖被鎖的持有者釋放。我們假設(shè)不進行這一步校驗:

  1. 客戶端A獲取鎖,后發(fā)線程掛起了。時間大于鎖的過期時間。
  2. 鎖過期后,客戶端B獲取鎖。
  3. 客戶端A恢復(fù)以后,處理完相關(guān)事件,向redis發(fā)起 del命令。鎖被釋放
  4. 客戶端C獲取鎖。這個時候一個系統(tǒng)中同時兩個客戶端持有鎖。

造成這個問題的關(guān)鍵,在于客戶端B持有的鎖,被客戶端A釋放了。

鎖的釋放必須使用lua腳本,保證操作的原子性。鎖的釋放包含了get,判斷,del三個步驟。如果不能保證三個步驟的原子性,分布式鎖就會有并發(fā)問題。

注意了以上細節(jié),一個單redis節(jié)點的分布式鎖就達成了。

在這個分布式鎖中還是存在一個單點的redis。也許你會說,Redis是 master-slave的架構(gòu),發(fā)生故障的時候切換到slave就好,但是Redis的復(fù)制是異步的。

  1. 如果在客戶端A在master上拿到了鎖。
  2. 在master將數(shù)據(jù)同步到slave上之前,master宕機。
  3. 客戶端B就從slave上又一次拿到了鎖。

這樣由于Master的宕機,造成了同時多人持有鎖。如果你的系統(tǒng)可用接受短時時間內(nèi),有多人持有鎖。這個簡單的方案就能解決問題。

但是如果解決這個問題。Redis的官方提供了一個Redlock的解決方案。

RedLock 的實現(xiàn)

為了解決,Redis單點的問題。Redis的作者提出了RedLock的解決方案。方案非常的巧妙和簡潔。
RedLock的核心思想就是,同時使用多個Redis Master來冗余,且這些節(jié)點都是完全的獨立的,也不需要對這些節(jié)點之間的數(shù)據(jù)進行同步。

假設(shè)我們有N個Redis節(jié)點,N應(yīng)該是一個大于2的奇數(shù)。RedLock的實現(xiàn)步驟:

  1. 取得當前時間
  2. 使用上文提到的方法依次獲取N個節(jié)點的Redis鎖。
  3. 如果獲取到的鎖的數(shù)量大于 (N/2+1)個,且獲取的時間小于鎖的有效時間(lock validity time)就認為獲取到了一個有效的鎖。鎖自動釋放時間就是最初的鎖釋放時間減去之前獲取鎖所消耗的時間。
  4. 如果獲取鎖的數(shù)量小于 (N/2+1),或者在鎖的有效時間(lock validity time)內(nèi)沒有獲取到足夠的說,就認為獲取鎖失敗。這個時候需要向所有節(jié)點發(fā)送釋放鎖的消息。

對于釋放鎖的實現(xiàn)就很簡單了。想所有的Redis節(jié)點發(fā)起釋放的操作,無論之前是否獲取鎖成功。

同時需要注意幾個細節(jié):

重試獲取鎖的間隔時間應(yīng)當是一個隨機范圍而非一個固定時間。這樣可以防止,多客戶端同時一起向Redis集群發(fā)送獲取鎖的操作,避免同時競爭。同時獲取相同數(shù)量鎖的情況。(雖然概率很低)

如果某master節(jié)點故障之后,回復(fù)的時間間隔應(yīng)當大于鎖的有效時間。

  1. 假設(shè)有A,B,C三個Redis節(jié)點。
  2. 客戶端foo獲取到了A、B兩個鎖。
  3. 這個時候B宕機,所有內(nèi)存的數(shù)據(jù)丟失。
  4. B節(jié)點回復(fù)。
  5. 這個時候客戶端bar重新獲取鎖,獲取到B,C兩個節(jié)點。
  6. 此時又有兩個客戶端獲取到鎖了。

所以如果恢復(fù)的時間將大于鎖的有效時間,就可以避免以上情況發(fā)生。同時如果性能要求不高,甚至可以開啟Redis的持久化選項。

總結(jié)

了解了Redis分布式的實現(xiàn)以后,其實覺得大多數(shù)的分布式系統(tǒng)其實原理很簡單,但是為了保證分布式系統(tǒng)的可靠性需要注意很多的細節(jié),瑣碎異常。

RedLock算法實現(xiàn)的分布式鎖就是簡單高效,思路相當巧妙。

但是RedLock就一定安全么?我還會寫一篇文章來討論這個問題。敬請大家期待。

以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持武林網(wǎng)。

發(fā)表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發(fā)表
主站蜘蛛池模板: 岳阳市| 洮南市| 庄浪县| 绥化市| 涟水县| 涿鹿县| 石棉县| 九江市| 海安县| 南开区| 红桥区| 扎赉特旗| 揭阳市| 水富县| 泸西县| 天长市| 全椒县| 印江| 绿春县| 舒兰市| 区。| 许昌县| 三原县| 呼伦贝尔市| 新疆| 台中县| 十堰市| 宁夏| 新巴尔虎左旗| 潞西市| 新邵县| 五台县| 土默特左旗| 文安县| 西安市| 张家港市| 谷城县| 红原县| 元阳县| 东丽区| 沧州市|