root/longdianningxing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

rev：redisson自动续期问题

Browse Source
This commit is contained in:
liuxy
2024-01-27 16:25:26 +08:00
parent 5768cf1d30
commit 7b880b48bc
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
lms/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java
View File

@@ -201,7 +201,7 @@ public class AcsToWmsServiceImpl implements AcsToWmsService {
String type = whereJson.getString("type"); String type = whereJson.getString("type");
JSONObject result = new JSONObject(); JSONObject result = new JSONObject();
RLock lock = redissonClient.getLock("acs_to_wms:" + type); RLock lock = redissonClient.getLock("acs_to_wms:" + type);
boolean tryLock = lock.tryLock(5, TimeUnit.SECONDS); boolean tryLock = lock.tryLock(5,20, TimeUnit.SECONDS);
try { try {
if (tryLock) { if (tryLock) {
String device_code = whereJson.getString("device_code"); String device_code = whereJson.getString("device_code");
@@ -625,8 +625,10 @@ public class AcsToWmsServiceImpl implements AcsToWmsService {
return result; return result;
} }
} finally { } finally {
if (tryLock) { if (lock.isLocked() && lock.isHeldByCurrentThread()) {
try {
lock.unlock(); lock.unlock();
}catch (Exception ex){}
} }
} }
result.put("status", HttpStatus.BAD_REQUEST.value()); result.put("status", HttpStatus.BAD_REQUEST.value());