NIO入门系列之第3章：从理论到实践：NIO 中的读和写

3.1 概述

读和写是 I/O 的基本过程。从一个通道中读取很简单：只需创建一个缓冲区，然后让通道将数据读到这个缓冲区中。写入也相当简单：创建一个缓冲区，用数据填充它，然后让通道用这些数据来执行写入操作。

在本节中，我们将学习有关在Java 程序中读取和写入数据的一些知识。我们将回顾 NIO 的主要组件(缓冲区、通道和一些相关的方法)，看看它们是如何交互以进行读写的。在接下来的几节中，我们将更详细地分析这其中的每个组件以及其交互。

在我们第一个练习中，我们将从一个文件中读取一些数据。如果使用原来的 I/O，那么我们只需创建一个FileInputStream 并从它那里读取。而在 NIO中，情况稍有不同：我们首先从FileInputStream 获取一个FileInputStream 对象，然后使用这个通道来读取数据。

在 NIO 系统中，任何时候执行一个读操作，您都是从通道中读取，但是您不是直接从通道读取。因为所有数据最终都驻留在缓冲区中，所以您是从通道读到缓冲区中。

因此读取文件涉及三个步骤：(1)从FileInputStream 获取 Channel，(2) 创建 Buffer，(3) 将数据从 Channel 读到 Buffer 中。

现在，让我们看一下这个过程。

第一步是获取通道。我们从 FileInputStream 获取通道：

<code>FileInputStream fin = </code><code>new</code> <code>FileInputStream( </code><code>"readandshow.txt"</code> <code>);</code>

<code>FileChannel fc = fin.getChannel();</code>

下一步是创建缓冲区：

<code>ByteBuffer buffer = ByteBuffer.allocate( </code><code>1024</code> <code>);</code>

最后，需要将数据从通道读到缓冲区中，如下所示：

<code>fc.read( buffer );</code>

您会注意到，我们不需要告诉通道要读多少数据到缓冲区中。每一个缓冲区都有复杂的内部统计机制，它会跟踪已经读了多少数据以及还有多少空间可以容纳更多的数据。我们将在缓冲区内部细节中介绍更多关于缓冲区统计机制的内容。

<code>// ReadAndShow</code>

<code>package</code> <code>com.mzsx.nio;</code>

<code>import</code> <code>java.io.*;</code>

<code>import</code> <code>java.nio.*;</code>

<code>import</code> <code>java.nio.channels.*;</code>

