【大数据】学习笔记 1 Java SE 第14章 File类与IO流 14.5 缓冲流

妖狐艹你老母 2024-03-22 14:29 76阅读 0赞

### 【大数据】学习笔记 ###

#### 文章目录 ####

*   *  【大数据】学习笔记
     *   *  1 Java SE
         *   *  第14章 File类与IO流
             *   *  14.5 缓冲流
                 *   *  14.5.1 构造方法
                     *  14.5.2 效率测试
                     *  14.5.3 字符缓冲流特有方法
                     *  14.5.4 流的关闭顺序

![在这里插入图片描述][f49819f08ebc470c8d193bfb9e98fa9d.png_pic_center]

#### 1 Java SE ####

##### 第14章 File类与IO流 #####

###### 14.5 缓冲流 ######

缓冲流,也叫高效流，按照数据类型分类：

*  **字节缓冲流**：`BufferedInputStream`，`BufferedOutputStream`
 *  **字符缓冲流**：`BufferedReader`，`BufferedWriter`

缓冲流的基本原理，是在创建流对象时，会创建一个内置的默认大小的缓冲区数组，通过缓冲区读写，减少系统IO次数，从而提高读写的效率。

###### 14.5.1 构造方法 ######

*  `public BufferedInputStream(InputStream in)` ：创建一个 新的缓冲输入流。
 *  `public BufferedOutputStream(OutputStream out)`： 创建一个新的缓冲输出流。

构造举例，代码如下：

// 创建字节缓冲输入流
    BufferedInputStream bis = new BufferedInputStream(new FileInputStream("bis.txt"));
    // 创建字节缓冲输出流
    BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream("bos.txt"));

*  `public BufferedReader(Reader in)` ：创建一个 新的缓冲输入流。
 *  `public BufferedWriter(Writer out)`： 创建一个新的缓冲输出流。

构造举例，代码如下：

// 创建字符缓冲输入流
    BufferedReader br = new BufferedReader(new FileReader("br.txt"));
    // 创建字符缓冲输出流
    BufferedWriter bw = new BufferedWriter(new FileWriter("bw.txt"));

###### 14.5.2 效率测试 ######

查询API，缓冲流读写方法与基本的流是一致的，我们通过复制大文件（622MB），测试它的效率。

package com.dingjiaxiong.buffer;
    
    import org.junit.Test;
    
    import java.io.*;
    
    /**
     * @Projectname: BigDataStudy
     * @Classname: BufferedIO
     * @Author: Ding Jiaxiong
     * @Date:2023/4/28 13:26
     */
    
    public class BufferedIO {
        
        @Test
        public void testNoBuffer() throws IOException {
        
            // 记录开始时间
            long start = System.currentTimeMillis();
            // 创建流对象
            FileInputStream fis = new FileInputStream("jdk8.exe");
            FileOutputStream fos = new FileOutputStream("copy.exe");
            // 读写数据
            byte[] data = new byte[1024];
            int len;
            while ((len = fis.read(data)) != -1) {
        
                fos.write(data, 0, len);
            }
    
            fos.close();
            fis.close();
    
            // 记录结束时间
            long end = System.currentTimeMillis();
            System.out.println("普通流复制时间:" + (end - start) + " 毫秒");
        }
    
        @Test
        public void testUseBuffer() throws IOException {
        
            // 记录开始时间
            long start = System.currentTimeMillis();
            // 创建流对象
            BufferedInputStream bis = new BufferedInputStream(new FileInputStream("jdk8.exe"));
            BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream("copy.exe"));
            // 读写数据
            int len;
            byte[] data = new byte[1024];
            while ((len = bis.read(data)) != -1) {
        
                bos.write(data, 0, len);
            }
    
            bos.close();
            bis.close();
            // 记录结束时间
            long end = System.currentTimeMillis();
            System.out.println("缓冲流使用数组复制时间:" + (end - start) + " 毫秒");
        }
    }

![在这里插入图片描述][fd3f473e798847a1919a7cffdf6aaccb.png_pic_center]

测试结果

![在这里插入图片描述][8dd1972174c44b63b60855d20b71f634.png_pic_center]

![在这里插入图片描述][ab4e646db13e4e1dbea22e2a4d27d732.png_pic_center]

![在这里插入图片描述][8fe5255e48c14385ab307ef1f0b4a9e4.png_pic_center]

###### 14.5.3 字符缓冲流特有方法 ######

字符缓冲流的基本方法与普通字符流调用方式一致，不再阐述，我们来看它们具备的特有方法。

