Swoole怎么实现WebSocket实时聊天-Swoole-PHP中文网

Swoole怎么实现WebSocket实时聊天

尼克

发布： 2025-10-13 09:15:01

原创

134人浏览过

使用Swoole实现WebSocket实时聊天，核心是利用其异步常驻内存特性构建高性能服务器。1. 创建Swoole\WebSocket\Server实例监听9502端口，通过on('open')、on('message')、on('close')回调处理连接、消息接收与断开；在message事件中遍历$server->connections调用push()向所有客户端广播消息。2. 前端使用原生WebSocket API连接ws://your-server-ip:9502，通过onopen、onmessage、onclose监听状态，并用send()发送数据，实现双向通信。3. 为支持用户标识，在open事件中解析请求参数（如user_id），将fd与用户名关联存储于$clients数组，广播时显示来源用户。4. 部署时需开放防火墙端口，使用supervisor守护进程，生产环境建议Nginx反代并启用WSS，注意fd回收与内存管理，可结合多进程提升并发能力。Swoole凭借高效IO性能，配合连接管理与广播机制，可快速搭建稳定实时聊天系统。

swoole怎么实现websocket实时聊天

使用 Swoole 实现 WebSocket 实时聊天，核心在于利用 Swoole 的异步、常驻内存特性搭建一个高性能的 WebSocket 服务器。整个流程包括服务端监听连接、处理消息、广播消息，以及客户端通过浏览器 WebSocket API 进行通信。

1. 搭建 Swoole WebSocket 服务器

Swoole 提供了 WebSocket\Server 类，可以直接创建 WebSocket 服务。以下是一个基础的服务端实现：

$server = new Swoole\WebSocket\Server("0.0.0.0", 9502);

$server->on('open', function ($server, $req) {
    echo "客户端 {$req->fd} 已连接\n";
});

$server->on('message', function ($server, $frame) {
    echo "收到消息: {$frame->data} 来自客户端 {$frame->fd}\n";

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

$server->on('close', function ($server, $fd) {
    echo "客户端 {$fd} 已断开\n";
});

$server->start();

登录后复制

说明：

监听 9502 端口，允许外部访问。
open 回调：客户端连接成功触发。
message 回调：收到客户端消息时执行。
close 回调：客户端断开连接时触发。
push() 方法向指定客户端发送数据。

2. 客户端 HTML + JavaScript 连接

前端使用原生 WebSocket API 连接 Swoole 服务：

ViiTor实时翻译

AI实时多语言翻译专家！强大的语音识别、AR翻译功能。

116

查看详情

<script>
const ws = new WebSocket("ws://your-server-ip:9502");

ws.onopen = () => {
    console.log("已连接到聊天服务器");
};

ws.onmessage = (event) => {
    const div = document.createElement("div");
    div.textContent = event.data;
    document.getElementById("chat").appendChild(div);
};

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

// 发送消息
function send() {
    const input = document.getElementById("msg");
    ws.send(input.value);
    input.value = "";
}
</script>

<div id="chat"></div>
<input type="text" id="msg" />
<button onclick="send()">发送</button>

登录后复制

确保将 your-server-ip 替换为实际服务器 IP 或域名。

3. 改进：用户标识与房间功能

真实场景中需要识别用户并支持多房间聊天。可以在连接时传递参数（如 token 或用户名），并通过 fd 关联信息：

$clients = [];

$server->on('open', function ($server, $req) use (&$clients) {
    $userId = $req->get['user_id'] ?? '匿名';
    $clients[$req->fd] = $userId;
    echo "用户 {$userId} ({$req->fd}) 加入\n";
});

$server->on('message', function ($server, $frame) use (&$clients) {
    $user = $clients[$frame->fd] ?? '未知用户';
    $msg = $frame->data;

    foreach ($server->connections as $fd) {
        if ($server->isEstablished($fd)) {
            $server->push($fd, "[{$user}]: {$msg}");
        }
    }
});

登录后复制

客户端连接时可传参：
ws://your-ip:9502?user_id=张三