redis 分布式鎖

2021-10-23 16:18:06 字數 1798 閱讀 7744

使用redis,如果某個執行緒沒有搶到鎖,就讓他睡眠一會兒。

誤刪:假設執行緒1獲得了lock,過期時間是10s,如果第10秒redis執行了過期,刪除了lock,而執行緒1下訂單還需要兩秒鐘執行,那麼第二個執行緒就會獲得鎖,第12s的時候,執行緒1刪除鎖lock,執行緒2失去鎖lock,另外的執行緒3獲取鎖。也就是說,過期時間不應該小於業務執行時間,因此需要在下面的**中引入守護程序

解鎖時,需要看設定時的value與此時redis的value是否相同,如果不判斷,有可能出現超賣,也就是說,上面的"第12s的時候,執行緒1刪除鎖lock,執行緒2失去鎖lock,另外的執行緒3獲取了鎖" ,執行緒3獲取了不應該得到的鎖,有可能超賣(想想賣票的例子),如果不設定守護程序,執行緒1也不應該刪去執行緒2的鎖,因此解鎖時需要額外判斷

下面是加鎖的過程,守護程序在其中實現:

@component

public

class

redislock

trycatch

(interruptedexception e)}}

//嘗試加鎖,被lock呼叫

public

boolean

trylock()

return

true;}

return

false;}

// 守護程序,保證在持有者執行任務的時候,redis中的值不會過期。

static

class

myrunble

implements

runnable

@override

public

void

run(

)try

catch

(interruptedexception e)}}

}

下面是解鎖的**:請放入redislock 中。

//解鎖,注意檢視resource.eval方法引數的意思。

public

void

unlock()

throws exception

resource.

close()

;}}

配置類()

@configuration

public

class

springconfig

}

測試:countdownlatch用來控制主線程的結束,如果不設定,程式會很快結束。

private

int count =6;

@autowired

@qualifier

("redislock"

)private redislock lock;

private countdownlatch countdownlatch =

newcountdownlatch(6

);@test

public

void

test()

throws interruptedexception

public

class

ticketsrunble

implements

runnable

}catch

(exception e)

finally

catch

(exception e)}}

}}

redis分布式鎖

redis分布式鎖 直接上 我寫了四個redis分布式鎖的方法,大家可以提個意見 第一種方法 redis分布式鎖 param timeout public void lock long timeout thread.sleep 100 catch exception e override publi...

Redis分布式鎖

分布式鎖一般有三種實現方式 1.資料庫樂觀鎖 2.基於redis的分布式鎖 3.基於zookeeper的分布式鎖.首先,為了確保分布式鎖可用,我們至少要確保鎖的實現同時滿足以下四個條件 互斥性。在任意時刻,只有乙個客戶端能持有鎖。不會發生死鎖。即使有乙個客戶端在持有鎖的期間崩潰而沒有主動解鎖,也能保...

redis分布式鎖

使用redis的setnx命令實現分布式鎖 redis為單程序單執行緒模式,採用佇列模式將併發訪問變成序列訪問,且多個客戶端對redis的連線並不存在競爭關係。redis的setnx命令可以方便的實現分布式鎖。setnx key value 將key的值設為value,當且僅當key不存在。如給定的...