PHP: полный мануал с примерами, функциями и ООП

<?php
// orders.txt из архива: TEA, перевод строки, COFFEE, перевод строки.
$stream = fopen(__DIR__ . '/orders.txt', 'rb');
if ($stream === false) {
    echo "Не удалось открыть файл\n";
    exit(1);
}
$first = fread($stream, 4);
$position = ftell($stream);
$rest = stream_get_contents($stream);
if ($first === false || $position === false || $rest === false) {
    fclose($stream);
    echo "Не удалось прочитать файл\n";
    exit(1);
}
echo "Первая порция: ", trim($first), "\n";
echo "Позиция: ", $position, "\n";
echo "Остаток: ", trim($rest), "\n";
fclose($stream);

Первая порция: TEA
Позиция: 4
Остаток: COFFEE

Файл orders.txt включён в пример: ровно TEA\nCOFFEE\n, 11 байт. Первый fread забирает TEA и один байт перевода строки. Следующее чтение начинается с позиции 4. trim здесь только убирает перевод строки при показе, сам файл не меняется.

<?php
// Это только учебная копия из ZIP, не журнал работающего сайта.
$path = __DIR__ . '/demo-log.txt';
$stream = fopen($path, 'ab');
if ($stream === false) {
    throw new RuntimeException('Не удалось открыть учебный журнал');
}
try {
    if (fwrite($stream, "paid\n") !== 5) {
        throw new RuntimeException('Строка записана не целиком');
    }
} finally {
    fclose($stream);
}
$log = file_get_contents($path);
if ($log === false) {
    throw new RuntimeException('Не удалось прочитать журнал');
}
echo "После a: ", str_replace("\n", '|', $log), "\n";

$stream = fopen($path, 'wb');
if ($stream === false) {
    throw new RuntimeException('Не удалось открыть учебный отчёт');
}
try {
    if (fwrite($stream, "new\n") !== 4) {
        throw new RuntimeException('Строка записана не целиком');
    }
} finally {
    fclose($stream);
}
$report = file_get_contents($path);
if ($report === false) {
    throw new RuntimeException('Не удалось прочитать отчёт');
}
echo "После w: ", str_replace("\n", '|', $report), "\n";

После a: created|paid|
После w: new|

Режим a сохранил created и добавил paid. Режим w очистил файл уже при открытии; затем мы записали new. Вертикальная черта в результате заменяет перевод строки только для наглядности. При каждом новом запуске используйте исходную учебную копию demo-log.txt из архива. Здесь короткая запись обязана быть полной: иной результат превращаем в ошибку; далее появится цикл для частичных записей.

<?php
$stream = fopen('php://temp', 'w+b');
if ($stream === false) {
    throw new RuntimeException('Не удалось создать временный поток');
}
try {
    if (fwrite($stream, "TEA;2\n") !== 6) {
        throw new RuntimeException('Запись неполная');
    }
    $atEnd = stream_get_contents($stream);
    if ($atEnd === false) {
        throw new RuntimeException('Ошибка чтения');
    }
    echo 'До rewind: ', strlen($atEnd), " байт\n";
    if (!rewind($stream)) {
        throw new RuntimeException('Не удалось перейти в начало');
    }
    $report = stream_get_contents($stream);
    if ($report === false) {
        throw new RuntimeException('Ошибка чтения');
    }
    echo 'После rewind: ', $report;
} finally {
    fclose($stream);
}

До rewind: 0 байт
После rewind: TEA;2

После fwrite позиция находится за шестью записанными байтами. Чтение «отсюда до конца» возвращает пустую строку, а не ошибку. rewind возвращает позицию на начало этого же потока. Закрытие освобождает временное хранилище; новое fopen("php://temp", ...) создаст другой пустой поток.

<?php
function writeAll($stream, string $text): int
{
    $offset = 0;
    $length = strlen($text);
    while ($offset < $length) {
        $written = fwrite($stream, substr($text, $offset));
        if ($written === false || $written === 0) {
            throw new RuntimeException('Не удалось продолжить запись');
        }
        $offset += $written;
    }
    return $offset;
}

