Redis分布式锁代码实现(Java)
【代码】Redis分布式锁代码实现(Java)
·
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<Object> rlist = redisTemplate.exec();
if (rlist == null) {
continue;
}
}
redisTemplate.unwatch();
break;
}
}
}
更多推荐
已为社区贡献7条内容
所有评论(0)