參考：http://xinsync.xju.edu.cn/index.php/archives/category/prglang/java/mina

簡單介紹：MINA框架是對java的NIO包的一個封裝，簡化了NIO程序開發的難度，封裝了很多底層的細節，然開發者把精力集中到業務邏輯上來，最近做了一個相關的項目，為了備忘對MINA做一個總結。

下面這個start方法用來初始化MINA：

Java代碼

1. private void start(int port, WebContext ctx)    
2.       throws IOException, InstantiationException   
3.         , IllegalAccessException, ClassNotFoundException {   
4.     //初始化Acceptor   
5.     NioSocketAcceptor acceptor = new NioSocketAcceptor(5);   
6.            
7.        java.util.concurrent.Executor threadPool = Executors.newFixedThreadPool(1500);//建立線程池   
8.        //加入過濾器（Filter）到Acceptor   
9.        acceptor.getFilterChain().addLast("exector", new ExecutorFilter(threadPool));   
10. acceptor.getFilterChain().addLast("codec",    
11.        new ProtocolCodecFilter(new WebDecoder()，new WebEncoder()));   
12.        LoggingFilter filter = new LoggingFilter();   
13.     filter.setExceptionCaughtLogLevel(LogLevel.DEBUG);   
14.     filter.setMessageReceivedLogLevel(LogLevel.DEBUG);   
15.     filter.setMessageSentLogLevel(LogLevel.DEBUG);   
16.     filter.setSessionClosedLogLevel(LogLevel.DEBUG);   
17.     filter.setSessionCreatedLogLevel(LogLevel.DEBUG);   
18.     filter.setSessionIdleLogLevel(LogLevel.DEBUG);   
19.     filter.setSessionOpenedLogLevel(LogLevel.DEBUG);   
20.     acceptor.getFilterChain().addLast("logger", filter);    
21.            
22.        acceptor.setReuseAddress(true);//設置的是主服務監聽的端口可以重用   
23.            
24.        acceptor.getSessionConfig().setReuseAddress(true);//設置每一個非主監聽連接的端口可以重用   
25.        acceptor.getSessionConfig().setReceiveBufferSize(1024);//設置輸入緩沖區的大小   
26.        acceptor.getSessionConfig().setSendBufferSize(10240);//設置輸出緩沖區的大小   
27. //設置為非延遲發送，為true則不組裝成大包發送，收到東西馬上發出   
28.        acceptor.getSessionConfig().setTcpNoDelay(true);   
29. //設置主服務監聽端口的監聽隊列的最大值為100，如果當前已經有100個連接，再新的連接來將被服務器拒絕   
30.        acceptor.setBacklog(100);   
31.        acceptor.setDefaultLocalAddress(new InetSocketAddress(port));   
32.        //加入處理器（Handler）到Acceptor   
33.        acceptor.setHandler(new WebHandler());   
34.     acceptor.bind();   
35. }  

private void start(int port, WebContext ctx)
throws IOException, InstantiationException
, IllegalAccessException, ClassNotFoundException {
//初始化Acceptor
NioSocketAcceptor acceptor = new NioSocketAcceptor(5);
java.util.concurrent.Executor threadPool = Executors.newFixedThreadPool(1500);//建立線程池
//加入過濾器（Filter）到Acceptor
acceptor.getFilterChain().addLast("exector", new ExecutorFilter(threadPool));
acceptor.getFilterChain().addLast("codec",
new ProtocolCodecFilter(new WebDecoder()，new WebEncoder()));
LoggingFilter filter = new LoggingFilter();
filter.setExceptionCaughtLogLevel(LogLevel.DEBUG);
filter.setMessageReceivedLogLevel(LogLevel.DEBUG);
filter.setMessageSentLogLevel(LogLevel.DEBUG);
filter.setSessionClosedLogLevel(LogLevel.DEBUG);
filter.setSessionCreatedLogLevel(LogLevel.DEBUG);
filter.setSessionIdleLogLevel(LogLevel.DEBUG);
filter.setSessionOpenedLogLevel(LogLevel.DEBUG);
acceptor.getFilterChain().addLast("logger", filter);
acceptor.setReuseAddress(true);//設置的是主服務監聽的端口可以重用
acceptor.getSessionConfig().setReuseAddress(true);//設置每一個非主監聽連接的端口可以重用
acceptor.getSessionConfig().setReceiveBufferSize(1024);//設置輸入緩沖區的大小
acceptor.getSessionConfig().setSendBufferSize(10240);//設置輸出緩沖區的大小
//設置為非延遲發送，為true則不組裝成大包發送，收到東西馬上發出
acceptor.getSessionConfig().setTcpNoDelay(true);
//設置主服務監聽端口的監聽隊列的最大值為100，如果當前已經有100個連接，再新的連接來將被服務器拒絕
acceptor.setBacklog(100);
 acceptor.setDefaultLocalAddress(new InetSocketAddress(port));
//加入處理器（Handler）到Acceptor
acceptor.setHandler(new WebHandler());
acceptor.bind();
}

 NioSocketAcceptor是MINA的適配器，一切都是從這里開始的。MINA中有個過濾器和處理器的概念，過濾器用來過濾數據，處理器用來處理數據。具體來說MINA的處理模型就是request->過濾器A->過濾器B->處理器->過濾器B->過濾器A->response,這里的request和response類似serlvet的request和response。

