Apache MINA (3) NioSocketAcceptor初始化

上一篇博客ApacheMINA(2)HelloWorld!以一個例子實現(xiàn)了mina客戶端和服務(wù)端的通訊，現(xiàn)在通過源碼來了解建立連接和通訊的過程（基于tcp/ip的實現(xiàn)）。

服務(wù)端通過創(chuàng)建一個NioSocketAcceptor來接受請求，客戶端通過創(chuàng)建NioSocketConnector來連接服務(wù)端并發(fā)送請求，從整體的體系結(jié)構(gòu)來看二者的關(guān)系。

IoService是對于服務(wù)器端接受連接和客戶端發(fā)起連接兩類行為的一個抽象。IoServer用來執(zhí)行真正的I/O操作，以及管理I/O會話。兩個子接口為IoAcceptor和IoConnector。IoAcceptor用來接受連接，與客戶端進行通訊。IoConnector用來發(fā)起連接，與服務(wù)端進行通訊。IoAcceptor和IoConnector都分別有基于TCP/IP協(xié)議協(xié)議，UDP/IP協(xié)議以及虛擬機管道通訊的子接口。HelloWorld例子里面實現(xiàn)的是基于TCP/IP協(xié)議的通訊，用了mina默認的實現(xiàn)類NioSocketAcceptor和NioSocketConnector。

首先從服務(wù)端的NioSocketAcceptor開始：

1.NioSocketAcceptor的父類為AbstractPollingIoAcceptor，很多實現(xiàn)是在父類中實現(xiàn)的。在構(gòu)造此類的時候，同時也構(gòu)造了NioProcessor類

public NioSocketAcceptor() {
        super(new DefaultSocketSessionConfig(), NioProcessor.class);
        ((DefaultSocketSessionConfig) getSessionConfig()).init(
}
AbstractPollingIoAcceptor

Java代碼

protected AbstractPollingIoAcceptor(IoSessionConfig sessionConfig,
            Class<? extends IoProcessor<S>> processorClass) {
        this(sessionConfig, null, new SimpleIoProcessorPool<S>(processorClass),
                true);
}
SimpleIoProcessorPool

Java代碼

private static final int DEFAULT_SIZE = Runtime.getRuntime().availableProcessors() + 1;
……
public SimpleIoProcessorPool(Class<? extends IoProcessor<S>> processorType) {
        this(processorType, null, DEFAULT_SIZE);
}

初始化NioProcessor，個數(shù)為cpu個數(shù)+1，為每個IoProcessor初始化一個默認的Excutor

this.executor=Executors.newCachedThreadPool();

初始化cpu+1個放到privatefinalIoProcessor<S>[]pool中，用來處理NioSession，所以S為NioSession

public final class NioProcessor extends AbstractPollingIoProcessor<NioSession>…

2.初始化完SimpleIoProcessorPool，回到AbstractPollingIoAcceptor的構(gòu)造方法中,調(diào)用NioSocketAcceptor中的init()方法打開selector通道，完成NioSocketAcceptor的構(gòu)造。

3.然后在上一篇HelloWorld的例子中設(shè)置了SocketSessionConfig的readBufferSize；

接收數(shù)據(jù)的過濾器，例子中設(shè)置的是TextLineCodecFactory（按照行一行為一個單位讀取數(shù)據(jù)）；

實現(xiàn)IoHandlerAdapter來處理客戶的請求。

4.最后執(zhí)行acceptor.bind(newInetSocketAddress(SERVER_PORT))，指定服務(wù)提供綁定的端口，同時執(zhí)行AbstractPollingIoAcceptor中的bindInternal方法,

……
ServerSocketChannel channel = ServerSocketChannel.open();
……

然后配制socket的一些基本屬性，并注冊此事件是可連接的事件

// This is a non blocking socket channel
       channel.configureBlocking(false);

       // Configure the server socket,
       ServerSocket socket = channel.socket();

       // Set the reuseAddress flag accordingly with the setting
       socket.setReuseAddress(isReuseAddress());

       // and bind.
       socket.bind(localAddress, getBacklog());

       // Register the channel within the selector for ACCEPT event
       channel.register(selector, SelectionKey.OP_ACCEPT);

當接收到請求時調(diào)用accept()方法法處理接收連接，把SocektChannel綁定到NioSession中

當接收到請求時調(diào)用accept()方法法處理接收連接，把SocektChannel綁定到NioSession中
Java代碼

綁定完成后喚醒NIO的selector開始接收請求

selector.wakeup();

小結(jié)：

通過解析NioSocketAcceptor的構(gòu)造方法，bind()等代碼大概了解了mina服務(wù)端初始化相關(guān)的一些信息，同時涉及了mina框架相關(guān)的IoProcessorIoSessionIoServiceListener等，在下一篇文章中會再做進一步的分析接收到最終的處理請求的過程。