PHP 8 WebSocket demo fully working with textalk/websocket client

Author: niccolovettorello1997

examples/php8-demo/README.md

@@ -0,0 +1,78 @@
+# PHP 8 WebSocket Example (Ratchet)
+
+This example shows a minimal WebSocket **server** and **client** compatible with **PHP 8.3+** (including PHP 8.4).
+
+It demonstrates:
+
+- A simple Ratchet WebSocket server (tested with Ratchet >= 0.4)
+- A standalone PHP client using the `textalk/websocket` library
+- Full compatibility with Linux and macOS
+
+> **Note**  
+> The client uses `textalk/websocket`, which is **not a dependency of Ratchet itself**.  
+> We intentionally keep it separate to avoid introducing new PHP version requirements into Ratchet’s core `composer.json`.
+
+---
+
+## Requirements
+
+- PHP `^7.4|^8.0` (required by `textalk/websocket`)
+- Ratchet (already installed in the main project)
+
+---
+
+## How to run
+
+### 1. Install Ratchet dependencies (from the project root)
+
+```
+composer install
+```
+
+### 2. Install the client dependency (inside the `php8-demo` example folder)
+
+```
+composer require textalk/websocket
+```
+
+**Note:**
+
+This should create a specific `composer.json` file *inside* the `php8-demo` folder. This keeps the example self-contained and avoids adding new dependencies to Ratchet itself.
+
+### 3. Start the WebSocket server
+
+```
+php server.php
+```
+
+You should see:
+
+```
+WebSocket server started at ws://127.0.0.1:8080
+```
+
+### 4. Run the PHP client
+
+```
+php client.php
+```
+
+Expected output:
+
+```
+Connected to WebSocket server
+Message sent
+Message received from server: Client <number> says: Hello from PHP 8 client!
+Connection closed
+```
+
+---
+
+## Tested with
+
+| OS      | PHP Version |
+|---------|-------------|
+| Linux   | 8.3.x       |
+| macOS   | 8.4.x       |
+
+This example ensures full compatibility with modern PHP versions without affecting Ratchet’s backward compatibility.

examples/php8-demo/client.php

@@ -0,0 +1,28 @@
+<?php
+
+require __DIR__ . '/vendor/autoload.php';
+
+use WebSocket\Client;
+
+try {
+    $client = new Client("ws://127.0.0.1:8080", [
+        'timeout' => 5,
+        'headers' => ['Origin' => 'http://127.0.0.1']
+    ]);
+
+    echo "[" . date('H:i:s') . "] Connected to WebSocket server\n";
+
+    // Send a message
+    $client->send("Hello from PHP 8 client!");
+    echo "[" . date('H:i:s') . "] Message sent\n";
+
+    // Get a response (timeout 5s)
+    $response = $client->receive();
+    echo "[" . date('H:i:s') . "] Message received from server: $response\n";
+
+    $client->close();
+    echo "[" . date('H:i:s') . "] Connection closed\n";
+
+} catch (\Exception $e) {
+    echo "[" . date('H:i:s') . "] Client error: " . $e->getMessage() . "\n";
+}

examples/php8-demo/server.php

@@ -0,0 +1,51 @@
+<?php
+
+require __DIR__ . '/../../vendor/autoload.php';
+
+use Ratchet\MessageComponentInterface;
+use Ratchet\ConnectionInterface;
+use Ratchet\Server\IoServer;
+use Ratchet\WebSocket\WsServer;
+use Ratchet\Http\HttpServer;
+
+class DemoChat implements MessageComponentInterface {
+    protected array $clients = [];
+
+    public function onOpen(ConnectionInterface $conn) {
+        $this->clients[$conn->resourceId] = $conn;
+        echo "[" . date('H:i:s') . "] New connection: ({$conn->resourceId})\n";
+    }
+
+    public function onMessage(ConnectionInterface $from, $msg) {
+        echo "[" . date('H:i:s') . "] Message received from {$from->resourceId}: $msg\n";
+
+        foreach ($this->clients as $client) {
+            try {
+                $client->send("Client {$from->resourceId} says: $msg");
+            } catch (\Exception $e) {
+                echo "[" . date('H:i:s') . "] Error while sending message to client {$client->resourceId}: {$e->getMessage()}\n";
+            }
+        }
+    }
+
+    public function onClose(ConnectionInterface $conn) {
+        unset($this->clients[$conn->resourceId]);
+        echo "[" . date('H:i:s') . "] Connection closed: ({$conn->resourceId})\n";
+    }
+
+    public function onError(ConnectionInterface $conn, \Exception $e) {
+        echo "[" . date('H:i:s') . "] Error: {$e->getMessage()}\n";
+        $conn->close();
+    }
+}
+
+// Running WebSocket server at ws://127.0.0.1:8080
+$server = IoServer::factory(
+    new HttpServer(
+        new WsServer(new DemoChat())
+    ),
+    8080
+);
+
+echo "[" . date('H:i:s') . "] WebSocket server started at ws://127.0.0.1:8080\n";
+$server->run();