1.IoService的作用

IoService提供了基本的io服務(wù)并管理 I/O Sessions，詳細內(nèi)容如下：

• sessions管理 : 創(chuàng)建和刪除sessions, 檢測 idleness.
• 過濾器鏈管理 : 處理過濾鏈, 允許用戶改變過濾鏈
• handler 觸發(fā): 當接收到新消息等時，調(diào)用 handler
• 統(tǒng)計管理 : 更新下面發(fā)送的信息量：消息, 比特流, 和其他的東西
• 監(jiān)聽器管理 : 管理用戶可以建立的監(jiān)聽器
• 通信管理 : 處理服務(wù)端和客戶端兩者之間的數(shù)據(jù)傳輸

2.IoService詳細

IoService是所有IoConnector和IoAcceptor的父接口，提供io服務(wù)和session管理。提供了如下方法：

• getTransportMetadata()
• addListener()
• removeListener()
• isDisposing()
• isDisposed()
• dispose()
• getHandler()
• setHandler()
• getManagedSessions()
• getManagedSessionCount()
• getSessionConfig()
• getFilterChainBuilder()
• setFilterChainBuilder()
• getFilterChain()
• isActive()
• getActivationTime()
• broadcast()
• setSessionDataStructureFactory()
• getScheduledWriteBytes()
• getScheduledWriteMessages()
• getStatistics()

?

3.服務(wù)端IoService之IoAcceptor

創(chuàng)建

public TcpServer() throws IOException {// Create a TCP acceptorIoAcceptor 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..."); } // Create an UDP acceptor IoAcceptor acceptor = new NioDatagramAcceptor();

銷毀

// Stop the service, waiting for the pending sessions to be inactive acceptor.dispose(); 或者 // Stop the service, waiting for the processing session to be properly completed acceptor.dispose( true );

獲取IoService狀態(tài)：

isActive()

isDisposing()

isDisposed()

管理IoHandler

setHandler(IoHandler) 或者 getHandler()

管理過濾器鏈

// Add a logger filter DefaultIoFilterChainBuilder chain = acceptor.getFilterChain(); chain.addLast("logger", new LoggingFilter());或者 // 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);

?

?

4.客戶端IoService之IoConnector

• NioSocketConnector : the non-blocking Socket transport Connector
• NioDatagramConnector : the non-blocking UDP transport * Connector*
• AprSocketConnector : the blocking Socket transport * Connector*, based on APR
• ProxyConnector : a Connector providing proxy support
• SerialConnector : a Connector for a serial transport
• VmPipeConnector : the in-VM * Connector*

?

?

?

?

?

?

?

?

?

?

?

?

?

?

轉(zhuǎn)載于:https://www.cnblogs.com/davidwang456/archive/2013/04/09/3000717.html

總結(jié)

以上是生活随笔為你收集整理的mina 之IoService（翻译）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。