diff --git a/nflg-wms-scheduled/src/main/java/com/nflg/wms/scheduled/config/PowerJobWorkerConfiguration.java b/nflg-wms-scheduled/src/main/java/com/nflg/wms/scheduled/config/PowerJobWorkerConfiguration.java
index 5c8aaea7..a4004434 100644
--- a/nflg-wms-scheduled/src/main/java/com/nflg/wms/scheduled/config/PowerJobWorkerConfiguration.java
+++ b/nflg-wms-scheduled/src/main/java/com/nflg/wms/scheduled/config/PowerJobWorkerConfiguration.java
@@ -5,6 +5,7 @@ import cn.hutool.core.util.StrUtil;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
+import scala.Int;
import tech.powerjob.common.enums.Protocol;
import tech.powerjob.worker.PowerJobSpringWorker;
import tech.powerjob.worker.common.PowerJobWorkerConfig;
@@ -19,11 +20,14 @@ public class PowerJobWorkerConfiguration {
@Value("${powerjob.worker.server-address}")
private String severAddress;
+ @Value("${powerjob.worker.port}")
+ private int port;
+
@Bean
public PowerJobSpringWorker initPowerJobWorker() {
PowerJobWorkerConfig config = new PowerJobWorkerConfig();
config.setAppName(appName);
- config.setPort(RandomUtil.randomInt(10000, 20000));
+ config.setPort(port);
config.setServerAddress(StrUtil.split(severAddress, ","));
config.setProtocol(Protocol.HTTP);
// 如果没有大型 Map/MapReduce 的需求,建议使用内存来加速计算
diff --git a/nflg-wms-scheduled/src/main/resources/logback-spring.xml b/nflg-wms-scheduled/src/main/resources/logback-spring.xml
index 77f04d40..ca3e69f6 100644
--- a/nflg-wms-scheduled/src/main/resources/logback-spring.xml
+++ b/nflg-wms-scheduled/src/main/resources/logback-spring.xml
@@ -6,7 +6,7 @@
-
+
@@ -84,6 +84,7 @@
+