mesclient-op210A-2q-config/src/com/mes/netty/NettyClientHandler.java

package com.mes.netty;

import com.mes.ui.MesClient;
import com.mes.ui.MesRevice;
import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

import java.text.SimpleDateFormat;
import java.util.Date;

/**
 *处理网络通道的各种事件，如连接建立、数据读取、异常处理等
 *可以重写父类的方法来自定义事件处理逻辑，例如：
 *channelActive：处理连接激活事件
 *channelRead：处理接收到数据的事件
 *exceptionCaught：处理异常事件
 *作为Netty处理链中的一个节点，处理从网络接收的数据
 *这个类主要负责处理与MES服务器通信过程中的各种网络事件。
 */
public class NettyClientHandler extends ChannelInboundHandlerAdapter {

    private final SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    public static byte[] responseByte;

    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        System.out.println("mes connecting：" + sdf.format(new Date()));
    }

    @Override
    public void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
        Channel channel = ctx.channel();
        System.err.println("close tcp, ip：" + channel.remoteAddress());
        MesClient.tcp_connect_flag = false;
        MesClient.setTcpStatus();
        // 关闭通道
        channel.close();
    }

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        System.out.println("msg:"+msg);

        String mes_msg = formatResult(msg.toString());
        if(mes_msg == null || mes_msg.isEmpty()){ // error msg
            return;
        }

        String msg_type = ProtocolParam.getMsgType(mes_msg);
        System.out.println("msg_type="+msg_type);

        String processMsgRet = MesMsgUtils.processMsg(mes_msg, msg_type);
        System.out.println("processMsgRet="+processMsgRet);
        switch(msg_type) {
            case "AQDW": // 查询质量
                MesRevice.checkQualityRevice(processMsgRet,mes_msg);
                break;
            case "MKSW":
                MesRevice.startRevice(processMsgRet,mes_msg);
                break;
            case "MBDW":
                MesRevice.bindRevice(processMsgRet,mes_msg);
                break;
            case "MJBW":
                MesRevice.unbindRevice(processMsgRet,mes_msg);
                break;
            case "MQDW":
                MesRevice.updateResultRevice(processMsgRet,mes_msg);
                break;
        }


    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        ctx.close();
    }

    private String formatResult(String msg){
        System.err.println("length：" + msg.length() + " content：" + msg);
        String msgType = msg.substring(0,2).trim();
        if(msgType.equals("OK")){
            return msg.substring(3,msg.length());
        }else{
            return "";
        }
    }

}