Apache Mina 2.0中文开发指南：高性能网络通信框架详解
需积分: 14 13 浏览量
更新于2024-07-26
收藏 414KB PDF 举报
Apache Mina中文开发文档详细介绍了Apache Mina Server 2.0，这是一个高度优化的网络IO开发框架，专为Java开发者设计，支持TCP/IP和UDP/IP协议栈的高效通信。Mina强调了事件驱动和异步编程模型，其底层采用Java NIO（Non-blocking I/O）技术，使得开发者能够轻松构建高性能、可扩展的网络应用。
Mina的主要组件包括：
1. IoService：这是核心组件，运行在一个单独的线程中，负责监听套接字的连接请求，并通过Selector监控连接状态变化。IoService确保了I/O操作的异步处理，避免了阻塞，提高了系统吞吐量。
2. IoProcessor：这个接口在另一个独立线程中负责数据的读写操作，同样利用Selector进行事件管理。与传统的Java Socket编程不同，Mina将数据处理和连接管理分开，提高了代码的组织性和可维护性。
为了充分利用Mina，开发者需要具备一定的基础技能，包括但不限于Java IO（包括Blocking IO和NIO）、Java NIO、Java Socket编程、多线程和并发编程（尤其是java.util.concurrent包的API），因为这些是Mina开发的基础。
Mina的架构设计使得开发者可以专注于应用程序的核心业务逻辑，而无需深入底层网络通信细节。无论是在服务器端还是客户端，Mina都提供了封装好的接口，简化了网络通信的实现，提高了开发效率。整体来看，Apache Mina Server 2.0是一个强大的工具，对于追求高性能网络应用的Java开发者来说，是不可或缺的学习资源。
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页未读，继续阅读
点击了解资源详情
点击了解资源详情
点击了解资源详情
2022-09-20 上传
2022-09-20 上传
2018-07-06 上传
2012-05-14 上传
2022-09-24 上传
2010-09-02 上传
de76ydt3ddde
- 粉丝: 0
- 资源: 1
我的内容管理
展开
