Browse Source

释放锁

feature/teamB_zz_wgh
jianjun 3 years ago
parent
commit
3beb04c45f
  1. 9
      epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/aop/NoRepeatSubmitAop.java

9
epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/aop/NoRepeatSubmitAop.java

@ -49,6 +49,8 @@ public class NoRepeatSubmitAop {
long leaseTime = noRepeatSubmit.leaseTime(); long leaseTime = noRepeatSubmit.leaseTime();
//如果获取不到锁等待0秒直接返回 持锁时间为leaseTime //如果获取不到锁等待0秒直接返回 持锁时间为leaseTime
lock = distributedLock.getLock(RedisKeys.getNoRepeatSubmitKey(key), leaseTime, NumConstant.ZERO_L, TimeUnit.MILLISECONDS); lock = distributedLock.getLock(RedisKeys.getNoRepeatSubmitKey(key), leaseTime, NumConstant.ZERO_L, TimeUnit.MILLISECONDS);
//因为getLock如果获取失败抛异常 所以不做锁状态的判断
result = pjp.proceed();
} catch (Exception e) { } catch (Exception e) {
log.warn("noRepeatSubmit key:{},msg:{}", key, e.getMessage()); log.warn("noRepeatSubmit key:{},msg:{}", key, e.getMessage());
//"未获取到锁,重复提交了 //"未获取到锁,重复提交了
@ -56,13 +58,6 @@ public class NoRepeatSubmitAop {
} finally { } finally {
distributedLock.unLock(lock); distributedLock.unLock(lock);
} }
try {
//因为getLock如果获取失败抛异常 所以不做锁状态的判断
result = pjp.proceed();
} finally {
distributedLock.unLock(lock);
}
return result; return result;

Loading…
Cancel
Save