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 | 10 +++++-----
1 files changed, 5 insertions(+), 5 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 bb9cbdb..3689447 100644
--- a/src/main/java/com/ard/alarm/tube/service/TubeAlarmService.java
+++ b/src/main/java/com/ard/alarm/tube/service/TubeAlarmService.java
@@ -3,6 +3,7 @@
import com.alibaba.fastjson2.JSON;
import com.ard.utils.DateUtils;
import com.ard.utils.mqtt.MqttConsumer;
+import com.ard.utils.tcp.NettyTcpClient;
import com.ard.utils.udp.NettyUdpServer;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
@@ -13,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: 绠＄嚎娉勬紡鎶ヨ鏈嶅姟
@@ -28,9 +27,10 @@
public class TubeAlarmService {
@Resource
NettyUdpServer nettyUdpServer;
- @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
@@ -39,7 +39,7 @@
return;
}
nettyUdpServer.init(udpPort);
- log.info("UDP鏈嶅姟宸茬粡鍚姩");
+ log.info("绠＄嚎娉勯湶UDP鏈嶅姟宸插惎鍔�");
}
@Async("alarm")
--
Gitblit v1.9.3