怎样写一个分布式锁,用Java
时间: 2023-03-12 17:44:34 浏览: 110
详解Java如何实现基于Redis的分布式锁
可以使用 Java 的 `java.util.concurrent.locks.Lock` 接口来实现分布式锁。
你可以使用任意一种实现了 `Lock` 接口的锁,比如 `ReentrantLock` 或者 `ReentrantReadWriteLock`。这些锁都可以用来保证多线程之间的同步访问。
如果你想要实现一个分布式锁,你需要使用一个分布式存储来保存锁的状态,比如 Redis 或者 Zookeeper。
下面是一个简单的分布式锁的例子,使用了 Redis 来保存锁的状态:
```java
import redis.clients.jedis.Jedis;
public class DistributedLock {
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 请求标识
* @param expireTime 超期时间
* @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 请求标识
* @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";
阅读全文