Java NIO如何优化文件读写操作

Java NIO（New I/O）提供了更高效的文件读写操作方式，相比于传统的IO，NIO提供了非阻塞I/O、缓冲区和通道等特性，可以显著提高文件读写的性能。以下是一些使用Java NIO优化文件读写操作的方法：

1. 使用FileChannel

FileChannel是NIO中用于文件操作的通道，它提供了比传统的FileInputStream和FileOutputStream更高效的文件读写方式。

写入文件

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

public class NIOFileWriteExample {
    public static void main(String[] args) throws Exception {
        RandomAccessFile file = new RandomAccessFile("example.txt", "rw");
        FileChannel channel = file.getChannel();

        String newData = "New String to write to file...";
        ByteBuffer buf = ByteBuffer.allocate(48);
        buf.clear();
        buf.put(newData.getBytes());
        buf.flip();
        while (buf.hasRemaining()) {
            channel.write(buf);
        }

        channel.close();
        file.close();
    }
}

读取文件

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

public class NIOFileReadExample {
    public static void main(String[] args) throws Exception {
        RandomAccessFile file = new RandomAccessFile("example.txt", "r");
        FileChannel channel = file.getChannel();

        ByteBuffer buf = ByteBuffer.allocate(48);
        int bytesRead = channel.read(buf);
        while (bytesRead != -1) {
            buf.flip();
            while (buf.hasRemaining()) {
                System.out.print((char) buf.get());
            }
            buf.clear();
            bytesRead = channel.read(buf);
        }

        channel.close();
        file.close();
    }
}

2. 使用MappedByteBuffer

MappedByteBuffer可以将文件的一部分或全部映射到内存中，从而实现更高效的文件读写操作。

写入文件

import java.io.RandomAccessFile;
import java.nio.MappedByteBuffer;
import java.nio.channels.FileChannel;

public class NIOFileWriteMappedExample {
    public static void main(String[] args) throws Exception {
        RandomAccessFile file = new RandomAccessFile("example.txt", "rw");
        FileChannel channel = file.getChannel();

        long fileSize = 1024 * 1024; // 1MB
        MappedByteBuffer buffer = channel.map(FileChannel.MapMode.READ_WRITE, 0, fileSize);

        String newData = "New String to write to file...";
        buffer.put(newData.getBytes());

        channel.close();
        file.close();
    }
}

读取文件

import java.io.RandomAccessFile;
import java.nio.MappedByteBuffer;
import java.nio.channels.FileChannel;

public class NIOFileReadMappedExample {
    public static void main(String[] args) throws Exception {
        RandomAccessFile file = new RandomAccessFile("example.txt", "r");
        FileChannel channel = file.getChannel();

        long fileSize = channel.size();
        MappedByteBuffer buffer = channel.map(FileChannel.MapMode.READ_ONLY, 0, fileSize);

        while (buffer.hasRemaining()) {
            System.out.print((char) buffer.get());
        }

        channel.close();
        file.close();
    }
}

3. 使用AsynchronousFileChannel

AsynchronousFileChannel提供了异步文件读写操作，可以在不阻塞主线程的情况下进行文件操作。

异步写入文件

import java.nio.ByteBuffer;
import java.nio.channels.AsynchronousFileChannel;
import java.nio.file.Paths;
import java.nio.file.StandardOpenOption;
import java.util.concurrent.Future;

public class NIOAsyncWriteExample {
    public static void main(String[] args) throws Exception {
        AsynchronousFileChannel fileChannel = AsynchronousFileChannel.open(Paths.get("example.txt"), StandardOpenOption.WRITE);

        ByteBuffer buffer = ByteBuffer.wrap("New String to write to file...".getBytes());
        Future<Integer> operation = fileChannel.write(buffer, 0);

        // 等待操作完成
        operation.get();

        fileChannel.close();
    }
}

异步读取文件

import java.nio.ByteBuffer;
import java.nio.channels.AsynchronousFileChannel;
import java.nio.file.Paths;
import java.nio.file.StandardOpenOption;
import java.util.concurrent.Future;

public class NIOAsyncReadExample {
    public static void main(String[] args) throws Exception {
        AsynchronousFileChannel fileChannel = AsynchronousFileChannel.open(Paths.get("example.txt"), StandardOpenOption.READ);

        ByteBuffer buffer = ByteBuffer.allocate(1024);
        Future<Integer> operation = fileChannel.read(buffer, 0);

        // 等待操作完成
        while (!operation.isDone()) {
            // 可以在这里做其他事情
        }

        buffer.flip();
        while (buffer.hasRemaining()) {
            System.out.print((char) buffer.get());
        }

        fileChannel.close();
    }
}

4. 使用BufferedChannel

BufferedChannel可以提供缓冲功能，减少对底层资源的访问次数，从而提高性能。

import java.io.RandomAccessFile;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;
import java.nio.channels.ReadableByteChannel;
import java.nio.channels.WritableByteChannel;

public class NIOBufferedChannelExample {
    public static void main(String[] args) throws Exception {
        RandomAccessFile sourceFile = new RandomAccessFile("source.txt", "r");
        RandomAccessFile destFile = new RandomAccessFile("dest.txt", "rw");

        FileChannel sourceChannel = sourceFile.getChannel();
        FileChannel destChannel = destFile.getChannel();

        ByteBuffer buffer = ByteBuffer.allocate(1024);

        while (sourceChannel.read(buffer) != -1) {
            buffer.flip();
            destChannel.write(buffer);
            buffer.clear();
        }

        sourceChannel.close();
        destChannel.close();
        sourceFile.close();
        destFile.close();
    }
}

通过以上方法，可以显著提高Java NIO文件读写操作的性能。选择合适的方法取决于具体的应用场景和需求。