gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

feat:(1.3.0-beta1): 修复启动失败问题

Browse Source
This commit is contained in:
opensnail 2024-12-25 21:51:45 +08:00
parent 03bc07fe95
commit dc8e6de80a
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/register/ClientRegister.java
View File

@ -22,6 +22,8 @@ import com.fasterxml.jackson.core.type.TypeReference;
import com.google.common.collect.Lists;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.scheduling.TaskScheduler;
import org.springframework.stereotype.Component;
@ -43,14 +45,13 @@ import java.util.stream.Collectors;
*/
@Component(ClientRegister.BEAN_NAME)
@Slf4j
@RequiredArgsConstructor
public class ClientRegister extends AbstractRegister {
ExecutorService executorService = Executors.newFixedThreadPool(5);
private final RefreshNodeSchedule refreshNodeSchedule;
public static final String BEAN_NAME = "clientRegister";
public static final int DELAY_TIME = 30;
protected static final LinkedBlockingDeque<ServerNode> QUEUE = new LinkedBlockingDeque<>(1000);
@Autowired
@Lazy
private RefreshNodeSchedule refreshNodeSchedule;
@Override
public boolean supports(int type) {
@ -124,9 +125,8 @@ public class ClientRegister extends AbstractRegister {
}
@Component
@Slf4j
@RequiredArgsConstructor
public class RefreshNodeSchedule extends AbstractSchedule {
private final ExecutorService executorService = Executors.newFixedThreadPool(5);
@Override
protected void doExecute() {
@ -161,7 +161,7 @@ public class ClientRegister extends AbstractRegister {
return;
}
SnailJobLog.LOCAL.info("start refresh client nodes：{}", waitRefreshDBClientNodes);
SnailJobLog.LOCAL.debug("start refresh client nodes：{}", waitRefreshDBClientNodes);
// 刷新DB
refreshExpireAt(waitRefreshDBClientNodes);