本章,我們講述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..."); }這樣,建立了一個Tcp Server,如果你想建立一個UDP server,那麼可以改為IoAcceptor acceptor = new NioDatagramAcceptor();
要釋放該連接,則可調用
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);