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 的需求,建议使用内存来加速计算