$ composer require thenlabs/websocket-server 1.0.x-dev

users[$nickname] = $event->getConnection(); } public function onMessage(MessageEvent $event): void { $senderUser = $event->getConnection(); $senderNick = array_search($senderUser, $this->users); $message = $event->getMessage(); // send the message to the other users. foreach ($this->users as $user) { if ($user !== $senderUser) { $user->send("{$senderNick}: {$message}"); } } } public function onClose(CloseEvent $event): void { $user = $event->getConnection(); $nickname = array_search($user, $this->users); // notify to the other users. foreach ($this->users as $otherUser) { if ($otherUser !== $user) { $otherUser->send("The user {$nickname} has disconnected."); } } unset($this->users[$nickname]); } } ">

// example/MyChatServer.php

use ThenLabs\WebSocketServer\Event\CloseEvent;
use ThenLabs\WebSocketServer\Event\MessageEvent;
use ThenLabs\WebSocketServer\Event\OpenEvent;
use ThenLabs\WebSocketServer\WebSocketServer;

class MyChatServer extends WebSocketServer
{
    protected $users = [];

    public function onOpen(OpenEvent $event): void
    {
        $request = $event->getRequest();
        $nickname = explode('/', $request->getRequestUri())[1];

        // notify to the connected users previously.
        foreach ($this->users as $user) {
            $user->send("User '{$nickname}' has connected.");
        }

        // add the new user to the list.
        $this->users[$nickname] = $event->getConnection();
    }

    public function onMessage(MessageEvent $event): void
    {
        $senderUser = $event->getConnection();
        $senderNick = array_search($senderUser, $this->users);

        $message = $event->getMessage();

        // send the message to the other users.
        foreach ($this->users as $user) {
            if ($user !== $senderUser) {
                $user->send("{$senderNick}: {$message}");
            }
        }
    }

    public function onClose(CloseEvent $event): void
    {
        $user = $event->getConnection();
        $nickname = array_search($user, $this->users);

        // notify to the other users.
        foreach ($this->users as $otherUser) {
            if ($otherUser !== $user) {
                $otherUser->send("The user {$nickname} has disconnected.");
            }
        }

        unset($this->users[$nickname]);
    }
}

// example/start-server.php

require_once __DIR__.'/../vendor/autoload.php';
require_once __DIR__.'/MyChatServer.php';

$config = [
    'host' => $argv[1] ?? '127.0.0.1',
    'port' => $argv[2] ?? 9090,
];

$server = new MyChatServer($config);
$server->start();

$ php example/start-server.php

$ java -jar path/to/selenium-server-standalone-x.y.z.jar

$ ./vendor/bin/pyramidal