Java超详细梳理IO流的使用方法上

在Java中，I/O流是非常重要的概念，可以让我们在程序中读写数据。Java的I/O库提供了各种类型的流，例如字节流、字符流和缓冲流。在本文中，我们将详细讲解Java中I/O流的使用方法。

前置知识

在学习Java中I/O流的使用方法之前，我们需要掌握以下基础知识：

1. Java中的输入输出流的概念及基本操作；
2. Java中的字节流与字符流的区别及使用场景；
3. Java中的File类的使用。

如果您还不熟悉上述知识，建议您先学习相关基础知识。

Java中的InputStream和OutputStream

InputStream和OutputStream是Java中I/O库提供的基本流。InputStream用于读取数据，OutputStream用于写数据。

InputStream的使用方法

InputStream有多个实现，包括FileInputStream、ByteArrayInputStream和PipedInputStream等。下面我们以FileInputStream为例讲解InputStream的使用方法。

try {
    FileInputStream inputStream = new FileInputStream("input.txt");
    int data = inputStream.read();
    while(data != -1) {
        // 处理读取到的数据
        System.out.println((char) data);
        data = inputStream.read();
    }
} catch (IOException e) {
    e.printStackTrace();
}

上面的代码中我们创建了一个FileInputStream对象，用于读取文件input.txt中的数据。然后我们使用inputStream.read()方法读取数据，每次读取一个字节，直到读取到文件末尾（即read()方法返回-1）。

OutputStream的使用方法

OutputStream有多个实现，包括FileOutputStream、ByteArrayOutputStream和PipedOutputStream等。下面我们以FileOutputStream为例讲解OutputStream的使用方法。

try {
    FileOutputStream outputStream = new FileOutputStream("output.txt");
    String data = "This is sample data";
    byte[] bytes = data.getBytes();
    outputStream.write(bytes);
    outputStream.flush();
    outputStream.close();
} catch (IOException e) {
    e.printStackTrace();
}

上面的代码中我们创建了一个FileOutputStream对象，用于写入文件output.txt中。我们将字符串数据转换为字节数组，然后通过outputStream.write()方法写入数据。最后，我们通过outputStream.flush()方法将数据刷新到磁盘上，然后关闭输出流。

Java中的Reader和Writer

Reader和Writer是Java中I/O库提供的用于读写字符数据的流。Reader用于读取字符数据，Writer用于写字符数据。

Reader的使用方法

Reader有多个实现，包括FileReader、InputStreamReader和StringReader等。下面我们以FileReader为例讲解Reader的使用方法。

try {
    FileReader reader = new FileReader("input.txt");
    int data = reader.read();
    while(data != -1) {
        // 处理读取到的数据
        System.out.println((char) data);
        data = reader.read();
    }
} catch (IOException e) {
    e.printStackTrace();
}

上面的代码中我们创建了一个FileReader对象，用于读取文件input.txt中的字符数据。然后我们使用reader.read()方法读取数据，每次读取一个字符，直到读取到文件末尾（即read()方法返回-1）。

Writer的使用方法

Writer有多个实现，包括FileWriter、OutputStreamWriter和StringWriter等。下面我们以FileWriter为例讲解Writer的使用方法。

try {
    FileWriter writer = new FileWriter("output.txt");
    String data = "This is sample data";
    writer.write(data);
    writer.flush();
    writer.close();
} catch (IOException e) {
    e.printStackTrace();
}

上面的代码中我们创建了一个FileWriter对象，用于写入文件output.txt中。我们使用writer.write()方法写入字符数据。最后，我们通过writer.flush()方法将数据刷新到磁盘上，然后关闭输出流。

使用缓冲流

在Java中，我们还可以使用缓冲流来提高I/O操作的效率。缓冲流会将数据暂存在内存中，然后一次性写入磁盘或读取数据。下面我们以BufferedReader和BufferedWriter为例讲解缓冲流的使用方法。

使用BufferedReader读取数据

try {
    BufferedReader reader = new BufferedReader(new FileReader("input.txt"));
    String line = reader.readLine();
    while(line != null) {
        // 处理读取到的数据
        System.out.println(line);
        line = reader.readLine();
    }
    reader.close();
} catch (IOException e) {
    e.printStackTrace();
}

上面的代码中我们创建了一个BufferedReader对象，用于读取文件input.txt中的文本数据。我们使用reader.readLine()方法读取数据，读取到文件末尾时返回null。

使用BufferedWriter写入数据

try {
    BufferedWriter writer = new BufferedWriter(new FileWriter("output.txt"));
    String data = "This is sample data";
    writer.write(data);
    writer.newLine();
    writer.flush();
    writer.close();
} catch (IOException e) {
    e.printStackTrace();
}

上面的代码中我们创建了一个BufferedWriter对象，用于写入文件output.txt中。我们使用writer.write()方法写入字符数据，并使用writer.newLine()方法写入换行符。最后，我们通过writer.flush()方法将数据刷新到磁盘上，然后关闭输出流。

示例说明

下面我们以读取CSV文件并将数据写入数据库为例，实现完整的I/O操作。

读取CSV文件

try {
    BufferedReader reader = new BufferedReader(new FileReader("data.csv"));
    String line = reader.readLine();
    while(line != null) {
        String[] values = line.split(",");
        // 将数据写入数据库
        insertDataIntoDatabase(values);
        line = reader.readLine();
    }
    reader.close();
} catch (IOException e) {
    e.printStackTrace();
}

上面的代码中我们通过BufferedReader读取CSV文件中的数据。我们使用readLine()方法读取每行数据，并使用String的split()方法将数据按照逗号分隔成一个数组。最后，我们将数据写入到数据库中。

将数据写入数据库

public void insertDataIntoDatabase(String[] values) {
    // 假设这里使用了JDBC进行数据库操作
    Connection connection = getConnection();
    String sql = "INSERT INTO table_name (col1, col2, col3) VALUES (?, ?, ?)";
    PreparedStatement statement = connection.prepareStatement(sql);
    statement.setString(1, values[0]);
    statement.setString(2, values[1]);
    statement.setString(3, values[2]);
    statement.executeUpdate();
    statement.close();
}

上面的代码中我们假设使用JDBC进行数据库操作。我们创建了一个数据库连接，然后使用PrepareStatement对象将CSV文件中的数据插入到数据库中。最后，我们关闭PrepareStatement对象和数据库连接。