Mina2.0快速入门

MinaTimeServer.java

<!--<br /><br />Code highlighting produced by Actipro CodeHighlighter (freeware)<br />http://www.CodeHighlighter.com/<br /><br />-->packagecom.vista;

importjava.io.IOException;
importjava.net.InetSocketAddress;
importjava.nio.charset.Charset;

importorg.apache.mina.core.service.IoAcceptor;
importorg.apache.mina.core.session.IdleStatus;
importorg.apache.mina.filter.codec.ProtocolCodecFilter;
importorg.apache.mina.filter.codec.textline.TextLineCodecFactory;
importorg.apache.mina.filter.logging.LoggingFilter;
importorg.apache.mina.transport.socket.nio.NioSocketAcceptor;


publicclassMinaTimeServer
{
privatestaticfinalintPORT=6488;
publicstaticvoidmain(String[]args)throwsIOException
{
//监听即将到来的TCP连接
IoAcceptoracceptor=newNioSocketAcceptor();
acceptor.getFilterChain().addLast("logger",newLoggingFilter());
acceptor.getFilterChain().addLast("codec",newProtocolCodecFilter(newTextLineCodecFactory(Charset.forName("UTF-8"))));

acceptor.setHandler(newTimeServerHandler());

acceptor.getSessionConfig().setReadBufferSize(2048);
acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE,10);

acceptor.bind(newInetSocketAddress(PORT));
System.out.println("服务器启动");
}

}

TimeServerHandler.java

<!--<br /><br />Code highlighting produced by Actipro CodeHighlighter (freeware)<br />http://www.CodeHighlighter.com/<br /><br />-->packagecom.vista;

importjava.util.Date;

importorg.apache.mina.core.service.IoHandlerAdapter;
importorg.apache.mina.core.session.IdleStatus;
importorg.apache.mina.core.session.IoSession;

publicclassTimeServerHandlerextendsIoHandlerAdapter
{

publicvoidexceptionCaught(IoSessionsession,Throwablecause)throwsException
{
cause.printStackTrace();
}
publicvoidmessageReceived(IoSessionsession,Objectmessage)throwsException
{
StringstrMsg=message.toString();
if(strMsg.trim().equalsIgnoreCase("quit"))
{
session.close();
return;
}
Datedate=newDate();
session.write(date.toString());
System.out.println("Messagewritten");
}
publicvoidsessionIdle(IoSessionsession,IdleStatusstatus)throwsException
{
System.out.println("IDLE"+session.getIdleCount(status));
}

}

测试：

Client Output	Server Output
user@myhost:~> telnet 127.0.0.1 9123 Trying 127.0.0.1... Connected to 127.0.0.1. Escape character is '^]'. hello Wed Oct 17 23:23:36 EDT 2007 quit Connection closed by foreign host. user@myhost:~>	MINA Time server started. Message written...

参考资料：1，MINA v2.0 Quick Start Guide