探究java IO之PushbackInputStream類

緩存的新應用之一就是回推（pushback）的實現。回推用於輸入流，以容許讀取字節，而後再將它們返回（回推）到流中。PushbackInputStream類實現了這一思想，提供了一種機制，能夠「偷窺」來自輸入流的內容而不對它們進行破壞。

PushbackInputStream類具備如下構造函數：

PushbackInputStream(InputStream inputStream)
PushbackInputStream(InputStream inputStream,int numBytes)

第一種形式建立的流對象容許將一個字節返回到輸入流； 第二種形式建立的流對象具備一個長度爲numBytes的回推緩存，從而容許將多個字節回推到輸入流中。

除了熟悉的來自InputStream的方法外，PushbackInputStream類還提供了unread()方法，以下所示：

void unread(int b)
void unread(byte[] buffer)
void unread(byte[] buffer,int offset,int numBytes)

第一種形式回推b的低字節，這會使得後續的read()調用會把這個字節再次讀取出來。第二種形式回推buffer中的字節。第三種形式回推buffer中從offset開始的numBytes個字節。當回推緩存已滿時，若是試圖回推字節，就會拋出IOException異常。

用幾個示例測試一下：

package io;

import java.io.ByteArrayInputStream;
import java.io.PushbackInputStream;

public class PushbackInputStreamDemo1 {
    public static void main(String[] args) throws Exception {
        String s = "abcdefg";
        /*
         * PushbackInputStream pbin = new PushbackInputStream(in)
         * 這個構造函數建立的對象一次只能回推一個字節
         */
        try (ByteArrayInputStream in = new ByteArrayInputStream(s.getBytes());
                        PushbackInputStream pbin = new PushbackInputStream(in)) {
            int n;
            while ((n = pbin.read()) != -1) {
                System.out.println((char) n);
                if('b' == n) pbin.unread('U');
            }
        }
    }
}

示例2：

package io;

import java.io.ByteArrayInputStream;
import java.io.PushbackInputStream;

public class PushbackInputStreamDemo1 {
    public static void main(String[] args) throws Exception {
        String s = "abcdefg";
        /*
         * PushbackInputStream pbin = new PushbackInputStream(in,3)
         * 這個構造函數建立的對象一次能夠回推一個緩存
         */
        try (ByteArrayInputStream in = new ByteArrayInputStream(s.getBytes());
                        PushbackInputStream pbin = new PushbackInputStream(in, 3)) {
            int n;
            byte[] buffer = new byte[3];
            while ((n = pbin.read(buffer)) != -1) {
                System.out.println(new String(buffer));
                if(new String(buffer).equals("abc"))pbin.unread(new byte[]{'M','N','O'});
                buffer = new byte[3];
            }
        }
    }
}

示例3：

package io;

import java.io.ByteArrayInputStream;
import java.io.PushbackInputStream;

public class PushbackInputStreamDemo1 {
    public static void main(String[] args) throws Exception {
        String s = "abcdefg";
        /*
         * PushbackInputStream pbin = new PushbackInputStream(in,4)
         * 這個構造函數建立的對象一次能夠回推一個緩存
         */
        try (ByteArrayInputStream in = new ByteArrayInputStream(s.getBytes());
                        PushbackInputStream pbin = new PushbackInputStream(in, 4)) {
            int n;
            byte[] buffer = new byte[4];
            while ((n = pbin.read(buffer)) != -1) {
                System.out.println(new String(buffer));
                //取回推緩存中的一部分數據 
                if(new String(buffer).equals("abcd"))pbin.unread(buffer,2,2);
                buffer = new byte[4];
            }
        }
    }
}

注：PushbackInputStream對象會使得InputStream對象（用於建立PushbackInputStream對象）的mark()或reset()方法無效。對於準備使用mark()或reset()方法的任何流來講，都應當使用markSupported()方法進行檢查。