（每日持续更新）jdk api之BufferedReader基础

1.8 BufferedReader

BufferedReader 是 Java 中 Reader 的缓冲流实现，用于提高读取字符数据的性能。它提供了一些额外的属性和方法，以增强对字符流的操作。

以下是 BufferedReader 的一些常用属性和方法：

属性：

protected char[] cb：
- 用于存储缓冲数据的字符数组。可以通过构造函数指定缓冲区大小，也可以通过 getBuf() 方法获取。
protected int nChars：
- 缓冲区中当前有效字符的数量。
protected int nextChar：
- 下一个要被读取的字符的索引。当达到缓冲区末尾时，会触发填充缓冲区的操作。
protected Reader in：
- 内部原始的字符输入流。可以通过构造函数传入或通过 getIn() 方法获取。

构造函数：

BufferedReader(Reader in)：
- 使用默认缓冲区大小创建 BufferedReader 对象。
BufferedReader(Reader in, int size)：
- 使用指定缓冲区大小创建 BufferedReader 对象。

方法：

void close()：
- 关闭字符输入流及其底层流。
void mark(int readAheadLimit)：
- 在当前流位置设置标记，最多允许跳过 readAheadLimit 个字符。
boolean markSupported()：
- 判断此流是否支持 mark 和 reset 操作。
int read()：
- 读取单个字符。返回读取的字符的 Unicode 值，如果已到达流的末尾，则返回 -1。
int read(char[] cbuf, int off, int len)：
- 将字符读入数组 cbuf，从偏移量 off 开始，最多读取 len 个字符。返回实际读取的字符数，如果已到达流的末尾，则返回 -1。
String readLine()：
- 读取一行文本。返回包含行内容的字符串，不包括行终止符（\r、\n 或 \r\n）。
boolean ready()：
- 判断是否可以从流中读取数据，而不会被阻塞。
void reset()：
- 将流的位置重置到最后一次调用 mark 方法设置的位置。
long skip(long n)：
- 跳过输入流中的 n 个字符。

使用示例：

javaCopy code
import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;

public class BufferedReaderExample {

    public static void main(String[] args) {
        String filePath = "example.txt";

        try (FileReader fileReader = new FileReader(filePath);
             BufferedReader bufferedReader = new BufferedReader(fileReader)) {

            String line;
            while ((line = bufferedReader.readLine()) != null) {
                // 处理读取的每一行文本
                System.out.println(line);
            }

        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

在这个例子中，BufferedReader 被用来包装一个 FileReader，以提供缓冲功能。通过 readLine 方法逐行读取文本文件内容。这种方式能够提高读取性能，减少与底层输入流的直接交互次数。

应用场景

BufferedReader 主要用于提高读取字符数据的性能，特别是在读取文本文件时。以下是一些适合使用 BufferedReader 的应用场景：

文本文件读取：

当从文本文件中逐行读取数据时，使用 BufferedReader 可以提高读取效率。

javaCopy code
try (FileReader fileReader = new FileReader("example.txt");
     BufferedReader bufferedReader = new BufferedReader(fileReader)) {
    String line;
    while ((line = bufferedReader.readLine()) != null) {
        // 处理读取的每一行文本
        System.out.println(line);
    }
} catch (IOException e) {
    e.printStackTrace();
}

网络数据读取：

在从网络连接中读取字符数据时，使用 BufferedReader 可以减少网络 I/O 操作，提高读取性能。

javaCopy code
try (Socket socket = new Socket("example.com", 80);
     InputStream socketInputStream = socket.getInputStream();
     InputStreamReader reader = new InputStreamReader(socketInputStream);
     BufferedReader bufferedReader = new BufferedReader(reader)) {
    String line;
    while ((line = bufferedReader.readLine()) != null) {
        // 处理读取的每一行文本
        System.out.println(line);
    }
} catch (IOException e) {
    e.printStackTrace();
}

日志文件分析：

当分析大型日志文件时，使用 BufferedReader 可以逐行读取日志信息，方便进行分析和处理。

javaCopy code
try (FileReader fileReader = new FileReader("application.log");
     BufferedReader bufferedReader = new BufferedReader(fileReader)) {
    String line;
    while ((line = bufferedReader.readLine()) != null) {
        // 分析日志信息
        // ...
    }
} catch (IOException e) {
    e.printStackTrace();
}

配置文件解析：

在解析配置文件时，使用 BufferedReader 可以方便地逐行读取配置信息。

javaCopy code
try (FileReader fileReader = new FileReader("config.properties");
     BufferedReader bufferedReader = new BufferedReader(fileReader)) {
    String line;
    while ((line = bufferedReader.readLine()) != null) {
        // 解析配置信息
        // ...
    }
} catch (IOException e) {
    e.printStackTrace();
}

总体而言，当需要频繁读取字符数据时，尤其是逐行读取文本文件时，使用 BufferedReader 可以减少 I/O 操作的次数，提高读取性能。在实际应用中，可以根据具体的场景和性能需求选择是否使用缓冲流。

实战例子

在实际项目中，BufferedReader 可以用于处理文本文件的读取。下面是一个简化的例子，模拟一个日志分析系统，从日志文件中读取数据并进行分析。

日志实体类：

javaCopy code
import java.util.Date;

public class LogEntry {
    private Date timestamp;
    private String message;

    // 构造方法、getter 和 setter 省略
}

日志分析器：

javaCopy code
import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.List;

public class LogAnalyzer {

    private static final String LOG_FILE_PATH = "application.log";

    public static void main(String[] args) {
        List logEntries = readAndAnalyzeLogs();
        
        // 在实际项目中，可以进一步对 logEntries 进行分析和处理
        for (LogEntry entry : logEntries) {
            System.out.println(entry.getTimestamp() + " - " + entry.getMessage());
        }
    }

    private static List readAndAnalyzeLogs() {
        List logEntries = new ArrayList();

        try (FileReader fileReader = new FileReader(LOG_FILE_PATH);
             BufferedReader bufferedReader = new BufferedReader(fileReader)) {

            String line;
            while ((line = bufferedReader.readLine()) != null) {
                LogEntry logEntry = parseLogEntry(line);
                if (logEntry != null) {
                    logEntries.add(logEntry);
                }
            }

        } catch (IOException e) {
            e.printStackTrace();
        }

        return logEntries;
    }

    private static LogEntry parseLogEntry(String logLine) {
        try {
            // 假设日志的格式为 "yyyy-MM-dd HH:mm:ss - Log message"
            SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            int timestampEndIndex = logLine.indexOf(" - ");
            if (timestampEndIndex != -1) {
                String timestampString = logLine.substring(0, timestampEndIndex);
                Date timestamp = dateFormat.parse(timestampString);
                String message = logLine.substring(timestampEndIndex + 3);
                return new LogEntry(timestamp, message);
            }
        } catch (ParseException e) {
            e.printStackTrace();
        }
        return null;
    }
}

在这个例子中，LogAnalyzer 类使用了 BufferedReader 从日志文件中读取数据。每一行日志都被解析为一个 LogEntry 对象，然后将这些对象存储在 logEntries 列表中。在实际项目中，你可以在 readAndAnalyzeLogs 方法中添加更多的日志分析逻辑。这个例子仅仅是一个演示，实际的日志分析系统可能会更加复杂。

本文来自网络，不代表协通编程立场，如若转载，请注明出处：https://www.net2asp.com/1f3ca87d3b.html