ApacheMINANioSocketAcceptor初始化.doc

Apache MINA 3 NioSocketAcceptor初始化 Posted by chiyan on 2012-12-10Leave a comment? 1 Go to comments 上一篇博客Apache MINA 2 Hello World!?以一个例子实现了mina客户端和服务端的通讯，现在通过源码来了解建立连接和通讯的过程（基于tcp/ip的实现）。 服务端通过创建一个NioSocketAcceptor来接受请求，客户端通过创建NioSocketConnector来连接服务端并发送请求，从整体的体系结构来看二者的关系。IoService是对于服务器端接受连接和客户端发起连接两类行为的一个抽象。IoServer用来执行真正的 I/O 操作，以及管理 I/O 会话。两个子接口为IoAcceptor和IoConnector。IoAcceptor用来接受连接，与客户端进行通讯。IoConnector用来发起连接，与服务端进行通讯。IoAcceptor和IoConnector都分别有基于TCP/IP协议协议，UDP/IP协议以及虚拟机管道通讯的子接口。Hello World例子里面实现的是基于TCP/IP协议的通讯，用了mina默认的实现类NioSocketAcceptor和NioSocketConnector。 首先从服务端的NioSocketAcceptor开始： 1. NioSocketAcceptor的父类为AbstractPollingIoAcceptor，很多实现是在父类中实现的。在构造此类的时候，同时也构造了NioProcessor类 NioSocketAcceptor Java代码 public?NioSocketAcceptor super new?DefaultSocketSessionConfig ,?NioProcessor.class ; DefaultSocketSessionConfig ?getSessionConfig .init AbstractPollingIoAcceptor Java代码 protected?AbstractPollingIoAcceptor IoSessionConfig?sessionConfig, Class ??extends?IoProcessor ?processorClass this sessionConfig,?null,?new?SimpleIoProcessorPool processorClass , true ; SimpleIoProcessorPool Java代码 private?static?final?int?DEFAULT_SIZE? ?Runtime.getRuntime .availableProcessors ?+?1;?? ……?? public?SimpleIoProcessorPool Class ??extends?IoProcessor ?processorType this processorType,?null,?DEFAULT_SIZE ; 初始化NioProcessor，个数为cpu个数+1，为每个IoProcessor初始化一个默认的Excutor this.executor Executors.newCachedThreadPool ; 初始化cpu+1个放到private final IoProcessor [] pool 中，用来处理NioSession，所以S为NioSession Java代码 public?final?class?NioProcessor?extends?AbstractPollingIoProcessor … 2. 初始化完SimpleIoProcessorPool，回到AbstractPollingIoAcceptor的构造方法中,调用NioSocketAcceptor中的init 方法打开selector通道，完成NioSocketAcceptor的构造。 3. 然后在上一篇Hello World的例子中设置了SocketSessionConfig的readBufferSize； 接收数据的过滤器，例子中设置的是TextLineCodecFactory（按照行一行为一个单位读取数据）； 实现IoHandlerAdapter来处理客户的请求。 4. 最后执行acceptor.bind new InetSocketAddress SERVER_PORT ，指定服务提供绑定的端口，同时执行AbstractPollingIoAcceptor中的bindInternal方法, 调用startupAcceptor 负责初始化内部线程类