多Java进程共享文件计数器的读取异常与数据不一致问题

需求与已实现概述 #

• 目标：实现两个独立Java进程的Player对象互相收发消息，每条消息附加共享计数器，发送一条计数器递增1
• 已完成：
  • Main类创建两个子进程，各自运行ProcessPlayer实例
  • 用messageCounter.txt文件存储共享计数器，初始值0，通过Utils类处理文件的创建、删除、更新操作
  • ProcessPlayer类实现消息收发逻辑，发送消息时读取文件计数器，附加后更新计数器

问题逐个分析与解决 #

1. 首次运行计数器重复（如1被附加两次） #

原因

两个进程同时对计数器文件进行读写操作时存在竞态条件：进程A和B同时读取到文件中的同一个计数器值，各自加1后写回，最终导致同一个计数器值被重复使用。普通文件本身没有同步机制，无法保证多进程读写的原子性。

解决方案

使用**文件排他锁（FileLock）**保证同一时间只有一个进程能读写计数器文件，操作流程如下：

// 带锁的计数器读写逻辑示例
try (RandomAccessFile raf = new RandomAccessFile("messageCounter.txt", "rw");
     FileChannel channel = raf.getChannel()) {
    // 获取排他锁，直到获取到才继续执行
    FileLock lock = channel.lock();
    try {
        // 定位到文件开头读取计数器
        raf.seek(0);
        String counterStr = raf.readLine();
        int counter = counterStr == null ? 0 : Integer.parseInt(counterStr);
        // 计数器递增
        counter++;
        // 写回文件并截断多余内容
        raf.seek(0);
        raf.writeBytes(String.valueOf(counter));
        raf.setLength(String.valueOf(counter).length());
    } finally {
        // 释放锁
        lock.release();
    }
} catch (IOException e) {
    e.printStackTrace();
}

这样能确保读写操作的原子性，避免两个进程同时操作导致的计数器重复。

2. 第二次运行抛出NumberFormatException（输入字符串为空），需手动终止子进程 #

原因

• 第一次运行结束时，子进程未正常终止，残留的文件句柄导致计数器文件被占用，无法正确写入最终值，甚至被截断为空
• Utils类的初始化/清理逻辑存在问题：第二次启动时未正确检查文件状态，比如文件存在但内容为空，直接读取导致转换失败
• 进程退出时未执行清理操作，比如未关闭文件流，导致缓冲区内容未写入磁盘，文件内容异常

解决方案

• 添加进程关闭钩子：在ProcessPlayer中添加ShutdownHook，确保进程退出时关闭所有文件流，正确重置计数器或清理文件

  Runtime.getRuntime().addShutdownHook(new Thread(() -> {
      try (RandomAccessFile raf = new RandomAccessFile("messageCounter.txt", "rw")) {
          raf.seek(0);
          raf.writeBytes("0");
          raf.setLength(1);
      } catch (IOException e) {
          e.printStackTrace();
      }
  }));
  

• 启动前检查并初始化文件：Main类启动子进程前，先删除旧的计数器文件，重新创建并写入初始值0，避免残留异常内容

  // Main类启动前的文件初始化
  File counterFile = new File("messageCounter.txt");
  if (counterFile.exists()) {
      counterFile.delete();
  }
  try (FileWriter writer = new FileWriter(counterFile)) {
      writer.write("0");
  } catch (IOException e) {
      e.printStackTrace();
  }
  

• 确保子进程正常终止：在Main类中调用Process.waitFor()等待子进程结束，或者在退出时调用Process.destroy()强制终止子进程

3. 使用Scanner读取文件时抛出NoSuchElementException，提示文件为空但实际非空 #

原因

• Scanner默认以换行符作为分隔符，如果计数器文件中没有换行符，调用scanner.next()或scanner.nextLine()会因为找不到下一个元素抛出异常
• 文件流未正确定位到开头，导致Scanner读取位置错误，读到空内容
• 文件被其他进程占用或缓冲区未刷新，导致Scanner读取到的内容与实际磁盘文件内容不一致

解决方案

• 改用更可靠的文件读取方式：使用Files.readString()（Java 11+）或FileReader一次性读取文件内容，避免Scanner的分隔符问题

  String counterStr = Files.readString(Paths.get("messageCounter.txt")).trim();
  int counter = Integer.parseInt(counterStr);
  

• 使用try-with-resources自动管理流：确保文件流被正确关闭，缓冲区内容写入磁盘

  // 写入文件的正确姿势
  try (FileWriter writer = new FileWriter("messageCounter.txt")) {
      writer.write(String.valueOf(counter));
  } catch (IOException e) {
      e.printStackTrace();
  }
  

• 配合文件锁读取：读取文件前先获取锁，确保读取到的是完整、最新的文件内容，避免其他进程正在写入导致的部分读取

内容的提问来源于stack exchange，提问作者Usman_Codes._.