Apache Mina 2.0 深入解析与教程
需积分: 43 194 浏览量
更新于2024-07-25
收藏 414KB PDF 举报
"Apache Mina Server 深入教程V1.0"
Apache Mina Server 是一个高度可扩展的网络通信框架，专为构建高性能、高可靠性的网络应用程序而设计。它支持多种通信协议，包括基于TCP/IP和UDP/IP的网络通信，同时也能够处理JAVA对象的序列化和虚拟机内的管道通信。Mina的核心特性在于其事件驱动和异步操作的编程模型，这种模型默认基于Java NIO（非阻塞I/O）技术，以提高系统的并发性能。
Mina有两个主要的版本分支：1.x 和 2.x。在本教程中，我们将关注最新的2.0版本，需要注意的是，如果你正在使用的是Mina 1.x，可能会发现一些特定功能在新版本中不再适用。学习Mina 2.0，你需要具备基础的Java I/O、Java NIO、Java Socket以及Java线程和并发库（如`java.util.concurrent`包中的类和接口）的知识。
在Mina框架中，网络通信的结构被清晰地划分为两部分：服务端（Server）和客户端（Client）。Mina通过API将网络通信的细节与应用程序的业务逻辑隔离开，让开发者可以专注于数据的处理和业务流程。
Mina的工作流程可以概括为以下几个关键组件：
1. **IoService**：该接口在一个单独的线程上运行，负责处理连接的建立。它维护了自己的Selector，用于监听新的连接请求。
2. **IoProcessor**：这个接口在另一个独立的线程中工作，主要职责是检查通道（Channel）上的读写活动。与直接使用Java NIO编程不同，Mina的IoProcessor拥有自己的Selector，这样可以更细粒度地控制数据的读写，而不是像Java NIO那样通常只使用一个全局的Selector。
除此之外，Mina还提供了丰富的过滤器（Filter）机制，允许开发者插入自定义的处理逻辑，这些过滤器可以用于数据编码解码、安全认证、流量控制等多个方面。每个连接都会有一条由多个过滤器组成的链路，数据会在链路上按照过滤器的顺序进行处理。
此外，Mina支持事件驱动的编程模型，当网络事件（如连接建立、数据到达、连接关闭等）发生时，会触发相应的处理器方法，这使得开发者能够以非阻塞的方式处理网络通信，从而提高系统的响应性和吞吐量。
Apache Mina Server 是一个强大的工具，它简化了网络应用的开发，提供了高效的异步I/O处理，并通过过滤器链路和事件驱动模型赋予了高度的灵活性和可扩展性。对于需要构建高性能网络服务的开发者来说，理解并掌握Mina的使用将极大地提升其工作效率和代码质量。
E.
E.E.
E. IoBuffer order(ByteOrder bo)
IoBuffer order(ByteOrder bo)IoBuffer order(ByteOrder bo)
IoBuffer order(ByteOrder bo)：
：：
：
这个方法设置是 Big Endian 还是 Little Endian，JAVA 中默认是 Big Endian，C++和其他
语言一般是 Little Endian。
F.
F.F.
F. IoBuffer asReadOnlyBuffer()
IoBuffer asReadOnlyBuffer()IoBuffer asReadOnlyBuffer()
IoBuffer asReadOnlyBuffer()：
：：
：
这个方法设置 IoBuffer 为只读的。
G.
G.G.
G. B
BB
Boolean pr
oolean proolean pr
oolean prefixedDataAvailable(
efixedDataAvailable(efixedDataAvailable(
efixedDataAvailable(int prefixLength,int maxDataLength
int prefixLength,int maxDataLengthint prefixLength,int maxDataLength
int prefixLength,int maxDataLength)
))
)：
：：
：
这个方法用于数据的最开始的 1、2、4 个字节表示的是数据的长度的情况，prefixLentgh
表示这段数据的前几个字节（只能是 1、2、4 的其中一个）的代表的是这段数据的长度，
maxDataLength 表 示 最 多 要 读 取 的 字 节 数 。 返 回 结 果 依 赖 于 等 式
remaining()-prefixLength>=maxDataLength，也就是总的数据-表示长度的字节，剩下的字
节数要比打算读取的字节数大或者相等。
H.
H.H.
H. String getPrefixedString(int prefixLength,CharsetDecoder decoder)
String getPrefixedString(int prefixLength,CharsetDecoder decoder)String getPrefixedString(int prefixLength,CharsetDecoder decoder)
String getPrefixedString(int prefixLength,CharsetDecoder decoder)：
：：
：
如果上面的方法返回 true，那么这个方法将开始读取表示长度的字节之后的数据，注意要
保持这两个方法的 prefixLength 的值是一样的。
G、H 两个方法在后面讲到的 PrefixedStringDecoder 中的内部实现使用。
IoBuffer 剩余的方法与 ByteBuffer 都是差不多的，额外增加了一些便利的操作方法，例如：
IoBuffer
IoBuffer IoBuffer
IoBuffer putString(Strin
putString(StrinputString(Strin
putString(String value,
g value,g value,
g value,Charset
CharsetCharset
CharsetEncoder encoder)
Encoder encoder)Encoder encoder)
Encoder encoder)可以方便的以指定的编码方
式存储字符串、InputStream asInputStream()
InputStream asInputStream()InputStream asInputStream()
InputStream asInputStream()方法从 IoBuffer 剩余的未读的数据中转为
输入流等。
_______________________________________________________________________________
(8.)
(8.)(8.)
(8.)IoFuture
IoFutureIoFuture
IoFuture：
：：
：
在 Mina 的很多操作中，你会看到返回值是 XXXFuture，实际上他们都是 IoFuture 的子类，
看到这样的返回值，这个方法就说明是异步执行的，主要的子类有 ConnectFuture、
CloseFuture 、 ReadFuture 、 WriteFuture 。 这 个 接 口 的 大 部 分 操 作 都 和
java.util.concurrent.Future 接口是类似的，譬如：await()、awaitUninterruptibly()
等，一般我们常用 awaitUninterruptibly()方法可以等待异步执行的结果返回。
这个接口有如下常用的方法：
A.
A.A.
A. IoFuture addListener(IoFutureListener<?> list
IoFuture addListener(IoFutureListener<?> listIoFuture addListener(IoFutureListener<?> list
IoFuture addListener(IoFutureListener<?> listener)
ener)ener)
ener)：
：：
：
这 个 方 法 用 于 添 加 一 个 监 听 器 ， 在 异 步 执 行 的 结 果 返 回 时 监 听 器 中 的 回 调 方 法
operationComplete(IoFuture future)，也就是说，这是替代 awaitUninterruptibly()方
法另一种等待异步执行结果的方法，它的好处是不会产生阻塞。
B.
B.B.
B. IoFuture removeListener(IoFuture
IoFuture removeListener(IoFutureIoFuture removeListener(IoFuture
IoFuture removeListener(IoFutureListener<?> listener
Listener<?> listenerListener<?> listener
Listener<?> listener)
))
)：
：：
：
这个方法用于移除指定的监听器。
C.
C.C.
C. IoSession getSession()
IoSession getSession()IoSession getSession()
IoSession getSession()：
：：
：
这个方法返回当前的 IoSession。
剩余46页未读，继续阅读
2010-08-12 上传
2019-08-15 上传
2011-08-03 上传
2011-12-17 上传
2013-06-08 上传
2017-10-16 上传
点击了解资源详情
点击了解资源详情
2022-02-07 上传
graphicgod
- 粉丝: 43
- 资源: 24
我的内容管理
展开
