Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV

liurunyu

2024-08-20 b65cbfb8452a95575f0dc637b55ed49f058597fe

 pipIrr-platform/pipIrr-web/pipIrr-mwTest-rtu/src/main/java/com/dy/pipIrrMwTestRtu/tcpClient/TcpHandler.java

@@ -1,5 +1,6 @@
package com.dy.pipIrrMwTestRtu.tcpClient;

import com.dy.common.util.ByteUtil;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.apache.mina.core.service.IoHandlerAdapter;
@@ -16,6 +17,7 @@
     */
    @Override
    public void sessionCreated(IoSession session) throws Exception {
        super.sessionCreated(session);
    }

    /**
@@ -23,6 +25,7 @@
     */
    @Override
    public void sessionOpened(IoSession session) throws Exception {
        super.sessionOpened(session);
    }

    /**
@@ -30,6 +33,7 @@
     */
    @Override
    public void sessionClosed(IoSession session) throws Exception {
        super.sessionClosed(session);
    }

    /**
@@ -37,6 +41,7 @@
     */
    @Override
    public void sessionIdle(IoSession session, IdleStatus status) throws Exception {
        super.sessionIdle(session, status);
    }

    /**
@@ -51,6 +56,10 @@
     */
    @Override
    public void messageReceived(IoSession session, Object message) throws Exception {
        if(message != null){
            byte[] bs = (byte[])message ;
            log.info("收到中间件数据：" + ByteUtil.bytes2Hex(bs, true));
        }
    }

    /**
@@ -58,6 +67,12 @@
     */
    @Override
    public void messageSent(IoSession session, Object message) throws Exception {
        log.info("网络发送了数据，"
                + (session==null?"":(session.getRemoteAddress() != null?("中间件网址是：" + session.getRemoteAddress().toString()):"")) );
        if(message != null){
            byte[] bs = (byte[])message ;
            log.info("网络发送了数据：" + ByteUtil.bytes2Hex(bs, true));
        }
    }

    /**