PHP 실시간 통신 기능과 RESTful API의 결합 적용에 대한 논의

require __DIR__ . '/vendor/autoload.php';

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;
use RatchetServerIoServer;
use RatchetHttpHttpServer;
use RatchetWebSocketWsServer;

class WebSocketServer 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})
";
    }

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

    public function onClose(ConnectionInterface $conn) {
        $this->clients->detach($conn);
        echo "Connection {$conn->resourceId} has disconnected
";
    }

    public function onError(ConnectionInterface $conn, Exception $e) {
        echo "An error has occurred: {$e->getMessage()}
";
        $conn->close();
    }
}

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

$server->run();

class RestfulApi {
    private $webSocket;

    public function __construct() {
        $this->webSocket = new WebSocketClient('ws://localhost:8080');
    }

    public function handleRequest($request) {
        // 处理请求逻辑
        // ...

        // 向所有连接的客户端发送实时消息
        $this->webSocket->send(json_encode(['message' => 'New message']));

        // 返回响应
        // ...
    }
}

$api = new RestfulApi;
$request = json_decode(file_get_contents('php://input'), true);
$api->handleRequest($request);