Compare commits

1 Commits

Author SHA1 Message Date
zc
d60966dd3f 优化 2026-03-13 09:47:51 +08:00
7 changed files with 35 additions and 32 deletions

View File

@@ -119,5 +119,10 @@
<groupId>org.springframework</groupId> <groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId> <artifactId>spring-test</artifactId>
</dependency> </dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-all</artifactId>
<version>4.1.100.Final</version>
</dependency>
</dependencies> </dependencies>
</project> </project>

View File

@@ -21,5 +21,11 @@
<groupId>top.wms</groupId> <groupId>top.wms</groupId>
<artifactId>wms-common</artifactId> <artifactId>wms-common</artifactId>
</dependency> </dependency>
<dependency>
<groupId>javax.annotation</groupId>
<artifactId>javax.annotation-api</artifactId>
<version>1.3.2</version>
<scope>provided</scope>
</dependency>
</dependencies> </dependencies>
</project> </project>

View File

@@ -33,7 +33,6 @@ public class NettyTcpServer {
private EventLoopGroup workerGroup; private EventLoopGroup workerGroup;
private Channel serverChannel; private Channel serverChannel;
@PostConstruct @PostConstruct
public void start() throws InterruptedException { public void start() throws InterruptedException {
log.info("正在启动TCP服务端端口: {}", port); log.info("正在启动TCP服务端端口: {}", port);

View File

@@ -2,9 +2,6 @@ package top.wms.admin.controller.tcp.service;
import io.netty.channel.Channel; import io.netty.channel.Channel;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.web.bind.annotation.RequestParam;
import top.continew.starter.core.validation.CheckUtils;
import top.wms.admin.controller.tcp.manager.ChannelManager; import top.wms.admin.controller.tcp.manager.ChannelManager;
import top.wms.admin.controller.tcp.model.VMResult; import top.wms.admin.controller.tcp.model.VMResult;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
@@ -51,10 +48,8 @@ public class CommandService {
// 获取统计信息 // 获取统计信息
public String getStatistics() { public String getStatistics() {
return String.format("成功: %d, 失败: %d, 总数: %d", return String.format("成功: %d, 失败: %d, 总数: %d", successCount.get(), failCount.get(), successCount
successCount.get(), .get() + failCount.get());
failCount.get(),
successCount.get() + failCount.get());
} }
// 获取最新结果 // 获取最新结果
@@ -62,7 +57,6 @@ public class CommandService {
return resultQueue.peek(); return resultQueue.peek();
} }
@Autowired @Autowired
private ChannelManager channelManager; private ChannelManager channelManager;

View File

@@ -52,10 +52,9 @@ public class AHDZCConnect {
@PostConstruct @PostConstruct
public void init() { public void init() {
// 项目启动时初始化并启动服务 // 项目启动时初始化并启动服务
if (false) {
ScaleService(); ScaleService();
start(); start();
}
} }
@PreDestroy @PreDestroy

View File

@@ -14,7 +14,7 @@ spring.datasource:
# 请务必提前创建好名为 wms_admin 的数据库,如果使用其他数据库名请注意同步修改 DB_NAME 配置 # 请务必提前创建好名为 wms_admin 的数据库,如果使用其他数据库名请注意同步修改 DB_NAME 配置
url: jdbc:p6spy:mysql://127.0.0.1:3306/wms?serverTimezone=Asia/Shanghai&useSSL=true&useUnicode=true&characterEncoding=utf8&rewriteBatchedStatements=true&autoReconnect=true&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true url: jdbc:p6spy:mysql://127.0.0.1:3306/wms?serverTimezone=Asia/Shanghai&useSSL=true&useUnicode=true&characterEncoding=utf8&rewriteBatchedStatements=true&autoReconnect=true&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true
username: root username: root
password: test123$ password: root
# PostgreSQL 配置 # PostgreSQL 配置
# url: jdbc:p6spy:mysql://192.168.2.30:${DB_PORT:3306}/continew?serverTimezone=Asia/Shanghai&useSSL=true&useUnicode=true&characterEncoding=utf8&rewriteBatchedStatements=true&autoReconnect=true&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true # url: jdbc:p6spy:mysql://192.168.2.30:${DB_PORT:3306}/continew?serverTimezone=Asia/Shanghai&useSSL=true&useUnicode=true&characterEncoding=utf8&rewriteBatchedStatements=true&autoReconnect=true&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true
# username: ${DB_USER:root} # username: ${DB_USER:root}