TrueAsync\HttpServer ​

(PHP 8.6+, true_async_server 0.6+)

Classe principale del server integrato. Riceve la configurazione tramite il costruttore, accetta handler di protocollo, si avvia con start() e blocca il thread fino a 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
}

Metodi ​

__construct ​

public HttpServer::__construct(HttpServerConfig $config)

Crea il server con la configurazione data. La configurazione viene congelata in questa chiamata: i setter successivi lanciano HttpServerRuntimeException.

addHttpHandler ​

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

Registra l'handler per le richieste HTTP/1.1 e HTTP/2. Firma:

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

Ogni richiesta gira in una propria coroutine nello scope per richiesta. L'handler restituisce void; la risposta viene inviata tramite $response.

addStaticHandler ​

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

Registra un static mount (issue #13). Le richieste sotto $handler->getUrlPrefix() vengono servite interamente in C: niente coroutine, niente VM PHP.

I mount multipli vengono confrontati nell'ordine di registrazione. Dopo l'attach l'handler viene bloccato: qualsiasi setter lancia HttpServerRuntimeException.

Vedi StaticHandler.

addWebSocketHandler ​

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

In roadmap. RFC 6455, upgrade da HTTP/1.1 e HTTP/2.

addHttp2Handler ​

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

In roadmap. Attualmente le richieste HTTP/2 finiscono in addHttpHandler (dispatcher comune H1/H2).

addGrpcHandler ​

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

In roadmap. Sopra HTTP/2, RPC unary e streaming.

start ​

public HttpServer::start(): bool

Avvia il server e blocca il thread chiamante fino a stop() o a un errore fatale.

• Con setWorkers(1): gira l'event loop sul thread chiamante.
• Con setWorkers(N > 1): crea un Async\ThreadPool di N worker e ne attende il termine.

Restituisce true su arresto regolare. Lancia HttpServerException (e discendenti) per errori di avvio (bind fallito, build senza HTTP/3 ma con addHttp3Listener ecc.).

stop ​

public HttpServer::stop(): bool

Graceful shutdown:

1. Smette di accettare nuove connessioni.
2. Attende il termine delle richieste attive (fino a setShutdownTimeout()).
3. Chiude tutte le connessioni.

Restituisce true su arresto riuscito.

stop() cross-thread è in roadmap. Oggi l'arresto si fa di solito tramite SIGINT/SIGTERM.

isRunning ​

public HttpServer::isRunning(): bool

getConfig ​

public HttpServer::getConfig(): HttpServerConfig

Restituisce lo stesso oggetto config passato a __construct. Dopo l'avvio del server la configurazione è bloccata (isLocked() === true).

getHttp3Stats ​

public HttpServer::getHttp3Stats(): array

Observability per singolo listener HTTP/3. Una voce per ogni addHttp3Listener() nell'ordine di registrazione. Ogni voce contiene:

Restituisce un array vuoto quando l'estensione è compilata senza --enable-http3.

getRuntimeStats ​

public HttpServer::getRuntimeStats(): array

Snapshot degli allocatori interni del server. Aiuta ad attribuire la crescita dell'RSS a specifici sottosistemi.

getTelemetry ​

public HttpServer::getTelemetry(): array

In roadmap.

resetTelemetry ​

public HttpServer::resetTelemetry(): bool

In roadmap.

Esempio ​

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();

Vedi anche ​

• TrueAsync\HttpServerConfig
• TrueAsync\HttpRequest
• TrueAsync\HttpResponse
• Avvio rapido