<code>public</code> <code>class</code> <code>ReadAndShow {</code>

<code> </code><code>static</code> <code>public</code> <code>void</code> <code>main(String args[]) </code><code>throws</code> <code>Exception {</code>

<code> </code><code>//创建FileInputStream实例</code>

<code> </code><code>FileInputStream fin = </code><code>new</code> <code>FileInputStream(</code><code>"C:\\Users\\Qiang\\Desktop\\hydra.txt"</code><code>);</code>

<code> </code><code>FileChannel fc = fin.getChannel();</code>

<code> </code><code>//创建缓冲区</code>

<code> </code><code>ByteBuffer buffer = ByteBuffer.allocate(</code><code>1024</code><code>);</code>

<code> </code><code>//将数据从通道读到缓冲区中</code>

<code> </code><code>fc.read(buffer);</code>

<code> </code><code>buffer.flip();</code>

<code> </code><code>while</code> <code>(buffer.remaining() > </code><code>0</code><code>) {</code>

<code> </code><code>byte</code> <code>b = buffer.get();</code>

<code> </code><code>System.out.println(</code><code>"Character "</code> <code>+ i + </code><code>": "</code> <code>+ ((</code><code>char</code><code>) b)+</code><code>" , buffer.remaining():"</code><code>+buffer.remaining());</code>

<code> </code><code>fin.close();</code>

在 NIO 中写入文件类似于从文件中读取。首先从 FileOutputStream 获取一个通道：

<code>FileOutputStream fout = </code><code>new</code> <code>FileOutputStream( </code><code>"writesomebytes.txt"</code> <code>);</code>

<code>FileChannel fc = fout.getChannel();</code>

下一步是创建一个缓冲区并在其中放入一些数据- 在这里，数据将从一个名为message 的数组中取出，这个数组包含字符串"Some bytes"的 ASCII 字节(本教程后面将会解释buffer.flip() 和 buffer.put() 调用)。

<code> </code><code>buffer.put( message[i] );</code>

<code>buffer.flip();</code>

最后一步是写入缓冲区中：

<code>fc.write( buffer );</code>

注意在这里同样不需要告诉通道要写入多数据。缓冲区的内部统计机制会跟踪它包含多少数据以及还有多少数据要写入。

<code>// WriteSomeBytes</code>

<code>public</code> <code>class</code> <code>WriteSomeBytes {</code>

<code> </code><code>static</code> <code>private</code> <code>final</code> <code>byte</code> <code>message[] = { </code><code>83</code><code>, </code><code>111</code><code>, </code><code>109</code><code>, </code><code>101</code><code>, </code><code>32</code><code>, </code><code>98</code><code>, </code><code>121</code><code>,</code>

<code> </code><code>//实例化FileOutputStream</code>

<code> </code><code>FileOutputStream fout = </code><code>new</code> <code>FileOutputStream(</code><code>"C:\\Users\\Qiang\\Desktop\\writesomebytes.txt"</code><code>);</code>

<code> </code><code>FileChannel fc = fout.getChannel();</code>

<code> </code><code>//获取缓冲区</code>

<code> </code><code>//向缓冲区添加数据</code>

<code> </code><code>buffer.put(message[i]);</code>

<code> </code><code>//写入缓冲区</code>

<code> </code><code>fc.write(buffer);</code>

<code> </code><code>fout.close();</code>

下面我们将看一下在结合读和写时会有什么情况。我们以一个名为 CopyFile.java 的简单程序作为这个练习的基础，它将一个文件的所有内容拷贝到另一个文件中。CopyFile.java 执行三个基本操作：首先创建一个 Buffer，然后从源文件中将数据读到这个缓冲区中，然后将缓冲区写入目标文件。这个程序不断重复—读、写、读、写—直到源文件结束。

CopyFile 程序让您看到我们如何检查操作的状态，以及如何使用 clear() 和 flip() 方法重设缓冲区，并准备缓冲区以便将新读取的数据写到另一个通道中。

实例读写结合：

<code>// CopyFile</code>

<code>public</code> <code>class</code> <code>CopyFile {</code>

<code> </code><code>//需要输入源文件夹和目标文件的全路径</code>

<code> </code><code>if</code> <code>(args.length < </code><code>2</code><code>) {</code>

<code> </code><code>System.err.println(</code><code>"Usage: java CopyFile infile outfile"</code><code>);</code>

<code> </code><code>System.exit(</code><code>1</code><code>);</code>

<code> </code><code>String infile = args[</code><code>0</code><code>];</code>

<code> </code><code>String outfile = args[</code><code>1</code><code>];</code>

<code> </code><code>FileInputStream fin = </code><code>new</code> <code>FileInputStream(infile);</code>

<code> </code><code>FileOutputStream fout = </code><code>new</code> <code>FileOutputStream(outfile);</code>

<code> </code><code>FileChannel fcin = fin.getChannel();</code>

<code> </code><code>FileChannel fcout = fout.getChannel();</code>

<code> </code><code>while</code> <code>(</code><code>true</code><code>) {</code>

<code> </code><code>//清空缓冲区</code>

<code> </code><code>buffer.clear();</code>

<code> </code><code>//将数据从通道读到缓冲区中</code>

<code> </code><code>int</code> <code>r = fcin.read(buffer);</code>

<code> </code><code>break</code><code>;</code>

<code> </code><code>buffer.flip();</code>

<code> </code><code>fcout.write(buffer);</code>

<code> </code><code>fcin.close();</code>

<code> </code><code>fcout.close();</code>

因为缓冲区会跟踪它自己的数据，所以CopyFile 程序的内部循环 (inner loop) 非常简单，如下所示：

<code>fcin.read( buffer );</code>

<code>fcout.write( buffer );</code>

第一行将数据从输入通道fcin 中读入缓冲区，第二行将这些数据写到输出通道 fcout 。

下一步是检查拷贝何时完成。当没有更多的数据时，拷贝就算完成，并且可以在 read() 方法返回 -1 是判断这一点，如下所示：

<code>int</code> <code>r = fcin.read( buffer );</code>

<code> </code><code>break</code><code>;</code>

最后，在从输入通道读入缓冲区之前，我们调用 clear() 方法。同样，在将缓冲区写入输出通道之前，我们调用 flip() 方法，如下所示：

<code>buffer.clear();</code>

clear() 方法重设缓冲区，使它可以接受读入的数据。 flip() 方法让缓冲区可以将新读入的数据写入另一个通道。

本文转自梦朝思夕 51CTO博客，原文链接:http://blog.51cto.com/qiangmzsx/1409546

NIO入门系列之第3章：从理论到实践：NIO 中的读和写

继续阅读

关于Gradle配置的小结

Java小案例——随机数猜测随机数猜测

nginx location中斜线的位置的重要性

27 Best Free Eclipse Plug-ins for Java Developer to be ProductiveCode Quality PluginsText Editor PluginsDependency ManagementVersion Control Integration PluginsFramework Development Continuous Integration Related PluginsOther Utility Plugins

Java String.format方法的简单使用

neo4j之cypher使用文档

GitHub连夜封杀！这份阿里 10W 字内部 Java 字面试手册到底有多强？

spark/scala关于【资源文件】加载方法概述外部文件加载方案测试资源文件打包入jar包中小结

mybatis_入门程序Mybatis入门

AOP编程_Android优雅权限框架(1)概念基础，2021金三银四前言正文大纲正文

Effective Java 8:通用程序设计

OOM三种类型

工厂模式-三种类型

【递归】高效率求2的n次幂

win10本地scala和spark安装安装scala安装spark

scala (3) Function 和 Method