WebSocket-Bibliothek Ratchet: Echtzeit-Entwicklung in PHP

WebSocket-Bibliothek Ratchet für PHP: Erstellung von Echtzeitanwendungen

WebSocket ist ein Protokoll, das eine bidirektionale Kommunikation zwischen Client und Server über eine einzige dauerhafte Verbindung ermöglicht. Im Gegensatz zu traditionellem HTTP, bei dem jede Anfrage eine neue Verbindung öffnet, ermöglicht WebSocket die Übertragung von Daten in Echtzeit ohne Verzögerungen. Für PHP ist eine der beliebtesten Bibliotheken für die Arbeit mit WebSocket Ratchet. Diese Bibliothek basiert auf ReactPHP und bietet eine einfache und leistungsstarke API zur Erstellung von WebSocket-Servern.

Was ist Ratchet?

Ratchet ist eine Open-Source-PHP-Bibliothek, die es Entwicklern ermöglicht, Echtzeitanwendungen wie Chats, Benachrichtigungen, Online-Spiele und Überwachungssysteme zu erstellen. Sie abstrahiert die Komplexität der Arbeit mit Sockets und asynchronem Input/Output und bietet benutzerfreundliche Klassen und Schnittstellen.

Hauptfunktionen von Ratchet:

• Unterstützung von WebSocket gemäß RFC 6455
• Integration mit HTTP-Servern (z. B. über ReactPHP)
• Möglichkeit zur Erstellung eigener Nachrichtenhandler
• Unterstützung von WAMP (WebSocket Application Messaging Protocol) für Pub/Sub
• Leichtgewichtigkeit und hohe Leistung

Installation von Ratchet

Die Installation der Bibliothek erfolgt über Composer. Führen Sie im Terminal aus:

composer require cboden/ratchet

Nach der Installation erscheint in Ihrem Projekt der Ordner vendor mit den erforderlichen Abhängigkeiten, einschließlich ReactPHP.

Erstellung eines einfachen WebSocket-Servers

Betrachten wir ein grundlegendes Beispiel: Wir erstellen einen Server, der Verbindungen annimmt und eine Begrüßungsnachricht zurücksendet. Erstellen Sie dazu die Datei server.php:

<?phprequire 'vendor/autoload.php';

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

class MyWebSocket 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}";        $conn->send("Willkommen! Ihre ID: {$conn->resourceId}");    }

    public function onMessage(ConnectionInterface $from, $msg) {        echo "Nachricht von {$from->resourceId} erhalten: {$msg}";        // An alle Clients senden        foreach ($this->clients as $client) {            if ($from !== $client) {                $client->send("Nachricht von {$from->resourceId}: {$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();    }}

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

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

Starten Sie den Server mit dem Befehl:

php server.php

Der Server hört nun auf Port 8080. Zum Testen können Sie einen beliebigen WebSocket-Client verwenden, z. B. eine Browsererweiterung oder einfachen JavaScript-Code.

Clientseite mit JavaScript

Erstellen Sie eine HTML-Datei client.html:

<!DOCTYPE html><html><head>    <title>WebSocket-Client</title></head><body>    <input type="text" id="message" placeholder="G