如何用PHP实现支持多客户端同步通信的WebSocket服务器

一、纯PHP WebSocket的阻塞问题解决 #

你担心的WebSocketServer::run()循环阻塞是纯PHP单进程同步脚本的通病，可通过以下两种方式解决：

1. 非阻塞IO改造 #

用PHPsocket_select()实现非阻塞监听，避免死循环持续占用资源，仅在有连接事件（新连接、消息）时才处理逻辑：

$mainSocket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_bind($mainSocket, '0.0.0.0', 8080);
socket_listen($mainSocket);
$clients = [$mainSocket];

while (true) {
    $readSockets = $clients;
    // 非阻塞监听，超时设为0避免进程阻塞
    socket_select($readSockets, $writeSockets, $exceptSockets, 0);
    
    foreach ($readSockets as $sock) {
        // 处理新客户端连接
        if ($sock === $mainSocket) {
            $newClient = socket_accept($mainSocket);
            $clients[] = $newClient;
            // 需自行实现WebSocket协议握手逻辑
            handleWebSocketHandshake($newClient);
        } else {
            // 接收客户端消息
            $data = socket_read($sock, 4096);
            if ($data) {
                // 分发消息给所有其他在线客户端
                foreach ($clients as $client) {
                    if ($client !== $mainSocket && $client !== $sock) {
                        socket_write($client, encodeWebSocketFrame($data));
                    }
                }
            } else {
                // 客户端断开连接，清理资源
                $index = array_search($sock, $clients);
                unset($clients[$index]);
                socket_close($sock);
            }
        }
    }
}

注：纯PHP实现需要自行处理WebSocket握手、帧编码/解码逻辑，可参考WebSocket协议规范或复用现有库的核心代码。

2. 独立进程+中间件解耦 #

将WebSocket服务作为独立CLI进程运行，与你的Web项目（Apache/Nginx托管的PHP）完全分离：

• Web项目处理用户请求、修改数据库后，通过Redis、消息队列（如RabbitMQ）向WebSocket进程发送变更通知
• WebSocket进程独立监听中间件的通知，收到后立即推送给所有连接的客户端

这种方式下，WebSocket进程的循环不会影响Web请求，两者通过中间件通信，实现完全解耦。

二、用框架快速实现（推荐） #

纯PHP实现需要处理大量底层细节，使用成熟框架能大幅降低开发成本：

1. Workerman/Swoole（高性能异步框架） #

这两个是PHP生态中主流的异步框架，原生支持WebSocket，且天生非阻塞，性能远超纯PHP实现。以Workerman为例：

use Workerman\Worker;
require __DIR__ . '/vendor/autoload.php';

// 启动WebSocket服务
$wsWorker = new Worker('websocket://0.0.0.0:8080');
$wsWorker->count = 4; // 启动多进程提升并发能力

// 监听Redis订阅的数据库变更频道
$wsWorker->onWorkerStart = function($worker) {
    $redis = new Redis();
    $redis->connect('127.0.0.1', 6379);
    $redis->subscribe(['db_update'], function($redis, $chan, $msg) use ($worker) {
        // 推送给所有在线客户端
        foreach ($worker->connections as $conn) {
            $conn->send($msg);
        }
    });
};

// 处理客户端消息（支持双向通信场景）
$wsWorker->onMessage = function($conn, $data) use ($wsWorker) {
    foreach ($wsWorker->connections as $client) {
        $client->send($data);
    }
};

Worker::runAll();

你的Web项目在修改数据库后，只需往Redis的db_update频道发布一条消息，WebSocket进程就会自动完成推送。

2. Laravel + Laravel WebSockets #

如果你的项目基于Laravel框架，可直接使用Laravel WebSockets包：

• 在数据库模型的saved/updated事件中触发广播
• 前端用Laravel Echo连接WebSocket接收广播消息
• WebSocket服务独立运行，不会阻塞常规Web请求

三、核心原则：解耦实时推送与Web请求 #

无论采用哪种方案，核心思路都是将Web请求处理和实时推送服务分离：

1. Web层：处理用户请求、修改数据库，完成后向中间件（Redis/消息队列）发送变更通知
2. 推送层：独立进程监听中间件，收到通知后推送给所有客户端

这种架构既避免了阻塞问题，也让系统逻辑更清晰，便于后续维护。

四、轻量替代：Server-Sent Events（SSE） #

如果你的需求仅为服务器单向推送（不需要客户端向服务器发送消息），SSE是更轻量的选择：

• 后端通过PHP输出流持续发送数据
• 前端用EventSourceAPI接收消息
• 无需处理复杂的WebSocket协议，基于纯HTTP实现

但SSE不支持双向通信，仅适合服务器主动通知客户端的场景。

内容的提问来源于stack exchange，提问作者Abet Giron