一、使用 RedisTemplate 操作分布式锁
原子加锁(uuid Value+过期时间)+原子解锁(lua脚本)+加长过期时间
- UUID :让锁区分,防止错删其他锁
- 设置锁过期时间:当业务异常导致无法释放锁形成锁死,设置过期时间自动释放锁
- Lua脚本:能够保证删除操作的原子性
- 加长过期时间:过期时间必须大于业务执行时间
1.加锁 (set key)
try{
2.业务:向redis缓存存入数据
(1)查redis缓存数据,缓存有直接返回,(2)缓存没查到直接查数据库,(3)在锁释放之前 放入redis缓存
}
catch{
处理异常
}
finally{
3.释放锁 (delete key)
}
public Map<String, List<CategoryLevel2Vo>> getCatelogJsonFromDataWithRedisLock() {
//set NX key不存在才能set
//设置set lock hah EX 300 NX,设置过期时间EX,防止死锁,加锁跟设置过期时间必须是原子性操作
String uuid = UUID.randomUUID().toString();
Boolean lock = stringRedisTemplate.opsForValue().setIfAbsent("lock", uuid,300,TimeUnit.SECONDS);
//lock为true set成功
if (lock){
System.out.println("获取分布式锁成功");
//加锁成功
Map<String, List<CategoryLevel2Vo>> dataFromDb;
try {
dataFromDb = getDataFromDb();
} finally {
//释放锁(删除lock)
//使用lua删除锁脚本,或者值+比较值+删除锁(脚本可以保证原子性)
String redisScript = "if redis.call(\"get\",KEYS[1]) == ARGV[1] then return redis.call(\"del\",KEYS[1]) else return 0 end";
Long execute = stringRedisTemplate.execute(new DefaultRedisScript<Long>(redisScript, Long.class), Arrays.asList("lock"), uuid);
}
return dataFromDb;
}else {
//加锁失败
System.out.println("获取分布式锁失败,等待重试");
//休眠
try {
Thread.sleep(200);
} catch (InterruptedException e) {
e.printStackTrace();
}
//自旋
return getCatelogJsonFromDataWithRedisLock();
}
二、Lock锁
Lock锁与RedisTemplate 操作分布式锁区别,为什么Lock锁不用循环判断是否拿到锁?
- 自动续期,lock.lock()加锁时,看门狗LockWatchdogTimeout定时更新过期时间
- 防止死锁,当业务异常导致无法释放锁,看门狗默认30s释放锁
1.加锁 lock.lock() 或 lock.lock(10, TimeUnit.SECONDS);
try{
2.业务...
}catch{
处理异常
}finally{
3.释放锁 lock.unlock();
}
1.lock.lock(); 有续期
如果业务未完成,则锁自动续期,看门狗LockWatchdogTimeout默认时间30s,续期按
如果业务完成,则不会续期,如果不手动释放锁,默认30s后释放
如果占锁,则开启定时任务,重新设置过期时间(LockWatchdogTimeout),定时任务:使用掉三分之一的LockWatchdogTimeout就恢复成 30s
2.lock.lock(10, TimeUnit.SECONDS); 无续期,推荐使用
注意:设置锁时间必须大于业务执行时间,否则业务结束之前释放锁会被其他线程占锁,当业务结束释放时,删除了其他线程的锁
没有看门狗LockWatchdogTimeout
锁时间结束不会自动续期,设置锁时间大于业务执行时间
占锁成功,如果出现事故导致无法释放锁,在不抛出异常的情况下,会默认30s后释放锁,所以不会存在死锁的问题
@ResponseBody
@GetMapping("/testRedisson")
public String testRedisson(){
RLock lock = redissonClient.getLock("my-lock");
//加锁
lock.lock();
try {
System.out.println("加锁成功:" + Thread.currentThread().getId());
Thread.sleep(30000);
} catch (InterruptedException e) {
} finally {
//释放锁
System.out.println("锁释放:" + Thread.currentThread().getId());
lock.unlock();
}
return "hello redisson";
}