分支自 ard/ruoyi-api-alarm
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
liusuyi
2023-12-27 a20bc4abb2b913bf03dda03a45d835da090cf9aa 
 src/main/java/com/ard/utils/netty/tcp/ClientHandler.java


@@ -8,6 +8,7 @@


import com.ard.utils.util.GisUtils;


import com.ard.utils.mqtt.MqttProducer;


import io.netty.buffer.ByteBuf;


import io.netty.channel.Channel;


import io.netty.channel.ChannelHandlerContext;


import io.netty.channel.ChannelId;


import io.netty.channel.SimpleChannelInboundHandler;


@@ -16,6 +17,7 @@




import javax.xml.bind.DatatypeConverter;


import java.net.InetSocketAddress;


import java.net.SocketAddress;


import java.text.SimpleDateFormat;


import java.util.*;


import java.util.concurrent.ScheduledFuture;


@@ -61,7 +63,7 @@


        int port = ipSocket.getPort();


        String host = ipSocket.getHostString();


        log.error("与设备" + host + ":" + port + "连接断开!");


        ArdEquipRadar ardEquipRadar = ClientInitialize.tureConnectMap.get(id);


        ArdEquipRadar ardEquipRadar = ClientInitialize.tureConnectMap.get(host+ ":" + port);


        // 连接断开后的最后处理


        ctx.pipeline().remove(this);


        ctx.deregister();


@@ -82,8 +84,10 @@


     */


    @Override


    public void channelRead0(ChannelHandlerContext ctx, ByteBuf msg) throws Exception {


        ChannelId id = ctx.channel().id();


        ArdEquipRadar ardEquipRadar = ClientInitialize.tureConnectMap.get(id);


        InetSocketAddress ipSocket = (InetSocketAddress) ctx.channel().remoteAddress();


        int port = ipSocket.getPort();


        String host = ipSocket.getHostString();


        ArdEquipRadar ardEquipRadar = ClientInitialize.tureConnectMap.get(host+":"+port);


        // 处理接收到的消息


        byte[] byteArray = new byte[msg.readableBytes()];


        msg.getBytes(msg.readerIndex(), byteArray);