Java中FilterInputStream和FilterOutputStream的用法詳解

更新時(shí)間：2016年06月20日 08:55:45 作者：kuiwu-wang

這篇文章主要介紹了Java中FilterInputStream和FilterOutputStream的用法詳解,這兩個(gè)類分別用于封裝輸入和輸出流,需要的朋友可以參考下

FilterInputStream
FilterInputStream 的作用是用來“封裝其它的輸入流，并為它們提供額外的功能”。它的常用的子類有BufferedInputStream和DataInputStream。
BufferedInputStream的作用就是為“輸入流提供緩沖功能，以及mark()和reset()功能”。
DataInputStream 是用來裝飾其它輸入流，它“允許應(yīng)用程序以與機(jī)器無關(guān)方式從底層輸入流中讀取基本 Java 數(shù)據(jù)類型”。應(yīng)用程序可以使用DataOutputStream(數(shù)據(jù)輸出流)寫入由DataInputStream(數(shù)據(jù)輸入流)讀取的數(shù)據(jù)。
FilterInputStream 源碼(基于jdk1.7.40)：

package java.io;
public class FilterInputStream extends InputStream {
  protected volatile InputStream in;

  protected FilterInputStream(InputStream in) {
    this.in = in;
  }

  public int read() throws IOException {
    return in.read();
  }

  public int read(byte b[]) throws IOException {
    return read(b, 0, b.length);
  }

  public int read(byte b[], int off, int len) throws IOException {
    return in.read(b, off, len);
  }

  public long skip(long n) throws IOException {
    return in.skip(n);
  }

  public int available() throws IOException {
    return in.available();
  }

  public void close() throws IOException {
    in.close();
  }

  public synchronized void mark(int readlimit) {
    in.mark(readlimit);
  }

  public synchronized void reset() throws IOException {
    in.reset();
  }

  public boolean markSupported() {
    return in.markSupported();
  }
}

FilterOutputStream
FilterOutputStream 的作用是用來“封裝其它的輸出流，并為它們提供額外的功能”。它主要包括BufferedOutputStream, DataOutputStream和PrintStream。
(01) BufferedOutputStream的作用就是為“輸出流提供緩沖功能”。
(02) DataOutputStream 是用來裝飾其它輸出流，將DataOutputStream和DataInputStream輸入流配合使用，“允許應(yīng)用程序以與機(jī)器無關(guān)方式從底層輸入流中讀寫基本 Java 數(shù)據(jù)類型”。
(03) PrintStream 是用來裝飾其它輸出流。它能為其他輸出流添加了功能，使它們能夠方便地打印各種數(shù)據(jù)值表示形式。
FilterOutputStream 源碼(基于jdk1.7.40)：

package java.io;

public class FilterOutputStream extends OutputStream {
  protected OutputStream out;

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

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

  public void write(byte b[]) throws IOException {
    write(b, 0, b.length);
  }

  public void write(byte b[], int off, int len) throws IOException {
    if ((off | len | (b.length - (len + off)) | (off + len)) < 0)
      throw new IndexOutOfBoundsException();

    for (int i = 0 ; i < len ; i++) {
      write(b[off + i]);
    }
  }

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

  public void close() throws IOException {
    try {
     flush();
    } catch (IOException ignored) {
    }
    out.close();
  }
}

您可能感興趣的文章: