|
@ -55,7 +55,6 @@ public class NoRepeatSubmitAop { |
|
|
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如果获取失败抛异常 所以不做锁状态的判断
|
|
|
//因为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()); |
|
|
//"未获取到锁,重复提交了
|
|
|
//"未获取到锁,重复提交了
|
|
@ -64,6 +63,13 @@ public class NoRepeatSubmitAop { |
|
|
distributedLock.unLock(lock); |
|
|
distributedLock.unLock(lock); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
try { |
|
|
|
|
|
//因为getLock如果获取失败抛异常 所以不做锁状态的判断
|
|
|
|
|
|
result = pjp.proceed(); |
|
|
|
|
|
} finally { |
|
|
|
|
|
distributedLock.unLock(lock); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
return result; |
|
|
return result; |
|
|
|
|
|
|
|
|
} |
|
|
} |
|
|