1.setnx
鎖在redis中最簡(jiǎn)單的數(shù)據(jù)結(jié)構(gòu)就是string。最早的時(shí)候，上鎖的操作一般使用setnx，這個(gè)命令是當(dāng):lock不存在的時(shí)候set一個(gè)val，或許你還會(huì)記得使用expire來增加鎖的過期，解鎖操作就是使用del命令，偽代碼如下：
if (Redis::setnx("my:lock", 1)) {
　　Redis::expire("my:lock", 10);
　　// ... do something

　　Redis::del("my:lock")
}
這里其實(shí)是有問題的，問題就在于setnx和expire中間如果遇到crash等行為，可能這個(gè)lock就不會(huì)被釋放了。

2.set
現(xiàn)在官方建議直接使用set來實(shí)現(xiàn)鎖。我們可以使用set命令來替代setnx，就是下面這個(gè)樣子
if (Redis::set("my:lock", 1, "nx", "ex", 10)) {
　　... do something

　　Redis::del("my:lock")
}
上面的代碼把my:lock設(shè)置為1，當(dāng)且僅當(dāng)這個(gè)lock不存在的時(shí)候，設(shè)置完成之后設(shè)置過期時(shí)間為10。
獲取鎖的機(jī)制是對(duì)了，但是刪除鎖的機(jī)制直接使用del是不對(duì)的。因?yàn)橛锌赡軐?dǎo)致誤刪別人的鎖的情況。比如，這個(gè)鎖我上了10s，但是我處理的時(shí)間比10s更長(zhǎng)，到了10s，這個(gè)鎖自動(dòng)過期了，被別人取走了，并且對(duì)它重新上鎖了。那么這個(gè)時(shí)候，我再調(diào)用Redis::del就是刪除別人建立的鎖了。
官方對(duì)解鎖的命令也有建議，建議使用lua腳本，先進(jìn)行g(shù)et，再進(jìn)行del

主控：
$token = rand(1, 100000);

function lock() {
　　return Redis::set("my:lock", $token, "nx", "ex", 10);
}

function unlock() {
　　$script = `
　　if redis.call("get",KEYS[1]) == ARGV[1]
　　then
　　　　return redis.call("del",KEYS[1])
　　else
　　　　return 0
　　end?
　　`
　　return Redis::eval($script, "my:lock", $token)
}

if (lock()) {
　　// do something

　　unlock();
}

redis工具類：

public class RedisTool {private static final String LOCK_SUCCESS = "OK";private static final String SET_IF_NOT_EXIST = "NX";private static final String SET_WITH_EXPIRE_TIME = "PX";private static final Long RELEASE_SUCCESS = 1L;/*** 嘗試獲取分布式鎖* @param jedis Redis客戶端* @param lockKey 鎖* @param requestId 請(qǐng)求標(biāo)識(shí)* @param expireTime 超期時(shí)間* @return 是否獲取成功*/public static boolean tryGetDistributedLock(Jedis jedis, String lockKey, String requestId, int expireTime) {String result = jedis.set(lockKey, requestId, SET_IF_NOT_EXIST, SET_WITH_EXPIRE_TIME, expireTime);if (LOCK_SUCCESS.equals(result)) {return true;}return false;}/*** 釋放分布式鎖* @param jedis Redis客戶端* @param lockKey 鎖* @param requestId 請(qǐng)求標(biāo)識(shí)* @return 是否釋放成功*/public static boolean releaseDistributedLock(Jedis jedis, String lockKey, String requestId) {String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";Object result = jedis.eval(script, Collections.singletonList(lockKey), Collections.singletonList(requestId));if (RELEASE_SUCCESS.equals(result)) {return true;}return false;}}

?

其他：lua腳本的原子性：
Redis 使用單個(gè) Lua 解釋器去運(yùn)行所有腳本，并且， Redis 也保證腳本會(huì)以原子性(atomic)的方式執(zhí)行：當(dāng)某個(gè)腳本正在運(yùn)行的時(shí)候，不會(huì)有其他腳本或 Redis 命令被執(zhí)行。這和使用 MULTI / EXEC 包圍的事務(wù)很類似。在其他別的客戶端看來，腳本的效果(effect)要么是不可見的(not visible)，要么就是已完成的(already completed)。另一方面，這也意味著，執(zhí)行一個(gè)運(yùn)行緩慢的腳本并不是一個(gè)好主意。寫一個(gè)跑得很快很順溜的腳本并不難，因?yàn)槟_本的運(yùn)行開銷(overhead)非常少，但是當(dāng)你不得不使用一些跑得比較慢的腳本時(shí)，請(qǐng)小心，因?yàn)楫?dāng)這些蝸牛腳本在慢吞吞地運(yùn)行的時(shí)候，其他客戶端會(huì)因?yàn)榉?wù)器正忙而無法執(zhí)行命令。

轉(zhuǎn)載于:https://www.cnblogs.com/tinyj/p/10023615.html

總結(jié)

以上是生活随笔為你收集整理的使用Redis实现分布式锁的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。