redis 分布式锁 java 代码

当使用 Redis 实现分布式锁时，可以借助 Redis 的 SETNX（SET if Not eXists）命令来实现。下面是一个简单的 Java 代码示例：
import redis.clients.jedis.Jedis;

public class RedisDistributedLock {
private Jedis jedis;
private static final String LOCK_KEY = "my_lock";
private static final int LOCK_EXPIRE_TIME = 30000; // 锁的过期时间，单位毫秒

public RedisDistributedLock() {
jedis = new Jedis("localhost", 6379); // 连接 Redis 服务器
}

public boolean acquireLock(String requestId) {
long startTime = System.currentTimeMillis();
try {
while ((System.currentTimeMillis() - startTime) < LOCK_EXPIRE_TIME) {
String result = jedis.set(LOCK_KEY, requestId, "NX", "PX", LOCK_EXPIRE_TIME);
if ("OK".equals(result)) {
return true; // 获取锁成功
}
Thread.sleep(100); // 休眠一段时间后重试
}
} catch (Exception e) {
e.printStackTrace();
}
return false; // 获取锁失败
}

public void releaseLock(String requestId) {
try {
String lockValue = jedis.get(LOCK_KEY);
if (requestId.equals(lockValue)) {
jedis.del(LOCK_KEY);
}
} catch (Exception e) {
e.printStackTrace();
}
}

public static void main(String[] args) {
RedisDistributedLock lock = new RedisDistributedLock();
String requestId = "123456"; // 每个请求的唯一标识，可以使用 UUID 等方式生成
if (lock.acquireLock(requestId)) {
try {
// 执行业务逻辑
System.out.println("获取到锁，执行业务逻辑...");
Thread.sleep(5000); // 模拟业务处理时间
} catch (Exception e) {
e.printStackTrace();
} finally {
lock.releaseLock(requestId);
System.out.println("释放锁");
}
} else {
System.out.println("获取锁失败");
}
}
}
登录后复制
在上面的代码中，acquireLock 方法尝试获取分布式锁，如果获取成功则返回 true，否则返回 false。releaseLock 方法用于释放锁。
需要注意的是，在实际生产环境中，还需要考虑异常情况下的锁释放、锁的可重入性、锁的自动续期等问题。上述代码仅为简单示例，具体实现可能因项目需求而异。