third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: server elect bug

Browse Source
This commit is contained in:
tjq 2023-01-22 00:37:09 +08:00
parent e26f2df2d0
commit 4a41e322ab
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/election/ServerElectionService.java
View File

@ -117,7 +117,7 @@ public class ServerElectionService {
} }
}catch (Exception e) { }catch (Exception e) {
log.error("[ServerElection] write new server to db failed for app {}.", appName, e); log.error("[ServerElection] write new server to db failed for app {}.", appName, e);
}finally { } finally {
lockService.unlock(lockName); lockService.unlock(lockName);
} }
} }
@ -150,10 +150,10 @@ public class ServerElectionService {
.get(PING_TIMEOUT_MS, TimeUnit.MILLISECONDS); .get(PING_TIMEOUT_MS, TimeUnit.MILLISECONDS);
if (response.isSuccess()) { if (response.isSuccess()) {
log.info("[ServerElection] server[{}] is active, it will be the master.", serverAddress); log.info("[ServerElection] server[{}] is active, it will be the master.", serverAddress);
downServerCache.remove(serverAddress);
// 检测通过的是远程 server 的暴露地址，需要返回 worker 需要的协议地址 // 检测通过的是远程 server 的暴露地址，需要返回 worker 需要的协议地址
final JSONObject protocolInfo = JsonUtils.parseObject(response.getData(), JSONObject.class).getJSONObject(protocol); final JSONObject protocolInfo = JsonUtils.parseObject(response.getData(), JSONObject.class).getJSONObject(protocol);
if (protocolInfo != null) { if (protocolInfo != null) {
downServerCache.remove(serverAddress);
return protocolInfo.toJavaObject(ProtocolInfo.class).getAddress(); return protocolInfo.toJavaObject(ProtocolInfo.class).getAddress();
} }
} }