如何解析Mina代碼

小編給大家分享一下如何解析Mina代碼,相信大部分人都還不怎么了解,因此分享這篇文章給大家參考一下,希望大家閱讀完這篇文章后大有收獲,下面讓我們一起去了解一下吧!

創(chuàng)新互聯(lián)是一家集網站建設,九臺企業(yè)網站建設,九臺品牌網站建設,網站定制,九臺網站建設報價,網絡營銷,網絡優(yōu)化,九臺網站推廣為一體的創(chuàng)新建站企業(yè),幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強企業(yè)競爭力??沙浞譂M足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網需求。同時我們時刻保持專業(yè)、時尚、前沿,時刻以成就客戶成長自我,堅持不斷學習、思考、沉淀、凈化自己,讓我們?yōu)楦嗟钠髽I(yè)打造出實用型網站。

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

Mina的優(yōu)勢:

1. 用NIO實現(xiàn),無需太多線程??梢蕴幚淼牟l(fā)量更大。

2. 對于應用層來說,編程更方便。

好了廢話少說,先看個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è)務處理類       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是我們要操作的服務器對象。然后,向Acceptor里注冊了兩個filter。filter的概念類似于web服務器里的filter。filter處于你的業(yè)務端代碼和具體的發(fā)送數(shù)據(jù)代碼之間,它負責過濾或者說處理傳遞過來的信息。業(yè)務處理代碼,寫在Handler里。

代碼結構相當?shù)那逦?。我們需要填寫的業(yè)務代碼就是 Handler 和 Filter了。它們倆很相似,但是在概念上是有區(qū)別的。filter事實上主要是處理底層的通信字節(jié)流,通信協(xié)議等,一般跟業(yè)務邏輯沒什么關系。Handler是專門暴露給應用開發(fā)者,用來填寫業(yè)務處理代碼的。

看看下面的圖便知道了

如何解析Mina代碼

Mina暴露給開發(fā)者的接口主要是IoAcceptor(服務器端)或者IoConnector(客戶端)。Mina內部具體是怎么實現(xiàn)偵聽,處理連接的呢?我們先來介紹一下Mina的方法哲學或者說術語吧。

IoSession

IoSession: IoSession是一個客戶連接的抽象,整個通訊框架可以說,都是圍繞著IoSession工作的。

IoAcceptor: 初始化服務器,用的就是它

IoProcessor: 負責處理IoSession,包括創(chuàng)建,移除,讀寫事件的處理

IoFilter: 過濾消息或者說消息處理(通訊層的)

IoHandler: 消息處理(應用邏輯層的)

通訊層的核心類,事實上是IoAcceptor,IoProcessor,IoSession。在這里我們只分析IoAcceptor模式,也就是服務器端的代碼??蛻舳说拇a與此類似,大家可以自己研究。

首先,調用IoAcceptor.bind()方法時,服務器已經初始化完畢,這時服務器就在指定的端口上開始偵聽客戶端發(fā)來的連接請求。

當IoAcceptor偵聽到客戶端請求時,它就會把這個請求交給IoProcessor進行處理。然后IoAcceptor回去繼續(xù)偵聽。顯然,IoAcceptor的工作流程就是 偵聽 --> 傳遞請求 --> 繼續(xù)偵聽。

IoProcessor得任務則是處理這些連接的IO事件。顯然IoProcessor不可能和IoAcceptor在同一個線程里運行。他們兩個分工不同,可以并發(fā)執(zhí)行。Mina內部事實上維護了一個IoProcessor對象池,對象池的默認大小是CPU個數(shù)+1.也就是說,如果你的機器是4核的,可能就有5個IoProcessor(可以理解為線程)同時工作。

看看下面的示意圖吧,一圖勝千言:

如何解析Mina代碼

在這里主要分析IoAcceptor 和 IoProcessor。

IoAcceptor比較簡單,它的核心代碼都在AbstractPollingAccetor里,輪詢代碼在它的內部類Accetpor里的run方法里。請看下面的UML圖:

如何解析Mina代碼

IoProcessor比較復雜,它的主要代碼是在AbstractPollingProcessor里的,輪詢代碼在它的內部類Processor里的run方法實現(xiàn)。值得注意的是,IoAcceptor所持有的IoProcessor引用,事實上是一個對象池。對象池負責調度某個Processor來處理請求。下面是UML類圖

如何解析Mina代碼

以上是“如何解析Mina代碼”這篇文章的所有內容,感謝各位的閱讀!相信大家都有了一定的了解,希望分享的內容對大家有所幫助,如果還想學習更多知識,歡迎關注創(chuàng)新互聯(lián)行業(yè)資訊頻道!

網站名稱:如何解析Mina代碼
文章來源:http://muchs.cn/article18/gpgpdp.html

成都網站建設公司_創(chuàng)新互聯(lián),為您提供靜態(tài)網站、App開發(fā)面包屑導航、虛擬主機外貿建站、網站排名

廣告

聲明:本網站發(fā)布的內容(圖片、視頻和文字)以用戶投稿、用戶轉載內容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內容未經允許不得轉載,或轉載時需注明來源: 創(chuàng)新互聯(lián)

網站托管運營