OpenJDK 源码阅读之 Java 字节流输出类的实现

Java 的输入输出老是给人一种很混乱的感受，要想把这个问题搞清楚，必须对各类与输入输出相关的类之间的关系有所了解。只有你了解了他们之间的关系，知道设计这个类的目的是什么，才能更从容的使用他们。

这是这个系列的第二篇，描述字节输出类的实现，第一篇见：OpenJDK 源码阅读之 Java 字节流输入类的实现

字节流输出

图1 Java 字节输出类

• OutputStream

OutputStream是全部字节输出类的超类，这是个抽象类，须要实现其中定义的 write 函数，才能有实用的功能。

    public abstract void write(int b) throws IOException;

其它方法都是在 write 的基础上实现的。例如这个多态的　write ：

public void write(byte b[], int off, int len) 
throws IOException {
    if (b == null) {
        throw new NullPointerException();
    } else if ((off < 0) || (off > b.length) || (len < 0) ||
               ((off + len) > b.length) || ((off + len) < 0)) {
        throw new IndexOutOfBoundsException();
    } else if (len == 0) {
        return;
    }
    for (int i = 0 ; i < len ; i++) {
        write(b[off + i]);
    }
}

• FileOutputStream

FileOutputStream 会将内容输出到 File 或者 FileDescriptor， 此类是按照字节输出，若是想按照字符输出，可使用FileReader 类。

构造器中，须要指明输出的文件：

public FileOutputStream(File file, boolean append)
    throws FileNotFoundException
{
    String name = (file != null ? file.getPath() : null);
    SecurityManager security = System.getSecurityManager();
    if (security != null) {
        security.checkWrite(name);
    }
    if (name == null) {
        throw new NullPointerException();
    }
    this.fd = new FileDescriptor();
    this.append = append;

    fd.incrementAndGetUseCount();
    open(name, append);
}

写入操做是一个　native 函数，与操做系统相关。

private native void write(int b, boolean append) throws IOException;

若是对比一下字节输入类，你会发现输入和输出在实现上有很大的类似性，它们是对称的。

• ByteArrayOutputStream

ByteArrayOutputStream　会将数据写入字节数组中, 能够经过 toByteArray,toString 获得这些数据。

protected byte buf[];

初始化时，能够指定这个数组的大小：

public ByteArrayOutputStream(int size) {
    if (size < 0) {
        throw new IllegalArgumentException("Negative initial size: "
                                           + size);
    }
    buf = new byte[size];
}

写入时，会写入这个数组。write 会先保证数组的大小，若是不够用，还会自动进行扩充。

public synchronized void write(int b) {
    ensureCapacity(count + 1);
    buf[count] = (byte) b;
    count += 1;
}

• FilterOutputStream

全部有过滤功能的类的基类，例如，对输出流进行转化，或者添加新的功能。初始化时，须要提供一个底层的流，用于写入数据，FilterOUtputStream 类的全部方法都是经过调用这个底层流的方法实现的。

初始化时，

protected OutputStream out;
public FilterOutputStream(OutputStream out) {
    this.out = out;
}

写入时：

public void write(int b) throws IOException {
    out.write(b);
}

• BufferedOutputStream

BufferedOutputStream 是 FilterOutputStream 的子类，提供缓冲功能，因此，你不用每写入一个字节都要调用操做系统的write 方法，而是积累到缓冲区，而后一块儿写入。

缓冲区就是一个字节数组，在构造器中被初始化。

protected byte buf[];

public BufferedOutputStream(OutputStream out) {
    this(out, 8192);
}

public BufferedOutputStream(OutputStream out, int size) {
    super(out);
    if (size <= 0) {
        throw new IllegalArgumentException("Buffer size <= 0");
    }
    buf = new byte[size];
}

当调用 write(b) 时，并不真正写入，而是将要写入的数据存放在缓冲区内，等缓冲区满后，一次性写入数据。

public synchronized void write(int b) throws IOException {
    if (count >= buf.length) {
        flushBuffer();
    }
    buf[count++] = (byte)b;
}

• DataOutputStream

DataOutputStream 能够按 Java 的基本类型写入数据。写入的原理是，将基本类型数据中的字节分离出来，而后将这些字节写入。例如：

public final void writeBoolean(boolean v) throws IOException {
    out.write(v ? 1 : 0);
    incCount(1);
}

boolean 类型就是按照 0/1 的方式写入的。

public final void writeShort(int v) throws IOException {
    out.write((v >>> 8) & 0xFF);
    out.write((v >>> 0) & 0xFF);
    incCount(2);
}

short 是两个字节，须要将其中的两个字节分离出来，分别写入，incCount 加了2. writeChar 同理，由于它也是写入两个字节。

浮点数比较特殊，无法直接分离出各个字节，要调用 Float 的一个静态方法，把浮点数转化成四个字节，再经过 writeInt 写入。floatToInitBits 会调用一个 native 方法, 按照 IEEE 754 标准，完成其主要功能。

    public final void writeFloat(float v) throws IOException {
        writeInt(Float.floatToIntBits(v));
    }

• PipedOutputStream

管道输出流能够与一个管道输入流相关联，关联后，共用一个缓冲区，输出流写入数据，输入流读取数据，两者应该处于不一样线程，不然可能出现死锁。

原理上一篇文章在介绍 PipedInputStream 时，已经阐述。

另外，我以为在这里，有必要说一下那几个用于压缩和解压缩的类，实现就不说了，就讲下他们的功能与关系。

JAVA IO 压缩与解压缩

• InflaterInputStream: 用于解压 deflate 格式的压缩数据，底层流为压缩后的数据，read 返回解压后的数据。
• InflaterOutputStream: 用于解压 deflate 格式的压缩数据，底层流为压缩后的数据，write 写入解压后的数据。
• DeflaterInputStream: 用于压缩成 deflate 格式的数据，底层流为未压缩数据，read 返回压缩后的数据。

• DeflaterOutputStream: 用于压缩成 deflate 格式的数据，底层流为未压缩数据，write 写入压缩后的数据。

• GZIPInputStream: 用于解压 GZip 格式的压缩数据，底层流为压缩后的数据，read 返回解压后的数据。它是 InflaterInputStream 的子类。

• GZIPOutputStream: 用于压缩成 Gzip格式的数据，底层流为未压缩数据，write 写入压缩后的数据。是 DeflaterOutputStream 的子类(注意不是InflaterOutputStream) 。

不得不说，这个API设计的真是太反直觉了。GZIP 格式的解压和压缩一个是 GZIPInputStream，一个是 GZIPOutputStream。而 deflate 格式的解压和压缩，一个是 InflaterInputStream/InflaterOutputStream，另外一个是 DeflaterInputStream/DeflaterOutputStream。当同时须要对 gzip 和 deflate 压缩和解压缩时，就感受，真是反直觉。