Java代碼

1. acceptor.getFilterChain().addLast("exector", new ExecutorFilter(threadPool));   
2. //加入一個線程池到適配器，這里用的是jdk自帶的線程池  

acceptor.getFilterChain().addLast("exector", new ExecutorFilter(threadPool));
//加入一個線程池到適配器，這里用的是jdk自帶的線程池

Java代碼

1.  acceptor.getFilterChain().addLast("codec",    
2.         new ProtocolCodecFilter(new WebDecoder()，new WebEncoder()));   
3. //這里是處理邏輯的關鍵部位，請求的處理都是在WebDecoder類和WebEncoder類中處理，可以明顯從命名上看出來一個是用來解碼，另一個是用來編碼，requet過來后先進入WebDecoder類(實現了ProtocolDecoder接口)進行解碼處理，這里可以加入自己的邏輯把傳進來的流解碼成自己需要的信息。而WebEncoder類(實現了ProtocolEncoder接口)是進行編碼，在這個類里面加入自己的邏輯把處理后的信息組裝發送給客戶端(response)。而在解碼和編碼過程中WebHandler(擴展了IoHandlerAdapter抽象類)起到了處理器的作用。   
4. //request->WebDecoder->WebHandler->WebEncode->response  

 acceptor.getFilterChain().addLast("codec",
new ProtocolCodecFilter(new WebDecoder()，new WebEncoder()));
//這里是處理邏輯的關鍵部位，請求的處理都是在WebDecoder類和WebEncoder類中處理，可以明顯從命名上看出來一個是用來解碼，另一個是用來編碼，requet過來后先進入WebDecoder類(實現了ProtocolDecoder接口)進行解碼處理，這里可以加入自己的邏輯把傳進來的流解碼成自己需要的信息。而WebEncoder類(實現了ProtocolEncoder接口)是進行編碼，在這個類里面加入自己的邏輯把處理后的信息組裝發送給客戶端(response)。而在解碼和編碼過程中WebHandler(擴展了IoHandlerAdapter抽象類)起到了處理器的作用。
//request->WebDecoder->WebHandler->WebEncode->response

現在詳細描述一下request->WebDecoder->WebHandler->WebEncode->response的過程：

客戶端發送一個請求到MINA服務器，這里相當于來了一個requet。請求首先來到

Java代碼

1. WebDecoder類(實現了ProtocolDecoder接口)中的    
2. boolean decode(IoSession session, IoBuffer in, ProtocolDecoderOutput out) throws Exception{}方法   
3. /*  
4. 參數in：用戶請求信息全存在這里，讀數據就從in這里讀。  
5. 參數out：用來輸出處理后的數據到Filter的下一個過濾器，如果沒有過濾器了就輸出到WebHandler，這里有點和  
6. servelt的過濾器類似。利用out.write(Object object);這個函數可以把數據傳到下一個Filter。我們可以自己定義  
7. 一個對象，我們假設為Request，用它來傳遞消息，那末這里就可以寫成out.write(new RequsetMessage());  
8. 如果這個方法返回false，就是說當前邏輯包還沒接收完（也就是當前的IoBuffer并沒有包含足夠的數據），需要再次  
9. 執行decode方法（再次獲取新的IoBuffer），用來獲取足夠的數據。如果返回值為true就表示可以不執行decode方  
10. 法了，但是要激活handler方法，必須要調用out.write方法。  
11. public class RequestMessage{}//這里什么也不做  
12. */  

