<rt id="bn8ez"></rt>
<label id="bn8ez"></label>
  • 

    • <span id="bn8ez"></span>
    

    <label id="bn8ez"><meter id="bn8ez"></meter></label>
    

    
    

    




    







												


        

    
	

    
	
    
		
    
			
				
    夢幻之旅
    
				
    DEBUG - 天道酬勤
    
			    		
		
    
	
    

    

    
	
    
		
    
			
 
 ::
首頁 ::
新隨筆 ::
聯系 ::
聚合
 ::
管理 ::


			
			
				

    
	
    
		
    
			
			
			
				 
				671 
				隨筆 ::
				6 文章
				::
				256 評論
				::
				0 Trackbacks
			
		
    
	
    

    

			    		
		
    
	
    

    


    


    
	
					

    
	
	
	
    
		
    簡單介紹：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. }  
    

     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自帶的線程池  
      

    

    

    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  
    

     
    

    現在詳細描述一下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. */  
    

     然后到
    

    

    

    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.  */  
      

    然后到
    

    

    

    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. */  
    
	
    
	
	
    
		posted on 2011-09-04 02:28 HUIKK 閱讀(496) 評論(0)  編輯  收藏  所屬分類: java Net 
	
    

    







    
	    
    




    








    

				

    




    







    
        
	



主站蜘蛛池模板：
国产成人A亚洲精V品无码|
国产成人亚洲精品电影|
四虎在线免费视频|
亚洲avav天堂av在线网毛片|
亚洲色欲一区二区三区在线观看
|
国产成人亚洲精品电影|
中文字幕亚洲一区二区va在线|
久久综合国产乱子伦精品免费|
亚洲色欲色欲www在线播放|
国产日韩成人亚洲丁香婷婷|
久久久久久精品免费看SSS|
黄色毛片免费观看|
亚洲成a人不卡在线观看|
亚洲AV网站在线观看|
国产精彩免费视频|
日韩毛片一区视频免费|
亚洲国色天香视频|
国产日产亚洲系列最新|
成年美女黄网站色大免费视频|
国产精品偷伦视频观看免费|
久久精品国产亚洲av瑜伽|
在线观看亚洲人成网站|
亚洲日韩在线第一页|
热99re久久精品精品免费|
亚洲视频在线免费看|
最近更新免费中文字幕大全|
国产精品亚洲精品爽爽|
久久精品国产亚洲AV忘忧草18|
亚洲AV无码专区亚洲AV伊甸园|
亚洲а∨天堂久久精品|
最新猫咪www免费人成|
16女性下面无遮挡免费|
国产一二三四区乱码免费|
亚洲AV无码一区二区三区鸳鸯影院|
亚洲欧洲日本天天堂在线观看|
色噜噜AV亚洲色一区二区|
国产人妖ts在线观看免费视频|
嘿嘿嘿视频免费网站在线观看|
国产一精品一av一免费爽爽|
一区二区三区免费视频观看|
国产精品亚洲一区二区在线观看|