Androidjava 成神之路技术文

BufferedInputStream 缓冲区原理解析

2017-07-21  本文已影响227人  jijs

BufferedInputStream是带缓冲区的输入流,默认缓冲区大小是8M,能够减少访问磁盘的次数,提高文件读取性能;BufferedOutputStream是带缓冲区的输出流,能够提高文件的写入效率。BufferedInputStream与BufferedOutputStream分别是FilterInputStream类和FilterOutputStream类的子类,实现了装饰设计模式。

BufferedInputStream在其内部维护一个字节数组作为缓冲区,而从底层(文件)流中读取数据的操作还是调用InputStream的方法完成。

下面通过一个例子来讲解Buffered的缓冲区原理机制

public class BufferedInputStreamDemo {
    public static void main(String[] args) throws Exception {

        try (InputStream ai = new ByteArrayInputStream("1234567890".getBytes());
             InputStream bis = new BufferedInputStream(ai, 4)) {

            System.out.println("Char : " + (char) bis.read());    //step:1
            System.out.println("Char : " + (char) bis.read());    //step:2

            bis.mark(3);                                          //step:3
            System.out.println("-------mark(3)----------");

            System.out.println("Char : " + (char) bis.read());    //step:4
            System.out.println("Char : " + (char) bis.read());    //step:5
            System.out.println("Char : " + (char) bis.read());    //step:6

            bis.reset();                                          //step:7
            System.out.println("-------reset()----------");

            int b;
            while ((b = bis.read()) != -1) {
                System.out.println("char : " + (char) b);
            }

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

输出的结果为:

Char : 1
Char : 2
-------mark(3)----------
Char : 3
Char : 4
Char : 5
-------reset()----------
char : 3
char : 4
char : 5
char : 6
char : 7
char : 8
char : 9
char : 0

准备

构造一个BufferedInputStream对象,缓冲区的大小为4字节。从ByteArrayInputStream流中读取数据“1234567890”。

变量说明:

pos:是下一次待读取缓冲区的坐标
markpos:mark()标记的缓冲区坐标。默认markpos=-1。

step:1

** 操作:read()**

read()操作

第一次读取数据,首先初始化一个4字节大小的缓冲区,然后调用内部的fill()方法填充缓冲区,填充完成后开始读取缓冲区中的第一个元素“1”。
程序通过i++操作读取完第一个数据后pos坐标就会指向下一个待读取的元素(这里指向第二个元素)。

数组坐标是从0开始的,所以读取完成第一个元素后,pos=1。

pos=1

step:2

操作:read()

read()操作

读出元素“2”

pos=2

step:3

操作:mark (3)

reset(3)操作

执行mark(3)进行标记。这时markpos和pos坐标相同.

markpos=2
pos=2

step:4

** 操作:read()**

read()操作

读出元素“3”

markpos=2
pos=3

step:5

** 操作:read()**

read()操作

读出元素“4”

markpos=2
pos=4

step:6

** 操作:read()**

read()操作

当读取pos=4时,超出缓冲区容量,这时,需要重新再从目标流中读取元素。因为在step:3时mark标记过元素,当reset的时候还需要读取(元素“3和4”)。这时,需要把mark后的元素也要保留到缓冲区中,mark之前的数据丢弃(元素“1和2”)。剩下的容量读取新元素(还可读取两个元素“5、和6”)。
标记过的元素“3”的坐标现在为0。所以markpos=0。

读出元素“5”

markpos=0
pos=4

step:7

** 操作:reset()**

reset()操作

reset()后把pos的坐标置为0,然后在读取的时候又可以读取到元素“3、4、5”

后续while循环操作

read()操作

读取元素“3”、“4”、“5”时坐标的变化

后续while循环操作

read()操作

读取元素“6”

markpos=0
pos=4

注意:这时如果执行reset操作,那么将可以读取之前的4个元素(mark(3)的时候指定的是可以读取3个元素)

后续while循环操作

read()操作

缓冲区读完后,重新再读取一批数据,因为该缓冲区没有执行mark操作,此时设置markpos=-1。

最后一次读取

read()操作

读取元素“0”


想了解更多精彩内容请关注我的公众号

上一篇下一篇

猜你喜欢

热点阅读