Apache MINA学习

　　1.准备工作
　　mina官方下载地址：http://mina.apache.org/downloads.html，这里使用的版本是apache-mina-2.0.4-bin.zip。
　　slf4j官方下载地址：http://www.slf4j.org/download.html，这里使用的版本是slf4j-1.6.4.zip。

　　2.新手上路hello world
　　先通过一个基本的例子来初步认识mina。
　　新建项目MinaProj，继续新建包ning.mina和类MinaHelloWorldServer.java，目前只需要导入项目的jar：
　　mina-core-2.0.4.jar，
　　mina-transport-apr-2.0.4.jar，
　　mina-filter-compression-2.0.4.jar，
　　slf4j-api-1.6.4.jar（在mina自带的类库中具有该jar，但版本可能不是这个），
　　slf4j-simple-1.6.4.jar（mina类库中没有该jar，所以前面说到需要自行下载slf4j的类库，如果没有该jar，运行时会抛出Failed to load class "org.slf4j.impl.StaticLoggerBinder"的错误）。
　　代码清单：
　　MinaHelloWorldServer.java：

• package ning.mina;  
  
• 
  
• import java.io.IOException;  
  
• import java.net.InetSocketAddress;  
  
• 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 MinaHelloWorldServer {  
  
•     public static void main(String[] args) throws IOException {  
  
•         //建立mina监听服务器端         
  
•         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 HelloWorldServerHandler());  
  
•         //服务器端开启监听         
  
•         acceptor.bind(new InetSocketAddress(4321));  
  
•     }  
  
• }
  

　　HelloWorldServerHandler.java

• package ning.mina;  
  
• 
  
• import org.apache.mina.core.service.IoHandlerAdapter;  
  
• import org.apache.mina.core.session.IoSession;  
  
• 
  
• public class HelloWorldServerHandler extends IoHandlerAdapter {  
  
•     @Override
  
•     public void messageReceived(IoSession session, Object message) throws Exception {  
  
•         System.out.println("HelloWorldServerHandler receive message!");  
  
•         //直接转换object对象为string对象并打印  
  
•         String msg = message.toString();  
  
•         System.out.println("message:" + msg);  
  
•     }  
  
• }
  

　　MinaHelloWorldClient.java

• package ning.mina;  
  
• 
  
• import java.net.InetSocketAddress;  
  
• import java.nio.charset.Charset;  
  
• 
  
• import org.apache.mina.core.service.IoConnector;  
  
• import org.apache.mina.filter.codec.ProtocolCodecFilter;  
  
• import org.apache.mina.filter.codec.textline.TextLineCodecFactory;  
  
• import org.apache.mina.transport.socket.nio.NioSocketConnector;  
  
• 
  
• public class MinaHelloWorldClient {  
  
•     public static void main(String[] args) {  
  
•         //创建客户端连接器  
  
•         IoConnector connector = new NioSocketConnector();  
  
•         //设置超时时间  
  
•         connector.setConnectTimeoutMillis(5000);  
  
•         //设置字符串编码过滤器  
  
•         connector.getFilterChain().addLast("codec",  
  
•             new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"))));  
  
•         //设置业务逻辑处理类  
  
•         connector.setHandler(new HelloWorldClientHandler("Hello world,mina!!"));  
  
•         //连接  
  
•         connector.connect(new InetSocketAddress("127.0.0.1", 4321));  
  
•     }  
  
• 
  
• }  
  

　　HelloWorldClientHandler.java

• package ning.mina;  
  
• 
  
• import org.apache.mina.core.service.IoHandlerAdapter;  
  
• import org.apache.mina.core.session.IoSession;  
  
• 
  
• public class HelloWorldClientHandler extends IoHandlerAdapter {  
  
•     private String message;  
  
• 
  
•     public HelloWorldClientHandler(String message) {  
  
•         this.message = message;  
  
•     }  
  
•       
  
•     @Override
  
•     public void sessionOpened(IoSession session) {  
  
•         //发送消息  
  
•         session.write(message);  
  
•     }  
  
• }
  

　　代码一共四个类，依次是服务器端，服务器端处理类，客户端，客户端处理类。先运行服务器端，再运行客户端，可以看到控制台打印出了"Hello world,mina!!"字样，运行成功。
　　3.MINA介绍
　　架构
　　首先看MINA的架构图：

  

                    图1

如图所示，使用MINA搭建应用需要遵循三层架构，应具有IO服务，IO过滤器，IO处理器三个层次。

• IO服务：封装了具体的NIO底层实现，完成具体IO操作。
  
• IO过滤器：将IO的字节流转换成对象或其他数据结构，或进行横切的处理操作，可以使用多个过滤器组成过滤器链。
  
• IO处理器：具体业务逻辑的处理类。
  

　　MINA将底层实现，技术架构与业务逻辑进行了很好的解耦，使用者只需要关心需要处理的业务逻辑和发送接收的数据即可。

IOService

看两张UML类图：

                             图2

                                  图3

IOService：图2和图3展示了图1IOService的类图，例子中的IOAcceptor和IOConnector均继承自IOService接口。IOService是执行IO操作的地方，是所有类和接口的顶层接口，它有服务器端和客户端两种实现。

IOAcceptor：服务器端接口，用来建立，监听，等待连接。

IOConnector：客户端接口，用来发起连接。

根据不同的数据类型，IOAcceptor和IOConnector具有不同的实现。

IOService比较重要的方法：

void setHandler(IoHandler handler)：设置业务处理器

DefaultIoFilterChainBuilder getFilterChain()：获得处理器链

IOSession

类图：

　　图4
　　IOSession表示一个网络会话，具有不同类型的实现。可以用来保存自定义的属性，也可以在各层次间交换数据。与HTTP的session比较相似。
　　IOSession比较重要的方法：
　　CloseFuture close(boolean immediately)：参数为true的话立即关闭当前会话，false表示数据都发送完毕后再关闭。
　　Object getAttribute(Object key)：获取键位key的值。
　　Object setAttribute(Object key, Object value)：设置键为key，值为value的对象到会话中。
　　IOFilter
　　IOFilter在IOService和IOHandler之间，请求在到达IO处理器之前，要经过若干个过滤器处理，比如编码转换，日志记录，权限控制等。它能很好的满足横切需求，也能组成过滤器链，如果过滤不通过则终止请求，不再发送到IO处理器。
　　IOHandler
　　IOHandler是具体的业务逻辑处理接口，请求经过过滤器后到达。IOHandler有若干的方法会在不同的阶段被调用。一般情况只需要将自己的类继承IoHandlerAdapter并重写相应的方法即可完成功能，IoHandlerAdapter具有IOHandler的空实现。
　　sessionCreated--新连接建立的时候触发
　　sessionOpened--新连接打开的时候触发，在sessionCreated之后被调用。
　　sessionClosed--连接被关闭的时候触发。
　　sessionIdle--连接被闲置的时候触发。
　　exceptionCaught--有异常抛出但是没有被catch的时候触发。
　　messageReceived--有消息接收的时候触发。
　　messageSent--消息发送的时候触发。
　　4.结语
　　在了解学习使用MINA的过程中，深深感觉到MINA的魅力所在，使用方便，安全，化繁为简，其使用的架构，线程都十分值得深入研究。待继续学习后再补充完善文章内容。