Java多线程下在文件指定偏移量写入字节的实现（等价Node.js fs.write）

对应Node.js中fs.write(fd, buffer, offset, length, position, callback)的功能（通过position指定文件内的写入偏移量），Java中有两种主流实现方案，同时兼顾多线程场景的安全性：

方案1：使用RandomAccessFile #

RandomAccessFile支持通过seek()方法定位到文件指定偏移量，再执行写入操作。但它本身不是线程安全的，需要通过同步机制保证seek()和write()的原子性，避免多线程下指针被篡改导致写入位置错误。

代码示例 #

import java.io.RandomAccessFile;
import java.io.IOException;

public class PositionedFileWriter {
    private final RandomAccessFile raf;

    public PositionedFileWriter(String filePath) throws IOException {
        // 以读写模式打开文件
        this.raf = new RandomAccessFile(filePath, "rw");
    }

    /**
     * 向文件指定偏移量写入字节
     * @param buffer 待写入的字节缓冲区
     * @param bufferOffset 缓冲区的起始偏移量
     * @param length 要写入的字节长度
     * @param filePosition 文件内的写入偏移量
     */
    public void write(byte[] buffer, int bufferOffset, int length, long filePosition) throws IOException {
        // 同步RandomAccessFile实例，保证seek和write操作原子性
        synchronized (raf) {
            raf.seek(filePosition);
            raf.write(buffer, bufferOffset, length);
        }
    }

    public void close() throws IOException {
        raf.close();
    }
}

方案2：使用FileChannel（推荐） #

FileChannel提供了write(ByteBuffer src, long position)方法，直接支持指定文件偏移量写入，且该方法不会修改通道的当前位置——多线程下各自调用该方法写入不同区域时，无需额外同步，天然线程安全；若写入同一区域，则需自行加锁或使用文件锁控制并发。

这种方案性能优于RandomAccessFile，更适合多线程高并发场景。

代码示例 #

import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;
import java.io.RandomAccessFile;
import java.io.IOException;

public class ChannelPositionedWriter {
    private final FileChannel channel;

    public ChannelPositionedWriter(String filePath) throws IOException {
        RandomAccessFile raf = new RandomAccessFile(filePath, "rw");
        this.channel = raf.getChannel();
    }

    /**
     * 向文件指定偏移量写入字节
     * @param buffer 待写入的字节缓冲区
     * @param bufferOffset 缓冲区的起始偏移量
     * @param length 要写入的字节长度
     * @param filePosition 文件内的写入偏移量
     */
    public void write(byte[] buffer, int bufferOffset, int length, long filePosition) throws IOException {
        ByteBuffer byteBuffer = ByteBuffer.wrap(buffer, bufferOffset, length);
        // FileChannel.write可能无法一次性写完所有字节，需循环直到缓冲区耗尽
        while (byteBuffer.hasRemaining()) {
            long bytesWritten = channel.write(byteBuffer, filePosition);
            filePosition += bytesWritten;
        }
    }

    public void close() throws IOException {
        channel.close();
    }
}

额外说明 #

• 也可以通过FileOutputStream获取FileChannel：

  FileOutputStream fos = new FileOutputStream(filePath, true); // true表示追加模式，但不影响指定位置写入
  FileChannel channel = fos.getChannel();
  

• 若多线程需要写入同一文件区域，可通过channel.lock(filePosition, length, false)获取文件锁，避免数据覆盖。

多线程场景注意事项 #

• 写入不同文件区域：使用FileChannel的带position的write方法无需额外同步，性能最优。
• 写入同一文件区域：无论哪种方案，都需要通过应用层锁（如synchronized、ReentrantLock）或文件锁来保证数据一致性，防止多线程写入冲突。

内容的提问来源于stack exchange，提问作者xplore