Apache Mina 學習筆記(3) - IoService

本章，我們講述MINA的IoService - 一個在服務端、客戶端提供所有I/O服務的基本類，作用於與對端的收發訊息，管理sseions，連接等。

它是一個接口，在服務端由IoAcceptor實現，客戶端由IoConnector實現。

我們會在下面這幾部分中介紹這個介面：

IoService Introduction
IoService Details
IoAcceptor
IoConnector
IoService 簡介5ions
IoConn？它是Mina十分關鍵的部分。

如上圖所述，IoService有很多的職責：

會話管理
過濾鏈管理
Handler調用
統計管理
監聽管理
;

當IoAcceptor或IoConnector運行的時候，該方法返回傳輸的元數據，通常包括name(nio,apr,txtx),連接類型（面向連接或無連接）。

addListener

允許新增一個IoServiceListener去監聽指定的事件

removeListener

移除一個指定的IoserviceListener

isDisposingcom Dispose，那麼返回服務的狀態

dispose

用來釋放服務申請的所有資源，使用者需要用上述兩個方法先檢查服務是否已經完全dispose。當你要關閉服務時，請務必呼叫該方法

getHandler

返回與服務關聯的方法

setHandler

設定IoHandler去解決伺服器得到的請求，該Handler傳回session的配置

getFilterChainBuilder

回傳Filter chain builder，當需要加入過濾的時候，需要呼叫該方法。

IoService 詳細

Ioservice 這個介面在MINA中被兩個重要的類別實作：IoAcceptor 和 IoConnector。在服務端，你需要選擇IoAcceptor，而在客戶端你需要選用IoConnector。

IoAcceptor

在MINA中，有一些已經實現的類別：

NioSocketAcceptor : the non-blocking Socket transport IoAcceptor
NioDatagram: the non-blocking Socket transport IoAcceptor
NioDatagramsceptor et transport IoAcceptor, based on APR
VmPipeSocketAcceptor : the in-VM IoAcceptor

選擇一個你需要的IoAcceptor。

下圖是IoAcceptor類別和介面




IoConnector

NioSocketConnector : the non-blocking Socket transport IoConnector
NioDatacideSopk blocking Socket transport IoConnector, based on APR
ProxyConnector : a IoConnector providing proxy support
SerialConnector : a IoConnector for a serial transport
VmPipeConnector : the in-VM IoConnector

public TcpServer() throws IOException {  
    // Create a TCP acceptor  
    IoAcceptor acceptor = new NioSocketAcceptor();  
  
    // Associate the acceptor to an IoHandler instance (your application)  
    acceptor.setHandler(this);  
  
    // Bind : this will start the server...  
    acceptor.bind(new InetSocketAddress(PORT));  
  
    System.out.println("Server started...");  
}

要釋放該連接，則可調用

acceptor.dispose(true)

// Add a logger filter  
DefaultIoFilterChainBuilder chain = new DefaultIoFilterChainBuilder();  
chain.addLast("logger", new LoggingFilter());  
  
// And inject the created chain builder in the service  
acceptor.setFilterChainBuilder(chain);