Apache mina基本上可以看成是一个基于java nio的web通信框架,特点是编程接口简单,但是功能完善,性能也不错。
mina可以提供基于TCP、UDP、符合RS232的顺序通信以及vm内部的基于管道的通信,这些通信方式都以一致的接口暴露,通过接口的不同实现完成。首先来看一下这些接口已经他们之间的交互关系。
主要的接口包括以下几个:
IOService:IOAcceptor和IOConnector的父接口,定义了两者都会用到的一些方法;
IOAcceptor:服务器端需要实现的接口;
IOConnector:客户端需要实现的接口;
IOProcessor:mina内部使用的一个接口,用来管理session,并且利用session来完成具体的io操作
IOSession:每个IOSession都表示一种类型的连接,并且维护与这个链接有关的所有信息。
IOFilter:mina中,发送和接收消息时都需要经过一个过滤器链,这个链用来进行日志记录、编码转换等工作。
这几个接口之间的协作关系如下:
另外还有一个接口,叫做IOHandler,这个接口被注册到IOAcceptor或者IOConnector中,是客户端必须要实现的一个接口,通过这接口里面的方法客户端可以通过mina提供的通信框架发送或者接收网络消息,以及其他的一些事件,比如Session创建等。这个接口接收到的消息是经过IOFilter链过滤过的,通过这个接口发送的消息也需要经过IOFilter链的过滤。读网络上的数据的时候过滤发生在IOProcessor中,而由于写是在IOHandler中直接触发的,所以写的过滤是在IOSession中发生的。
下面简要介绍一下TCP通信方式下,服务器端的启动、绑定和channel建立过程,客户端的连接和channel简历过程大致类似。
TCP的通信涉及到服务器端和客户端,在mina中服务器端使用一个叫做NioSocketAcceptor的类来表示,它继承自AbstractPollingIoAcceptor,从名字可以看出,mina的TCP服务器端实现的基本原理是轮询,在老版本的mina中(也就是netty)中就是这么实现的,只不过由于Java后来有了nio,也就把实现迁移到nio上了。
创建NioSocketAcceptor的时候会创建一个NIOProcessor,这是IOProcessor的一个实现类,这个Processor会被用来管理后续创建的NIOSession。在默认情况下,如果不指定IOProcessor,mina会把这个NIOProcessor在封装一下,变成一个SimpleIoProcessorPool,这个IOProcessor池同时也实现了IOProcessor接口,所以可以被当成IOProcessor来使用,这个是一个Wrapper模式的应用。在SimpleIoProcessorPool内部,会根据IOProcessor的具体类型创建一个或者多个IOProcessor实例,在使用NioSocketAcceptor的时候,就会创建一个或者多个NIOProcessor的实例。这个不是真正意义上的池,因为内部实现是把所有的NIOProcessor放到一个数组中,在有新的NIOSession被创建的时候会从数组中根据NIOSession的id对数组的长度取模,然后拿到一个IOProcessor来处理NIOSession。这些初始化工作完成之后,NioSocketAcceptor就会打开java nio里面的Selector,但是这个时候还没有真正开始接受连接请求,我们需要把这个NioSocketAcceptor绑定到一个具体的地址上。
绑定调用NioSocketAcceptor的bind方法,传入一个或者一组地址。NioSocketAcceptor会启动一个名字叫Acceptor的线程来完成绑定工作。绑定的过程简单来说就是开一个ServerSocketChannel,然后把它与Selector关联起来,用来接收连接请求。这个线程会一直运行,直到被取消绑定为止。每次调用bind方法,都会开这么一个线程,所有的线程都被放到一个线程池里面运行,这个线程池用的是java Executor线程池框架,这些线程池共用一个Selector。
当有新的连接请求过来之后,也就是TCP的客户端调用了NIOSocketConnector的connect方法之后,Acceptor线程会把这个请求转换成一个NIOSession,然后添加到 NIOProcessor中。在默认情况下,Acceptor会首先从SimpleIoProcessorPool里面选取一个NIOProcessor,然后调用这个NIOProcessor的add方法来把NIOSession添加到这个NIOProcessor中。这个过程NIOProcessor会启动一个名叫Processor的线程来处理与这个NIOSession有关的所有IO操作。默认情况下,每个NIOProcessor会用调用Executors.newCachedThreadPool()来创建一个线程池,其中的每个线程都会运行一个Processor,而每个Processor又都会关联到一个NIOSession。这个线程会在通信被服务器端或者客户端主动关闭,或者满足空闲条件的时候被终止。每一个NIOProcessor中管理的Session都共用同一个Selector。
mina支持用一个或者多个线程池来处理所有的IO请求,这个其实是通过设置SimpleProcessorPool里面的IOProcessor数组长度来实现的。因为每一个IOProcessor自己会维护一个线程池来处理所有的IO请求(每一次IO请求就是一个Session),如果把IOProcessor的数组长度设置成1,就是用一个线程池来处理所有的IO请求,如果大于1,那么就是用多个线程池来处理所有的IO请求。
客户端的处理过程大致类似,也是通过IOProcessor处理和维护所有的IO请求,只不过少了bind这一步操作。
- 大小: 5.9 KB
分享到:
相关推荐
mina连接,mina心跳连接,mina断线重连。其中客户端可直接用在android上。根据各方参考资料,经过自己的理解弄出来的。CSDN的资源分太难得了。
mina的使用初步入门mina的使用初步入门mina的使用初步入门
mina-core-2.0.0-M6.jar mina-example-2.0.0-M6.jar mina-filter-codec-netty-2.0.0-M6.jar mina-filter-compression-2.0.0-M6.jar mina-integration-beans-2.0.0-M6.jar mina-integration-jmx-2.0.0-M6.jar mina-...
里面包含mina2.0的api(英文)和mina自学手册,还有mina的开发指导
mina的高级使用,mina文件图片传送,
深入理解Apache_Mina_(1)----_Mina的几个类 深入理解Apache_Mina_(2)----_与IoFilter相关的几个类 深入理解Apache_Mina_(3)----_与IoHandler相关的几个类 深入理解Apache_Mina_(4)----_IoFilter和IoHandler的区别和...
mina内部源码,可以深入的研究下,重构修改后获得的效率更加突出
Apache MINA是 Apache 组织一个较新的项目,它为开发高性能和高可用性的网络应用程序提供了非常便利的框架。 当前发行的 MINA 版本支持基于 Java NIO 技术的 TCP/UDP 应用程序开发、串口通讯程序(只在最新的预览版...
Apache Mina Server 2.0中文参考手册V1.0,Apache Mina2.0学习笔记(修订版)Apache Mina Server 2.0中文参考手册V1.0,Apache Mina2.0学习笔记(修订版)
mina.jar 包,内涵mina所需的所有jar包, 解压即可,测试可用。mina.jar 包,内涵mina所需的所有jar包, 解压即可,测试可用。
mina运行最基本的demo,实现客户端输入数据的返回。其中还包含mina的jar包
项目包含有mina的服务端与客户端,客户端发送心跳包,服务端响应心跳包
mina客户端,服务器端的demo
mina mina传输对象的示例 mina框架 mina示例
mina demo
mina源码
1.mina socket客户度工程相关类,添加mina jar包后可独立运行。 2.mina若有空闲连接则使用已有连接,若无则新建mina连接; 3.mina空闲连接超过保活时间25分钟后,自动删除; 4.mina发送指令后,接收指定时长内收到的...
许多刚接触mina的朋友,对于mina的编解码器的编写很迷惑.希望这个文档可以帮助朋友们少走弯路。 资源中是一个比较典型的编解码器写法。生成了可执行文件。并对编解码器的代码有详细注释。
mina新手案例,mina新手教程源码 mina+springboot最简单的案例。用的IDEA * mina服务端 * 1、添加@Controller注解和 @PostConstruct注解,代表启动springboot项目时也调用该类下的该方法, * 启动springboot项目...
MINA开发文档总结,有如下内容Apache_Mina_Server_2.0中文参考手册V1.0.pdf 深入理解Apache_Mina.pdf MINA2官方教程翻译.pdf Mina2源码分析.pdf