Commit cc3229e2 by 黄明步

.

parent 2c7463cd
......@@ -448,6 +448,7 @@ public class RetransmissionService {
}
// setOcrTask(ocrServerAddress.getIp());
// setActiveServer(ocrServerAddress.getIp());
log.info("使用服务器:【{}】进行识别", ocrServerAddress.getIp());
addServerRequestCount(ocrServerAddress.getIp(), 1);
String ocrApi = "http://" + ocrServerAddress.getIp() + ":" + ocrServerAddress.getOcrPort();
......@@ -739,9 +740,10 @@ public class RetransmissionService {
// 获取公平锁
distributedRedisLock.getFairLock(LOCK_NAME);
try {
log.info("获取到锁,开始自增");
Long incr = redisService.incr(SERVER_REQUEST_TASK + ip, delta);
if (incr < 0) {
redisService.set(SERVER_REQUEST_TASK + ip, 0L, 30, TimeUnit.SECONDS);
redisService.set(SERVER_REQUEST_TASK + ip, 0L, 3, TimeUnit.MINUTES);
}
} catch (Exception e) {
log.error("缓存服务器请求量任务失败", e);
......@@ -809,7 +811,7 @@ public class RetransmissionService {
if (ObjUtil.isNotNull(obj) && obj instanceof Number) {
return ((Number) obj).longValue() <= 0;
}
return false;
return true;
}).collect(Collectors.toList());
ServerInfo serverInfo;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment