Redis分布式锁代码实现(Java)
public class RedisLock {
public static Boolean getLock(RedisTemplate redisTemplate, String key, String value, long timeout) {
Boolean lock = redisTemplate.opsForValue().setIfAbsent(key,value,timeout,TimeUnit.SECONDS); //获取锁
return lock;
}
public static void closeLock(RedisTemplate redisTemplate,String key, String value) {
while (true) {
redisTemplate.watch(key);//保证原子性
String revalue=String.valueOf(redisTemplate.opsForValue().get(key));
if (value.equalsIgnoreCase(revalue)) {//判断是否是当前锁
redisTemplate.setEnableTransactionSupport(true);
redisTemplate.multi();
redisTemplate.delete(key);
List
if (rlist == null) {
continue;
}
}
redisTemplate.unwatch();
break;
}
}
}
参考阅读
评论可见，请评论后查看内容，谢谢！！！
您阅读本篇文章共花了：
发表评论