java封装Redission分布式锁
时间: 2024-04-29 20:21:58 浏览: 96
Redisson 是一个基于 Redis 的 Java 驻内存数据网格(In-Memory Data Grid)。它提供了一些分布式锁的实现,包括可重入锁、公平锁、联锁等。下面是使用 Redisson 实现分布式锁的示例代码:
1. 引入 Redisson 依赖
```xml
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson</artifactId>
<version>3.12.5</version>
</dependency>
```
2. 创建 Redisson 客户端
```java
Config config = new Config();
config.useSingleServer().setAddress("redis://127.0.0.1:6379");
RedissonClient redisson = Redisson.create(config);
```
3. 获取锁
```java
RLock lock = redisson.getLock("mylock");
lock.lock();
try {
// 执行业务逻辑
} finally {
lock.unlock();
}
```
在获取锁时,如果锁已经被其他线程占用,则当前线程会阻塞等待锁的释放。可以通过 `lock.tryLock()` 方法尝试获取锁而不阻塞等待。
```java
RLock lock = redisson.getLock("mylock");
if (lock.tryLock()) {
try {
// 执行业务逻辑
} finally {
lock.unlock();
}
} else {
// 获取锁失败
}
```
4. 关闭 Redisson 客户端
```java
redisson.shutdown();
```
封装后的分布式锁示例:
```java
import org.redisson.Redisson;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
public class DistributedLock {
private static RedissonClient redisson;
static {
Config config = new Config();
config.useSingleServer().setAddress("redis://127.0.0.1:6379");
redisson = Redisson.create(config);
}
public static RLock getLock(String lockKey) {
return redisson.getLock(lockKey);
}
public static void shutdown() {
redisson.shutdown();
}
}
```
使用示例:
```java
RLock lock = DistributedLock.getLock("mylock");
lock.lock();
try {
// 执行业务逻辑
} finally {
lock.unlock();
}
DistributedLock.shutdown();
```
阅读全文