PHP使用Swoole实现WebSocket 实时在线人数统计教程【实战】-js教程-PHP中文网

$server->connections不能直接当在线人数用，因其仅存各worker独立的活跃fd，存在进程间不共享、断连未触发onclose、多标签/设备重复计数等问题；须结合redis set去重统计真实用户数。

php使用swoole实现websocket 实时在线人数统计教程【实战】

WebSocket 连接数不等于在线人数，直接用 $server->connections 计数会漏掉断连未清理、心跳超时未踢出、多进程共享状态缺失等问题。

为什么 `$server->connections` 不能直接当在线人数用

这个数组只存当前活跃的连接 fd，但 Swoole 的 Worker 进程间不共享内存，$server->connections 在每个 Worker 内是独立副本；而且客户端静默断网、浏览器关闭标签页、网络闪断等场景下，onClose 不一定触发，fd 会残留。更关键的是：一个用户开多个标签页或设备登录，会对应多个 fd，但业务上通常算作“1 人”。

Worker 进程间无法通过 $server->connections 汇总全局连接数
未设置 heartbeat_idle_time 和 heartbeat_check_interval 时，死连接长期滞留
没有绑定用户 ID 到 fd 的映射，无法去重统计真实用户数

用 Redis + fd → uid 映射做去重计数

在 onOpen 阶段完成用户身份校验（如解析 token），把 uid 与当前 $fd 关联写入 Redis Set；onClose 或心跳超时时，从 Set 中移除该 uid 对应的 fd 记录。最终在线人数 = SCARD online_users:{room_id}（按房间隔离）或 SCARD online_users:global（全局）。

示例关键逻辑：

btpanel phpsite 宝塔面板PHP网站

宝塔面板 PHP 网站管理：站点创建、删除、启停、PHP 版本切换、域名管理、SSL证书管理、伪静态管理、数据库管理

下载

// onOpen 中
$uid = $this->verifyToken($request->get['token'] ?? '');
if ($uid) {
    $key = 'online_users:global';
    $redis->sAdd($key, $uid);
    $redis->expire($key, 86400); // 防误存
}
<p>// onClose 中
$uid = $this->getUidByFd($fd); // 从本地缓存或 Redis Hash 查
if ($uid) {
$redis->sRem('online_users:global', $uid);
}</p>

必须用 SET 而非 LIST 或 HASH，天然去重
不要在 onClose 里查数据库，Redis SREM 是 O(1)，毫秒级
建议加一层本地 static $fdToUid = [] 缓存，避免每次 onMessage 都查 Redis

如何让心跳检测真正生效并触发清理

Swoole 默认不自动踢死连接，必须显式配置并配合 onHeartbeat（Swoole ≥ 4.5.0）或手动 tick 定时扫描。否则即使设置了 heartbeat_idle_time=60，也不会自动 close fd。

启用心跳：在 Server::set() 中加入 'heartbeat_idle_time' => 60, 'heartbeat_check_interval' => 10
必须监听 onHeartbeat 事件，在里面调用 $server->close($fd) 才算真正断开
若用旧版 Swoole（tick + $server->connection_info($fd) 检查 last_time
前端需每 heartbeat_idle_time * 0.8 秒发一次 ping，否则服务端认为失联

并发增长时 Redis 成为瓶颈？加本地计数兜底

高频进/出场景下，Redis 的 SADD/SREM 会成为性能拐点。可采用“本地 + Redis 双写 + 定期对账”策略：每个 Worker 维护一个 static $localCount = 0，onOpen 时 ++$localCount，onClose 时 --$localCount，再异步（如每 5 秒）将差值同步到 Redis。

注意点：