JavaIO中神奇的flush

这篇文章在之前已经写过，只是没有在公众号发布过。该文阅读量已经达到了 36553 次了，有必要分享给大家。

后续我会陆续的把一些大家评论比较多并且很好的知识点在公众号分享给大家，希望和大家在编程的道路上一起进步，把苦涩的日子变得有趣一点。

无意中发现了一个巨牛的人工智能教程，忍不住分享一下给大家。教程不仅是零基础，通俗易懂，而且非常风趣幽默，像看小说一样！觉得太牛了，所以分享给大家。点这里可以跳转到教程。

内容概要

Java IO 流的设计不得不让人拍案叫绝，佩服设计者鬼斧天工的手法。

如果你是 Java 初学者，我敢保证第一次接触 Java 的 IO 类，一定会 ”狂晕！”，倒不是因为它有多么难学而是太多让人难以琢磨，让人有种 “不识庐山真面目” 的感觉，当你用心学完之后也会收获 “只缘身在此山中” 的顿悟。

在 Java 编程的日子中尤其是在网络编程中，几乎离不开 Java 的 IO 流，所以学好和用好它是很有必要的。

关于 Java 的 IO 流的分类，可以去找找相关的资料，今天跟大家分享一下其中比较神奇的 flush 方法。

flush 与 OutputStream

该类实现了 Flushable 接口，所以重写了 flush 方法，看看 flush() 源码，会更加的让你明白：

1	public void flush() throws IOException { }

Sorry，该实现为空。这里的 flush() 居然是一个空方法，什么也没做。看清楚啊，该方法不是抽象方法，是一个实实在在的方法。除了方法体中一无所有，其它还好！看JDK的API如何解释吧！

flush 
public void flush() throws IOException 
刷新此输出流并强制写出所有缓冲的输出字节。
flush 的常规协定是：如果此输出流的实现已经缓冲了以前写入的任何字节，则调用此方法指示应将这些字节立即写入它们预期的目标。 
如果此流的预期目标是由基础操作系统提供的一个抽象（如一个文件），则刷新此流只能保证将以前写入到流的字节传递给操作系统进行写入，但不保证能将这些字节实际写入到物理设备（如磁盘驱动器）。
OutputStream 的 flush 方法不执行任何操作。
指定者： 接口 Flushable 中的 flush 
抛出： IOException - 如果发生 I/O 错误。

开始，我安慰自己，该类是一个抽象类，它的子类肯定重写了该方法。

好吧，OutputStream 的直接子类有：ByteArrayOutputStream 、FileOutputStream、FilterOutputStream、ObjectOutputStream 、OutputStream、PipedOutputStream 等几个类。

注意：这里的子类 OutputStream 是包 org.omg.CORBA.portable 的。

对于 FileOutputStream、ByteArrayOutputStream、org.omg.CORBA.portable.OutputStream 类它们的 flush() 方法均是从父类继承的 flush 方法。

FilterOutputStream 类重写了 flush() 方法，但是实质还是调用父类的 flush() 方法。ObjectOutputStream、PipedOutputStream 类重写了 flush() 方法。

JDK 中，有两大类IO流即字节流和字符流（包括输入和输出），这些流类中有些是带有缓冲区功能的有些是没有的。BufferedInputStream 和 BufferedOutputStream 是字节缓冲区类；BufferedReader 和 BufferedWriter 是字符缓冲区类。

来举两个小例子，第一个例子主要是使用非缓冲区的 IO 流向文本中写入指定的字符串，第二个例子是使用带有缓冲区的 IO 流向文本中写入一定的字节数据。

1、例子1：向文本中写入字符串

import java.io.BufferedOutputStream; 
import java.io.DataOutputStream; 
import java.io.File; 
import java.io.FileOutputStream;

public class Test { 	
    public static void main(String[] args) throws Exception { 		
        File file = new File("text.txt"); 		
        if (!file.exists()) {		
            file.createNewFile(); 		
        } 		
        FileOutputStream fos = new FileOutputStream(file);
        BufferedOutputStream bos = new BufferedOutputStream(fos);	
        DataOutputStream dos = new DataOutputStream(fos);
        dos.writeBytes("java io");
    } 
}

这段代执行后，会在当前目录下产生 1KB 的文件（内容为 java io）。

特别注意，这里没有调用 flush 方法，只是调用了 writeBytes 方法。调用流程图如下：

2、例子2：向文本中写入一定字节的数据

import java.io.BufferedOutputStream; 
import java.io.File; 
import java.io.FileOutputStream; 

public class Test { 	
    public static void main(String[] args) throws Exception { 		
        File file = new File("text.txt"); 		
        if (!file.exists()) { 			
            file.createNewFile(); 		
        } 		
        FileOutputStream fos = new FileOutputStream(file); 		
        BufferedOutputStream bos = new BufferedOutputStream(fos); 		
        byte[] b = new byte[1024*8]; 		
        bos.write(b); 		
        bos.flush(); 	
    }
}

