请选择 进入手机版 | 继续访问电脑版

[IO] JavaIO之PushBackInputStream (十四)

编程语言 编程语言 1336 人阅读 | 0 人回复

功能简介

PushBackInputStream是针对于输入的一种扩展功能 装饰器模式中的具体的装饰类,抽象的装饰器为FilterInputStream PushBackInputStream的重点在于理解缓冲区的使用手段

image.png

流本身不支持回退功能,想要能够pushBack 显然必须能够缓存数据 PushBackInputStream内部维护了一个字节数组

image.png

不要想当然的认为,类似BufferedInputStream,内部缓冲了一个数组,所有的数据都要经过这个缓冲区,然后对他做处理 他内部维护的缓冲区,仅仅保存pushBack的字节

还需要注意的是他的内部缓冲区是从后往前写入的,也就是下图中的,从右往左 下标索引大的先写入

一旦写满, 会抛出异常 throw new IOException("Push back buffer is full");

image.png

image.png

推回一个字节 由于是从最后开始.,一旦pos等于0也就是到了最前面,就无处可放了 所以抛出异常 否则,就在前面写入一个

本文作者:程序员潇然 疯狂的字节X https://crazybytex.com/

image.png

推回 指定字节数组b 从off偏移量开始的len个字节 推回len个长度,既然是从后往前设置数据,那么pos的值就是可用 空间 的个数 如果空间不够,抛出异常 否则,pos直接向前移动到指定位置 然后借助于System.arraycopy 将b 偏移量off开始拷贝到

image.png

是unread(byte[] b, int off, int len)的简化形式 用于拷贝整个数组

从unread可以清晰的看出来 内部的缓冲区,只是为了给被回退掉的数据使用的 每次回退就是在最前面(下表索引较小的位置) 写入数据

read

只要明确了unread以及内部缓冲区的存放形式即可很清楚的知道read的工作方式了

image.png

既然是从最后开始往前依次存放,初始时 pos == buf.length 那么但凡有数据,pos必然,小于buf.length 也就是说,读取一个字节时,如果回退缓冲内有数据,直接返回一个字节 否则,调用父类的read方法,而父类FilterInputStream 只是简单的 封装转发请求 实际上就是直接使用内部的InputStream进行处理

多参数的read方法,将数据写入到指定的字节数组b中

回退缓冲区中有效字节个数为avail = buf.length - pos; 如果缓冲区中有数据,那么将首先从回退缓冲区中读取数据

如果读取的字节数少于 len 个字节,那么它将从底层输入流中读取字节

image.png

PushBackInputStream 不支持标记点相关的操作

image.png

总结

PushBackInputStream的实现逻辑比较清晰

我内部有一个缓冲区,你要是回退了我就往里面写入数据

每次的数据读取都是先看看缓冲区里面有没有数据,有的话就先读取回退缓冲区的

否则,就再去使用实际的流去进行读取

看得出来,如果你从来不曾回退过,那么好像什么都一样,还是使用原来的InputStream 进行读取

common_log.png 转载务必注明出处:程序员潇然,疯狂的字节X,https://crazybytex.com/thread-150-1-1.html

关注下面的标签,发现更多相似文章

文章被以下专栏收录:

    黄小斜学Java

    疯狂的字节X

  • 目前专注于分享Java领域干货,公众号同步更新。原创以及收集整理,把最好的留下。
    包括但不限于JVM、计算机科学、算法、数据库、分布式、Spring全家桶、微服务、高并发、Docker容器、ELK、大数据等相关知识,一起进步,一起成长。
热门推荐
[CXX1300] CMake '3.18.1' was not
[md][CXX1300] CMake '3.18.1' was not found in SDK, PATH, or
[若依]微服务springcloud版新建增添加一个
[md]若依框架是一个比较出名的后台管理系统,有多个不同版本。
解决waiting for all target devices to co
[md]解决Launching app ,waiting for all target devices to co