如何确保 Java 安全复制外部程序正在写入的文件-java教程-PHP中文网

如何确保 Java 安全复制外部程序正在写入的文件

java 无法跨平台可靠判断一个文件是否已被外部程序完全写入；必须依赖协作式约定（如重命名、临时目录、就绪标记文件等）来规避竞态问题。

java 无法跨平台可靠判断一个文件是否已被外部程序完全写入；必须依赖协作式约定（如重命名、临时目录、就绪标记文件等）来规避竞态问题。

在多进程协同场景中（例如非 Java 程序生成文件，Java 程序消费文件），直接轮询 File.length() 或检查文件是否“存在”完全不可靠——因为文件可能正被写入中，此时复制将导致截断、损坏或数据丢失。Java 标准库（包括 Files.copy()、FileChannel 或 WatchService）均无法跨操作系统准确探测“写入完成”状态：Linux 的 inotify 不暴露写锁信息，Windows 的 ReadDirectoryChangesW 也无法区分追加写与写入结束，而 JVM 层面更无统一抽象。

因此，根本解法不是让 Java “检测完成”，而是让生产方主动“声明完成”。以下是经过生产验证的四种主流策略，按推荐优先级排序：

✅ 1. 原子重命名（最推荐，零依赖，强一致性）

生产方先将文件写入临时名称（如 data.csv.tmp），写完后原子重命名为最终名（如 data.csv）。Java 只监听最终名的 CREATE 事件（通过 WatchService）或定期扫描目标目录，一旦发现该文件即视为就绪。

// Java 端示例：使用 WatchService 监听 CREATE 事件（仅响应重命名后的最终文件）
try (WatchService watcher = FileSystems.getDefault().newWatchService()) {
    Path dir = Paths.get("/input");
    dir.register(watcher, StandardWatchEventKinds.ENTRY_CREATE);

    while (true) {
        WatchKey key = watcher.take();
        for (WatchEvent> event : key.pollEvents()) {
            if (event.kind() == StandardWatchEventKinds.ENTRY_CREATE) {
                Path fileName = (Path) event.context();
                if (fileName.toString().endsWith(".csv")) { // 过滤最终文件名
                    Path src = dir.resolve(fileName);
                    Path dst = Paths.get("/output", fileName.toString());
                    Files.copy(src, dst, StandardCopyOption.REPLACE_EXISTING);
                    System.out.println("Copied: " + fileName);
                }
            }
        }
        if (!key.reset()) break;
    }
}

⚠️ 注意：重命名在同文件系统内是原子操作，且所有主流 OS（Linux/macOS/Windows）均支持，真正平台无关。

Java Maven Secondary Analysis

分析ZIP压缩包或GitLab仓库中的Java Maven项目，确定二次开发范围、类数量、模块分布及生产相关指标。

下载

✅ 2. 临时目录 + 移动（语义清晰，适合大文件）

生产方在独立目录（如 /tmp/staging/）中完成全部写入，再通过 mv（Linux/macOS）或 MoveFileEx（Windows）将其移动至监控目录 /input/。移动操作同样具备原子性，Java 可安全监听 /input/ 中的新文件。

✅ 3. 就绪标记文件（显式信号，调试友好）

生产方写完主文件后，额外创建一个空标记文件（如 data.csv.ready）。Java 同时检查主文件存在性与对应 .ready 文件存在性，二者同时满足才执行复制。

Path dataFile = Paths.get("/input/data.csv");
Path readyFile = Paths.get("/input/data.csv.ready");
if (Files.exists(dataFile) && Files.exists(readyFile)) {
    Files.copy(dataFile, Paths.get("/output/data.csv"));
    Files.delete(readyFile); // 清理标记
}