PHP使用Swoole与WebSocket实现弹幕系统的完整指南

月亮慢半拍

发布时间：2026-10-14| 5人浏览过

原创

本文介绍了利用PHP的Swoole扩展结合WebSocket技术实现实时弹幕系统的完整方案。文章详细讲解了从环境准备、服务器端代码编写（包括连接管理与消息广播），到前端客户端实现及性能优化技巧，帮助开发者构建高并发、低延迟的实时通讯应用。

准备工作

构建基于Swoole的WebSocket服务前，需确保运行环境已正确安装Swoole扩展。若尚未安装，可通过pecl命令进行安装：

pecl install swoole

安装完成后，建议重启Web服务器或确保PHP CLI环境识别该扩展，即可开始编码。

启动WebSocket服务器

Swoole提供了直观的API来创建WebSocket服务器。以下代码演示了如何初始化服务器并监听指定端口，同时处理基本的生命周期事件：

// 创建WebSocket服务器对象，监听0.0.0.0:9501端口
$server = new Swoole\WebSocket\Server("0.0.0.0", 9501);

// 监听WebSocket连接打开事件
$server->on('open', function (Swoole\WebSocket\Server $server, $request) {
    echo "connection open: {$request->fd}\n";
});

// 监听WebSocket消息事件
$server->on('message', function (Swoole\WebSocket\Server $server, $frame) {
    echo "received message: {$frame->data}\n";

    // 广播消息给所有客户端
    foreach ($server->connections as $fd) {
        $server->push($fd, $frame->data);
    }
});

// 监听WebSocket连接关闭事件
$server->on('close', function ($ser, $fd) {
    echo "connection close: {$fd}\n";
});

// 启动服务器
$server->start();

关键优化与注意事项

异步非阻塞设计

Swoole的核心优势在于其协程驱动的异步非阻塞模型。在处理on('message')回调时，严禁执行数据库查询、文件I/O等阻塞操作。应充分利用Swoole提供的异步组件（如Async MySQL、Redis等）以保持服务器的高吞吐量。

智能消息广播

基础广播遍历所有连接效率较低且易向发送者重复推送数据。推荐使用Task异步任务队列处理消息分发，或在内存中维护在线用户列表以提升性能：

// 示例：使用Task异步推送
$server->task(['fd' => $fd, 'message' => $frame->data]);

精确的客户端标识管理

为优化广播逻辑并避免自发自收，建议在on('open')阶段记录文件描述符（fd）：

$clientIds = [];

$server->on('open', function (Swoole\WebSocket\Server $server, $request) use (&$clientIds) {
    echo "connection open: {$request->fd}\n";
    $clientIds[] = $request->fd;
});

$server->on('message', function (Swoole\WebSocket\Server $server, $frame) use ($clientIds) {
    // 排除发送者自身进行广播
    foreach ($clientIds as $fd) {
        if ($fd != $frame->fd) {
            $server->push($fd, $frame->data);
        }
    }
});

断连状态清理

连接断开时务必同步清理注册表，防止无效连接干扰后续的消息推送：

$server->on('close', function ($ser, $fd) use (&$clientIds) {
    echo "connection close: {$fd}\n";
    $index = array_search($fd, $clientIds);
    if ($index !== false) {
        unset($clientIds[$index]);
    }
});

前端客户端实现

前端页面可使用原生JavaScript WebSocket API与Swoole服务器对接。以下是包含输入框与消息展示容器的基础HTML结构及JS逻辑：

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <title>WebSocket弹幕</title>
</head>
<body>
    <input type="text" id="messageInput" placeholder="输入弹幕消息">
    <button onclick="sendMessage()">发送</button>
    <div id="danmuContainer" style="border: 1px solid #ccc; height: 300px; overflow-y: auto;"></div>

    <script>
        const ws = new WebSocket("ws://your_server_ip:9501");

        ws.onopen = function(event) {
            console.log("连接成功");
        };

        ws.onmessage = function(event) {
            const danmuContainer = document.getElementById("danmuContainer");
            const node = document.createElement("div");
            node.textContent = event.data;
            danmuContainer.appendChild(node);
        };

        ws.onclose = function(event) {
            console.log("连接关闭");
        };

        function sendMessage() {
            const input = document.getElementById("messageInput");
            if(ws.readyState === WebSocket.OPEN) {
                ws.send(input.value);
                input.value = "";
            }
        }
    </script>
</body>
</html>