|  |  | 
 |  |  | 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; | 
 |  |  | 
 |  |  |      */ | 
 |  |  |     @Override | 
 |  |  |     public void sessionCreated(IoSession session) throws Exception { | 
 |  |  |         super.sessionCreated(session); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  | 
 |  |  |      */ | 
 |  |  |     @Override | 
 |  |  |     public void sessionOpened(IoSession session) throws Exception { | 
 |  |  |         super.sessionOpened(session); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  | 
 |  |  |      */ | 
 |  |  |     @Override | 
 |  |  |     public void sessionClosed(IoSession session) throws Exception { | 
 |  |  |         super.sessionClosed(session); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  | 
 |  |  |      */ | 
 |  |  |     @Override | 
 |  |  |     public void sessionIdle(IoSession session, IdleStatus status) throws Exception { | 
 |  |  |         super.sessionIdle(session, status); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  | 
 |  |  |      */ | 
 |  |  |     @Override | 
 |  |  |     public void messageReceived(IoSession session, Object message) throws Exception { | 
 |  |  |         if(message != null){ | 
 |  |  |             byte[] bs = (byte[])message ; | 
 |  |  |             log.info("收到中间件数据:" + ByteUtil.bytes2Hex(bs, true)); | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  | 
 |  |  |      */ | 
 |  |  |     @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)); | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** |