Public/cf_imes_server
6
0
Fork 0
mirror of http://192.168.1.205:9980/cf_devdept2/cf_imes_server.git synced 2026-08-14 05:42:06 +08:00
Code Issues Packages Projects Releases Wiki Activity

RedisLockUtil加锁解锁修复sonar.LocksNotUnlockedCheck

Browse Source
This commit is contained in:
gaoqr
2025-05-22 15:13:13 +08:00
parent ee9f308d2e
commit 59222bd1e7
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cf-framework/cf-spring-boot-starter-redis/src/main/java/com/cf/imes/framework/redis/util/RedisLockUtil.java
+6 -6
View File
@@ -35,8 +35,8 @@ public class RedisLockUtil {
public boolean acquireLock(String key) { public boolean acquireLock(String key) {
boolean getLock = false; boolean getLock = false;
try { try {
RLock lock = redissonClient.getLock(key); RLock rLock = redissonClient.getLock(key);
return lock.tryLock(chenfengCacheProperties.getLockWaitTime(), chenfengCacheProperties.getLockTimeout(), TimeUnit.MILLISECONDS); return rLock.tryLock(chenfengCacheProperties.getLockWaitTime(), chenfengCacheProperties.getLockTimeout(), TimeUnit.MILLISECONDS);
} catch (Exception e) { } catch (Exception e) {
log.error("[RedisLockUtil][lock]加锁失败", e); log.error("[RedisLockUtil][lock]加锁失败", e);
return getLock; return getLock;
@@ -54,10 +54,10 @@ public class RedisLockUtil {
public boolean acquireLock(String key, Integer waitTime, Integer timeout) { public boolean acquireLock(String key, Integer waitTime, Integer timeout) {
boolean getLock = false; boolean getLock = false;
try { try {
RLock lock = redissonClient.getLock(key); RLock rLock = redissonClient.getLock(key);
int wt = ObjectUtil.isNull(waitTime) ? chenfengCacheProperties.getLockWaitTime() : waitTime; int wt = ObjectUtil.isNull(waitTime) ? chenfengCacheProperties.getLockWaitTime() : waitTime;
int to = ObjectUtil.isNull(timeout) ? chenfengCacheProperties.getLockTimeout() : timeout; int to = ObjectUtil.isNull(timeout) ? chenfengCacheProperties.getLockTimeout() : timeout;
return lock.tryLock(wt, to, TimeUnit.MILLISECONDS); return rLock.tryLock(wt, to, TimeUnit.MILLISECONDS);
} catch (Exception e) { } catch (Exception e) {
log.error("[RedisLockUtil][lock]加锁失败", e); log.error("[RedisLockUtil][lock]加锁失败", e);
return getLock; return getLock;
@@ -72,8 +72,8 @@ public class RedisLockUtil {
*/ */
public void releaseLock(String key) { public void releaseLock(String key) {
try { try {
RLock lock = redissonClient.getLock(key); RLock rLock = redissonClient.getLock(key);
lock.unlock(); rLock.unlock();
} catch (Exception e) { } catch (Exception e) {
log.error("[RedisLockUtil][unlock]解锁失败", e); log.error("[RedisLockUtil][unlock]解锁失败", e);
} }