WebDecoder類(實現了ProtocolDecoder接口)中的
boolean decode(IoSession session, IoBuffer in, ProtocolDecoderOutput out) throws Exception{}方法
/*
參數in：用戶請求信息全存在這里，讀數據就從in這里讀。
參數out：用來輸出處理后的數據到Filter的下一個過濾器，如果沒有過濾器了就輸出到WebHandler，這里有點和
servelt的過濾器類似。利用out.write(Object object);這個函數可以把數據傳到下一個Filter。我們可以自己定義
一個對象，我們假設為Request，用它來傳遞消息，那末這里就可以寫成out.write(new RequsetMessage());
如果這個方法返回false，就是說當前邏輯包還沒接收完（也就是當前的IoBuffer并沒有包含足夠的數據），需要再次
執行decode方法（再次獲取新的IoBuffer），用來獲取足夠的數據。如果返回值為true就表示可以不執行decode方
法了，但是要激活handler方法，必須要調用out.write方法。
public class RequestMessage{}//這里什么也不做
*/

 然后到

Java代碼

1. WebHandler(擴展了IoHandlerAdapter抽象類)中的   
2. void messageReceived(IoSession session, Object message) throws Exception{}方法   
3. WriteFuture future = session.write(response);//session中必須加入這個代碼，才會激活encode方法   
4. future.addListener(IoFutureListener.CLOSE);//這個的作用是發送完畢后關閉連接，加了就是短連接，不然是長連接   
5. IoFutureListener里面有個operationComplete(IoFuture future)方法，當流發送完成之后才調用這個方法。   
6. /*  
7. 參數message：用來獲取Filter傳遞過來的對象.對應代碼RequestMessage request = (RequestMessage) message;  
8. 參數session:用來發送數據到Filter.對應代碼session.write(new ResponseMessage());  
9. public class ResponseMessage{}//這里什么也不做,假設存放處理后的數據  
10. 注意：對于一個MINA程序而言，對于WebHandler類只生成一個對象，所以要考慮線程安全問題  
11.  */  

WebHandler(擴展了IoHandlerAdapter抽象類)中的
void messageReceived(IoSession session, Object message) throws Exception{}方法
WriteFuture future = session.write(response);//session中必須加入這個代碼，才會激活encode方法
future.addListener(IoFutureListener.CLOSE);//這個的作用是發送完畢后關閉連接，加了就是短連接，不然是長連接
IoFutureListener里面有個operationComplete(IoFuture future)方法，當流發送完成之后才調用這個方法。
/*
參數message：用來獲取Filter傳遞過來的對象.對應代碼RequestMessage request = (RequestMessage) message;
參數session:用來發送數據到Filter.對應代碼session.write(new ResponseMessage());
public class ResponseMessage{}//這里什么也不做,假設存放處理后的數據
注意：對于一個MINA程序而言，對于WebHandler類只生成一個對象，所以要考慮線程安全問題
 */

然后到

Java代碼

1. WebEncoder類(實現了ProtocolEncoder接口)中的   
2. boolean encode(IoSession session, Object message, ProtocolEncoderOutput out) throws Exception{}    
3. 方法   
4. /*  
5. 參數message：用來獲取上一個Filter節點的數據或者處理器的數據（如果這個過濾器為最靠近處理器的那個）  
6. ResponseMessage response = (ResponseMessage)message;  
7. 參數out：用來輸出數據到下一個Filter節點過或者到客戶端,用out.write(Object encodedMessage)把數據發送  
8. 出去，但是要注意的是，如果這個Filter下一個節點如果是客戶端的話，那個這個encodedMessage數據必須為  
9. IoBuffer類型的，可以利用IoBuffer.wrap(byte[] byteArray)這個方法來格式化輸出數據  
10. */