解析Mina代碼三部曲
首先，Mina是什么?能幫我們做什么?我研究一個(gè)新技術(shù)的時(shí)候，首先問(wèn)的就是這樣的問(wèn)題。我個(gè)人的理解就是Mina是一個(gè)關(guān)注于通訊層的框架，任何需要底層通訊的應(yīng)用，都可以使用它。更詳細(xì)準(zhǔn)確的介紹，請(qǐng)看官方網(wǎng)站http://mina.apache.org/
Mina的優(yōu)勢(shì)：
1. 用NIO實(shí)現(xiàn)，無(wú)需太多線程。可以處理的并發(fā)量更大。
2. 對(duì)于應(yīng)用層來(lái)說(shuō)，編程更方便。
好了廢話少說(shuō)，先看個(gè)Demo吧
- public static void main(String[] args) throws IOException {
- // 創(chuàng)建Acceptor
- IoAcceptor acceptor = new NioSocketAcceptor();
- // 注冊(cè)filter
- acceptor.getFilterChain().addLast( "logger", new LoggingFilter() );
- acceptor.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" ))));
- // 注冊(cè)你的業(yè)務(wù)處理類(lèi)
- acceptor.setHandler( new TimeServerHandler() );
- // 配置參數(shù)
- acceptor.getSessionConfig().setReadBufferSize( 2048 );
- acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 );
- // 讓Acceptor在綁定的地址偵聽(tīng)
- acceptor.bind( new InetSocketAddress(PORT) );
- }
- public interface IoHandler {
- void sessionCreated(IoSession session) throws Exception;
- void sessionOpened(IoSession session) throws Exception;
- void sessionClosed(IoSession session) throws Exception;
- void sessionIdle(IoSession session, IdleStatus status) throws Exception;
- void exceptionCaught(IoSession session, Throwable cause) throws Exception;
- void messageReceived(IoSession session, Object message) throws Exception;
- void messageSent(IoSession session, Object message) throws Exception;
- }
首先new一個(gè)Acceptor，可以看出，Acceptor是我們要操作的服務(wù)器對(duì)象。然后，向Acceptor里注冊(cè)了兩個(gè)filter。filter的概念類(lèi)似于web服務(wù)器里的filter。filter處于你的業(yè)務(wù)端代碼和具體的發(fā)送數(shù)據(jù)代碼之間，它負(fù)責(zé)過(guò)濾或者說(shuō)處理傳遞過(guò)來(lái)的信息。業(yè)務(wù)處理代碼，寫(xiě)在Handler里。
代碼結(jié)構(gòu)相當(dāng)?shù)那逦Ｎ覀冃枰顚?xiě)的業(yè)務(wù)代碼就是 Handler 和 Filter了。它們倆很相似，但是在概念上是有區(qū)別的。filter事實(shí)上主要是處理底層的通信字節(jié)流，通信協(xié)議等，一般跟業(yè)務(wù)邏輯沒(méi)什么關(guān)系。Handler是專(zhuān)門(mén)暴露給應(yīng)用開(kāi)發(fā)者，用來(lái)填寫(xiě)業(yè)務(wù)處理代碼的。
看看下面的圖便知道了
#p#
Mina暴露給開(kāi)發(fā)者的接口主要是IoAcceptor(服務(wù)器端)或者IoConnector(客戶(hù)端)。Mina內(nèi)部具體是怎么實(shí)現(xiàn)偵聽(tīng)，處理連接的呢?我們先來(lái)介紹一下Mina的方法哲學(xué)或者說(shuō)術(shù)語(yǔ)吧。
IoSession
IoSession： IoSession是一個(gè)客戶(hù)連接的抽象，整個(gè)通訊框架可以說(shuō)，都是圍繞著IoSession工作的。
IoAcceptor： 初始化服務(wù)器，用的就是它
IoProcessor： 負(fù)責(zé)處理IoSession，包括創(chuàng)建，移除，讀寫(xiě)事件的處理
IoFilter： 過(guò)濾消息或者說(shuō)消息處理(通訊層的)
IoHandler： 消息處理(應(yīng)用邏輯層的)
通訊層的核心類(lèi)，事實(shí)上是IoAcceptor，IoProcessor，IoSession。在這里我們只分析IoAcceptor模式，也就是服務(wù)器端的代碼。客戶(hù)端的代碼與此類(lèi)似，大家可以自己研究。
首先，調(diào)用IoAcceptor.bind()方法時(shí)，服務(wù)器已經(jīng)初始化完畢，這時(shí)服務(wù)器就在指定的端口上開(kāi)始偵聽(tīng)客戶(hù)端發(fā)來(lái)的連接請(qǐng)求。
當(dāng)IoAcceptor偵聽(tīng)到客戶(hù)端請(qǐng)求時(shí)，它就會(huì)把這個(gè)請(qǐng)求交給IoProcessor進(jìn)行處理。然后IoAcceptor回去繼續(xù)偵聽(tīng)。顯然，IoAcceptor的工作流程就是 偵聽(tīng) --> 傳遞請(qǐng)求 --> 繼續(xù)偵聽(tīng)。
IoProcessor得任務(wù)則是處理這些連接的IO事件。顯然IoProcessor不可能和IoAcceptor在同一個(gè)線程里運(yùn)行。他們兩個(gè)分工不同，可以并發(fā)執(zhí)行。Mina內(nèi)部事實(shí)上維護(hù)了一個(gè)IoProcessor對(duì)象池，對(duì)象池的默認(rèn)大小是CPU個(gè)數(shù)+1.也就是說(shuō)，如果你的機(jī)器是4核的，可能就有5個(gè)IoProcessor(可以理解為線程)同時(shí)工作。
看看下面的示意圖吧，一圖勝千言：
#p#
在這里主要分析IoAcceptor 和 IoProcessor。
IoAcceptor比較簡(jiǎn)單，它的核心代碼都在AbstractPollingAccetor里，輪詢(xún)代碼在它的內(nèi)部類(lèi)Accetpor里的run方法里。請(qǐng)看下面的UML圖：
IoProcessor比較復(fù)雜，它的主要代碼是在AbstractPollingProcessor里的，輪詢(xún)代碼在它的內(nèi)部類(lèi)Processor里的run方法實(shí)現(xiàn)。值得注意的是，IoAcceptor所持有的IoProcessor引用，事實(shí)上是一個(gè)對(duì)象池。對(duì)象池負(fù)責(zé)調(diào)度某個(gè)Processor來(lái)處理請(qǐng)求。下面是UML類(lèi)圖
【編輯推薦】
- 巧解使Eclipse崩潰的JVM terminated問(wèn)題
- JVM terminated令Eclipse崩潰問(wèn)題的解決
- Java編譯過(guò)程與c/c++編譯過(guò)程有何不同
- 淺談jvm.dll裝載過(guò)程與源代碼分析
- Java虛擬機(jī)（JVM）中的內(nèi)存設(shè)置詳解
