package com.dy.rtuMw3rd.tcp4Bjnl; 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; import org.apache.mina.core.session.IdleStatus; import org.apache.mina.core.session.IoSession; import org.apache.mina.filter.FilterEvent; /** * @Author: liurunyu * @Date: 2025/03/18 14:20 * @Description */ public class TcpHandler extends IoHandlerAdapter { private static Logger log = LogManager.getLogger(TcpHandler.class.getName()) ; /** * {@inheritDoc} */ @Override public void sessionCreated(IoSession session) throws Exception { super.sessionCreated(session); } /** * {@inheritDoc} */ @Override public void sessionOpened(IoSession session) throws Exception { super.sessionOpened(session); } /** * {@inheritDoc} */ @Override public void sessionClosed(IoSession session) throws Exception { super.sessionClosed(session); } /** * {@inheritDoc} */ @Override public void sessionIdle(IoSession session, IdleStatus status) throws Exception { super.sessionIdle(session, status); } /** * {@inheritDoc} */ @Override public void exceptionCaught(IoSession session, Throwable cause) throws Exception { } /** * {@inheritDoc} */ @Override public void messageReceived(IoSession session, Object message) throws Exception { } /** * {@inheritDoc} */ @Override public void messageSent(IoSession session, Object message) throws Exception { if(message != null){ log.info("北京农林--发送数据:" + new String((byte[])message, "UTF-8")); } } /** * {@inheritDoc} */ @Override public void inputClosed(IoSession session) throws Exception { session.closeNow(); } /** * {@inheritDoc} */ @Override public void event(IoSession session, FilterEvent event) throws Exception { } }