WebSocket in PHP: Echtzeit-Anwendungen von Grund auf erstellen

WebSocket in PHP: Erstellung von Echtzeit-Anwendungen von Grund auf

Moderne Webanwendungen erfordern eine sofortige Reaktion auf Benutzeraktionen. Das standardmäßige HTTP-Protokoll, das nach dem „Anfrage-Antwort“-Prinzip funktioniert, ist für Aufgaben, bei denen Daten in Echtzeit aktualisiert werden müssen – Chats, Benachrichtigungen, Börsenkurse oder Online-Spiele – schlecht geeignet. Die Lösung für dieses Problem ist WebSocket. In diesem Artikel werden wir uns ansehen, wie man WebSocket in PHP implementiert, einen einfachen Chat erstellt und die besten Praktiken betrachtet.

Was ist WebSocket und warum wird es in PHP benötigt?

WebSocket ist ein Kommunikationsprotokoll, das eine dauerhafte bidirektionale Verbindung zwischen Client (Browser) und Server bereitstellt. Im Gegensatz zu HTTP können nach dem Aufbau der Verbindung Daten jederzeit in beide Richtungen übertragen werden, ohne dass wiederholte Anfragen erforderlich sind. Dies ist für Echtzeit-Anwendungen von entscheidender Bedeutung.

PHP gilt traditionell als Sprache für die Serverlogik, die nach dem Schema „Start-Ausführen-Beenden“ arbeitet. Mit dem Aufkommen asynchroner Bibliotheken wie Ratchet und ReactPHP ist PHP jedoch zu einem vollwertigen Werkzeug für die Erstellung von WebSocket-Servern geworden. Die Hauptvorteile der Verwendung von WebSocket in PHP sind:

• Sofortige Datenzustellung – ohne Verzögerungen durch wiederholte HTTP-Anfragen.
• Reduzierte Serverlast – eine einzige Verbindung ersetzt Dutzende von Long Polling-Anfragen.
• Einfache Integration – wenn Ihr Projekt bereits auf PHP basiert, müssen Sie den Technologie-Stack nicht ändern.

Installation und Konfiguration der Ratchet-Bibliothek

Für die Arbeit mit WebSocket in PHP verwenden wir die Bibliothek Ratchet (in Verbindung mit ReactPHP). Die Installation erfolgt über Composer:

composer require cboden/ratchet

Nach der Installation erstellen wir eine Basisklasse für den WebSocket-Server. In Ratchet wird der Server über das Interface MessageComponentInterface implementiert, das vier Methoden enthält:

• onOpen – wird beim Verbinden eines neuen Clients aufgerufen.
• onMessage – verarbeitet eine eingehende Nachricht.
• onClose – wird beim Trennen eines Clients ausgelöst.
• onError – behandelt Verbindungsfehler.

Beispiel eines einfachen Servers:

<?phpuse Ratchet\\MessageComponentInterface;use Ratchet\\ConnectionInterface;

class ChatServer implements MessageComponentInterface {    protected $clients;

    public function __construct() {        $this->clients = new \\SplObjectStorage;    }

    public function onOpen(ConnectionInterface $conn) {        $this->clients->attach($conn);        echo "Neue Verbindung: {$conn->resourceId}";    }

    public function onMessage(ConnectionInterface $from, $msg) {        foreach ($this->clients as $client) {            if ($from !== $client) {                $client->send($msg);            }        }    }

    public function onClose(ConnectionInterface $conn) {        $this->clients->detach($conn);        echo "Verbindung {$conn->resourceId} geschlossen";    }

    public function onError(ConnectionInterface $conn, \\Exception $e) {        echo "Fehler: {$e->getMessage()}";        $conn->close();    }}

Starten des WebSocket-Servers und Client-Seite

Zum Starten des Servers erstellen wir ein Skript server.php:

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

use Ratchet\\Server\\IoServer;use Ratchet\\Http\\HttpServer;use Ratchet\\WebSocket\\WsServer;

$server = IoServer::factory(    new HttpServer(        new WsServer(            new ChatServer()        )    ),    8080);

echo "WebSocket-Server gestartet auf Port 8080";$server->run();

Starten Sie den Server mit dem Befehl:

php server.php