Java for Beginner

Раздел 11. Работа с файлами, I/O и сетью (NIO.2)

Глава 2. Современный NIO.2 (java.nio.file)

SeekableByteChannel — произвольный доступ к файлу. Символические и жёсткие ссылки

До этого момента мы работали с файлами через высокоуровневые абстракции: читали целиком, писали целиком, копировали, перемещали. Но файловая система — это в первую очередь последовательность байтов на диске, и иногда нужно читать или писать не с начала, а с произвольной позиции.

Для этого в NIO.2 существует интерфейс SeekableByteChannel. Он объединяет возможности чтения, записи и позиционирования в единый канал, заменяя устаревший RandomAccessFile.

Вторая часть посвящена ссылкам в файловой системе — механизму, который позволяет одним данным соответствовать несколько имён. Символические и жёсткие ссылки — фундаментальная концепция Unix-файловых систем, и их непонимание часто приводит к багам при обходе деревьев, подсчёте размеров и резервном копировании.

Часть 1. SeekableByteChannel

SeekableByteChannel — это интерфейс в пакете java.nio.channels, расширяющий ByteChannel. ByteChannel в свою очередь объединяет ReadableByteChannel и WritableByteChannel, то есть поддерживает и чтение, и запись. Добавление приставки "Seekable" означает, что канал позволяет изменять текущую позицию чтения/записи — "перематывать" указатель в произвольное место файла.

Канал (channel) в Java NIO — это абстракция для соединения с сущностью, способной выполнять операции ввода-вывода: файл, сокет, пайп. Каналы работают с буферами (ByteBuffer), а не с потоками байтов. Это позволяет использовать прямой (direct) ввод-вывод, минуя промежуточное копирование в кучу JVM.

Интерфейс SeekableByteChannel декларирует три ключевых метода, отсутствующих в обычном ByteChannel:
position() — возвращает текущую позицию в файле.
position(long newPosition) — устанавливает новую позицию.
size() — возвращает текущий размер файла в байтах.

Открытие канала: Files.newByteChannel()

Метод Files.newByteChannel(Path path, OpenOption... options) возвращает SeekableByteChannel для указанного пути. Это фабричный метод, который делегирует создание канала текущему FileSystemProvider.

import java.nio.file.*;
import java.nio.channels.SeekableByteChannel;
import java.nio.ByteBuffer;
import java.io.IOException;
import java.nio.charset.StandardCharsets;

public class ChannelOpener {
    
    public void openForRead(Path file) throws IOException {
        // Открываем только для чтения
        try (SeekableByteChannel channel = Files.newByteChannel(file, StandardOpenOption.READ)) {
            System.out.println("Размер файла: " + channel.size());
            System.out.println("Текущая позиция: " + channel.position());
        }
    }
    
    public void openForWrite(Path file) throws IOException {
        // Открываем для чтения и записи, создаём если нет, обрезаем если есть
        try (SeekableByteChannel channel = Files.newByteChannel(file,
                StandardOpenOption.READ,
                StandardOpenOption.WRITE,
                StandardOpenOption.CREATE,
                StandardOpenOption.TRUNCATE_EXISTING)) {
            
            // Записываем данные
            ByteBuffer buffer = ByteBuffer.wrap("Hello, World".getBytes(StandardCharsets.UTF_8));
            channel.write(buffer);
        }
    }
}

StandardOpenOption — режимы открытия

StandardOpenOption — это enum, определяющий, как именно открывать или создавать файл. Каждая опция соответствует флагу системного вызова open() (POSIX):
READ — открыть для чтения. Файл должен существовать. Соответствует флагу O_RDONLY.
WRITE — открыть для записи. Файл должен существовать. Соответствует флагу O_WRONLY (в комбинации с READ даёт O_RDWR).
APPEND — все операции записи производятся в конец файла, независимо от текущей позиции. Соответствует флагу O_APPEND. Позиция после записи не изменяется (остаётся там, где была до записи).
CREATE — создать файл, если он не существует. Соответствует O_CREAT.
CREATE_NEW — создать файл, но выбросить исключение, если он уже существует. Соответствует O_CREAT | O_EXCL. Атомарная операция.
TRUNCATE_EXISTING — если файл существует и открыт для записи, обрезать его размер до 0. Соответствует O_TRUNC.
DELETE_ON_CLOSE — удалить файл при закрытии канала. Полезно для временных файлов.
SYNC — каждая операция записи синхронизирует данные и метаданные с диском. Соответствует O_SYNC. Сильно снижает производительность, но гарантирует durability.
DSYNC — синхронизирует только данные, не метаданные. Соответствует O_DSYNC.
SPARSE — создать разреженный файл (sparse file), если файловая система поддерживает.

Разреженный файл (sparse file) — это файл, в котором последовательности нулевых байтов не занимают место на диске. Файловая система хранит только информацию о "дырах" (holes), а не сами нули. При чтении таких областей возвращаются нулевые байты. Разреженные файлы экономят дисковое пространство при работе с большими файлами, большая часть которых пуста.

Durability (стойкость) — свойство системы хранения, гарантирующее, что записанные данные сохранятся даже при сбое питания. SYNC и DSYNC принудительно сбрасывают данные из кэша страниц ОС на физическое устройство хранения.

Чтение и запись с произвольной позиции

public class RandomAccessExample {
    
    public void readFromPosition(Path file, long position, int length) throws IOException {
        try (SeekableByteChannel channel = Files.newByteChannel(file, StandardOpenOption.READ)) {
            // Устанавливаем позицию
            channel.position(position);
            
            ByteBuffer buffer = ByteBuffer.allocate(length);
            int bytesRead = channel.read(buffer);
            
            buffer.flip();  // переключаем буфер из режима записи в режим чтения
            byte[] data = new byte[bytesRead];
            buffer.get(data);
            
            System.out.println("Прочитано с позиции " + position + ": " + new String(data));
        }
    }
    
    public void writeAtPosition(Path file, long position, String data) throws IOException {
        try (SeekableByteChannel channel = Files.newByteChannel(file,
                StandardOpenOption.READ, StandardOpenOption.WRITE)) {
            
            channel.position(position);
            
            ByteBuffer buffer = ByteBuffer.wrap(data.getBytes(StandardCharsets.UTF_8));
            channel.write(buffer);
            
            // После записи позиция сдвинулась на количество записанных байт
            System.out.println("Новая позиция: " + channel.position());
        }
    }
    
    public void appendToFile(Path file, String data) throws IOException {
        // Способ 1: через APPEND опцию
        try (SeekableByteChannel channel = Files.newByteChannel(file,
                StandardOpenOption.WRITE, StandardOpenOption.APPEND)) {
            ByteBuffer buffer = ByteBuffer.wrap(data.getBytes(StandardCharsets.UTF_8));
            channel.write(buffer);
        }
        
        // Способ 2: через position(size()) — ручное позиционирование в конец
        try (SeekableByteChannel channel = Files.newByteChannel(file,
                StandardOpenOption.READ, StandardOpenOption.WRITE)) {
            channel.position(channel.size());  // переходим в конец
            ByteBuffer buffer = ByteBuffer.wrap(data.getBytes(StandardCharsets.UTF_8));
            channel.write(buffer);
        }
    }
}

ByteBuffer — это класс в Java NIO, представляющий блок памяти, через который производится ввод-вывод. Буфер имеет три ключевых свойства: capacity (ёмкость), limit (предел) и position (текущая позиция). Метод flip() переключает буфер из режима записи (write) в режим чтения (read): устанавливает limit = position, position = 0.

#Java #для_новичков #beginner #IO #NIO #SeekableByteChannel

👍4

53 views08:59