IO流概述

// 装饰器模式的结构特征
public class BufferedInputStream extends FilterInputStream {
    // FilterInputStream 继承 InputStream 并持有 InputStream 引用
    // 这就是"自己也是流，内部又包装了一个流"
}

import java.io.FileInputStream;
import java.io.IOException;

public class EmployeeByteReader {
    public static void main(String[] args) {
        // 使用 try-with-resources 自动关闭流（JDK 7+）
        try (FileInputStream fis = new FileInputStream("C:/data/employees.txt")) {
            byte[] buffer = new byte[1024];
            int len;
            StringBuilder sb = new StringBuilder();
            while ((len = fis.read(buffer)) != -1) {
                // 将字节数组转为字符串
                sb.append(new String(buffer, 0, len));
            }
            System.out.println("=== 飞翔科技员工列表（字节流读取）===");
            System.out.println(sb.toString());
        } catch (IOException e) {
            System.err.println("读取员工文件失败：" + e.getMessage());
        }
    }
}

import java.io.*;

public class EmployeeBufferedReader {
    public static void main(String[] args) {
        // 装饰器模式：FileInputStream -> InputStreamReader -> BufferedReader
        // FileInputStream:     节点流，连接文件
        // InputStreamReader:  处理流，字节->字符（桥梁）
        // BufferedReader:     处理流，添加缓冲和按行读取
        try (BufferedReader br = new BufferedReader(
                new InputStreamReader(
                    new FileInputStream("C:/data/employees.txt"), "UTF-8"))) {
            String line;
            System.out.println("=== 飞翔科技员工列表（装饰器链读取）===");
            while ((line = br.readLine()) != null) {
                String[] parts = line.split("\\|");
                System.out.printf("姓名：%-6s  职位：%-8s  年龄：%s%n",
                    parts[0], parts[1], parts[2]);
            }
        } catch (IOException e) {
            System.err.println("读取员工文件失败：" + e.getMessage());
        }
    }
}

// ❌ 错误：流未关闭，文件句柄泄漏
FileInputStream fis = new FileInputStream("data.txt");
byte[] data = new byte[1024];
fis.read(data);
// 没有 fis.close(); —— 文件句柄一直被占用
// 多次调用后可能报错：Too many open files

// ❌ 错误：close() 在 finally 中但没处理 null 和异常
FileInputStream fis = null;
try {
    fis = new FileInputStream("data.txt");
    // ...操作
} catch (IOException e) {
    e.printStackTrace();
} finally {
    fis.close();  // 如果 fis 为 null 或 close() 本身抛异常呢？
}

// ✅ 正确：try-with-resources 自动关闭，代码简洁安全
try (FileInputStream fis = new FileInputStream("data.txt");
     BufferedInputStream bis = new BufferedInputStream(fis)) {
    byte[] data = new byte[1024];
    int len;
    while ((len = bis.read(data)) != -1) {
        System.out.write(data, 0, len);
    }
} catch (IOException e) {
    System.err.println("IO操作失败：" + e.getMessage());
}
// try 块结束时，bis.close() 和 fis.close() 自动按逆序调用