使用Webman + WebSocket实现实时在线聊天室-php教程-PHP中文网

websocket连接建立后立刻断开，根本原因是http与ws端口未分离：webman默认仅启http服务，websocket必须由独立端口（如7272）承载，不可复用http端口；直接修改config/server.php中type为websocket会导致http路由失效且ws://无法连接。

使用webman + websocket实现实时在线聊天室

WebSocket连接建立后立刻断开？检查Webman的HTTP和WS端口是否分离

Webman默认只启动HTTP服务，websocket协议必须由独立的WebSocket服务器承载，不能复用HTTP端口。常见错误是直接在config/server.php里把type改成websocket——这会导致HTTP路由失效，且客户端用ws://连不上。

正确做法是启用双端口：HTTP端口（如8080）处理静态资源和登录页，WebSocket端口（如7272）专供ws://连接。需在config/server.php中添加第二个server配置：

[
    'name' => 'websocket',
    'type' => 'websocket',
    'host' => '0.0.0.0',
    'port' => 7272,
    'sock_type' => SWOOLE_SOCK_TCP,
    'ssl' => false,
]

注意：type必须为websocket，不是http；若启用HTTPS，ssl设为true，且需配ssl_cert_file和ssl_key_file。

onMessage里发消息给所有人？别直接遍历$connections

Webman的WebSocket\Connection对象不支持直接foreach($this->connections)，因为底层使用Swoole协程，连接池是跨进程隔离的。硬遍历只会拿到当前Worker进程里的连接，导致“部分人收不到消息”。

必须通过Webman\WebSocket\Server提供的广播方法：

$server->broadcast($data)：向所有在线连接广播（自动跨Worker）
$server->to($fd)->send($data)：向指定fd发送（fd来自$connection->getFd()）
$server->to($group)->send($data)：需先调用$server->join($fd, $group)加入分组

示例：用户发消息时带上昵称和时间，广播给所有人：

public function onMessage($connection, $data)
{
    $msg = json_decode($data, true);
    $broadcastData = [
        'type' => 'chat',
        'nickname' => $msg['nickname'] ?? '匿名',
        'content' => htmlspecialchars($msg['content']),
        'time' => date('H:i')
    ];
    $this->server->broadcast(json_encode($broadcastData, JSON_UNESCAPED_UNICODE));
}

用户离线状态不准？主动close()比等待超时更可靠

浏览器标签页关闭、网络中断等场景下，onClose不一定立即触发——Swoole默认等待60秒才判定连接断开。这会导致onClose里清理用户状态延迟，出现“人已走但头像还亮着”的问题。

WebSocket 8.18.2

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

下载

应在前端监听beforeunload或pagehide，主动发送离线包：

window.addEventListener('beforeunload', () => {
    if (ws && ws.readyState === WebSocket.OPEN) {
        ws.send(JSON.stringify({type: 'logout'}));
        ws.close();
    }
});

后端onMessage中识别该类型并立即清理：

if ($msg['type'] === 'logout') {
    // 从session或redis中移除该fd对应用户
    $this->server->disconnect($connection->getFd());
    return;
}

同时建议在onClose里做兜底清理，但不依赖它作为唯一离线依据。

上线人数突增就卡顿？避免在onOpen/onClose里查数据库

每有1个用户连接/断开，onOpen和onClose都会执行。如果在里面调用MySQL查询或RedisHGETALL，高并发时会阻塞整个Worker进程，造成连接堆积甚至雪崩。

优化方向：

用户信息尽量存在内存（如$_SESSION或static::$userCache），首次登录时存，后续复用
在线人数统计改用Redis原子操作：INCR online_count / DECR online_count
如需持久化用户状态，改用协程MySQL客户端（co\MySQL）或投递到TaskWorker异步处理

特别注意：Webman的onOpen是同步上下文，不能await协程，强行go()也不推荐——优先精简逻辑，而非加协程。

真实压测中，未优化的onOpen查一次DB会让QPS从3000+掉到不足500；去掉DB调用后，单Worker轻松支撑5000+并发连接。