Файловые операции в PHP: как избежать и обработать ошибки ввода вывода

Расширенные примеры работы с файлами и обработка ошибок

Пример 1: Рекурсивное чтение директории с обработкой ошибок доступа

function listFilesRecursive(string $dir, int $depth = 0): array {
    $result = [];
    try {
        $iterator = new DirectoryIterator($dir);
    } catch (\RuntimeException $e) {
        error_log('Нет доступа к ' . $dir . ': ' . $e->getMessage());
        return [];
    }

    foreach ($iterator as $item) {
        if ($item->isDot()) continue;
        if ($item->isDir()) {
            $sub = listFilesRecursive($item->getPathname(), $depth + 1);
            $result = array_merge($result, $sub);
        } else {
            $result[] = $item->getPathname();
        }
    }
    return $result;
}

$files = listFilesRecursive('/var/log');
print_r($files);

Array
(
    [0] => /var/log/syslog
    [1] => /var/log/auth.log
    // ... пропущены директории без прав
)

Пример 2: Безопасная запись с блокировкой и обработкой ошибок блокировки

$filename = 'counter.txt';
$handle = fopen($filename, 'c+');
if (!$handle) {
    throw new \RuntimeException('Не удалось открыть файл');
}

try {
    if (!flock($handle, LOCK_EX)) {
        throw new \RuntimeException('Не удалось получить эксклюзивную блокировку');
    }
    
    $counter = (int) fread($handle, 1024);
    $counter++;
    
    rewind($handle);
    if (ftruncate($handle, 0) === false) {
        throw new \RuntimeException('Ошибка усечения файла');
    }
    if (fwrite($handle, (string)$counter) === false) {
        throw new \RuntimeException('Ошибка записи');
    }
    
    flock($handle, LOCK_UN);
} catch (\Throwable $e) {
    // логируем и, возможно, повторяем
    error_log('Counter error: ' . $e->getMessage());
    throw $e;
} finally {
    fclose($handle);
}

(пустой вывод, если успешно; в лог запишется сообщение при ошибке)

Пример 3: Чтение удалённого файла с обработкой таймаута

$context = stream_context_create([
    'http' => [
        'timeout' => 5, // секунд
        'method' => 'GET',
        'ignore_errors' => true
    ]
]);

$url = 'https://example.com/data.json';
$result = @file_get_contents($url, false, $context);

if ($result === false) {
    $error = error_get_last();
    throw new \RuntimeException('Не удалось загрузить ' . $url . ': ' . $error['message']);
}

$data = json_decode($result, true);
if (json_last_error() !== JSON_ERROR_NONE) {
    throw new \RuntimeException('Ошибка парсинга JSON: ' . json_last_error_msg());
}

При успешном выполнении $data содержит массив; при ошибке таймаута - исключение с сообщением о таймауте.

Пример 4: Работа с CSV с проверкой целостности строк

$handle = fopen('data.csv', 'r');
if ($handle === false) {
    throw new \RuntimeException('Не удалось открыть CSV');
}

try {
    $headers = fgetcsv($handle);
    if ($headers === false || count($headers) < 2) {
        throw new \RuntimeException('Некорректный заголовок CSV');
    }
    
    $lineNumber = 1;
    while (($row = fgetcsv($handle)) !== false) {
        $lineNumber++;
        if (count($row) !== count($headers)) {
            error_log("Строка $lineNumber: неверное количество полей, пропуск");
            continue;
        }
        // обработка строки
    }
} finally {
    fclose($handle);
}

(логирование пропущенных строк, остальные обрабатываются)

Пример 5: Создание временного файла и гарантированное удаление

$tmpFile = tempnam(sys_get_temp_dir(), 'php_');
if ($tmpFile === false) {
    throw new \RuntimeException('Не удалось создать временный файл');
}

try {
    file_put_contents($tmpFile, $data);
    // использование файла...
} finally {
    if (file_exists($tmpFile) && !unlink($tmpFile)) {
        error_log('Не удалось удалить временный файл: ' . $tmpFile);
    }
}

(временный файл существует в системе до удаления)

Пример 6: Использование stream wrapper для кастомной обработки ошибок

class ErrorLogStream {
    private $handle;
    
    public function stream_open($path, $mode, $options, &$opened_path) {
        $this->handle = fopen('/dev/null', 'w'); // заглушка
        return true;
    }
    
    public function stream_write($data) {
        // вместо записи пишем в лог
        error_log('Ошибка записи в поток: ' . $data);
        return strlen($data);
    }
}

stream_wrapper_register('errorlog', 'ErrorLogStream');

$stream = fopen('errorlog://dummy', 'w');
if ($stream) {
    fwrite($stream, 'Это сообщение будет залогировано');
    fclose($stream);
}

(в логе появится строка 'Ошибка записи в поток: Это сообщение будет залогировано')