function makeReport(array $rows): string
{
    $stream = fopen('php://temp', 'w+b');
    if ($stream === false) {
        throw new RuntimeException('Не удалось создать отчёт');
    }
    try {
        foreach ($rows as $row) {
            // Данные уже проверены: короткий SKU без ; и положительное количество.
            writeAll($stream, $row['sku'] . ';' . $row['quantity'] . "\n");
        }
        if (!rewind($stream)) {
            throw new RuntimeException('Не удалось перейти в начало');
        }
        $result = stream_get_contents($stream);
        if ($result === false) {
            throw new RuntimeException('Не удалось прочитать отчёт');
        }
        return $result;
    } finally {
        fclose($stream);
    }
}

$report = makeReport([
    ['sku' => 'TEA', 'quantity' => 2],
    ['sku' => 'COFFEE', 'quantity' => 1],
]);
echo $report;

TEA;2
COFFEE;1

makeReport получает массив строк, возвращает готовую строку и сама ничего не печатает. echo вызывается снаружи: строку можно показать или передать компоненту отправки письма. writeAll учитывает частичную запись и прекращает работу при false/0 вместо бесконечного цикла. Разделитель ; подходит только оговорённым учебным SKU; для произвольного CSV используйте fputcsv с явными настройками. Тип resource нельзя записать как обычный тип параметра: контракт $stream — открытый доступный для записи поток.

<?php
function writeAll($stream, string $text): int
{
    $offset = 0;
    $length = strlen($text);
    while ($offset < $length) {
        $written = fwrite($stream, substr($text, $offset));
        if ($written === false || $written === 0) {
            throw new RuntimeException('Не удалось продолжить запись');
        }
        $offset += $written;
    }
    return $offset;
}

$source = fopen(__DIR__ . '/stock.txt', 'rb');
if ($source === false) {
    throw new RuntimeException('Нет учебной выгрузки');
}
try {
    $target = fopen('php://temp/maxmemory:8', 'w+b');
    if ($target === false) {
        throw new RuntimeException('Не удалось создать копию');
    }
    try {
        $total = 0;
        while (!feof($source)) {
            $chunk = fread($source, 4);
            if ($chunk === false) {
                throw new RuntimeException('Ошибка чтения');
            }
            if ($chunk === '') {
                if (feof($source)) {
                    break;
                }
                throw new RuntimeException('Чтение не продвинулось');
            }
            $total += writeAll($target, $chunk);
        }
        if (!rewind($target)) {
            throw new RuntimeException('Не удалось перейти в начало');
        }
        // Только для показа маленькой fixture. Большой файл так не собираем.
        $preview = stream_get_contents($target);
        if ($preview === false) {
            throw new RuntimeException('Ошибка чтения копии');
        }
        echo 'Скопировано: ', $total, " байт\n";
        echo $preview;
    } finally {
        fclose($target);
    }
} finally {
    fclose($source);
}

Скопировано: 11 байт
TEA
COFFEE

Порция 4 байта выбрана для видимого маленького опыта, а не как оптимальный размер для сервера. Цикл рассчитан на локальный блокирующий файловый поток. php://temp/maxmemory:8 разрешает временному хранилищу перейти на диск при росте; это порог памяти, а не предел размера отчёта. Произвольную сетевую неблокирующую связь этим циклом не обслуживают.

<?php
$readContext = stream_context_create([
    'http' => [
        'method' => 'GET',
        'header' => ['Accept: application/json'],
        'timeout' => 5.0,
        'follow_location' => 0,
        'ignore_errors' => true,
    ],
    'ssl' => [
        'verify_peer' => true,
        'verify_peer_name' => true,
        'allow_self_signed' => false,
    ],
]);
$sendContext = stream_context_create([
    'http' => [
        'method' => 'POST',
        'header' => ['Content-Type: application/json', 'Accept: application/json'],
        'content' => json_encode(['sku' => 'TEA', 'stock' => 8], JSON_THROW_ON_ERROR),
        'timeout' => 5.0,
        'follow_location' => 0,
    ],
    'ssl' => ['verify_peer' => true, 'verify_peer_name' => true],
]);
$readOptions = stream_context_get_options($readContext);
$sendOptions = stream_context_get_options($sendContext);
echo $readOptions['http']['method'], ': TLS=',
    $readOptions['ssl']['verify_peer'] ? 'on' : 'off', "\n";
