PHP上的WebSocket：从零开始创建实时应用

轻松学习Python，无需理论负担。在浏览器中直接解决带自动检查的实践任务，无需安装任何东西。

WebSocket 在 PHP 上的应用：从零开始打造实时应用

现代 Web 应用要求对用户操作做出即时响应。标准 HTTP 协议遵循"请求-响应"模式，难以胜任需要实时更新数据的场景——例如聊天、通知、股票行情或在线游戏。解决这一问题的方案是 WebSocket。本文将剖析如何在 PHP 中实现 WebSocket，构建一个简易聊天应用，并探讨最佳实践。

什么是 WebSocket 以及为何 PHP 需要它？

WebSocket 是一种通信协议，能在客户端（浏览器）与服务器之间建立持久双向连接。与 HTTP 不同，连接建立后，数据可在任意时刻双向传输，无需重复请求。这对实时应用至关重要。

PHP 传统上被视为遵循"启动-执行-终止"模式的服务器端语言。然而，随着 Ratchet 和 ReactPHP 等异步库的出现，PHP 已成为创建 WebSocket 服务器的得力工具。在 PHP 中使用 WebSocket 的主要优势包括：

即时数据传递——无需因重复 HTTP 请求而延误。
降低服务器负载——一个连接可替代数十次 Long Polling 请求。
易于集成——若项目已基于 PHP，则无需更换技术栈。

安装与配置 Ratchet 库

要在 PHP 中处理 WebSocket，我们将使用 Ratchet 库（与 ReactPHP 配合使用）。通过 Composer 安装：

composer require cboden/ratchet

安装完成后，创建一个基础 WebSocket 服务器类。在 Ratchet 中，服务器通过 MessageComponentInterface 接口实现，该接口包含四个方法：

onOpen——新客户端连接时调用。
onMessage——处理收到的消息。
onClose——客户端断开连接时触发。
onError——处理连接错误。

简易服务器示例：

<?phpuse Ratchet\\MessageComponentInterface;use Ratchet\\ConnectionInterface;

class ChatServer implements MessageComponentInterface {    protected $clients;

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

    public function onOpen(ConnectionInterface $conn) {        $this->clients->attach($conn);        echo "新连接: {$conn->resourceId}";    }

    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 "连接 {$conn->resourceId} 已关闭";    }

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

启动 WebSocket 服务器与客户端

创建 server.php 脚本以启动服务器：

<?phprequire __DIR__ . '/vendor/autoload.php';

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

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

echo "WebSocket 服务器已在端口 8080 启动";$server->run();

使用以下命令启动服务器：