JDK源码-InputStream系列

byte

了解InputStream前,我们先了解下byte.

  • byte存在的意义:
    byte,字节,java中一种基本类型.通常在读取非文本文件(图片,声音,可执行文件,网络通信的数据)需要通过字节数组来保存文件中的内容.
    一个byte占用了8个bit位,所以byte的取值范围为-128到127.
    内存的最小单元是字节,Intel的X86的芯片内存地址是通过字节编的,指针可以指向的最小内存单元就是一个字节,16位的机器是两个字节,32位的机器是四个字节.
  • byte的包装类

byte的包装类就是Byte,列举一下常见方法

  • toString(byte b) //静态的,调用了Integer.toString()
  • ByteCache() //不是很懂,也不是静态方法啊
  • parseByte(String s) //超过范围或者不是数字会报:NumberFormatException,调用了Integer.parseInt()
  • valueOf() //把括号里的参数变成Byte对象,超过范围或者不是数字会报:NumberFormatException
  • byteValue() //返回Byte里的byte
  • shortValue() //返回short,代码里加了强转,平时不写是隐式类型转换,jvm实现的。
  • intValue(),longValue() //同上
  • floatValue(),doubleValue() //同上,但是不知道精度是否会丢失【TODO】
  • toString() //源码里调用了Integer.toString,非静态
  • hashCode() //返回这个类的hashCode
  • equals() //直接比byte了,也不用比hashCode了
  • compareTo(Byte anotherByte) //和另外一个Byte比较大小
  • compare(byte x, byte y) //静态方法

InputStream

抽象架构图

InputSteam是所有字节输入流的实现类的基类.它封装了流处理类的基本操作.

缓存区字节数组最大值
private static final int MAX_SKIP_BUFFER_SIZE = 2048;
从输入流中读取数据的下一个字节,返回int
public abstract int read() throws IOException;
从输入流中读取b.length大小的字节,并存储到字节数组b.
public int read(byte b[]) throws IOException {
        return read(b, 0, b.length);
    }

该方法调用了抽象方法:read(),通过该方法获取流中下一个元素.

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

        int c = read();
        if (c == -1) {
            return -1;
        }
        b[off] = (byte)c;

        int i = 1;
        try {
            for (; i < len ; i++) {
                c = read();
                if (c == -1) {
                    break;
                }
                b[off + i] = (byte)c;
            }
        } catch (IOException e) {
        }
        return i;
    }

原始流处理器

接收一个Byte数组对象,或者一个FileDiscriptor对象,一个String对象,或者其他类型的流源对象.
主要一下四种:

ByteArrayInputStream
  • ByteArrayInputStream里的方法基本上都被synchronized关键字修饰,所以它是线程安全的.
  • ByteArrayInputStream底层是一个缓冲字节数组
/**
     * An array of bytes that was provided
     * by the creator of the stream. Elements <code>buf[0]</code>
     * through <code>buf[count-1]</code> are the
     * only bytes that can ever be read from the
     * stream;  element <code>buf[pos]</code> is
     * the next byte to be read.
     */
    protected byte buf[];
  • 一般情况下很少使用ByteArrayInputStream,它存在的意义一方面是扩展了InputStream基类,可以通过它赖操作字节数组,另一方面,相当于是其他所有流的一个中间状态.,用来缓存其他流输入的数据.
  • 关闭一个字节流是没有意义的.
/**
     * Closing a <tt>ByteArrayInputStream</tt> has no effect. The methods in
     * this class can be called after the stream has been closed without
     * generating an <tt>IOException</tt>.
     */
    public void close() throws IOException {
    }
FileInputStream

先了解下一些相关类的实现:JDK源码-File系列

  • FileInputStream用来操作文件流数据,通过构造函数可知,可以通过文件路径,文件对象,文件描述符对象来创建文件输入流对象.
public FileInputStream(String name) throws FileNotFoundException {
        this(name != null ? new File(name) : null);
    }

