修改nettyTCP客户端断开重连 增加数据库连接池 修改日志打印

‘liusuyi’

2023-07-05 1fd64b07ddb99c2d9cc8a358b71aceb6a2c81492

 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")