HTTP-расширение PHP: от базовых запросов до асинхронного пула

Пример 1: Отправка PUT-запроса с JSON и получение подробной информации об ответе

    <?php
    use Http\Client\HttpClient;
    use Http\Message\RequestFactory;
    use Http\Message\StreamFactory;
    use Http\Discovery\HttpClientDiscovery;
    use Http\Discovery\MessageFactoryDiscovery;
    use Http\Discovery\StreamFactoryDiscovery;

    $httpClient = HttpClientDiscovery::find();
    $requestFactory = MessageFactoryDiscovery::find();
    $streamFactory = StreamFactoryDiscovery::find();

    $data = ['title' => 'Тест', 'content' => 'Пример обновления'];
    $body = $streamFactory->createStream(json_encode($data, JSON_UNESCAPED_UNICODE));

    $request = $requestFactory->createRequest(
        'PUT',
        'https://jsonplaceholder.typicode.com/posts/1',
        ['Content-Type' => 'application/json', 'Accept' => 'application/json'],
        $body
    );

    $response = $httpClient->sendRequest($request);

    echo "Статус: " . $response->getStatusCode() . "\n";
    echo "Заголовки:\n";
    foreach ($response->getHeaders() as $name => $values) {
        echo "  $name: " . implode(', ', $values) . "\n";
    }
    $responseBody = (string) $response->getBody();
    echo "Тело ответа:\n$responseBody\n";
    ?>
  

Статус: 200
Заголовки:
  date: Fri, 07 Jul 2023 12:00:00 GMT
  content-type: application/json; charset=utf-8
  ...
Тело ответа:
{
  "userId": 1,
  "id": 1,
  "title": "Тест",
  "content": "Пример обновления",
  "completed": false
}
  

Пояснение: в примере создается поток из JSON-строки, отправляется PUT-запрос, затем выводится полная информация об ответе. Важно указывать заголовок Content-Type, чтобы сервер правильно интерпретировал тело.

Пример 2: Работа с куки через HttpCookie

    <?php
    // Создание куки
    $cookie = new HttpCookie('session_id', 'abc123');
    $cookie->setDomain('.example.com');
    $cookie->setPath('/');
    $cookie->setMaxAge(3600); // 1 час
    echo $cookie->toString() . "\n";

    // Парсинг куки из строки
    $parsed = HttpCookie::fromString('user=ivan; path=/; expires=Wed, 21 Oct 2025 07:28:00 GMT');
    echo $parsed->getName() . ": " . $parsed->getValue() . "\n";

    // Использование в запросе
    $request = new HttpRequest('https://example.com/profile', HttpRequest::METH_GET);
    $request->setCookies([$cookie, $parsed]);
    $response = $request->send();
    ?>
  

session_id=abc123; domain=.example.com; path=/; max-age=3600
user: ivan
  

Класс HttpCookie упрощает создание и разбор куки, а также их прикрепление к запросу. Обратите внимание на корректное указание домена и пути для избежания проблем с безопасностью.

Пример 3: Обработка больших ответов с потоковым чтением

    <?php
    use Http\Client\HttpClient;
    use Http\Message\RequestFactory;
    use Http\Discovery\HttpClientDiscovery;
    use Http\Discovery\MessageFactoryDiscovery;

    $httpClient = HttpClientDiscovery::find();
    $requestFactory = MessageFactoryDiscovery::find();

    $request = $requestFactory->createRequest('GET', 'https://speed.hetzner.de/100MB.bin');
    $response = $httpClient->sendRequest($request);

    $bodyStream = $response->getBody();
    // Поочередное чтение частями по 8192 байта
    while (!$bodyStream->eof()) {
        $chunk = $bodyStream->read(8192);
        // Обработка чанка, например, запись в файл
        file_put_contents('downloaded_part', $chunk, FILE_APPEND);
    }
    echo "Файл загружен частями.\n";
    ?>
  

Пояснение: для работы с большими файлами не следует загружать весь ответ в память - используется потоковый режим. Метод read() возвращает указанное количество байт, eof() проверяет конец потока. В данном примере файл сохраняется порциями.

Пример 4: Создание и отправка multipart/form-data запроса

    <?php
    use Http\Client\HttpClient;
    use Http\Message\RequestFactory;
    use Http\Message\StreamFactory;
    use Http\Discovery\HttpClientDiscovery;
    use Http\Discovery\MessageFactoryDiscovery;
    use Http\Discovery\StreamFactoryDiscovery;

    $httpClient = HttpClientDiscovery::find();
    $requestFactory = MessageFactoryDiscovery::find();
    $streamFactory = StreamFactoryDiscovery::find();

    // Формирование multipart-тела вручную (упрощенно)
    $boundary = '----WebKitFormBoundary' . uniqid();
    $bodyParts = [
        "--$boundary\r\nContent-Disposition: form-data; name=\"username\"\r\n\r\nIvan",
        "--$boundary\r\nContent-Disposition: form-data; name=\"avatar\"; filename=\"photo.jpg\"\r\nContent-Type: image/jpeg\r\n\r\n" . file_get_contents('photo.jpg'),
        "--$boundary--\r\n"
    ];
    $body = $streamFactory->createStream(implode("\r\n", $bodyParts));

    $request = $requestFactory->createRequest(
        'POST',
        'https://httpbin.org/post',
        ['Content-Type' => "multipart/form-data; boundary=$boundary"],
        $body
    );

    $response = $httpClient->sendRequest($request);
    echo $response->getBody();
    ?>
  

Этот пример демонстрирует ручное составление multipart-тела. В реальных проектах рекомендуется использовать специализированные библиотеки (например, php-http/multipart-stream-builder), так как ручное формирование чревато ошибками в границах и кодировке.

Пример 5: Асинхронные запросы через HttpRequestPool с обработкой ошибок

    <?php
    $pool = new HttpRequestPool();
    $urls = [
        'https://httpstat.us/200',
        'https://httpstat.us/404',
        'https://httpstat.us/500',
    ];

    $requests = [];
    foreach ($urls as $url) {
        $req = new HttpRequest($url, HttpRequest::METH_GET);
        $req->setOptions(['timeout' => 5]);
        $requests[] = $req;
        $pool->attach($req);
    }

    try {
        $pool->send();
    } catch (HttpException $e) {
        echo "Ошибка пула: " . $e->getMessage() . "\n";
    }

    foreach ($pool->getFinished() as $req) {
        $info = $req->getResponseInfo();
        $code = $req->getResponseCode();
        echo "URL: " . $req->getUrl() . " -> Код: $code\n";
        if ($code == 200) {
            echo "Тело: " . substr($req->getResponseBody(), 0, 50) . "...\n";
        } else {
            echo "Ошибка: " . $req->getResponseStatus() . "\n";
        }
    }
    ?>
  

URL: https://httpstat.us/200 -> Код: 200
Тело: 200 OK...
URL: https://httpstat.us/404 -> Код: 404
Ошибка: Not Found
URL: https://httpstat.us/500 -> Код: 500
Ошибка: Internal Server Error
  

В этом примере параллельно отправляются три запроса, результаты обрабатываются независимо. Важно установить таймауты, чтобы при зависании одного запроса не блокировать весь пул надолго. Исключение ловится на уровне пула, но каждый запрос может содержать свою ошибку, которую можно проверить через методы getResponseCode() и getResponseStatus().