public FileInputStream(File file) throws FileNotFoundException {
        String name = (file != null ? file.getPath() : null);
        SecurityManager security = System.getSecurityManager();
        if (security != null) {
            security.checkRead(name);
        }
        if (name == null) {
            throw new NullPointerException();
        }
        if (file.isInvalid()) {
            throw new FileNotFoundException("Invalid file path");
        }
        fd = new FileDescriptor();
        fd.attach(this);
        path = name;
        open(name);
    }
public FileInputStream(FileDescriptor fdObj) {
        SecurityManager security = System.getSecurityManager();
        if (fdObj == null) {
            throw new NullPointerException();
        }
        if (security != null) {
            security.checkRead(fdObj);
        }
        fd = fdObj;
        path = null;

        /*
         * FileDescriptor is being shared by streams.
         * Register this stream with FileDescriptor tracker.
         */
        fd.attach(this);
    }
  • FileInputStream的读取操作和打开文件的操作都是调用本地的native方法.
 /**
     * Opens the specified file for reading.
     * @param name the name of the file
     */
    private native void open0(String name) throws FileNotFoundException;

    // wrap native call to allow instrumentation
    /**
     * Opens the specified file for reading.
     * @param name the name of the file
     */
    private void open(String name) throws FileNotFoundException {
        open0(name);
    }

    /**
     * Reads a byte of data from this input stream. This method blocks
     * if no input is yet available.
     *
     * @return     the next byte of data, or <code>-1</code> if the end of the
     *             file is reached.
     * @exception  IOException  if an I/O error occurs.
     */
    public int read() throws IOException {
        return read0();
    }

    private native int read0() throws IOException;
PipedInputStream&PipedOutputStream

PipedInputStream与PipedOutputStream的设计,主要为了实现线程之间可以通过字节流来传输数据,来达到通信.

参考文章:Java流编程实例及代码

StringBufferInputStream

StringBufferInputStream:将一个字符串缓冲区转换为一个输入流。接收一个String对象作为流的源。(JDK帮助文档上说明:已过时。此类未能正确地将字符转换为字节。从JDK1.1开始,从字符串创建流的首选方法是通过StringReader类进行创建。只有字符串中每个字符的低八位可以由此类使用。)

ObjectInputStream/ObjectOutputStream

详见JDK源码-InputStream系列之ObjectOutputStream/ObjectInputStream

链接流处理器

FilterInputStream
  • FilterInputStream主要用于包装一些其他的基本数据的流对象.
  • 该类以及父类,子类的设计对应了装饰者模式.通过FilterInputStream的代理,所有的子类都可以装饰一个InputStream类型的对象.这样,就能够实现所有装饰类之间的互相转换了.
  • FilterInputStream实现了InputStream接口,同样实现了流处理对象的那一套方法.
BufferedInputStream
  • 它存在的意义是给另外的输入流添加功能,例如,提供“缓冲功能”以及支持“mark()标记”和“reset()重置方法”。
  • 它的底层实现是一个内部缓存数组.在读取输入流的时候,它会分批读入到缓冲区,当缓冲区中的数据被读完之后,输入流会再次填充数据缓冲区.
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 212,185评论 6 493
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,445评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 157,684评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,564评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,681评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,874评论 1 290
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,025评论 3 408
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,761评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,217评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,545评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,694评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,351评论 4 332
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,988评论 3 315
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,778评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,007评论 1 266
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,427评论 2 360
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,580评论 2 349

推荐阅读更多精彩内容

  • tags:io categories:总结 date: 2017-03-28 22:49:50 不仅仅在JAVA领...
    行径行阅读 2,171评论 0 3
  • 1. Java基础部分 基础部分的顺序:基本语法,类相关的语法,内部类的语法,继承相关的语法,异常的语法,线程的语...
    子非鱼_t_阅读 31,598评论 18 399
  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,633评论 18 139
  • 早上为儿子做好早餐送他上学,儿子给我讲了昨天在学校发生的事情! 有个女同学交作业时找不到作业本了,她告诉老师:“老...
    缪璘夙阅读 316评论 0 0
  • 邓平1阅读 146评论 0 0