首先引入四个包:
[size=large]mina-core-2.0.0.jar
slf4j-api-1.6.1.jar
slf4j-jdk14-1.6.1.jar
slf4j-log4j12-1.6.1.jar
接着创建一个主服务类:MinaTimeServer
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.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 { public static void main(String[] args) throws IOException { IoAcceptor acceptor = new NioSocketAcceptor(); //This filter will log all information such as newly created //sessions, messages received, messages sent, session closed acceptor.getFilterChain().addLast("logger", new LoggingFilter()); //This filter will translate binary or protocol specific data into //message object and vice versa. We use an existing TextLine //factory because it will handle text base message for you ( //you don't have to write the codec part) acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter( new TextLineCodecFactory(Charset.forName("UTF-8")))); acceptor.setHandler(new TimeServerHandler()); acceptor.getSessionConfig().setReadBufferSize(BUF_SIZE); //the first parameter defines what actions to check for when //determining if a session is idle, the second parameter defines //the length of time in seconds that must occur before a session //is deemed to be idle. acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10); acceptor.bind(new InetSocketAddress(PORT)); } private static final int PORT = 8181,BUF_SIZE = 2048; }
再创建一个handler来管理事件
package mina; import java.util.Date; import org.apache.mina.core.service.IoHandlerAdapter; import org.apache.mina.core.session.IdleStatus; import org.apache.mina.core.session.IoSession; public class TimeServerHandler extends IoHandlerAdapter { @Override public void exceptionCaught(IoSession session, Throwable cause) throws Exception { cause.printStackTrace(); } @SuppressWarnings("deprecation") @Override public void messageReceived(IoSession session, Object message) throws Exception { String str = message.toString(); System.out.println("Message received:"+str); if(str.trim().equalsIgnoreCase("quit")){ session.close(); return; } Date date = new Date(); session.write(date.toString()); System.out.println("Message written."); } @Override public void messageSent(IoSession session, Object message) throws Exception { super.messageSent(session, message); } @Override public void sessionClosed(IoSession session) throws Exception { super.sessionClosed(session); } @Override public void sessionCreated(IoSession session) throws Exception { super.sessionCreated(session); } @Override public void sessionIdle(IoSession session, IdleStatus status) throws Exception { System.out.println("IDLE"+session.getIdleCount(status)); } @Override public void sessionOpened(IoSession session) throws Exception { // TODO Auto-generated method stub super.sessionOpened(session); } }
运行MinaTimeServer,再用telnet来连接,命令格式如:telnet 127.0.0.1 8181
(第一节结束,第二节待续)[/size]