springboot+redis的分布式锁(原子性)使用到setIfAbsent()
在Spring Boot中使用Redis进行分布式锁通常涉及到RedisTemplate
或StringRedisTemplate
,并且可以使用setIfAbsent
方法来实现。setIfAbsent
方法会尝试在Redis中设置一个键值对,如果键不存在则设置成功,返回true
;如果键已经存在,则不做任何操作,返回false
。
以下是一个使用setIfAbsent
方法实现分布式锁的示例:
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.stereotype.Component;
@Component
public class RedisDistributedLock {
@Autowired
private StringRedisTemplate redisTemplate;
public boolean lock(String key, String value, long timeout, TimeUnit unit) {
// 尝试获取锁
boolean isLockAcquired = redisTemplate.opsForValue().setIfAbsent(key, value, timeout, unit);
// 如果获取到锁,返回true,否则返回false
return isLockAcquired;
}
public void unlock(String key, String value) {
// 获取Redis中该键对应的值
ValueOperations<String, String> ops = redisTemplate.opsForValue();
String currentValue = ops.get(key);
// 确保解锁是安全的,只有在锁是由该客户端持有时才执行解锁操作
if (currentValue != null && currentValue.equals(value)) {
redisTemplate.delete(key);
}
}
}
在这个例子中,lock
方法尝试获取分布式锁,如果成功,返回true
,并设置锁的超时时间;如果未成功,返回false
。unlock
方法则用于释放锁,它会检查是否是锁的拥有者再执行解锁操作。
请注意,这只是一个简单的分布式锁实现,它没有考虑可重入性、死锁检测、锁降级等高级特性。在生产环境中,分布式锁通常需要更复杂的实现,例如使用RedLock算法等。
评论已关闭