Apache Mina Server 2.0中文参考手册：高性能网络通信框架解析

需积分: 43 175 浏览量更新于2024-07-29 收藏 414KB PDF 举报

"Apache Mina Server 2.0中文参考手册V1.0" Apache Mina 是一个强大的网络通信应用框架，专为构建高性能、高可扩展性的网络服务而设计。该框架支持多种通信协议，包括基于TCP/IP和UDP/IP的协议栈，并且能够处理JAVA对象的序列化和虚拟机内部通信。Mina的核心理念是提供事件驱动和异步操作的编程模型，其中异步IO默认依赖于Java NIO（非阻塞I/O）作为底层实现。 Mina有1.x和2.x两个主要分支，本参考手册聚焦于最新的2.0版本。对于那些仍在使用Mina 1.x的开发者，需要注意某些特性和功能可能不适用于新版本。学习和使用Mina 2.0之前，应具备以下基础知识： 1. **JAVA IO**: 了解基本的输入输出流操作，如FileInputStream, FileOutputStream, BufferedReader, BufferedWriter等。 2. **Java NIO**: 熟悉非阻塞I/O的概念，包括Selector, Channel, Buffer等组件的使用。 3. **Java Socket**: 知道如何创建和管理Socket连接，以及进行数据的发送和接收。 4. **Java 线程及并发库**: 掌握多线程编程，熟悉java.util.concurrent包下的类和接口，如ExecutorService, Semaphore, ThreadPoolExecutor等。在Mina框架中，网络通信的架构分为两个关键部分： 1. **IoService**: 这个接口负责在单独的线程上处理套接字的创建，维护自己的Selector来监听新的连接请求。Selector用于监控多个通道（Channel）的就绪状态，当有新的连接到达时，IoService会触发相应的事件处理。 2. **IoProcessor**: 此接口在另一个线程上运行，它的任务是检查通道上是否存在可读写的数据。同样，IoProcessor也有自己的Selector，它负责数据的读写操作。与传统的Java NIO编程不同，Mina将数据处理和服务创建分隔开，提供了更高级别的抽象。 Mina的执行流程如下： 1. 客户端发起连接请求，IoService的Selector检测到新的连接并进行处理。 2. 一旦连接建立，IoService创建一个IoSession对象，该对象代表了客户端和服务器之间的会话。 3. IoSession被交给IoProcessor，IoProcessor开始监控这个通道上的读写活动。 4. 当数据准备好读取或写入时，IoProcessor调用预先注册的处理器或过滤器链来处理这些事件。 5. 应用程序通过注册的事件处理器来处理业务逻辑，如数据解析、响应生成等。 6. 数据通过过滤器链进行处理后，由IoProcessor进行实际的网络传输。过滤器（Filter）是Mina中的一个重要概念，它们可以对数据进行预处理和后处理，实现了通信逻辑的解耦。用户可以自定义过滤器来实现特定的功能，如加密、压缩、身份验证等。 Apache Mina Server 2.0提供了强大而灵活的网络通信基础设施，让开发者能够专注于业务逻辑，而不是底层的网络细节。通过熟练掌握Mina的使用，可以有效地提高网络应用的开发效率和性能。

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. IoBuffer asReadOnlyBuffer()

IoBuffer asReadOnlyBuffer()IoBuffer asReadOnlyBuffer()

IoBuffer asReadOnlyBuffer()：

：：

：

这个方法设置 IoBuffer 为只读的。

G.G.

G. B

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. 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. 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. IoFuture removeListener(IoFuture

IoFuture removeListener(IoFutureIoFuture removeListener(IoFuture

IoFuture removeListener(IoFutureListener<?> listener

Listener<?> listenerListener<?> listener

Listener<?> listener)

))

)：

：：

：

这个方法用于移除指定的监听器。

C.C.

C. IoSession getSession()

IoSession getSession()IoSession getSession()

IoSession getSession()：

：：

：

这个方法返回当前的 IoSession。

举个例子，我们在客户端调用 connect()方法访问 Server 端的时候，实际上这就是一个异

步执行的方法，也就是调用 connect()方法之后立即返回，执行下面的代码，而不管是否连

接成功。那么如果我想在连接成功之后执行一些事情（譬如：获取连接成功后的 IoSession

对象），该怎么办呢？按照上面的说明，你有如下两种办法：

第一种

第一种第一种

第一种：

：：

：

ConnectFuture future = connector.connect(new InetSocketAddress(

HOSTNAME, PORT));

// 等待是否连接成功，相当于是转异步执行为同步执行。

future.awaitUninterruptibly();

// 连接成功后获取会话对象。如果没有上面的等待，由于connect()方法是异步的，session

可能会无法获取。

session = future.getSession();

第二种

第二种第二种

第二种：

：：

：

ConnectFuture future = connector.connect(new InetSocketAddress(

HOSTNAME, PORT));

future.addListener(new IoFutureListener<ConnectFuture>() {

@Override

public void operationComplete(ConnectFuture future) {

try {

Thread.sleep(5000);

} catch (InterruptedException e) {

e.printStackTrace();

}

IoSession session = future.getSession();

System.out.println("++++++++++++++++++++++++++++");

}

});

System.out.println("*************");

为了更好的看清楚使用监听器是异步的，而不是像 awaitUninterruptibly()那样会阻塞主

线程的执行，我们在回调方法中暂停 5 秒钟，然后输出+++，在最后输出***。我们执行代码

之后，你会发现首先输出***（这证明了监听器是异步执行的），然后 IoSession 对象 Created，

系统暂停 5 秒，然后输出+++，最后 IoSession 对象 Opened，也就是 TCP 连接建立。

_______________________________________________________________________________

4.4.

4.日志配置

日志配置日志配置

日志配置：

：：

：

前面的示例代码中提到了使用 SLF4J 作为日志门面，这是因为 Mina 内部使用的就是 SLF4J，

你也使用 SLF4J 可以与之保持一致性。

Mina 如果想启用日志跟踪 Mina 的运行细节，你可以配置 LoggingFilter 过滤器，这样你可

以看到 Session 建立、打开、空闲等一系列细节在日志中输出，默认 SJF4J 是按照 DEBUG

级别输出跟踪信息的，如果你想给某一类别的 Mina 运行信息输出指定日志输出级别，可以

调用 LoggingFilter 的 setXXXLogLevel(LogLevel.XXX)。

剩余46页未读，继续阅读

xjauzcy

粉丝: 8
资源: 12

Apache Mina Server 2.0中文参考手册：高性能网络通信框架解析

Apache Mina Server 2.0中文参考手册V1.0,Apache Mina2.0学习笔记(修订版)

Apache_Mina_Server_2.0中文参考手册V1.0.pdf

Apache_Mina_Server_2.0_V1.0.rar_apache_apache中文手册_mina

Apache_Mina_Server_2.0中文参考手册

Apache_Mina_Server_2.0V1.0.rar_mina

Apache_Mina_Server_2.0.rar_mina

Apache-Mina-Server-2.0中文参考手册V1.0.docx

这是Apache Mina Server 2.0的中文参考手册，版本为1.0

Apache Mina Server 2.0 中文参考手册

Apache Mina Server 2.0中文参考手册详解

最新资源