Как работают потоки в PHP и что делать при сбоях

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

Ниже приведены подробные примеры кода с пояснениями и результатами выполнения.

Пример 1: Создание кастомного обработчика ошибок для записи лога

Вместо вывода ошибок на экран, можно записывать их в файл с меткой времени.

function customErrorHandler($errno, $errstr, $errfile, $errline) {
    $log = "[" . date('Y-m-d H:i:s') . "] $errstr in $errfile line $errline\n";
    file_put_contents('/var/log/php_stream_errors.log', $log, FILE_APPEND);
    return true;
}
set_error_handler('customErrorHandler');

// Пример с ошибкой
$result = @fopen('/nonexistent.log', 'r');
// Ошибка будет записана в лог, а не отображена

Результат: в файл /var/log/php_stream_errors.log будет добавлена строка вида:
[2025-04-10 15:30:25] fopen(/nonexistent.log): failed to open stream: No such file or directory in /www/index.php line 12

Пример 2: Использование stream_context для HTTP Basic аутентификации

Для доступа к защищённому ресурсу требуется передать логин и пароль в заголовке Authorization.

$url = 'https://api.example.com/private/data';
$username = 'user';
$password = 'pass';
$options = [
    'http' => [
        'method' => 'GET',
        'header' => "Authorization: Basic " . base64_encode("$username:$password"),
        'timeout' => 10
    ]
];
$context = stream_context_create($options);
$response = @file_get_contents($url, false, $context);
if ($response === false) {
    $error = error_get_last();
    echo "Ошибка: " . $error['message'];
} else {
    echo "Успешно получены данные: " . substr($response, 0, 100);
}

Результат:
Успешно получены данные: { "status": "ok", ... }

Пример 3: Работа с потоком, возвращающим ошибку 404

При использовании file_get_contents с HTTP потоком, ошибка 404 не вызывает предупреждение по умолчанию. Для проверки статуса ответа можно использовать специальную обёртку.

$url = 'https://httpstat.us/404';
$context = stream_context_create(['http' => ['ignore_errors' => true]]);
$response = @file_get_contents($url, false, $context);
if (strpos($http_response_header[0], '404') !== false) {
    echo "Сервер вернул ошибку 404 Not Found";
} else {
    echo "Данные получены";
}

Результат:
Сервер вернул ошибку 404 Not Found

Пример 4: Создание собственного stream wrapper для протокола myproto

Можно зарегистрировать свой wrapper, который будет выполнять особую логику при открытии потоков.

class MyStreamWrapper {
    private $position;
    private $data;
    public function stream_open($path, $mode, $options, &$opened_path) {
        $this->data = "Содержимое из пользовательского потока";
        $this->position = 0;
        return true;
    }
    public function stream_read($count) {
        $ret = substr($this->data, $this->position, $count);
        $this->position += strlen($ret);
        return $ret;
    }
    public function stream_eof() {
        return $this->position >= strlen($this->data);
    }
    public function stream_stat() { return []; }
}
stream_wrapper_register('myproto', 'MyStreamWrapper');
$content = file_get_contents('myproto://test');
echo $content;

Результат:
Содержимое из пользовательского потока

Пример 5: Обработка ошибки тайм-аута при соединении с удалённым сервером

Если сервер не отвечает в течение заданного времени, поток завершится с ошибкой. Таймаут можно задать в контексте.

$url = 'http://192.0.2.1:81';
$opts = ['http' => ['timeout' => 2]];
$context = stream_context_create($opts);
$result = @file_get_contents($url, false, $context);
if ($result === false) {
    $error = error_get_last();
    echo 'Тайм-аут или другая ошибка: ' . $error['message'];
} else {
    echo 'Успешно: ' . $result;
}

Результат (пример):
Тайм-аут или другая ошибка: file_get_contents(http://192.0.2.1:81): failed to open stream: Connection timed out