springboot 基于redis实现分布式锁示例
时间: 2023-07-06 11:22:40 浏览: 62
下面是使用 Spring Boot 基于 Redis 实现分布式锁的示例代码:
首先在 pom.xml 中添加 Redis 相关依赖:
```xml
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
```
然后创建一个 Redis 分布式锁的工具类:
```java
@Component
public class RedisLockUtil {
@Autowired
private RedisTemplate<String, String> redisTemplate;
/**
* 尝试获取分布式锁
* @param key 锁的名称
* @param value 锁的值
* @param expireTime 锁的过期时间,单位为秒
* @return 是否成功获取锁
*/
public boolean tryLock(String key, String value, long expireTime) {
Boolean result = redisTemplate.opsForValue().setIfAbsent(key, value, Duration.ofSeconds(expireTime));
return result != null ? result : false;
}
/**
* 释放分布式锁
* @param key 锁的名称
* @param value 锁的值
*/
public void unlock(String key, String value) {
String currentValue = redisTemplate.opsForValue().get(key);
if (StringUtils.isNotBlank(currentValue) && StringUtils.equals(currentValue, value)) {
redisTemplate.delete(key);
}
}
}
```
在上述代码中,我们使用了 RedisTemplate 对 Redis 进行操作,其中 tryLock() 方法尝试获取分布式锁,如果获取成功则返回 true,否则返回 false。unlock() 方法释放分布式锁。
最后,在需要使用分布式锁的地方注入 RedisLockUtil 并使用它进行加锁和解锁,示例如下:
```java
@Service
public class UserService {
@Autowired
private RedisLockUtil redisLockUtil;
public void updateUser(User user) {
String lockKey = "updateUser:" + user.getId();
String lockValue = UUID.randomUUID().toString();
try {
boolean lockResult = redisLockUtil.tryLock(lockKey, lockValue, 60);
if (lockResult) {
// 获取分布式锁成功,执行更新操作
// ...
} else {
// 获取分布式锁失败,抛出异常或者重试
// ...
}
} finally {
// 释放分布式锁
redisLockUtil.unlock(lockKey, lockValue);
}
}
}
```
在上述代码中,我们调用 RedisLockUtil 的 tryLock() 方法尝试获取分布式锁,如果获取成功则执行更新操作,否则抛出异常或者重试。最后在 finally 块中调用 RedisLockUtil 的 unlock() 方法释放分布式锁。