echo $sendOptions['http']['method'], ': ',
    $sendOptions['http']['content'], "\n";

GET: TLS=on
POST: {"sku":"TEA","stock":8}

Здесь не было ни одного HTTP-запроса. stream_context_create только создаёт ресурс с настройками; stream_context_get_options позволяет их посмотреть. Чтобы применить контекст, его передают конкретному открытию потока. Для https настройки HTTP тоже лежат под ключом http, а проверка TLS — под ssl. Отправляющий контекст показан как данные: реальная запись во внешний сервис требует его контракта и политики повторов.

<?php
function responseStatus(array $headers): int
{
    $status = null;
    foreach ($headers as $line) {
        if (preg_match('~^HTTP/\d(?:\.\d)?\s+([1-5]\d{2})(?:\s|$)~i', $line, $match) === 1) {
            $status = (int) $match[1];
        }
    }
    if ($status === null) {
        throw new RuntimeException('Нет HTTP-статуса');
    }
    return $status;
}

$responses = [
    ['HTTP/1.1 200 OK', 'Content-Type: application/json'],
    ['HTTP/1.1 404 Not Found', 'Content-Type: application/json'],
    ['HTTP/1.1 100 Continue', 'HTTP/1.1 200 OK'],
];
foreach ($responses as $headers) {
    $status = responseStatus($headers);
    echo $status, $status === 200 ? ': принять' : ': отклонить', "\n";
}
try {
    responseStatus(['Content-Type: application/json']);
} catch (RuntimeException $error) {
    echo $error->getMessage(), "\n";
}

200: принять
404: отклонить
200: принять
Нет HTTP-статуса

Это массивы учебных заголовков, а не ответы живого сервера. Помощник запоминает последнюю строку статуса, например после промежуточного 100. Решение «принимаем только 200» относится к нашему чтению остатков: другой endpoint может ожидать 201, 204 или иной документированный результат.

<?php
function responseStatus(array $headers): int
{
    $status = null;
    foreach ($headers as $line) {
        if (preg_match('~^HTTP/\d(?:\.\d)?\s+([1-5]\d{2})(?:\s|$)~i', $line, $match) === 1) {
            $status = (int) $match[1];
        }
    }
    if ($status === null) {
        throw new RuntimeException('Нет HTTP-статуса');
    }
    return $status;
}

function fetchTeaStock(): int
{
    // Замените только на фиксированный доверенный адрес своего API.
    $url = 'https://api.example.test/inventory/TEA';
    $context = stream_context_create([
        'http' => [
            'method' => 'GET',
            'header' => ['Accept: application/json', 'Connection: close'],
            'timeout' => 5.0,
            'follow_location' => 0,
            'ignore_errors' => true,
        ],
        'ssl' => [
            'verify_peer' => true,
            'verify_peer_name' => true,
            'allow_self_signed' => false,
        ],
    ]);
    $stream = null;
    // Узкая область: предупреждение ввода-вывода становится нашей ошибкой.
    // Путь/URL и текст низкоуровневой ошибки не возвращаем посетителю.
    set_error_handler(function (int $severity, string $message): never {
        throw new RuntimeException('Не удалось прочитать источник остатков');
    }, E_WARNING);
    try {
        $stream = fopen($url, 'rb', false, $context);
        if ($stream === false) {
            throw new RuntimeException('Источник недоступен');
        }
        $metadata = stream_get_meta_data($stream);
        $status = responseStatus($metadata['wrapper_data'] ?? []);
        // Читаем на один байт больше лимита, чтобы обнаружить переполнение.
        $body = stream_get_contents($stream, 65_537);
        $afterRead = stream_get_meta_data($stream);
        if ($body === false || ($afterRead['timed_out'] ?? false)) {
            throw new RuntimeException('Ответ не прочитан вовремя');
        }
        if (strlen($body) > 65_536) {
            throw new RuntimeException('Ответ больше допустимого');
        }
        if ($status !== 200) {
            throw new RuntimeException('Источник вернул HTTP ' . $status);
        }
        $data = json_decode($body, false, 32, JSON_THROW_ON_ERROR);
        if (!$data instanceof stdClass
            || ($data->sku ?? null) !== 'TEA'
            || !is_int($data->stock ?? null)
            || $data->stock < 0) {
            throw new RuntimeException('Неверная структура остатков');
        }
        return $data->stock;
    } finally {
        restore_error_handler();
        if (is_resource($stream)) {
            fclose($stream);
        }
    }
}
// Вызов после настройки реального endpoint: $stock = fetchTeaStock();