*  BufferedReader：`public String readLine()`: 读一行文字。
 *  BufferedWriter：`public void newLine()`: 写一行行分隔符,由系统属性定义符号。

package com.dingjiaxiong.buffer;
    
    import org.junit.Test;
    
    import java.io.*;
    
    /**
     * @Projectname: BigDataStudy
     * @Classname: BufferedIOLine
     * @Author: Ding Jiaxiong
     * @Date:2023/4/28 13:30
     */
    
    public class BufferedIOLine {
        
        @Test
        public void testReadLine() throws IOException {
        
            // 创建流对象
            BufferedReader br = new BufferedReader(new FileReader("in.txt"));
            // 定义字符串,保存读取的一行文字
            String line;
            // 循环读取,读取到最后返回null
            while ((line = br.readLine()) != null) {
        
                System.out.println(line);
            }
            // 释放资源
            br.close();
        }
    
        @Test
        public void testNewLine() throws IOException {
        
            // 创建流对象
            BufferedWriter bw = new BufferedWriter(new FileWriter("out.txt"));
            // 写出数据
            bw.write("尚");
            // 写出换行
            bw.newLine();
            bw.write("硅");
            bw.newLine();
            bw.write("谷");
            bw.newLine();
            // 释放资源
            bw.close();
        }
    }

![在这里插入图片描述][507def1922d24401a5918f3ba5a23d86.png_pic_center]

![在这里插入图片描述][3fc276c74ac1400cbcd1522f3b75f403.png_pic_center]

###### 14.5.4 流的关闭顺序 ######

package com.dingjiaxiong.buffer;
    
    import org.junit.Test;
    
    import java.io.BufferedWriter;
    import java.io.FileWriter;
    import java.io.IOException;
    
    /**
     * @Projectname: BigDataStudy
     * @Classname: IOClose
     * @Author: Ding Jiaxiong
     * @Date:2023/4/28 13:32
     */
    
    public class IOClose {
        
        @Test
        public void test01() throws IOException {
        
            FileWriter fw = new FileWriter("d:/1.txt");
            BufferedWriter bw = new BufferedWriter(fw);
    
            bw.write("hello");
    
            fw.close();
            bw.close();//java.io.IOException: Stream closed
            /*
            缓冲流BufferedWriter，把数据先写到缓冲区，
            默认情况下是当缓冲区满，或调用close，或调用flush这些情况才会把缓冲区的数据输出。
    
            bw.close()时，需要把数据从缓冲区的数据输出。
    
            数据的流向： 写到bw（缓冲区）-->fw ->"d:/1.txt"
            此时，我先把fw关闭了，bw的数据无法输出了
             */
        }
    
        @Test
        public void test02() throws IOException {
        
            FileWriter fw = new FileWriter("d:/1.txt");
            BufferedWriter bw = new BufferedWriter(fw);
    
            bw.write("hello");
    
            bw.close();
            fw.close();
            /*
            原则：
            先关外面的，再关里面的。
    
            例如：
            FileWriter fw = new FileWriter("d:/1.txt"); //里面        穿内衣
            BufferedWriter bw = new BufferedWriter(fw); //外面        穿外套
    
            关闭
            bw.close();  //先关外面的                                
            fw.close(); //再关里面的                                 
             */
        }
    }

![在这里插入图片描述][faff62f5d10545b18b51765e10fb16a4.png_pic_center]

![在这里插入图片描述][a4ac50b1717542b48a94ed42ccebf21f.png_pic_center]

[f49819f08ebc470c8d193bfb9e98fa9d.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/6ed5dca21ae14fb2a6b323f0ea4ed0f5.png
[fd3f473e798847a1919a7cffdf6aaccb.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/582cea4b611940d4a13d9d1e08afb7aa.png
[8dd1972174c44b63b60855d20b71f634.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/b695e8c913e44f5fb45083d21db64630.png
[ab4e646db13e4e1dbea22e2a4d27d732.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/350bfdf3e83647a8aacd7ed3adb27549.png
[8fe5255e48c14385ab307ef1f0b4a9e4.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/1e18349eac1f4e169d2de965e7d17b2d.png
[507def1922d24401a5918f3ba5a23d86.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/04a83fc6b626452180f12abb8b628005.png
[3fc276c74ac1400cbcd1522f3b75f403.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/d346850aaef04da596c350f76fc87bcb.png
[faff62f5d10545b18b51765e10fb16a4.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/8bc22ef2d0c54f39b38c99a6429cbc65.png
[a4ac50b1717542b48a94ed42ccebf21f.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/7f827685e75343309ff382d1542680e0.png