apache mina 学习笔记二（HelloWorld)
官网上有一个发送时间的服务类作为入门的例子http://mina.apache.org/mina-project/quick-start-guide.html
我们需要的两个jar都可以从下载的压缩包中找到
mina-core-2.0.7.jar
slf4j-api-1.6.6.jar
服务器代码分为两个类，一个启动服务的类MinaTimeServer.java，另外一个是处理请求的类TimeServerHandler.java
直接上代码吧。
package cn.tang.test;
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 {
private static final int PORT=9123;
public static void main(String[] args) throws IOException {
IoAcceptor acceptor = new NioSocketAcceptor();
acceptor.getFilterChain().addLast("logger", new LoggingFilter());
acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"))));
acceptor.setHandler(new TimeServerHandler());
acceptor.getSessionConfig().setReadBufferSize(2048);
acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);
acceptor.bind(new InetSocketAddress(PORT));
}
}
为了理解请求过来Session的创建和销毁时机，比官网的多些了一些方法。
package cn.tang.test;
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();
}
@Override
public void messageReceived(IoSession session, Object message) throws Exception {
String str = message.toString();
if (str.trim().equalsIgnoreCase("quit")) {
session.close();
return;
}
Date date = new Date();
session.write(date.toString());
System.out.println("Message written...");
}
@Override
public void sessionCreated(IoSession session) throws Exception {
System.out.println("sessionCreated...");
}
@Override
public void sessionOpened(IoSession session) throws Exception {
System.out.println("sessionOpened...");
}
@Override
public void sessionClosed(IoSession session) throws Exception {
System.out.println("sessionClosed...");
}
@Override
public void sessionIdle(IoSession session, IdleStatus status) throws Exception {
System.out.println("IDLE " + session.getIdleCount(status));
}
}
页:
[1]