在Mina的API中提供了一個(gè)ExecutorFilter，該線程池實(shí)現(xiàn)了IoFilter接口，它可以作為一個(gè)IoFilter添加到IoFilterChain中，它的作用就是將I/O Processor中的事件通過其自身封裝的一個(gè)線程池來轉(zhuǎn)發(fā)到下一個(gè)過濾器中。在沒有添加該線程模型時(shí)，I/O Processor的事件是通過方法來觸發(fā)的，然后轉(zhuǎn)發(fā)給IoHandler。在沒有添加該線程池的時(shí)候，所有的事件都是在單線程模式下運(yùn)行的，也就是說有的事件和處理(IO Processor，IoHandler，IoFilter)都是運(yùn)行在同一個(gè)線程上，這個(gè)線程就是IO Processor的線程，但是這個(gè)線程的數(shù)量受到CPU核數(shù)的影響，因此系統(tǒng)的性能也直接受CPU核數(shù)的影響。

比較復(fù)雜的應(yīng)用一般都會(huì)用到該線程池，你可以根據(jù)你的需求在IoFilterchain中你可以添加任意數(shù)量的線程池，這些線程池可以組合成一個(gè)事件驅(qū)動(dòng)(SEDA)的處理模型。對(duì)于一般的應(yīng)用來說不是線程的數(shù)量越多越好，線程的數(shù)量越多可能會(huì)加劇CPU切換線程所耗費(fèi)的時(shí)間，反而會(huì)影響系統(tǒng)的性能，因此，線程的數(shù)量需要根據(jù)實(shí)際的需要由小到大，逐步添加，知道找到適合你系統(tǒng)的最佳線程的數(shù)量。ExcutorFilter的配置過程如下：

    
      
        SocketAcceptor acceptor = ...; DefaultIoFilterChainBuilder filterChainBuilder = acceptor.getDefaultConfig().getFilterChain(); filterChainBuilder.addLast("threadPool", new ExecutorFilter(Executors.newCachedThreadPool()); 
      
    
  

?在配置該線程池的時(shí)候需要注意的一個(gè)問題是，當(dāng)你使用自定的ProtocolCodecFactory時(shí)候一定要將線程池配置在該過濾器之后，如下所示：

    
      
        DefaultIoFilterChainBuilder filterChainBuilder = acceptor.getDefaultConfig().getFilterChain(); // 和CPU綁定的操作配置在過濾器的前面 filterChainBuilder.addLast("codec", new ProtocolCodecFactory(...)); // 添加線程池 filterChainBuilder.addLast("threadPool", new ExecutorFilter(Executors.newCachedThreadPool()); 
      
    
  

?因?yàn)槟阕约簩?shí)現(xiàn)的ProtocolCodecFactory直接讀取和轉(zhuǎn)換的是二進(jìn)制數(shù)據(jù)，這些數(shù)據(jù)都是由和CPU綁定的I/O Processor來讀取和發(fā)送的，因此為了不影響系統(tǒng)的性能，也應(yīng)該將數(shù)據(jù)的編解碼操作綁定到I/O Processor線程中，因?yàn)樵贘ava中創(chuàng)建和線程切換都是比較耗資源的，因此建議將ProtocolCodecFactory配置在ExecutorFilter的前面。關(guān)于ProtocolCodecFactory詳細(xì)講述會(huì)在后續(xù)的文檔中給出，此處就不多說了。

最后給出一個(gè)服務(wù)器線程模型完整配置的例子，該例子和KFCClient一起配置使用，詳細(xì)代碼在附件中，此處只給出代碼的主要部分：???????

    
      
        SocketAddress address = new InetSocketAddress("localhost", 4321); /*** * 配置SocketAcceptor監(jiān)聽器的I/O Processor的線程的數(shù)量, 此處的I/O * Processor的線程數(shù)量由CPU的核數(shù)決定，但Acceptor 的線程數(shù)量只有一個(gè)，也就是接收客戶端連接的線程數(shù)只有一個(gè)， * Acceptor的線程數(shù)量不能配置。 * */ IoAcceptor acceptor = new SocketAcceptor(Runtime.getRuntime() .availableProcessors() + 1, Executors.newCachedThreadPool()); acceptor.getDefaultConfig().setThreadModel(ThreadModel.MANUAL); // 配置數(shù)據(jù)的編解碼器 acceptor.getDefaultConfig().getFilterChain().addLast("codec", new ProtocolCodecFilter(new ObjectSerializationCodecFactory())); // 此處為你自己實(shí)現(xiàn)的編解碼器 // config.getFilterChain().addLast("codec", new // ProtocolCodecFactory(...)); // 為IoFilterChain添加線程池 acceptor.getDefaultConfig().getFilterChain().addLast("threadPool", new ExecutorFilter(Executors.newCachedThreadPool())); acceptor.getDefaultConfig().getFilterChain().addLast("logger", new LoggingFilter()); // 綁定服務(wù)器端口 acceptor.bind(address, new KFCFoodPriceHandler()); System.out.println(" 服務(wù)器開始在 8000 端口監(jiān)聽 ......."); // ==========================================// // 此處為客戶端的I/O Processor線程數(shù)的配置，你可以模仿 // // IoAcceptor配置來實(shí)現(xiàn) // // ==========================================// /*** * 配置SocketConnector監(jiān)聽器的I/O Processor的線程的數(shù)量, 此處的I/O * Processor的線程數(shù)量由CPU的核數(shù)決定，但SocketConnector * 的線程數(shù)量只有一個(gè)，也就是接收客戶端連接的線程數(shù)只有一個(gè)， SocketConnector的線程數(shù)量不能配置。 * */ // SocketConnector connector = new SocketConnector(Runtime.getRuntime() // .availableProcessors() + 1, Executors.newCachedThreadPool()); } 
      
    
    
      
      
    
  

深入理解Apache Mina（5）---- 配置Mina的 線程模型