Контекстный пример проверяется синтаксически, сетевой запуск не заявляется. Нужны доверенный HTTPS endpoint с JSON {"sku":"TEA","stock":8}, разрешённый allow_url_fopen, OpenSSL и актуальное хранилище CA. .test — учебный адрес. Реальный ответ должен соответствовать контракту; ошибку перехватывает верхний обработчик приложения. timeout — таймаут чтения, не гарантированный общий дедлайн запроса. Редиректы отключены; код не является универсальным HTTP-клиентом.

<?php
// Функция вызывается HTTP-обработчиком после проверки метода, доступа
// и Content-Type. Сервер также должен ограничивать размер тела запроса.
function readStockBody(): array
{
    $stream = fopen('php://input', 'rb');
    if ($stream === false) {
        throw new RuntimeException('Не удалось открыть тело запроса');
    }
    try {
        $body = stream_get_contents($stream, 8193);
        if ($body === false) {
            throw new RuntimeException('Ошибка чтения тела');
        }
        if (strlen($body) > 8192) {
            throw new LengthException('Тело больше 8192 байт');
        }
        $data = json_decode($body, false, 16, JSON_THROW_ON_ERROR);
        if (!$data instanceof stdClass
            || !is_string($data->sku ?? null)
            || preg_match('/\A[A-Z0-9-]{1,32}\z/', $data->sku) !== 1
            || !is_int($data->stock ?? null)
            || $data->stock < 0) {
            throw new InvalidArgumentException('Ожидались sku и целый stock >= 0');
        }
        return ['sku' => $data->sku, 'stock' => $data->stock];
    } finally {
        fclose($stream);
    }
}

Это часть JSON endpoint, не готовый публичный обработчик. Нужны POST, application/json, аутентификация/проверка прав; для cookie-сессии — соответствующая защита CSRF. Внешний код сопоставляет ошибки чтения, размера, JSON и полей с ответами 4xx/5xx без внутренних деталей. php://input отдаёт байты тела и не превращает их автоматически в массив $_POST. Multipart-формы и загрузки рассматриваются отдельно.

<?php
ob_start();
$stream = null;
try {
    $stream = fopen('php://output', 'wb');
    if ($stream === false) {
        throw new RuntimeException('Не удалось открыть вывод');
    }
    if (fwrite($stream, "report ready\n") !== 13) {
        throw new RuntimeException('Запись неполная');
    }
    $captured = ob_get_contents();
    if ($captured === false) {
        throw new RuntimeException('Нет буфера');
    }
} finally {
    if (is_resource($stream)) {
        fclose($stream);
    }
    ob_end_clean();
}
echo 'Перехвачено: ', $captured;

Перехвачено: report ready

Поток php://output идёт в механизм вывода PHP, как echo: наш ob_start перехватил запись в строку. Это не то же самое, что прямой CLI stdout. В HTTP заголовки отправляют до фактического тела, а поведение доставки клиенту ещё зависит от буферов сервера.