From c3738f4f55eb5da7003c6b699bac3c66badd6c61 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9B=B9=E9=B9=8F=E9=A3=9E?= Date: Sat, 9 May 2026 14:27:07 +0800 Subject: [PATCH] =?UTF-8?q?feat(config):=20=E5=A2=9E=E5=8A=A0PowerJobWorke?= =?UTF-8?q?r=E7=AB=AF=E5=8F=A3=E9=85=8D=E7=BD=AE=E6=94=AF=E6=8C=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 从属性文件读取powerjob.worker.port配置项 - 将端口号设置为读取的配置值，替代随机生成 - 优化PowerJobWorker初始化，提升配置灵活性 - 修复配置类导入的无用scala.Int依赖问题 --- .../wms/scheduled/config/PowerJobWorkerConfiguration.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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 的需求，建议使用内存来加速计算