使用Redis實現(xiàn)分布式鎖的代碼演示
一、引言
在分布式系統(tǒng)中，多個節(jié)點可能會同時訪問共享資源，這就可能導(dǎo)致數(shù)據(jù)不一致的問題。為了解決這個問題，分布式鎖應(yīng)運(yùn)而生。Redis作為一個高性能的內(nèi)存數(shù)據(jù)庫，提供了多種機(jī)制來實現(xiàn)分布式鎖，本文將詳細(xì)介紹如何使用Redis實現(xiàn)分布式鎖。
二、分布式鎖的基本概念
分布式鎖是一種跨多個進(jìn)程或節(jié)點的鎖機(jī)制，用于協(xié)調(diào)對共享資源的訪問。它保證了在任意時刻，只有一個客戶端能夠持有鎖，從而避免了并發(fā)訪問導(dǎo)致的數(shù)據(jù)不一致問題。
三、Redis實現(xiàn)分布式鎖的原理
Redis提供了多種命令和機(jī)制來實現(xiàn)分布式鎖，以下是幾種常見的實現(xiàn)方式：
1. SETNX命令
SETNX（SET if Not eXists）命令用于在鍵不存在時設(shè)置鍵的值。如果鍵已經(jīng)存在，則操作失敗。這個命令可以用來實現(xiàn)簡單的分布式鎖。但是，SETNX命令本身并不具備設(shè)置過期時間的功能，因此需要結(jié)合EXPIRE命令一起使用。然而，這兩個命令并不是原子的，如果SETNX成功但EXPIRE失敗，就可能導(dǎo)致死鎖。
2. SET命令的擴(kuò)展參數(shù)
Redis的SET命令支持多個擴(kuò)展參數(shù)，如NX（Not eXists）、EX（Expire seconds）和PX（Expire milliseconds）。其中，NX和EX/PX組合使用可以實現(xiàn)原子性的加鎖操作。例如，SET lock_key unique_lock_value NX EX 10命令表示在lock_key不存在時設(shè)置其值為unique_lock_value，并設(shè)置過期時間為10秒。
3. Lua腳本保證原子性
為了確保加鎖和釋放鎖的原子性，可以使用Lua腳本將多個Redis命令打包成一個原子操作。例如，可以使用Lua腳本來實現(xiàn)加鎖和設(shè)置過期時間的原子操作。
四、Redis實現(xiàn)分布式鎖的步驟
1. 引入Redis依賴
在Spring Boot項目中，可以通過在pom.xml文件中添加Redis的依賴來引入Redis支持。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>2. 加鎖實現(xiàn)
加鎖操作可以使用SET命令的擴(kuò)展參數(shù)或Lua腳本來實現(xiàn)。以下是一個使用SET命令的擴(kuò)展參數(shù)實現(xiàn)加鎖的示例：
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.script.DefaultRedisScript;
import org.springframework.stereotype.Component;
import java.util.Collections;
import java.util.concurrent.TimeUnit;
@Component
public class RedisLockUtil {
@Autowired
private StringRedisTemplate redisTemplate;
private static final String LOCK_SUCCESS = "OK";
private static final Long RELEASE_SUCCESS = 1L;
/**
* 嘗試獲取分布式鎖
*
* @param lockKey 鎖鍵
* @param requestId 請求標(biāo)識
* @param expireTime 過期時間
* @param timeUnit 時間單位
* @return 是否獲取成功
*/
public boolean tryLock(String lockKey, String requestId, long expireTime, TimeUnit timeUnit) {
String result = redisTemplate.opsForValue().setIfAbsent(lockKey, requestId, expireTime, timeUnit);
return LOCK_SUCCESS.equals(result);
}
}3. 釋放鎖實現(xiàn)
釋放鎖操作需要確保只釋放自己持有的鎖，以防止誤刪其他客戶端的鎖。這可以通過先獲取鎖的值，然后判斷該值是否與自己的請求標(biāo)識一致來實現(xiàn)。為了確保操作的原子性，可以使用Lua腳本來實現(xiàn)。
import org.springframework.data.redis.core.script.DefaultRedisScript;
/**
* 釋放分布式鎖
*
* @param lockKey 鎖鍵
* @param requestId 請求標(biāo)識
* @return 是否釋放成功
*/
public boolean unlock(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";
DefaultRedisScript<Long> redisScript = new DefaultRedisScript<>();
redisScript.setScriptText(script);
redisScript.setResultType(Long.class);
return redisTemplate.execute(redisScript, Collections.singletonList(lockKey), requestId) == RELEASE_SUCCESS;
}4. 設(shè)置鎖過期時間
在加鎖時，需要設(shè)置鎖的過期時間，以防止死鎖的發(fā)生。過期時間應(yīng)根據(jù)具體業(yè)務(wù)需求來設(shè)置，不宜過長或過短。
五、代碼演示
1. 引入依賴
確保在pom.xml文件中引入了Redis的依賴。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>2. 加鎖與釋放鎖的工具類
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.script.DefaultRedisScript;
import org.springframework.stereotype.Component;
import java.util.Collections;
import java.util.concurrent.TimeUnit;
@Component
public class RedisLockUtil {
@Autowired
private StringRedisTemplate redisTemplate;
private static final String LOCK_SUCCESS = "OK";
private static final Long RELEASE_SUCCESS = 1L;
/**
* 嘗試獲取分布式鎖
*
* @param lockKey 鎖鍵
* @param requestId 請求標(biāo)識
* @param expireTime 過期時間
* @param timeUnit 時間單位
* @return 是否獲取成功
*/
public boolean tryLock(String lockKey, String requestId, long expireTime, TimeUnit timeUnit) {
String result = redisTemplate.opsForValue().setIfAbsent(lockKey, requestId, expireTime, timeUnit);
return LOCK_SUCCESS.equals(result);
}
/**
* 釋放分布式鎖
*
* @param lockKey 鎖鍵
* @param requestId 請求標(biāo)識
* @return 是否釋放成功
*/
public boolean unlock(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";
DefaultRedisScript<Long> redisScript = new DefaultRedisScript<>();
redisScript.setScriptText(script);
redisScript.setResultType(Long.class);
return redisTemplate.execute(redisScript, Collections.singletonList(lockKey), requestId) == RELEASE_SUCCESS;
}
}3. 使用示例
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class LockController {
@Autowired
private RedisLockUtil redisLockUtil;
@GetMapping("/lock")
public String lock(@RequestParam String lockKey, @RequestParam long expireTime) {
String requestId = String.valueOf(System.currentTimeMillis());
if (redisLockUtil.tryLock(lockKey, requestId, expireTime, TimeUnit.MILLISECONDS)) {
try {
// 執(zhí)行業(yè)務(wù)邏輯
return "加鎖成功，執(zhí)行業(yè)務(wù)邏輯";
} finally {
redisLockUtil.unlock(lockKey, requestId);
}
} else {
return "加鎖失敗，請重試";
}
}
}六、注意事項與優(yōu)化
1. 死鎖問題
如果客戶端在持有鎖期間崩潰而沒有釋放鎖，就可能導(dǎo)致死鎖。為了避免這種情況，可以設(shè)置鎖的過期時間，當(dāng)鎖過期時自動釋放。
2. 鎖競爭與重試機(jī)制
在高并發(fā)環(huán)境下，多個客戶端可能會同時嘗試獲取同一個鎖，這就可能導(dǎo)致鎖競爭。為了
到此這篇關(guān)于使用Redis實現(xiàn)分布式鎖的技術(shù)詳解的文章就介紹到這了,更多相關(guān)Redis分布式鎖內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
Redis過期刪除機(jī)制與內(nèi)存淘汰策略的解析指南
在使用 Redis 構(gòu)建緩存系統(tǒng)時,很多開發(fā)者只設(shè)置了 EXPIRE 但卻忽略了背后 Redis 的過期刪除機(jī)制與內(nèi)存淘汰策略,下面小編就來和大家詳細(xì)介紹一下2025-06-06
這篇文章主要為大家詳細(xì)介紹了基于redis實現(xiàn)token驗證用戶是否登陸，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價值，感興趣的小伙伴們可以參考一下2019-08-08
使用redis-plus-plus庫連接redis的實現(xiàn)方法
本文主要介紹了使用redis-plus-plus庫連接redis的實現(xiàn)方法,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2025-02-02
這篇文章主要介紹了Redis模仿手機(jī)驗證碼發(fā)送功能，通過示例代碼給大家講解通過用戶輸入手機(jī)號以及驗證碼進(jìn)行校驗，代碼簡單易懂，需要的朋友可以參考下2021-09-09
通過 Redis 實現(xiàn) RPC 遠(yuǎn)程方法調(diào)用(支持多種編程語言)
這篇文章主要介紹了通過 Redis 實現(xiàn) RPC 遠(yuǎn)程方法調(diào)用,支持多種編程語言,本文就以Ruby和Python為例,給出了實現(xiàn)代碼,需要的朋友可以參考下2014-09-09
本篇文章主要介紹了Redis實現(xiàn)分布式鎖的方法示例，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-10-10
這篇文章主要給大家介紹了關(guān)于redis的bigkey掃描腳本的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2018-07-07
這篇文章主要給大家介紹了關(guān)于如何利用Redis如何實現(xiàn)自動補(bǔ)全功能的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對大家學(xué)習(xí)或者使用Redis具有一定的參考學(xué)習(xí)價值，需要的朋友們下面來一起學(xué)習(xí)學(xué)習(xí)吧2019-09-09
Govern Service 基于 Redis 的服務(wù)治理平臺安裝過程詳解
Govern Service 是一個輕量級、低成本的服務(wù)注冊、服務(wù)發(fā)現(xiàn)、 配置服務(wù) SDK，通過使用現(xiàn)有基礎(chǔ)設(shè)施中的 Redis 不用給運(yùn)維部署帶來額外的成本與負(fù)擔(dān)，接下來通過本文給大家分享Govern Service 基于 Redis 的服務(wù)治理平臺的相關(guān)知識，感興趣的朋友一起看看吧2021-05-05
這篇文章主要給大家介紹了關(guān)于redis中如何使用lua腳本讓你的靈活性提高5個逼格的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2018-10-10