MINA2官方教程翻译(2) 快速上手指南

一、介绍

该教程通过构建一个time server，带你走进给予MINA的应用程序开发的大门，但在开始之前我们需要具备下面的必要条件：

• MINA 2.x的核心包
• JDK 1.5 或更高版本
• SLF4J 1.3.0 或更高版本

1. Log4J 1.2的用户：slf4j-api.jar, slf4j-log4j12.jar, and Log4J 1.2.x
2. Log4J 1.3的用户：slf4j-api.jar, slf4j-log4j13.jar, and Log4J 1.3.x
3. java.util.logging的用户：slf4j-api.jar and slf4j-jdk14.jar

注意：请务必确认你所使用的slf4j-*.jar要与你的日志框架相匹配。例如，slf4j-log4j12.jar 和 log4j-1.3.x.jar不能在一起使用，否则会引起混乱。
我已经在Windows? 2000 professional 和 linux平台上测试了这个程序，如果你在运行这个程序的过程中遇到了问题，请立即联系我们的开发人员。

当然，这个程序是与开发环境(IDE, editors等等)无关的，它可以在任何你熟悉的平台中运行。另外，为了简化，编译命令与运行脚本都没有体现，如果你需要学习如何编译并运行java程序，请参考Java tutorial。

二、编写基于MINA框架的time server

我们从创建一个名为MinaTimeServer.java的文件开始，最初的代码如下：

public class MinaTimeServer {       public static void main(String[] args) {         // code will go here next     } } 

对所有人来说，这段代码应该是简单易懂的，我们只是简单的定义了一个main方法是这个程序能够正常运行起来。从现在开始，我们将逐步加入代码是其最终成为一个可用的server。首先，我们需要一个可以监听连接到来的对象，既然我们的程序是基于TCP/IP的，所以我们在程序中加入一个SocketAcceptor。

import org.apache.mina.core.service.IoAcceptor; import org.apache.mina.transport.socket.nio.NioSocketAcceptor;   public class MinaTimeServer {       public static void main( String[] args )     {         IoAcceptor acceptor = new NioSocketAcceptor();     }   } 

加入NioSocketAcceptor之后，我们可以继续定义一个handler类，并将其与NioSocketAcceptor绑定到一个端口上。

下面，我们在配置中增加一个filter，这个filter将把二进制数据或是协议相关的数据转换成为一个消息对象，反之亦然。我们使用现有的TextLine工厂类，以为它可以处理基于文本的信息(你不需要自己来实现编解码部分)。

import java.nio.charset.Charset;   import org.apache.mina.core.service.IoAcceptor; 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 )     {         IoAcceptor acceptor = new NioSocketAcceptor();           acceptor.getFilterChain().addLast( "logger", new LoggingFilter() );         acceptor.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" ))));     } } 

然后，我们定义一个handler，这个handler将对客户端的连接以及过去当前时间的请求做出服务。handler类必须实现IoHandler接口。对于大多数基于MINA的应用程序，这个操作无疑是一个很大的负担，因为它将处理客户端说有的请求。在这个教程中，我们的handler将继承自IoHandlerAdapter，这个类依照适配器模式来简化实现IoHandler接口所带来的代码量。

import java.io.IOException; import java.nio.charset.Charset;   import org.apache.mina.core.service.IoAcceptor; 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();           acceptor.getFilterChain().addLast( "logger", new LoggingFilter() );         acceptor.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" ))));           acceptor.setHandler(  new TimeServerHandler() );     } } 

现在，我们在NioSocketAcceptor增加一些Socket相关的配置：

import java.io.IOException; import java.nio.charset.Charset;   import org.apache.mina.core.session.IdleStatus; import org.apache.mina.core.service.IoAcceptor; 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();           acceptor.getFilterChain().addLast( "logger", new LoggingFilter() );         acceptor.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" ))));           acceptor.setHandler(  new TimeServerHandler() ); idle sessions         acceptor.getSessionConfig().setReadBufferSize( 2048 );         acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 );     } } 

在MinaTimeServer增加了两行新的内容，这些set方法分别设置了IoHandler、input buffer size和session对象上的idle属性。buffer size指明了底层操作系统应该给与新到来的数据分配多少空间；第二行指明了什么时候应该检测idle sessions。在setIdleTime这个方法中，第一参数指明了在检测session是否idle时，应该关心那一种活动，第二个参数指明了session变为idle状态时需要经过多长的时间。

handler的代码如下：

import java.util.Date;   import org.apache.mina.core.session.IdleStatus; import org.apache.mina.core.service.IoHandlerAdapter; 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 sessionIdle( IoSession session, IdleStatus status ) throws Exception     {         System.out.println( "IDLE " + session.getIdleCount( status ));     } } 

该类用到的方法有exceptionCaught、messageReceived和sessionIdle。在handler中，一定要定义exceptionCaught方法，该方法用来处理在远程连接中处理过程中发生的各种异常，如果这个方法没有被定义，我们可能不能发现这些异常。

在这个handler中，exceptionCaught方法只是简单地打印出异常堆栈信息并关闭连接，对于大多数程序来说，这是一种比较标准的操作，除非连接可以在异常条件下恢复。

messageReceived方法会接收客户端的数据并返回当前的的系统时间，如果从客户端接收到了消息‘quit’，则session会被关闭。与调用session.write(Object)的情况相同，不同的协议编解码器决定了传入该方法的对象(第二个参数)也是不同的。如果你没有指定协议编解码器，你最有可能接收到一个IoBuffer对象，当然，调用session.write(Object)也是一个IoBuffer对象。

当session持续idle的时间与acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 )设置的时间一致时，sessionIdle方法将被调用。

现在剩下的工作只是定义一个server监听的地址和端口了，当然还需要启动服务。代码如下：

正如你所见，这里调用了acceptor.setLocalAddress( new InetSocketAddress(PORT) );方法，该方法指明了server将在哪个IP和端口上监听。最后一步调用了IoAcceptor.bind()方法，该方法将端口与具体的客户端进程绑定在一起。

三、验证Time server

现在，我们编译上面的程序，编译完成后就可以运行并查看运行结果了。最简单的测试途径就是启动程序，并使用telnet与之建立连接：

四、接下来

获取更多资源，请浏览MINA的Documentation。你也可以阅读其他教程。