TrueAsync\HttpServer ​

(PHP 8.6+, true_async_server 0.6+)

Главный класс встроенного сервера. Получает конфиг через конструктор, принимает обработчики протоколов, запускается через start() и блокирует поток до stop().

namespace TrueAsync;

final class HttpServer
{
    public function __construct(HttpServerConfig $config);

    public function addHttpHandler(callable $handler): static;
    public function addStaticHandler(StaticHandler $handler): static;
    public function addWebSocketHandler(callable $handler): static;   // TODO
    public function addHttp2Handler(callable $handler): static;       // TODO
    public function addGrpcHandler(callable $handler): static;        // TODO

    public function start(): bool;
    public function stop(): bool;
    public function isRunning(): bool;

    public function getConfig(): HttpServerConfig;
    public function getHttp3Stats(): array;
    public function getRuntimeStats(): array;
    public function getTelemetry(): array;        // TODO
    public function resetTelemetry(): bool;       // TODO
}

Методы ​

__construct ​

public HttpServer::__construct(HttpServerConfig $config)

Создаёт сервер с заданным конфигом. Конфиг замораживается на этом вызове — последующие сеттеры бросают HttpServerRuntimeException.

addHttpHandler ​

public HttpServer::addHttpHandler(callable $handler): static

Регистрирует обработчик HTTP/1.1 и HTTP/2 запросов. Сигнатура:

function (HttpRequest $request, HttpResponse $response): void

Каждый запрос выполняется в собственной корутине в per-request scope. Обработчик возвращает void; ответ отправляется через $response.

addStaticHandler ​

public HttpServer::addStaticHandler(StaticHandler $handler): static

Регистрирует static-mount (issue #13). Запросы под $handler->getUrlPrefix() обслуживаются полностью в C — без спавна корутины, без захода в PHP VM.

Множественные mount'ы матчатся в порядке регистрации. После attach handler блокируется — любые сеттеры на нём бросают HttpServerRuntimeException.

См. StaticHandler.

addWebSocketHandler ​

public HttpServer::addWebSocketHandler(callable $handler): static

📋 Запланировано. RFC 6455, upgrade с HTTP/1.1 и HTTP/2.

addHttp2Handler ​

public HttpServer::addHttp2Handler(callable $handler): static

📋 Запланировано. Сейчас HTTP/2 запросы попадают в addHttpHandler (общий H1/H2 диспетчер).

addGrpcHandler ​

public HttpServer::addGrpcHandler(callable $handler): static

📋 Запланировано. Поверх HTTP/2, unary и streaming RPC.

start ​

public HttpServer::start(): bool

Запускает сервер и блокирует вызывающий поток до stop() или фатальной ошибки.

• При setWorkers(1) — крутит event-loop на вызывающем потоке.
• При setWorkers(N > 1) — спавнит Async\ThreadPool из N воркеров и awaitит их завершение.

Возвращает true при штатной остановке. Бросает HttpServerException (и наследников) при ошибках запуска (bind failed, отсутствует требуемая сборка для HTTP/3 при наличии addHttp3Listener и т.п.).

stop ​

public HttpServer::stop(): bool

Graceful shutdown:

1. Прекращает приём новых соединений.
2. Ждёт завершения активных запросов (до setShutdownTimeout()).
3. Закрывает все соединения.

Возвращает true при успешной остановке.

Cross-thread stop() — в roadmap. Сейчас остановку чаще всего инициируют через SIGINT/SIGTERM.

isRunning ​

public HttpServer::isRunning(): bool

getConfig ​

public HttpServer::getConfig(): HttpServerConfig

Возвращает тот же объект конфига, что был передан в __construct. После старта сервера конфиг заблокирован (isLocked() === true).

getHttp3Stats ​

public HttpServer::getHttp3Stats(): array

Per-listener observability для HTTP/3. Одна запись на каждый addHttp3Listener() в порядке регистрации. Каждая запись содержит:

Возвращает пустой массив, когда расширение собрано без --enable-http3.

getRuntimeStats ​

public HttpServer::getRuntimeStats(): array

Snapshot внутренних аллокаторов сервера. Помогает атрибутировать рост RSS на конкретные подсистемы.

getTelemetry ​

public HttpServer::getTelemetry(): array

📋 Запланировано.

resetTelemetry ​

public HttpServer::resetTelemetry(): bool

📋 Запланировано.

Пример ​

use TrueAsync\HttpServer;
use TrueAsync\HttpServerConfig;
use TrueAsync\StaticHandler;

$server = new HttpServer(
    (new HttpServerConfig())
        ->addListener('0.0.0.0', 8080)
        ->setWorkers(4)
);

$server->addStaticHandler(
    (new StaticHandler('/assets/', __DIR__ . '/public'))
        ->enablePrecompressed('br', 'gzip')
);

$server->addHttpHandler(function ($req, $res) {
    $res->json(['ok' => true, 'path' => $req->getPath()]);
});

$server->start();

См. также ​

• TrueAsync\HttpServerConfig
• TrueAsync\HttpRequest
• TrueAsync\HttpResponse
• Quickstart