From 1fd64b07ddb99c2d9cc8a358b71aceb6a2c81492 Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: 星期三, 05 七月 2023 15:58:31 +0800
Subject: [PATCH] 修改nettyTCP客户端断开重连 增加数据库连接池 修改日志打印
---
src/main/java/com/ard/alarm/tube/service/TubeAlarmService.java | 13 ++++---------
1 files changed, 4 insertions(+), 9 deletions(-)
diff --git a/src/main/java/com/ard/alarm/tube/service/TubeAlarmService.java b/src/main/java/com/ard/alarm/tube/service/TubeAlarmService.java
index 3106e6a..3689447 100644
--- a/src/main/java/com/ard/alarm/tube/service/TubeAlarmService.java
+++ b/src/main/java/com/ard/alarm/tube/service/TubeAlarmService.java
@@ -14,8 +14,6 @@
import javax.annotation.Resource;
import java.util.HashMap;
import java.util.Map;
-import java.util.regex.Matcher;
-import java.util.regex.Pattern;
/**
* @Description: 绠＄嚎娉勬紡鎶ヨ鏈嶅姟
@@ -29,11 +27,10 @@
public class TubeAlarmService {
@Resource
NettyUdpServer nettyUdpServer;
- @Resource
- NettyTcpClient nettyTcpClient;
- @Value("${spring.netty.port}")
+
+ @Value("${spring.netty.udp.port}")
private Integer udpPort;
- @Value("${spring.netty.enabled}")
+ @Value("${spring.netty.udp.enabled}")
private String UdpServerEnable;
@PostConstruct
@@ -42,9 +39,7 @@
return;
}
nettyUdpServer.init(udpPort);
- log.info("UDP鏈嶅姟宸插惎鍔�");
- nettyTcpClient.init("127.0.0.1",1200);
- log.info("TCP瀹㈡埛绔凡鍚姩");
+ log.info("绠＄嚎娉勯湶UDP鏈嶅姟宸插惎鍔�");
}
@Async("alarm")
--
Gitblit v1.9.3