如何读取正在写入的文件？Java实现的注意事项与处理方案

阿华AIGC实验室

2026-5-7

Java实时读写文件做校验的注意事项与问题处理

嘿，这个需求确实很实用——很多自动化测试、结果监控类的场景都会需要实时读取正在写入的文件来做通过/失败/正确性校验。我来给你梳理下Java实现这个需求的关键注意事项，以及你关心的读取追上写入进度的问题：

一、Java实现实时读写的核心注意事项

1. 文件打开模式与锁机制

写入时绝对不要用独占写入模式！Java里FileOutputStream默认是覆盖写，但如果用new FileOutputStream(file, true)开启追加模式，能避免独占锁导致读取端无法访问文件。更推荐用NIO的FileChannel或Files类API，它们对并发读写的支持更灵活，也更容易控制锁的范围。

2. 缓冲区的同步问题

Java的缓冲流（比如BufferedWriter）会攒够一定数据才刷到磁盘，这会导致读取端看不到最新内容，校验延迟。解决办法：

写入端每次写完关键内容后调用flush()，强制把缓冲区数据刷到磁盘；
如果对实时性要求极高，可以直接使用无缓冲的原始字节/字符流（牺牲一点性能换实时性）。

3. 跨平台的文件系统差异

不同操作系统对文件并发读写的支持不一样：

Windows下如果写入流未关闭，某些读取方式可能报错；
Linux/Unix下相对宽松，但也要注意文件权限问题。
务必在目标运行的操作系统上做测试，避免跨平台踩坑。

4. 编码一致性

写入和读取必须使用完全相同的字符编码（比如UTF-8），否则会出现乱码直接导致校验逻辑失效。示例：

// 写入端
try (OutputStreamWriter writer = new OutputStreamWriter(new FileOutputStream("result.txt", true), StandardCharsets.UTF_8)) {
    writer.write("校验内容\n");
    writer.flush();
}

// 读取端
try (InputStreamReader reader = new InputStreamReader(new FileInputStream("result.txt"), StandardCharsets.UTF_8)) {
    // 读取逻辑
}

二、读取追上写入进度的行为与处理

默认情况下，Java的读取流（比如FileInputStream、BufferedReader）在读到文件末尾时，不会阻塞等待新内容，也不会抛出异常：

字节流会返回-1；
字符流（比如BufferedReader.readLine()）会返回null。

针对这种情况，有几种常见的处理方案：

1. 简单轮询读取

适合对实时性要求不高的场景，读到末尾时暂停一小段时间再重试：

try (BufferedReader reader = new BufferedReader(new FileReader("result.txt"))) {
    String line;
    while (true) {
        line = reader.readLine();
        if (line == null) {
            // 读到末尾，等待100ms后重试
            Thread.sleep(100);
            continue;
        }
        // 执行校验逻辑
        validateResult(line);
        // 读到结束标记就退出循环
        if ("__WRITE_COMPLETE__".equals(line)) {
            break;
        }
    }
} catch (IOException | InterruptedException e) {
    e.printStackTrace();
}

2. 用NIO的WatchService监听文件变化

Java 7+提供的WatchService可以监听目录下的文件修改事件，当写入端有新内容刷到磁盘时，再触发读取操作，比轮询更高效：

WatchService watchService = FileSystems.getDefault().newWatchService();
Path dir = Paths.get("文件所在目录");
dir.register(watchService, StandardWatchEventKinds.ENTRY_MODIFY);

// 记录上次读取的位置，避免重复读取
long lastReadPos = 0;
RandomAccessFile raf = new RandomAccessFile("result.txt", "r");

while (true) {
    WatchKey key = watchService.take();
    for (WatchEvent<?> event : key.pollEvents()) {
        if (event.context().toString().equals("result.txt")) {
            raf.seek(lastReadPos);
            String line;
            while ((line = raf.readLine()) != null) {
                validateResult(line);
                if ("__WRITE_COMPLETE__".equals(line)) {
                    raf.close();
                    watchService.close();
                    return;
                }
            }
            lastReadPos = raf.getFilePointer();
        }
    }
    key.reset();
}

注意：WatchService可能会触发重复的修改事件，需要做去重处理；另外要过滤掉临时文件（比如某些写入工具会先写临时文件再替换原文件）。

3. 用RandomAccessFile精确控制读取位置

通过记录每次读取的位置，下次直接从该位置开始读取，避免重复处理已读内容：

try (RandomAccessFile raf = new RandomAccessFile("result.txt", "r")) {
    long lastPos = 0;
    while (true) {
        long currentFileLength = raf.length();
        if (currentFileLength > lastPos) {
            raf.seek(lastPos);
            String line;
            while ((line = raf.readLine()) != null) {
                validateResult(line);
                if ("__WRITE_COMPLETE__".equals(line)) {
                    return;
                }
            }
            lastPos = raf.getFilePointer();
        } else {
            Thread.sleep(100);
        }
    }
} catch (IOException | InterruptedException e) {
    e.printStackTrace();
}