使用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 服务器。整个流程包括服务端监听连接、处理消息、广播消息，以及客户端通过浏览器 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 服务：
确保将 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=张三
4. 部署与注意事项
- 确保服务器防火墙开放 9502 端口。
- Swoole 服务需常驻运行，建议用 supervisor 管理进程。
- 生产环境建议配合 Nginx 反向代理，启用 WSS（WebSocket Secure）。
- 注意 fd 资源回收，避免内存泄漏。
- 大并发下可启用多进程和任务 worker 提升性能。
基本上就这些。Swoole 的高效 IO 处理能力非常适合实时聊天场景，只要理解连接管理与消息广播机制，就能快速实现稳定可用的 WebSocket 聊天系统。
