在 ThinkPHP 面试中，WebSocket 实时通信是一个高频且区分度较高的考点。面试官不仅关注你是否用过 Swoole 或 Workerman，更在意你是否理解 HTTP 与 WebSocket 的本质差异、如何在 PHP 生态中落地实时通信，以及面对并发、断线重连、鉴权等问题时的解决思路。本文从面试实战角度出发，系统梳理 ThinkPHP 中 WebSocket 的实现方案与核心知识点。
一、为什么 ThinkPHP 需要 WebSocket
传统 PHP 基于 HTTP 的请求-响应模型，每个请求结束后连接即断开，服务器无法主动向客户端推送消息。轮询（Polling）和长轮询（Long Polling）虽然能模拟实时效果，但存在资源浪费、延迟高、并发差等问题。
WebSocket 通过一次 HTTP 握手升级协议，建立全双工长连接，服务端与客户端可随时互相发送数据。对于在线聊天、实时通知、协同编辑、行情推送等场景，WebSocket 是更优解。
面试中常被追问：ThinkPHP 本身能直接跑 WebSocket 吗？ 答案是：ThinkPHP 作为 MVC 框架，原生并不内置 WebSocket 服务。需要借助 Swoole、Workerman 等常驻内存的扩展或库来承载 WebSocket 服务，ThinkPHP 负责业务逻辑、ORM 和路由层。
二、主流实现方案对比
| 方案 | 特点 | 适用场景 |
|---|---|---|
| Workerman | 纯 PHP 实现，无需扩展，上手快 | 中小型项目、快速验证 |
| Swoole | C 扩展，性能强，协程支持好 | 高并发、生产环境 |
| GatewayWorker | 基于 Workerman，支持分布式 | 多机部署、长连接集群 |
| 第三方服务 | 如 Pusher、融云 | 不想自维护长连接 |
面试建议：优先答 Swoole + ThinkPHP，再补充 Workerman 作为轻量替代方案，体现技术选型能力。
三、基于 Swoole 的实现步骤
1. 环境准备
安装 Swoole 扩展（pecl install swoole），并引入 ThinkPHP 的 Swoole 适配包，例如 topthink/think-swoole。该包提供了将 ThinkPHP 应用运行在 Swoole 服务器上的能力，并支持 WebSocket 事件回调。
2. 配置 WebSocket 服务
在 config/swoole.php 中开启 WebSocket：
return [
'server' => [
'host' => '0.0.0.0',
'port' => 9502,
'mode' => SWOOLE_PROCESS,
'sock_type' => SWOOLE_SOCK_TCP,
],
'websocket' => [
'enable' => true,
'route' => false, // 是否走 ThinkPHP 路由
],
];
3. 编写事件处理逻辑
Swoole 提供 onOpen、onMessage、onClose 三个核心回调。在 ThinkPHP 中通常通过事件监听或自定义类处理：
// app/listener/WebSocketListener.php
class WebSocketListener
{
public function onOpen($server, $request)
{
// 连接建立，可做鉴权
$token = $request->get['token'] ?? '';
if (!$this->checkToken($token)) {
$server->close($request->fd);
return;
}
// 将 fd 与用户绑定，存入 Redis 或 Swoole Table
Redis::set("ws:user:{$userId}", $request->fd);
}
public function onMessage($server, $frame)
{
$data = json_decode($frame->data, true);
// 根据业务类型分发：聊天、心跳、订阅等
switch ($data['type']) {
case 'ping':
$server->push($frame->fd, json_encode(['type' => 'pong']));
break;
case 'chat':
$this->handleChat($server, $frame->fd, $data);
break;
}
}
public function onClose($server, $fd)
{
// 清理用户与 fd 的映射
Redis::del("ws:user:{$userId}");
}
}
4. 消息推送
服务端主动推送时，通过保存的 fd 调用 $server->push($fd, $message)。若需广播，可遍历所有连接或使用 Redis 发布订阅在多个 Worker 进程间同步。
四、面试高频追问与解答
1. WebSocket 握手阶段如何鉴权？
WebSocket 握手本质是一个 HTTP GET 请求，携带 Upgrade: websocket 头。可在握手 URL 的 query 参数中带上 token，或在 Cookie 中携带 Session。服务端在 onOpen 中校验 token，非法则立即关闭连接。注意：不要等到 onMessage 才鉴权，否则会浪费连接资源。
2. 多进程/多机部署时如何保证消息可达？
Swoole 多 Worker 进程间内存不共享，A 进程无法直接 push B 进程持有的 fd。解决方案：
- 使用 Redis 发布订阅，各进程订阅同一频道，收到消息后推送给本进程管理的连接；
- 使用 Swoole Table 存储 fd 映射，但跨机仍需 Redis 或消息队列；
- 采用 GatewayWorker 架构，Gateway 负责连接，BusinessWorker 负责逻辑，天然支持分布式。
3. 心跳机制为什么必要？
长连接可能因网络中断、NAT 超时、代理断开而“假死”。需要客户端定时发送 ping，服务端回复 pong，并设置 heartbeat_check_interval 与 heartbeat_idle_time，超时未收到心跳则主动关闭连接，释放资源。
4. 如何与 ThinkPHP 的 ORM、验证器结合？
在 onMessage 中可以直接调用 ThinkPHP 的模型和验证器，因为 Swoole 适配包已将框架启动并常驻内存。但要注意：常驻内存下不能使用 $_GET、$_POST 等超全局变量，应通过 $frame->data 或 $request 对象获取数据。同时要避免单例污染，必要时使用协程上下文隔离。
5. 断线重连怎么做？
前端使用 WebSocket 的 onclose 事件，配合指数退避算法重连（如 1s、2s、4s、8s）。重连后需重新鉴权并恢复订阅关系。服务端可记录用户最后状态，重连后推送离线消息。
五、实战注意事项
- 连接数限制：单机 fd 数量受
ulimit限制，需调整系统参数；Swoole 可支撑数万连接，但业务逻辑要避免阻塞。 - 内存泄漏：常驻内存下全局变量、静态变量不会自动释放，需手动清理。
- 安全：校验 Origin 防止跨站 WebSocket 劫持；对消息内容做过滤，防止 XSS。
- 日志与监控：记录连接数、消息量、异常断开，便于排查问题。
六、总结
ThinkPHP 实现 WebSocket 的核心在于：用 Swoole 或 Workerman 承载长连接服务，ThinkPHP 负责业务逻辑。面试中要能说清选型理由、鉴权时机、多进程通信方案和心跳机制。掌握这些，不仅能应对面试，也能在实际项目中构建稳定高效的实时通信系统。
未经允许不得转载：任鹏个人博客 » ThinkPHP 面试精讲：WebSocket 实时通信实现
