Hutool 是一個 Java 工具包,提供了很多實用的功能,包括 Redis 操作。要使用 Hutool 進行分布式鎖,你可以按照以下步驟進行操作:
pom.xml
文件中添加以下依賴:<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-all</artifactId>
<version>5.7.18</version>
</dependency>
import cn.hutool.core.date.DateTime;
import cn.hutool.core.lang.Console;
import cn.hutool.core.map.MapUtil;
import cn.hutool.redis.Redis;
import cn.hutool.redis.RedisUtil;
import cn.hutool.redis.api.HashAPI;
import cn.hutool.redis.api.StringAPI;
import cn.hutool.redis.api.sync.StringSyncAPI;
public class RedisTool {
private static final String REDIS_HOST = "localhost";
private static final int REDIS_PORT = 6379;
private static final String REDIS_PASSWORD = "your_password"; // 如果沒有密碼,請刪除此行
private static final int REDIS_DB = 0;
public static void main(String[] args) {
RedisUtil redisUtil = RedisUtil.create(REDIS_HOST, REDIS_PORT, REDIS_PASSWORD, REDIS_DB);
String lockKey = "myLock";
String requestId = "myRequestId"; // 請求的唯一標識,可以使用 UUID 生成
boolean isLocked = tryLock(redisUtil, lockKey, requestId, 10000);
Console.log("Lock result: " + isLocked);
}
public static boolean tryLock(RedisUtil redisUtil, String lockKey, String requestId, int expireTime) {
// 嘗試獲取鎖
Boolean result = redisUtil.setIfAbsent(lockKey, requestId, expireTime);
if (result == null || !result) {
return false;
}
// 執行業務邏輯
try {
// ...
return true;
} finally {
// 釋放鎖
releaseLock(redisUtil, lockKey, requestId);
}
}
public static void releaseLock(RedisUtil redisUtil, String lockKey, String requestId) {
// 使用 Lua 腳本來釋放鎖,防止誤解鎖
String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";
redisUtil.eval(script, 1, lockKey, requestId);
}
}
在上述代碼中,我們首先創建了一個 RedisUtil
實例,用于連接 Redis 服務器。然后,我們定義了一個 tryLock
方法,用于嘗試獲取鎖。如果成功獲取鎖,我們將執行業務邏輯,然后調用 releaseLock
方法釋放鎖。
在 releaseLock
方法中,我們使用了 Lua 腳本來釋放鎖,這樣可以確保只有持有鎖的請求才能釋放鎖,防止誤解鎖。
現在,你可以使用 RedisTool
類進行分布式鎖的操作了。請注意,這里的示例僅用于演示目的,實際應用中可能需要根據具體需求進行調整。