一、分布式锁
java里面的锁机制针对的是同一个jvm进程进行共享资源的共享加锁,但在分布式系统中,一般一个服务都会部署多个节点,这种情况下就需要有单独的中间件来承担多节点间加锁的责任。
二、使用案例
// 1. 获取锁对象
RLock lock = redisson.getLock("orderPay:" + orderSN);
try {
// 2. 尝试加锁,没有就直接返回
boolean b = lock.tryLock();
if (!b) {
return ResponseEntity.status(500).body("正在执行,请勿频繁操作");
}
return ResponseEntity.ok("hello");
} catch (Exception e) {
return ResponseEntity.status(500).body("分布式锁获取失败");
} finally {
/**
* 主线程执行完毕后必须手动释放,因为不释放会一直被续期
*/
if (lock.isHeldByCurrentThread()) {
// 3. 解锁
lock.unlock();
}
}
三、redisson分布式锁的几个注意点
- 自动续期;
redisson分布式锁的自动续期是基于“watchdog的看门狗模式”,对于加锁时没有指定leaseTime(或者leaseTime设置为-1)的锁,redisson会设置一个默认过期时间30s,加锁成功后,会基于netty的时间轮创建一个时间轮任务进行锁的续期。这个时间轮按1/3 * 30 每10秒一次进行续期。 - 手动解锁。
必须在业务主线程中finally方法进行显示的调用解锁方法unlock(),如果不调用的话,续期线程会一直进行续期,不会自动停止。
四、加锁续期原理图
- 这里watchlog任务线程并非是”守护线程“,不会因为业务线程的执行完毕而自动停止,所以必须在业务代码中显示的执行解锁操作lock.unlock(),一般放在finally方法中。