|
|
@@ -77,35 +77,35 @@ public class DistributeLockAspect {
|
|
|
boolean lockResult = false;
|
|
|
if (waitTime == DistributeLockConstant.DEFAULT_WAIT_TIME) {
|
|
|
if (expireTime == DistributeLockConstant.DEFAULT_EXPIRE_TIME) {
|
|
|
- LOG.info(String.format("lock for key : %s", lockKey));
|
|
|
+// LOG.info(String.format("lock for key : %s", lockKey));
|
|
|
rLock.lock();
|
|
|
} else {
|
|
|
- LOG.info(String.format("lock for key : %s , expire : %s", lockKey, expireTime));
|
|
|
+// LOG.info(String.format("lock for key : %s , expire : %s", lockKey, expireTime));
|
|
|
rLock.lock(expireTime, TimeUnit.MILLISECONDS);
|
|
|
}
|
|
|
lockResult = true;
|
|
|
} else {
|
|
|
if (expireTime == DistributeLockConstant.DEFAULT_EXPIRE_TIME) {
|
|
|
- LOG.info(String.format("try lock for key : %s , wait : %s", lockKey, waitTime));
|
|
|
+// LOG.info(String.format("try lock for key : %s , wait : %s", lockKey, waitTime));
|
|
|
lockResult = rLock.tryLock(waitTime, TimeUnit.MILLISECONDS);
|
|
|
} else {
|
|
|
- LOG.info(String.format("try lock for key : %s , expire : %s , wait : %s", lockKey, expireTime, waitTime));
|
|
|
+// LOG.info(String.format("try lock for key : %s , expire : %s , wait : %s", lockKey, expireTime, waitTime));
|
|
|
lockResult = rLock.tryLock(waitTime, expireTime, TimeUnit.MILLISECONDS);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
if (!lockResult) {
|
|
|
- LOG.warn(String.format("lock failed for key : %s , expire : %s", lockKey, expireTime));
|
|
|
+// LOG.warn(String.format("lock failed for key : %s , expire : %s", lockKey, expireTime));
|
|
|
throw new DistributeLockException(distributeLock.errorMsg());
|
|
|
}
|
|
|
|
|
|
|
|
|
- LOG.info(String.format("lock success for key : %s , expire : %s", lockKey, expireTime));
|
|
|
+// LOG.info(String.format("lock success for key : %s , expire : %s", lockKey, expireTime));
|
|
|
response = pjp.proceed();
|
|
|
} finally {
|
|
|
if (rLock.isHeldByCurrentThread()) {
|
|
|
rLock.unlock();
|
|
|
- LOG.info(String.format("unlock for key : %s , expire : %s", lockKey, expireTime));
|
|
|
+// LOG.info(String.format("unlock for key : %s , expire : %s", lockKey, expireTime));
|
|
|
}
|
|
|
}
|
|
|
return response;
|