使用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不存在。如給定的...