Mina基础概念二

╰+哭是因爲堅強的太久メ 2022-06-13 08:47 143阅读 0赞

### Mina API ###

1、IoService：这个接口是服务端 IoAcceptor、客户端 IoConnector 的抽象，提供 IO 服务和管理 IoSession 的功能

2、IoAcceptor：可以多次调用 bind()方法（或者在一个方法中传入多个 SocketAddress 参数）同时监听多个端口。

3、ConnectFuture connect(SocketAddress remoteAddress,SocketAddress localAddress)方法，用于与 Server 端建立连接，第二个参数如果不传递则使用本地的一个随机端口访问 Server 端。这个方法是异步执行的，同样的，也可以同时连接多个服务端。

4、IoSession 这个接口用于表示 Server 端与 Client 端的连接，IoAcceptor.accept()的时候返回实例。 它有几个方法：write、close、setAttribute等

5、IoHandler一系列API  
如果你每隔一段时间，发送一些数据，那么 sessionCreated()方法只会在第一次调用，但是 sessionOpened()方法每次都会调用。  对于 TCP 来说，sessionOpened()是在连接被建立之后调用，你可以在这里执行一些认证操作、发送数据等。 消息发送成功之后，调用messageSent()。 接收到消息时调用方法messageReceived()，一般情况下，message 是一个 IoBuffer 类，如果你使用了协议编解码器，那么可以强制转换为你需要的类型。

connectFuture等

在 Mina 的很多操作中，你会看到返回值是 XXXFuture，实际上他们都是 IoFuture 的子类，主要的子类有 ConnectFuture、 CloseFuture 、 ReadFuture 、 WriteFuture 。看到这样的返回值，这个方法就说明是异步执行的，这个接口的大部分操作都和 java.util.concurrent.Future 接口是类似的,比如awaitUninterruptibly() ， 一般我们常用 awaitUninterruptibly()方法可以等待异步执行的结果返回。  研究下他的API中addListener方法，他是异步执行的，与awaitUninterruptibly()对比下，后者是异步转同步，连接过程中会阻塞在那里。

### 关于TCP连接的关闭 ###

无论在客户端还是服务端，IoSession 都用于表示底层的一个 TCP 连接，那么你会发现无论 是Server端还是Client端的IoSession调用close()方法之后，TCP连接虽然显示关闭， 但主线程仍然在运行，也就是 JVM 并未退出，这是因为 IoSession 的 close()仅仅是关闭了 TCP 的连接通道， 并没有关闭 Server 端、Client 端的程序。你需要调用 IoService 的 dispose() 方法停止 Server 端、Client 端。

### mina执行流程 ###

![Center][]

从Mina 执行流程图可以看出，在 IoProcessor 与 IoHandler 之间可以有很多的过滤器，这种设计方式为你提供可插拔似的扩展功能提供了非常便利的方式，目前的 Apache CXF、Apache Struts2 中的拦截器也都是一样的设计思路。Mina 中的 IoFilter 是单例的，IoService 实例上会绑定一个 DefaultIoFilterChainBuilder 实例， DefaultIoFilterChainBuilder会把使用内部的EntryImpl类把所有的过滤器按照顺序连在一起，组成一个过滤器链。无论是哪个方法，要注意必须在实现时调用参数 nextFilter 的同名方法，否则，过滤器链的执行将被中断，IoHandler 中的同名方法一样也不会被执行。

下面我们完整的综述一下 Mina 的工作流程：  
(1.) IoService 这个接口在一个线程上负责套接字的建立，拥有自己的 Selector，监听是否有连接被建立。   
(2.) IoProcessor：这个接口在另一个线程上负责检查是否有数据在通道上读写，也就是 说它也拥有自己的 Selector，这是与我们使用 JAVA NIO 编码时的一个不同之处， 通常在 JAVA NIO 编码中，我们都是使用一个 Selector，也就是不区分 IoService 与 IoProcessor 两个功能接口。另外，IoProcessor 负责调用注册在 IoService 上 的过滤器，并在过滤器链之后调用 IoHandler。  
(3.) IoFilter：这个接口定义一组拦截器，这些拦截器可以包括日志输出、黑名单过滤、 数据的编码（write 方向）与解码（read 方向）等功能，其中数据的 encode 与 decode 是最为重要的、也是你在使用 Mina 时最主要关注的地方。

设置日志的输出级别，默认是debug

LoggingFilter lf = new LoggingFilter(); 
    lf.setSessionOpenedLogLevel(LogLevel.ERROR);
    acceptor.getFilterChain().addLast("logger", lf);

(4.) IoHandler：这个接口负责编写业务逻辑，也就是接收、发送数据的地方。

参考：Mina\_2.0中文参考手册V1.0.pdf

[Center]: /images/20220613/101cc7078a4541caa76a88bad5a25d8d.png