如何用 TP8.0 做实时推送？Swoole WebSocket 与心跳检测机制【长连接】-ThinkPHP-PHP中文网

在thinkphp 8.0中启动swoole websocket服务需通过官方扩展think-swoole集成，而非直接new swoole\websocket\server；须安装swoole≥5.0扩展，配置server.php入口文件，启用heartbeat_idle_time与heartbeat_check_interval，并注册onopen/onmessage/onclose/onworkerstart事件，同时配合nginx反向代理正确设置upgrade和connection头以支持ws/wss协议。

如何用 tp8.0 做实时推送？swoole websocket 与心跳检测机制【长连接】

TP8.0 里怎么启动 Swoole WebSocket 服务？

ThinkPHP 8.0 本身不内置 WebSocket 服务，think-swoole 是官方推荐的扩展，但注意它默认只支持 HTTP/HTTP2，WebSocket 需手动集成 Swoole\WebSocket\Server。别直接在 app/command 下写裸 new Swoole\WebSocket\Server() —— 这样会绕过 TP 的容器和配置管理，后续没法注入日志、Db 等实例。

用命令行启动时，入口文件建议放在 server.php（根目录），而非 index.php
启动前确认已安装 swoole 扩展（php --ri swoole 查看版本，TP8 要求 Swoole ≥ 5.0）
set 中必须启用 heartbeat_idle_time 和 heartbeat_check_interval，否则心跳机制不会自动触发
不要复用 HTTP 的 Event 监听器，WebSocket 必须注册 onOpen、onMessage、onClose、onWorkerStart 四个事件

// server.php
$server = new Swoole\WebSocket\Server('0.0.0.0', 9502);
$server->set([
    'heartbeat_idle_time' => 60,
    'heartbeat_check_interval' => 25,
    'worker_num' => 4,
]);
$server->on('open', function ($server, $request) {
    echo "Client {$request->fd} connected\n";
});
// ... 其他事件
$server->start();

客户端连不上？常见连接失败原因

WebSocket connection to 'ws://...' failed 错误大多不是代码问题，而是环境或协议错配：

TP8 默认走 http://，但浏览器 WebSocket 要求 ws://（开发环境）或 wss://（生产），Nginx 反向代理必须加 Upgrade 和 Connection 头
Swoole 启动后检查端口是否被占用：lsof -i :9502 或 netstat -tuln | grep 9502
客户端 URL 写成 http:// 或漏掉端口（如 ws://127.0.0.1 而非 ws://127.0.0.1:9502）
如果用域名访问，确保 DNS 解析正确，且服务监听的是 0.0.0.0 而非 127.0.0.1

心跳包怎么发？自己实现还是靠 Swoole 自带？

Swoole 的 heartbeat_idle_time 和 heartbeat_check_interval 是服务端自动踢人机制，它不发心跳帧，只检测客户端是否超时未发 ping。真正的心跳交互（ping/pong）需客户端主动发 ping，服务端收到后自动回 pong —— 这是 WebSocket 协议原生支持的，无需手动处理。

WebSocket 8.18.2

WebSocket 8.18.2 是该协议规范的一个重要迭代版本，主要优化了连接稳定性与数据传输效率。它通过全双工通信机制，允许客户端与服务器在单一长连接上实时交换数据，大幅降低传统 HTTP 轮询的开销。该版本增强了心跳保活、自动重连及二进制帧传输能力，适用于即时通讯、在线游戏及金融行情推送等低延迟场景，为开发者提供更可靠的实时网络交互基础。

下载

客户端 JS 每 30s 发一次 ws.send(JSON.stringify({ type: 'ping' })) 是多余操作，反而增加负担
正确做法：JS 用原生 ws.ping()（部分浏览器不支持），更稳的是用定时器 + ws.send('\x89\x00')（二进制 ping 帧），但绝大多数场景直接依赖 Swoole 自动检测即可
若业务需要“应用层心跳”（比如上报在线状态），那才需要自定义 type: 'heartbeat' 消息，并在 onMessage 中解析处理

用户上线/下线怎么同步？FD 不稳定怎么办？

Swoole 的 $fd 是连接级唯一 ID，但它在进程重启、服务器 reload、客户端断线重连后会变。别拿 $fd 当用户标识存数据库或 Redis。

登录成功后，让客户端立刻发一条 { "type": "login", "token": "xxx" }，服务端校验 token 并绑定 $fd → user_id 到 Redis（key 用 user:{id}:fd）
onClose 里根据 $fd 反查 user_id，清理 Redis 中的映射，并广播下线事件
广播别用 $server->push($fd, $msg) 遍历所有连接，改用 $server->connections 迭代 + 排除自身，或用 Redis Pub/Sub 解耦（尤其多 Worker 时）