增加nettyTcp客户端

‘liusuyi’

2023-06-25 0b25d230881ce4d56233a4834eb520d120f9a7a9

 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;
@@ -28,6 +29,8 @@
public class TubeAlarmService {
    @Resource
    NettyUdpServer nettyUdpServer;
    @Resource
    NettyTcpClient nettyTcpClient;
    @Value("${spring.netty.port}")
    private Integer udpPort;
    @Value("${spring.netty.enabled}")
@@ -40,6 +43,8 @@
        }
        nettyUdpServer.init(udpPort);
        log.info("UDP服务已经启动");
        nettyTcpClient.init("112.98.126.2",1200);
        log.info("TCP客户端已连接");
    }

    @Async("alarm")