这段代执行后，会在当前目录下产生 8KB 字节的文件。调用关系如下：

现在我们修改第二个例子的代码，主要修改两个地方

（1）、注释掉调用 flush() 方法；

（2）、将 byte 大小改为 1024 大小。

修改如下：

import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileOutputStream;

public class Test {
    public static void main(String[] args) throws Exception {
        File file = new File("text.txt");
        if (!file.exists()) {
            file.createNewFile();
        }
        FileOutputStream fos = new FileOutputStream(file);
        BufferedOutputStream bos = new BufferedOutputStream(fos);
        byte[] b = new byte[1024];
        bos.write(b);
        //bos.flush();
    }
}

OK，再次运行代码，额的神啊？？？文件大小居然是0字节。

why？

仔细的你会发现，第一个例子中的代码中并没有调用 flush() 方法，居然可以正常的写入。为什么第二个就不可以呢？还是从源码入手找答案吧！

DataOutputStream 继承 FilterOutputStream ，实现了 DataOutput 接口。我们知道 FilterOutputStream 类重写了 flush() 方法，但是实质还是调用父类的 flush() 方法。DataOutputStream 类的 flush() 方法效仿其父类 FilterOutputStream 的做法，如下：

1
2
3

public void flush() throws IOException { 	
    out.flush(); 
}

那么，即使你在第一个例子的代码后面加上 dos.flush() 结果也是正常的，与不加是一样的效果，因为它们的父类 flush() 方法均为空，这就是为什么第一个代码的神奇所在。

再看看第二个代码的 “病因” 在哪里？先看看 BufferedOutputStream 类的结构：

1	public class BufferedOutputStream extends FilterOutputStream

再看看，它的 flush() 方法：

public synchronized void flush() throws IOException {         
    flushBuffer(); 
    out.flush();
} 

/** Flush the internal buffer */    
private void flushBuffer() throws IOException {   
    if (count > 0) { 	    
        out.write(buf, 0, count); 	    
        count = 0;        
    }    
}

不错，该类重写了 flush() 方法，不像前面几个类那样不是继承就是山寨父类的 flush() 方法。BufferedOutputStream 类是一个使用了缓冲技术的类，这种类一把都会自己实现 flush() 方法。

那么，有人会问使用这种类的时候，难道必须使用 flush() 方法吗，当然不是喽？？！！不过有个前提，你的字节数据必须不能小于 8KB。实例代码，注意没有 flush()方法。

（1）、写入的数据不小于8KB

如下示例代码，byte 大小改为 8KB：

import java.io.BufferedOutputStream; 
import java.io.File; 
import java.io.FileOutputStream; 

public class Test { 	
    public static void main(String[] args) throws Exception { 	
        File file = new File("text.txt"); 		
        if (!file.exists()) { 	
            file.createNewFile(); 	
        } 		
        FileOutputStream fos = new FileOutputStream(file); 		
        BufferedOutputStream bos = new BufferedOutputStream(fos); 		
        byte[] b = new byte[1024*8]; 	
        bos.write(b); 		
        //bos.flush(); 
    }
}

执行代码，会产生大小为 8KB 的文本文件。

（2）、修改默认缓冲区大小

如下示例代码，修改一下构造 BufferedOutputStream 的方法，设置默认缓冲区大小为 1024。

File file = new File("text4.txt");
if (!file.exists()) {
    file.createNewFile();
}
FileOutputStream fos = new FileOutputStream(file);
BufferedOutputStream bos = new BufferedOutputStream(fos, 1024);
byte[] b = new byte[1024];
bos.write(b);
//bos.flush();

执行代码，会产生 1KB 大小的文本文件。

这里提醒一下，如果你的文件读写没有达到预期目的，十之八九是因为你没有调用 flush() 或者 close() 方法。

另外，字符流类大多数都实现了 flush() 或者 close() 方法，只不过，它们调用的是 StreamEncoder 类的该方法。该类位于 sun.nio.cs 包下面，其源码在我们JDK中是没有的。

可以点击 StreamEncoder.java 查看源码。

flush 与 Writer

该类 Writer 是一个抽象类，声明如下：

1	public abstract class Writer implements Appendable, Closeable, Flushable

Writer 类的 flush() 方法是一个抽象方法，其子类一般都实现了该方法。

所以，一般使用字符流之后需要调用一下 flush() 或者 close() 方法。

1	abstract public void flush() throws IOException;

细节请看JDK的API，或者Java的源码以及上面的 StreamEncoder 类源码。

今天就说到这里吧，本文主要借助Java IO中字节流与字符流的 flush() 方法，来说明学编程语言看源码和思考是很重要的。

总之，不管你使用哪种流（字符、字节、具有缓冲的流）技术，不妨调用一下 flush() 或者 close() 方法，防止数据无法写到输出流中。

学习没有一蹴而就的方法，坚持思考、练习才是王道~