Асинхронное программирование в PHP: полное руководство для начинающих

Введение в асинхронное программирование в PHP

Традиционный PHP работает синхронно: каждая операция выполняется последовательно. Если скрипту нужно отправить HTTP-запрос или прочитать файл, он ждет завершения операции, блокируя выполнение всего кода. Для веб-приложений с высокой нагрузкой это становится узким местом. Асинхронное программирование решает эту проблему, позволяя выполнять несколько задач одновременно без блокировки основного потока.

В этом руководстве мы разберем, как работает асинхронность в PHP, какие инструменты доступны и как их использовать на практике. Вы узнаете о генераторах, библиотеках ReactPHP и Swoole, а также о новых возможностях PHP 8.1 — Fiber.

Основы асинхронного программирования

Что такое асинхронность и зачем она нужна?

Представьте, что вы готовите завтрак. Синхронный подход: вы ставите чайник, ждете, пока он закипит, затем начинаете жарить яйца. Асинхронный подход: вы ставите чайник и, пока вода греется, параллельно готовите яичницу. В PHP это означает, что вместо ожидания ответа от базы данных или внешнего API, вы можете выполнять другой код.

Основные преимущества асинхронного подхода:

• Повышение производительности при I/O-операциях (сеть, диски, базы данных)
• Экономия серверных ресурсов — меньше потоков обрабатывают больше запросов
• Возможность создания реального времени (чаты, уведомления, стриминг)

Проблема синхронного кода

Рассмотрим классический пример: получение данных с двух удаленных API. Синхронный код будет выполняться последовательно:

<?php
function fetchData($url) {
    $ch = curl_init($url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    $result = curl_exec($ch); // Блокировка на время запроса
    curl_close($ch);
    return $result;
}

$start = microtime(true);
$data1 = fetchData('https://api.example.com/users');
$data2 = fetchData('https://api.example.com/posts');
echo "Время: " . (microtime(true) - $start);
?>

Если каждый запрос занимает 2 секунды, общее время выполнения будет 4 секунды, хотя мы могли бы выполнять запросы параллельно.

Инструменты для асинхронности в PHP

1. Генераторы (yield) — легкая асинхронность

Генераторы появились в PHP 5.5 и позволяют создавать функции, которые могут приостанавливать свое выполнение и возвращать управление вызывающему коду. Это основа для создания корутин.

<?php
function generator() {
    echo "Начало генератора\n";
    yield 1;
    echo "После первого yield\n";
    yield 2;
    echo "Конец\n";
}

$gen = generator();
foreach ($gen as $value) {
    echo "Получено: $value\n";
}
?>

Генераторы можно использовать для организации неблокирующих операций в связке с циклом событий. Однако для полноценной асинхронности этого недостаточно — нужна библиотека.

2. ReactPHP — событийно-ориентированная библиотека

ReactPHP — это популярная библиотека для асинхронного программирования. Она предоставляет цикл событий (Event Loop), неблокирующие сокеты, HTTP-клиент и сервер. Установка через Composer:

composer require react/event-loop react/http

Пример асинхронного HTTP-запроса:

<?php
require 'vendor/autoload.php';

use React\EventLoop\Factory;
use React\HttpClient\Client;
use React\HttpClient\Response;

$loop = Factory::create();
$client = new Client($loop);

$request = $client->request('GET', 'https://api.example.com/data');
$request->on('response', function (Response $response) {
    $response->on('data', function ($chunk) {
        echo "Получен фрагмент: " . strlen($chunk) . " байт\n";
    });
    $response->on('end', function () {
        echo "Запрос завершен\n";
    });
});
$request->end();

echo "Запрос отправлен, ждем...\n";
$loop->run();
?>

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

3. Swoole — высокопроизводительный сервер

Swoole — это расширение PHP, которое добавляет встроенную поддержку корутин, многопоточности и асинхронных I/O. Оно работает как HTTP-сервер, заменяя традиционный FPM. Установка:

pecl install swoole

Пример асинхронного сервера на Swoole:

<?php
use Swoole\Coroutine;
use function Swoole\Coroutine\run;

run(function () {
    // Параллельные запросы
    $results = [];
    $results[] = Coroutine::create(function () {
        return file_get_contents('https://api.example.com/users');
    });
    $results[] = Coroutine::create(function () {
        return file_get_contents('https://api.example.com/posts');
    });

    // Ждем все результаты
    foreach ($results as $result) {
        echo "Длина: " . strlen($result) . "\n";
    }
});
?>

Swoole автоматически переключает контекст при блокирующих операциях — разработчику не нужно вручную управлять асинхронностью. Это делает код похожим на синхронный, но работающим асинхронно.

4. Fiber (PHP 8.1+) — нативная поддержка корутин

Начиная с PHP 8.1, в языке появились Fiber — легковесные потоки, управляемые на уровне языка. Fiber позволяет разработчику вручную приостанавливать и возобновлять выполнение кода без блокировки основного потока.

<?php
$fiber = new Fiber(function (): void {
    echo "Fiber 1: старт\n";
    Fiber::suspend(); // Передаем управление обратно
    echo "Fiber 1: продолжение\n";
});

echo "Основной поток: запуск Fiber\n";
$fiber->start();
echo "Основной поток: Fiber приостановлен\n";
$fiber->resume();
echo "Основной поток: Fiber завершен\n";
?>

Fiber — это низкоуровневый механизм. Для удобства работы с ними созданы библиотеки-обертки, например, amphp/amp:

composer require amphp/