优化雷达tcp客户端

‘liusuyi’

2023-12-28 dfdc6bdfda10de4c01fb1cfe43cabf050e71f8c3

 src/main/java/com/ard/utils/netty/tcp/DynamicClientHandler.java

@@ -44,23 +44,22 @@
    @Override
    protected void channelRead0(ChannelHandlerContext ctx, ByteBuf msg) {
        // 处理接收到的数据
        // ...
        Channel channel = ctx.channel();
        ArdEquipRadar ardEquipRadar = DynamicClient.ConnectMap.get(channel);
        // 处理接收到的消息
        byte[] byteArray = new byte[msg.readableBytes()];
        msg.getBytes(msg.readerIndex(), byteArray);
        byte[] bytes = MessageParsing.receiveCompletePacket(byteArray);
        if (bytes != null) {
            processData(ardEquipRadar, bytes);
        }
        //byte[] byteArray = new byte[msg.readableBytes()];
        //msg.getBytes(msg.readerIndex(), byteArray);
        //byte[] bytes = messageParsing.receiveCompletePacket(byteArray);
        //if (bytes != null) {
        //    processData(ardEquipRadar, bytes);
        //}
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        // 处理异常
        // ...
        log.error("处理异常");
        log.error("处理异常"+cause.getMessage());
    }

    private ScheduledFuture<?> heartbeatTask;