使用redis實現分布式鎖。
import lombok.extern.slf4j.slf4j;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.data.redis.core.stringredistemplate;
import org.springframework.stereotype.component;
import org.springframework.util.stringutils;
/** * redis的分布式鎖
*/@component
@slf4j
public class redislock
//2.處理死鎖-redis中有鎖,但是可能鎖的時間已經過期了
string currentvalue = redistemplate.opsforvalue().get(key);
//如果鎖過期了
if(!stringutils.isempty(currentvalue)
&&long.parselong(currentvalue)造成死鎖的原因:當乙個執行緒進來時,設定了key值,拿到了鎖,但是執行下面的業務邏輯時,卡住了。這時候其他的執行緒進來,只會返回false,拿不到鎖,無法執行業務邏輯。
解決:獲取當前鎖對應的時間,如果當前時間已經超過了超時的時間,那麼就說明死鎖了。這時候,使用getset方法,首先獲取上乙個鎖的值,並且將鎖的值更改。如果上乙個鎖是等於當前死鎖的值,那麼就讓當前執行緒獲得鎖,以此來解決死鎖問題。
使用:private static final int timeout = 10 * 1000; //超時時間 10s
@autowired
private redislock redislock;
public void lock()
//加鎖的**,保證以下的**單執行緒執行
//解鎖
redislock.unlock(productid,string.valueof(time));
}
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不存在。如給定的...