diff --git a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/base/db/DBInitialize.java b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/base/db/DBInitialize.java index 0765fe96..a387e1ce 100644 --- a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/base/db/DBInitialize.java +++ b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/base/db/DBInitialize.java @@ -58,10 +58,10 @@ public class DBInitialize implements EventListener { @Init public void init() throws Throwable { -// // aot 阶段,不初始化数据库 -// if (NativeDetector.isAotRuntime()) { -// return; -// } + // aot 阶段,不初始化数据库 + if (NativeDetector.isAotRuntime()) { + return; + } Assert.notNull(dbConfig.getType(), "neutrino.data.db.type不能为空!"); dbTypeEnum = DbTypeEnum.of(dbConfig.getType()); Assert.notNull(dbTypeEnum, "neutrino.data.db.type取值异常!"); diff --git a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/service/JobInfoService.java b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/service/JobInfoService.java index 35379fbb..9ae7c1ee 100644 --- a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/service/JobInfoService.java +++ b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/service/JobInfoService.java @@ -35,11 +35,9 @@ import org.noear.solon.Solon; import org.noear.solon.annotation.Component; import org.noear.solon.annotation.Init; import org.noear.solon.annotation.Inject; +import org.noear.solon.core.runtime.NativeDetector; -import java.util.Date; -import java.util.HashMap; -import java.util.List; -import java.util.Map; +import java.util.*; import java.util.stream.Collectors; /** @@ -67,6 +65,10 @@ public class JobInfoService implements IJobSource { @Init public void init() { + // aot 阶段,不初始化 + if (NativeDetector.isAotRuntime()) { + return; + } jobHandlerMap.put("DataCleanJob", dataCleanJob); jobHandlerMap.put("DemoJob", demoJob); jobHandlerMap.put("FlowReportForDayJob", flowReportForDayJob); @@ -107,6 +109,10 @@ public class JobInfoService implements IJobSource { @Override public List sourceList() { + // aot 阶段,不查数据库 + if (NativeDetector.isAotRuntime()) { + return Collections.emptyList(); + } List jobInfoList = Lists.newArrayList(); List jobInfoDOList = jobInfoMapper.findList(); if (CollectionUtil.isEmpty(jobInfoDOList)) { diff --git a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/service/JobLogService.java b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/service/JobLogService.java index 766419ac..b7e6789e 100644 --- a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/service/JobLogService.java +++ b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/service/JobLogService.java @@ -35,7 +35,9 @@ import org.dromara.neutrinoproxy.server.dal.entity.JobLogDO; import org.dromara.solonplugins.job.IJobCallback; import org.dromara.solonplugins.job.JobInfo; import org.noear.solon.annotation.Component; +import org.noear.solon.core.runtime.NativeDetector; +import java.util.Collections; import java.util.Date; import java.util.List; import java.util.stream.Collectors; @@ -53,6 +55,10 @@ public class JobLogService implements IJobCallback { @Override public void executeLog(JobInfo jobInfo, String param, Throwable throwable) { + // aot 阶段,不查数据库 + if (NativeDetector.isAotRuntime()) { + return; + } Integer code = 0; String msg = ""; if (null == throwable) { diff --git a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/service/LicenseService.java b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/service/LicenseService.java index f1830055..2c0a3dac 100644 --- a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/service/LicenseService.java +++ b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/service/LicenseService.java @@ -34,6 +34,7 @@ import org.noear.solon.annotation.Component; import org.noear.solon.annotation.Init; import org.noear.solon.annotation.Inject; import org.noear.solon.core.bean.LifecycleBean; +import org.noear.solon.core.runtime.NativeDetector; import java.util.Arrays; import java.util.Date; @@ -238,6 +239,10 @@ public class LicenseService implements LifecycleBean { */ @Init public void init() { + // aot 阶段,不初始化 + if (NativeDetector.isAotRuntime()) { + return; + } licenseMapper.updateOnlineStatus(OnlineStatusEnum.OFFLINE.getStatus(), new Date()); } diff --git a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/service/PortMappingService.java b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/service/PortMappingService.java index 1683f708..1c1c2de0 100644 --- a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/service/PortMappingService.java +++ b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/service/PortMappingService.java @@ -40,6 +40,7 @@ import org.noear.solon.annotation.Component; import org.noear.solon.annotation.Init; import org.noear.solon.annotation.Inject; import org.noear.solon.core.bean.LifecycleBean; +import org.noear.solon.core.runtime.NativeDetector; import java.util.Comparator; import java.util.Date; @@ -295,6 +296,10 @@ public class PortMappingService implements LifecycleBean { */ @Init public void init() { + // aot 阶段,不初始化 + if (NativeDetector.isAotRuntime()) { + return; + } portMappingMapper.updateOnlineStatus(OnlineStatusEnum.OFFLINE.getStatus(), new Date()); // 未配置域名,则不需要处理域名映射逻辑