mina

Posted 2020-09-08

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了mina相关的知识，希望对你有一定的参考价值。

1、MINA是什么

MINA是apache的开源项目，是一个网络通信层封装框架。融合了多种通信协议，如：TCP/IP、UDP/IP等，采用NIO的非阻塞通信。

2、MINA的简单应用

2.1 下载相关jar包，注意日志的对应版本。

mina-core-2.0.7.jar

mina-example-2.0.7.jar

slf4j-api-1.6.6.jar

slf4j-log4j12-1.6.6.jar

log4j-1.2.17.jar

2.2 服务端代码

IoAcceptor acceptor = new NiosocketAcceptor();
DefaultIoFilterChainBuilder filterChain = acceptor.getFilterChain();
filterChain.addLast("logger", new LoggingFilter());
filterChain.addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName("UTF-8"))));
acceptor.getSessionConfig().setReadBufferSize(2048);
acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 3);
acceptor.setHandler(new TimeServerHandler());
acceptor.bind(new InetSocketAddress(PORT) );

public class TimeServerHandler extends IoHandlerAdapter
{
    public TimeServerHandler() {
        super();
    }

    @Override
    public void sessionCreated(IoSession session) throws Exception {
        super.sessionCreated(session);
        System.err.println("session is created !");
    }

    @Override
    public void sessionOpened(IoSession session) throws Exception {
        super.sessionOpened(session);
        System.err.println("session is open !");
    }

    @Override
    public void sessionClosed(IoSession session) throws Exception {
        super.sessionClosed(session);
        System.err.println("session is closed !");
    }

    @Override
    public void sessionIdle(IoSession session, IdleStatus status) throws Exception {
        super.sessionIdle(session, status);
        System.err.println("IDLE " + session.getIdleCount( status ));
    }

    @Override
    public void exceptionCaught(IoSession session, Throwable cause) throws Exception {
        super.exceptionCaught(session, cause);
    }

    @Override
    public void messageReceived(IoSession session, Object message) throws Exception {
//        super.messageReceived(session, message);
        String str = message.toString();
        System.err.println("receive message:"+str);
        if( str.trim().equalsIgnoreCase("quit") ) {
            session.closeOnFlush();
            return;
        }
        Date date = new Date();
        session.write(date.toString());
        System.out.println("Message written...");
    }

    @Override
    public void messageSent(IoSession session, Object message) throws Exception {
        System.err.println("ready send message!"+message.toString());
        super.messageSent(session, message);
    }

    @Override
    public void inputClosed(IoSession session) throws Exception {
        super.inputClosed(session);
    }
}

2.3 客户端代码

NioSocketConnector connector = NioSocketConnector();
connector.setConnectTimeoutMillis();
DefaultIoFilterChainBuilder filterChain = connector.getFilterChain();
filterChain.addLast(, LoggingFilter());
filterChain.addLast(, ProtocolCodecFilter(TextLineCodecFactory(Charset.())));
connector.setHandler(TimeClientHandler());
IoSession session;
(;;) {
    {
        ConnectFuture future = connector.connect(InetSocketAddress(, ));
        future.awaitUninterruptibly();
        session = future.getSession();
        ;
    } (RuntimeIoException e) {
        System..println();
        e.printStackTrace();
        Thread.();
    }
}

3、MINA的重要类解读

3.1 IoService的子类。

技术分享