TrueAsync\HttpServer ​

(PHP 8.6+, true_async_server 0.6+)

Classe principale du serveur intégré. Reçoit la config via le constructeur, accepte des handlers de protocoles, démarre via start() et bloque le thread jusqu'à 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
}

Méthodes ​

__construct ​

public HttpServer::__construct(HttpServerConfig $config)

Crée un serveur avec la config donnée. La config est gelée sur cet appel — les setters ultérieurs lèvent HttpServerRuntimeException.

addHttpHandler ​

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

Enregistre un handler des requêtes HTTP/1.1 et HTTP/2. Signature :

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

Chaque requête s'exécute dans sa propre coroutine dans un per-request scope. Le handler retourne void ; la réponse est envoyée via $response.

addStaticHandler ​

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

Enregistre un static-mount (issue #13). Les requêtes sous $handler->getUrlPrefix() sont servies entièrement en C, sans spawn de coroutine, sans entrée dans la VM PHP.

Les mounts multiples sont matchés dans l'ordre d'enregistrement. Après attach, le handler est verrouillé : tout setter lèvera HttpServerRuntimeException.

Voir StaticHandler.

addWebSocketHandler ​

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

📋 Planifié. RFC 6455, upgrade depuis HTTP/1.1 et HTTP/2.

addHttp2Handler ​

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

📋 Planifié. Pour l'instant, les requêtes HTTP/2 tombent dans addHttpHandler (dispatcher H1/H2 commun).

addGrpcHandler ​

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

📋 Planifié. Au-dessus de HTTP/2, RPC unary et streaming.

start ​

public HttpServer::start(): bool

Démarre le serveur et bloque le thread appelant jusqu'à stop() ou une erreur fatale.

• Avec setWorkers(1) : fait tourner l'event-loop sur le thread appelant.
• Avec setWorkers(N > 1) : spawn un Async\ThreadPool de N workers et await leur fin.

Retourne true à l'arrêt normal. Lève HttpServerException (et ses descendants) en cas d'erreur de démarrage (bind failed, build sans support HTTP/3 alors qu'il y a addHttp3Listener, etc.).

stop ​

public HttpServer::stop(): bool

Graceful shutdown :

1. Arrête d'accepter de nouvelles connexions.
2. Attend la fin des requêtes actives (jusqu'à setShutdownTimeout()).
3. Ferme toutes les connexions.

Retourne true à l'arrêt réussi.

Le stop() cross-thread est dans la roadmap. Pour l'instant, l'arrêt est le plus souvent initié via SIGINT/SIGTERM.

isRunning ​

public HttpServer::isRunning(): bool

getConfig ​

public HttpServer::getConfig(): HttpServerConfig

Renvoie le même objet de config qui a été passé à __construct. Après le démarrage du serveur, la config est verrouillée (isLocked() === true).

getHttp3Stats ​

public HttpServer::getHttp3Stats(): array

Observabilité par listener pour HTTP/3. Une entrée par addHttp3Listener() dans l'ordre d'enregistrement. Chaque entrée contient :

Renvoie un tableau vide quand l'extension est compilée sans --enable-http3.

getRuntimeStats ​

public HttpServer::getRuntimeStats(): array

Snapshot des allocateurs internes du serveur. Aide à attribuer la croissance du RSS à des sous-systèmes précis.

getTelemetry ​

public HttpServer::getTelemetry(): array

📋 Planifié.

resetTelemetry ​

public HttpServer::resetTelemetry(): bool

📋 Planifié.

Exemple ​

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

Voir aussi ​

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