如何实现PHP调用实时通信WebSocket服务_PHP实时通信WebSocket服务实现与Ratchet教程

composer require ratchet/rfc6455
composer require react/socket
composer require react/http

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

class Chat implements MessageComponentInterface {
    protected $clients;

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

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
        echo "New connection! ({$conn->resourceId})\n";
    }

    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 "Connection {$conn->resourceId} closed\n";
    }

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

// 启动 WebSocket 服务
$server = IoServer::factory(
    new HttpServer(new WsServer(new Chat())),
    8080
);

echo "WebSocket server started on port 8080...\n";
$server->run();

php websocket_server.php

const conn = new WebSocket('ws://localhost:8080');

conn.onopen = function(e) {
    console.log("Connected");
    conn.send("Hello Server!");
};

conn.onmessage = function(e) {
    console.log("Received: " + e.data);
};

use Predis\Client;

class Chat implements MessageComponentInterface {
    protected $clients;
    private $redis;

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

    private function listenRedis() {
        $loop = \React\EventLoop\Factory::create();
        $loop->addPeriodicTimer(0.1, function() {
            $msg = $this->redis->brpop('websocket:messages', 1);
            if ($msg) {
                foreach ($this->clients as $client) {
                    $client->send($msg[1]);
                }
            }
        });
        $loop->run();
    }

    // ... onOpen, onMessage 等方法保持不变
}

$redis = new Predis\Client();
$redis->lpush('websocket:messages', 'Hi from PHP script!');