新聞中心
首先,Mina是什么?能幫我們做什么?我研究一個新技術(shù)的時候,首先問的就是這樣的問題。我個人的理解就是Mina是一個關(guān)注于通訊層的框架,任何需要底層通訊的應(yīng)用,都可以使用它。更詳細準(zhǔn)確的介紹,請看官方網(wǎng)站http://mina.apache.org/

創(chuàng)新互聯(lián)建站不只是一家網(wǎng)站建設(shè)的網(wǎng)絡(luò)公司;我們對營銷、技術(shù)、服務(wù)都有自己獨特見解,公司采取“創(chuàng)意+綜合+營銷”一體化的方式為您提供更專業(yè)的服務(wù)!我們經(jīng)歷的每一步也許不一定是最完美的,但每一步都有值得深思的意義。我們珍視每一份信任,關(guān)注我們的成都網(wǎng)站制作、成都網(wǎng)站建設(shè)、外貿(mào)營銷網(wǎng)站建設(shè)質(zhì)量和服務(wù)品質(zhì),在得到用戶滿意的同時,也能得到同行業(yè)的專業(yè)認可,能夠為行業(yè)創(chuàng)新發(fā)展助力。未來將繼續(xù)專注于技術(shù)創(chuàng)新,服務(wù)升級,滿足企業(yè)一站式網(wǎng)絡(luò)營銷推廣需求,讓再小的品牌網(wǎng)站設(shè)計也能產(chǎn)生價值!
Mina的優(yōu)勢:
1. 用NIO實現(xiàn),無需太多線程??梢蕴幚淼牟l(fā)量更大。
2. 對于應(yīng)用層來說,編程更方便。
好了廢話少說,先看個Demo吧
- public static void main(String[] args) throws IOException {
- // 創(chuàng)建Acceptor
- IoAcceptor acceptor = new NioSocketAcceptor();
- // 注冊filter
- acceptor.getFilterChain().addLast( "logger", new LoggingFilter() );
- acceptor.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" ))));
- // 注冊你的業(yè)務(wù)處理類
- acceptor.setHandler( new TimeServerHandler() );
- // 配置參數(shù)
- acceptor.getSessionConfig().setReadBufferSize( 2048 );
- acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 );
- // 讓Acceptor在綁定的地址偵聽
- acceptor.bind( new InetSocketAddress(PORT) );
- }
IoHandler
- 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一個Acceptor,可以看出,Acceptor是我們要操作的服務(wù)器對象。然后,向Acceptor里注冊了兩個filter。filter的概念類似于web服務(wù)器里的filter。filter處于你的業(yè)務(wù)端代碼和具體的發(fā)送數(shù)據(jù)代碼之間,它負責(zé)過濾或者說處理傳遞過來的信息。業(yè)務(wù)處理代碼,寫在Handler里。
代碼結(jié)構(gòu)相當(dāng)?shù)那逦?。我們需要填寫的業(yè)務(wù)代碼就是 Handler 和 Filter了。它們倆很相似,但是在概念上是有區(qū)別的。filter事實上主要是處理底層的通信字節(jié)流,通信協(xié)議等,一般跟業(yè)務(wù)邏輯沒什么關(guān)系。Handler是專門暴露給應(yīng)用開發(fā)者,用來填寫業(yè)務(wù)處理代碼的。
看看下面的圖便知道了
#p#
Mina暴露給開發(fā)者的接口主要是IoAcceptor(服務(wù)器端)或者IoConnector(客戶端)。Mina內(nèi)部具體是怎么實現(xiàn)偵聽,處理連接的呢?我們先來介紹一下Mina的方法哲學(xué)或者說術(shù)語吧。
IoSession
IoSession: IoSession是一個客戶連接的抽象,整個通訊框架可以說,都是圍繞著IoSession工作的。
IoAcceptor: 初始化服務(wù)器,用的就是它
IoProcessor: 負責(zé)處理IoSession,包括創(chuàng)建,移除,讀寫事件的處理
IoFilter: 過濾消息或者說消息處理(通訊層的)
IoHandler: 消息處理(應(yīng)用邏輯層的)
通訊層的核心類,事實上是IoAcceptor,IoProcessor,IoSession。在這里我們只分析IoAcceptor模式,也就是服務(wù)器端的代碼。客戶端的代碼與此類似,大家可以自己研究。
首先,調(diào)用IoAcceptor.bind()方法時,服務(wù)器已經(jīng)初始化完畢,這時服務(wù)器就在指定的端口上開始偵聽客戶端發(fā)來的連接請求。
當(dāng)IoAcceptor偵聽到客戶端請求時,它就會把這個請求交給IoProcessor進行處理。然后IoAcceptor回去繼續(xù)偵聽。顯然,IoAcceptor的工作流程就是 偵聽 --> 傳遞請求 --> 繼續(xù)偵聽。
IoProcessor得任務(wù)則是處理這些連接的IO事件。顯然IoProcessor不可能和IoAcceptor在同一個線程里運行。他們兩個分工不同,可以并發(fā)執(zhí)行。Mina內(nèi)部事實上維護了一個IoProcessor對象池,對象池的默認大小是CPU個數(shù)+1.也就是說,如果你的機器是4核的,可能就有5個IoProcessor(可以理解為線程)同時工作。
看看下面的示意圖吧,一圖勝千言:
#p#
在這里主要分析IoAcceptor 和 IoProcessor。
IoAcceptor比較簡單,它的核心代碼都在AbstractPollingAccetor里,輪詢代碼在它的內(nèi)部類Accetpor里的run方法里。請看下面的UML圖:
IoProcessor比較復(fù)雜,它的主要代碼是在AbstractPollingProcessor里的,輪詢代碼在它的內(nèi)部類Processor里的run方法實現(xiàn)。值得注意的是,IoAcceptor所持有的IoProcessor引用,事實上是一個對象池。對象池負責(zé)調(diào)度某個Processor來處理請求。下面是UML類圖
【編輯推薦】
- 巧解使Eclipse崩潰的JVM terminated問題
- JVM terminated令Eclipse崩潰問題的解決
- Java編譯過程與c/c++編譯過程有何不同
- 淺談jvm.dll裝載過程與源代碼分析
- Java虛擬機(JVM)中的內(nèi)存設(shè)置詳解
新聞標(biāo)題:解析Mina代碼三部曲
瀏覽路徑:http://m.fisionsoft.com.cn/article/dpcihpe.html


咨詢
建站咨詢
