发表时间:2010-01-28
最后修改:2010-01-29
最近在学习NIO的技术,因此了解了一下Apache MINA,阅读了它的一部分代码,将自己的理解记录下来。
我用的是MINA版本是2.0.0 RC1,下载地址是http://mina.apache.org/
。据官方文档的介绍,2.0版本相比1.x版本有较大的变化,比如包结构、类名等等。
我是通过一个简单的服务程序的例子进行跟踪调试来分析它的源代码的,主要的理解有以下几点:
- MINA是基于事件驱动的,在应用层是先使用Filter对接收到的数据进行过滤,然后使用Handler进行业务上的处理。
- 各部分之间是通过NioSession来进行数据的共享、传递,一个Session对应于一个SocketChannel。
- 底层的网络功能是由NioAcceptor、NioProcesser来处理的。其中,NioAcceptor主要是进行ServerSocketChannel的绑定、OP_ACCEPT事件的注册监听;NioProcesser是负责Read、Write的事件注册监听、数据读写等。默认情况下,一个程序有一个Accetor,每个Acceptor有一个Selector(只负责OP_ACCEPT事件)、一个线程池(默认是用ExecutorService.newCachedThreadPool()创建的,里面实际上只运行了一个Acceptor线程);默认情况下,NioProcessor的个数等于机器的CPU个数加1,每个NioProcessor有一个Selector(负责OP_READ、OP_WTITE),每个NioProcessor可以处理多个NioSession(也就是说这些Session对应的Channel都在这个NioProcessor的Selector里注册),各个NioProcessor共用一个线程池(里面实际运行的线程数等于NioProcessor的个数,也就是一个NioProcessor对应一个Processor线程)。
- 当NioSession被add到一个NioProcessor之后,OP_READ事件马上就被注册了,然后Selector会被wake以处理新增加的NioSession;但是OP_WRITE事件要等到有数据要写得时候才会注册(据我的观察是这样,而且它会在数据已经发出之后再注册一遍,等到下一次没数据可写得时候再取消OP_WRITE)。
参考资料:http://www.ibm.com/developerworks/cn/java/j-lo-mina2/