mina2.0框架源码剖析

《mina2.0框架源码剖析》由会员上传分享，免费在线阅读，更多相关内容在应用文档-天天文库。

1、Mina2.0框架源码剖析Mina2.0快速入门MinaTimeServer.javapackage com.vista;import java.io.IOException;import java.net.InetSocketAddress;import java.nio.charset.Charset;import org.apache.mina.core.service.IoAcceptor;import org.apache.mina.core.session.IdleStatus;import org.

2、apache.mina.filter.codec.ProtocolCodecFilter;import org.apache.mina.filter.codec.textline.TextLineCodecFactory;import org.apache.mina.filter.logging.LoggingFilter;import org.apache.mina.transport.socket.nio.NioSocketAcceptor;public class MinaTimeServer {    p

3、rivate static final int PORT = 6488;    public static void main(String[] args) throws IOException     {        //监听即将到来的TCP连接        IoAcceptor acceptor = new NioSocketAcceptor();        acceptor.getFilterChain().addLast("logger", new LoggingFilter());       

4、 acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName("UTF-8"))));                acceptor.setHandler(new TimeServerHandler());                acceptor.getSessionConfig().setReadBufferSize(2048);       

5、 acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);                acceptor.bind(new InetSocketAddress(PORT));        System.out.println("服务器启动");    }}TimeServerHandler.javapackage com.vista;import java.util.Date;import org.apache.mina.core.s

6、ervice.IoHandlerAdapter;import org.apache.mina.core.session.IdleStatus;import org.apache.mina.core.session.IoSession;public class TimeServerHandler extends IoHandlerAdapter{    public void exceptionCaught(IoSession session, Throwable cause) throws Exception  

7、   {        cause.printStackTrace();    }    public void messageReceived(IoSession session, Object message) throws Exception     {        String strMsg = message.toString();        if(strMsg.trim().equalsIgnoreCase("quit"))        {            session.close()

8、;            return;        }        Date date = new Date();        session.write(date.toString());        System.out.println("Message written");    }    public void sessionIdle(IoSession