NIO2入门,异步通道API 文件系统API.docVIP

异步通道?提供支持连接、读取、以及写入之类非锁定操作的连接，并提供对已启动操作的控制机制。Java 7 中用于 Java Platform（NIO.2）的 More New I/O APIs，通过在?java.nio.channels?包中增加四个异步通道，从而增强了 Java 1.4 中的 New I/O APIs（NIO）： AsynchronousSocketChannel AsynchronousServerSocketChannel AsynchronousFileChannel AsynchronousDatagramChannel 这些类在风格上与 NIO 通道 API 很相似。他们共享相同的方法与参数结构体，并且大多数对于 NIO 通道类可用的参数，对于新的异步版本仍然可用。主要区别在于新通道可使一些操作异步执行。 异步通道 API 提供两种对已启动异步操作的监测与控制机制。第一种是通过返回一个?java.util.concurrent.Future?对象来实现，它将会建模一个挂起操作，并可用于查询其状态以及获取结果。第二种是通过传递给操作一个新类的对象，java.nio.channels.CompletionHandler，来完成，它会定义在操作完毕后所执行的处理程序方法。每个异步通道类为每个操作定义 API 副本，这样可采用任一机制。 异步套接字通道及特性 首先，我们将了解?AsynchronousServerSocketChannel?和?AsynchronousSocketChannel?类。我们将看到的第一个例子将演示如何利用这些新的类来实施简单的客户端/服务器。第一步，我们要设置服务器。 设置服务器 打开?AsychronousServerSocketChannel?并将其绑定到类似于?ServerSocketChannel?的地址： AsynchronousServerSocketChannel server = AsynchronousServerSocketChannel.open().bind(null); 方法?bind()?将一个套接字地址作为其参数。找到空闲端口的便利方法是传递一个?null?地址，它会自动将套接字绑定到本地主机地址，并使用空闲的?临时?端口。 接下来，可以告诉通道接受一个连接： FutureAsynchronousSocketChannel acceptFuture = server.accept(); 这是与 NIO 的第一个不同之处。接受调用总会立刻返回，并且，—— 不同于?ServerSocketChannel.accept()，它会返回一个SocketChannel?—— 它返回一个?FutureAsynchronousSocketChannel?对象，该对象可在以后用于检索AsynchronousSocketChannel。?Future?对象的通用类型是实际操作的结果。比如，读取或写入操作会因为操作返回读或写的字节数，而返回一个?FutureInteger。 利用?Future?对象，当前线程可阻塞来等待结果： AsynchronousSocketChannel worker = future.get(); 此处，其阻塞超时时间为 10 秒： AsynchronousSocketChannel worker = future.get(10, TimeUnit.SECONDS); 或者轮询操作的当前状态，还可取消操作： if (!future.isDone()) { future.cancel(true); } cancel()?方法可利用一个布尔标志来指出执行接受的线程是否可被中断。这是个很有用的增强；在以前的 Java 版本中，只能通过关闭套接字来中止此类阻塞 I/O 操作。 客户端设置 接下来，要通过打开并连接与服务器之间的?AsynchronousSocketChannel，来设置客户端： AsynchronousSocketChannel client = AsynchronousSocketChannel.open(); client.connect(server.getLocalAddress()).get(); 一旦客户端与服务器建立连接，可通过使用字节缓存的通道来执行读写操作，如清单 1 所示： 清单 1. 使用读写字节缓存 // send a message to the server ByteBuffer message = ByteBuffer.wrap(ping.getBytes()); client.write(message).get(); // read a messa