Реализация HTTP сервера с помощью PHP: варианты и инструкции

Расширенные примеры работы с HTTP серверами на PHP

1. Встроенный сервер с динамическим роутингом

Создайте файл router.php для перенаправления запросов на разные обработчики:

<?php
$path = parse_url($_SERVER['REQUEST_URI'], PHP_URL_PATH);

// Отдача статики
if (file_exists(__DIR__ . $path) && is_file(__DIR__ . $path)) {
    return false;
}

// Маршруты
switch ($path) {
    case '/':
        echo "<h1>Добро пожаловать!</h1>";
        break;
    case '/api/data':
        header('Content-Type: application/json');
        echo json_encode(['status' => 'ok']);
        break;
    default:
        http_response_code(404);
        echo "<h1>404 - Страница не найдена</h1>";
}

Запуск:

php -S localhost:8000 router.php

Теперь GET-запрос к /api/data вернёт JSON, а к корню - HTML-приветствие.

2. ReactPHP с маршрутизацией и middleware

Устанавливаем дополнительные пакеты:

composer require react/http-middleware
composer require react/psr7

Пример сервера с роутером:

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

use React\EventLoop\Factory;
use React\Http\Server;
use React\Http\Response;
use React\Http\Middleware\StreamingRequestMiddleware;
use React\Http\Middleware\LimitConcurrentRequestsMiddleware;
use Psr\Http\Message\ServerRequestInterface;

$loop = Factory::create();

$server = new Server($loop, function (ServerRequestInterface $request) {
    $path = $request->getUri()->getPath();
    switch ($path) {
        case '/':
            return new Response(200, ['Content-Type' => 'text/html'], '<h1>ReactPHP</h1>');
        case '/api/time':
            $time = date('Y-m-d H:i:s');
            return new Response(200, ['Content-Type' => 'application/json'], json_encode(['time' => $time]));
        default:
            return new Response(404, ['Content-Type' => 'text/plain'], 'Not Found');
    }
});

$socket = new React\Socket\Server('0.0.0.0:8080', $loop);
$server->listen($socket);
$loop->run();

Результат: при обращении к /api/time возвращается текущее время в формате JSON.

3. Swoole с корутинной базой данных и статикой

Убедитесь, что расширение Swoole установлено и активно. Пример сервера, который отдаёт статические файлы и использует корутину для запроса к MySQL (через swoole_mysql или PDO с корутиной):

<?php
$http = new Swoole\Http\Server('0.0.0.0', 9501);

// Обработка статических файлов
$http->on('request', function (Swoole\Http\Request $request, Swoole\Http\Response $response) {
    $path = $request->server['request_uri'];
    $filePath = __DIR__ . $path;
    if (is_file($filePath)) {
        $response->header('Content-Type', mime_content_type($filePath));
        $response->sendfile($filePath);
        return;
    }
    // Динамический ответ
    $response->header('Content-Type', 'application/json');
    $response->end(json_encode(['message' => 'Swoole server']));
});

$http->start();

Запуск:

php server.php

Теперь любые файлы в той же директории будут отдаваться. Если файл не найден - возвращается JSON.

4. Самописный сервер с поддержкой keep-alive (мультиплексирование через stream_select)

Более продвинутый учебный пример, использующий stream_select для одновременной обработки нескольких клиентов:

<?php
$server = stream_socket_server('tcp://0.0.0.0:8080', $errno, $errstr);
stream_set_blocking($server, false);
$clients = [];

while (true) {
    $read = array_merge([$server], $clients);
    $write = null;
    $except = null;
    if (stream_select($read, $write, $except, 0, 200000) > 0) {
        if (in_array($server, $read)) {
            $client = @stream_socket_accept($server, 0);
            if ($client) {
                stream_set_blocking($client, false);
                $clients[] = $client;
                echo "Новый клиент\n";
            }
            $read = array_filter($read, fn($r) => $r !== $server);
        }
        foreach ($read as $client) {
            $data = @fread($client, 1024);
            if ($data === false || feof($client)) {
                fclose($client);
                $clients = array_filter($clients, fn($c) => $c !== $client);
                continue;
            }
            $response = "HTTP/1.1 200 OK\r\nContent-Type: text/plain\r\nConnection: close\r\n\r\nHello from non-blocking server";
            fwrite($client, $response);
            fclose($client);
            $clients = array_filter($clients, fn($c) => $c !== $client);
        }
    }
}

Этот сервер обрабатывает несколько соединений без блокировки главного цикла, но не использует keep-alive - после каждого ответа соединение закрывается.

5. Использование Workerman для создания демона с многопоточностью

Workerman - ещё одна популярная PHP-библиотека для многопроцессных сетевых приложений. Пример HTTP сервера:

<?php
require_once __DIR__ . '/vendor/autoload.php';

use Workerman\Worker;
use Workerman\Lib\Timer;

$http_worker = new Worker('http://0.0.0.0:8080');
$http_worker->count = 4; // число процессов

$http_worker->onMessage = function ($connection, $data) {
    $connection->send('Hello from Workerman');
};

Worker::runAll();

Запуск из командной строки:

php worker.php start

Workerman автоматически форкает процессы, каждый из которых обрабатывает свои соединения. Отличное решение для high-availability при невысокой сложности.