要用workerman构建php实时多人在线游戏服务端,需基于websocket协议(wss)搭建长连接骨架,实现16ms帧同步调度、按房间/视野精准广播,并通过心跳保活与简易ack机制保障传输可靠性。

要让PHP支撑起实时多人在线游戏的底层通信,必须绕过传统HTTP请求-响应模型的瓶颈,用Workerman构建长连接、低延迟、可水平扩展的服务端骨架——这不是改几行配置就能跑起来的事,得从协议选型、帧同步节奏、广播过滤逻辑到心跳保活层层落地。
选择合适的通信协议与传输层
WebSocket是浏览器端唯一可行的实时通道,直接决定客户端接入成本。TCP适合Unity3D或原生App等非浏览器客户端,UDP则仅用于对丢包不敏感的辅助数据(如环境音效触发)。【WebSocket协议必须启用SSL(wss://)才能在现代浏览器中稳定运行,http://localhost:8080/ws 这类地址在Chrome 120+会直接被拦截】
创建Worker实例时明确指定协议和端口:
$ws_worker = new Worker('websocket://0.0.0.0:8080');
若需支持HTTPS/WSS,不能只改URL协议头,必须在Web服务器(Nginx/Apache)反向代理层配置证书并透传Upgrade头,Workerman本身不处理TLS握手。
搭建帧同步最小可行循环
帧同步不是Workerman内置功能,而是靠你亲手搭一个16ms精度的调度器。所有玩家输入、状态演算、广播打包必须严格卡在同一个时间切片里执行,否则客户端看到的动作会像卡顿录像。
第一步:在start.php顶部引入Timer类
use Workerman\Timer;
第二步:定义全局帧计数器与输入队列
$frame_id = 0; $clientInput = [];
第三步:启动16ms定时器,统一驱动模拟逻辑
Timer::add(0.016, function() use (&$frame_id, &$clientInput) { $frame_id++; // 采集本帧所有已到达的输入 $state = []; foreach ($clientInput as $cid => $input) { // 执行移动/跳跃/攻击等逻辑,生成该玩家本帧状态 $state[$cid] = computePlayerState($cid, $input); } // 广播带帧号的状态包 $broadcast_data = json_encode(['frame' => $frame_id, 'state' => $state]); Gateway::sendToAll($broadcast_data); // 清空本帧输入队列 $clientInput = []; });
注意:computePlayerState()函数内严禁调用sleep()、file_get_contents()、PDO::query()等阻塞操作,否则整个帧周期被拖垮,后续帧堆积导致雪崩式延迟。
实现精准广播而非全量推送
一万人同时在线,不代表每次技能释放都要推送给所有人。广播必须按房间、视野、阵营做过滤,否则带宽和CPU瞬间飙红。
方法一:基于预设room属性过滤(推荐)
在onConnect回调中为每个连接绑定房间ID:$connection->room = 'arena_101';
广播时直接比对:foreach ($worker->connections as $conn) { if (isset($conn->room) && $conn->room === 'arena_101') { $conn->send($data); } }
方法二:查静态房间表(万级连接时更优)
维护一个static数组:static $rooms = ['arena_101' => [1001, 1002, 1005]]; // 房间ID => 在线连接ID数组
广播前先取目标房间连接列表,再逐个send,避免遍历全部连接。
【遍历$worker->connections时绝对不要unset()或$conn->close(),这会破坏引用结构,引发Connection is closed异常】
解决send()调用后客户端收不到的问题
Workerman的send()返回true只代表数据成功写入内核socket缓冲区,不代表对方已接收。网络抖动、手机休眠、TCP粘包都可能导致数据滞留。
加心跳保活:每30秒向所有连接发ping
Timer::add(30, function() { foreach ($worker->connections as $conn) { $conn->send('{"ping":1}'); } });
客户端收到后必须立即回{"pong":1},服务端onMessage里检测超时未回的连接主动close。
对关键帧做简易ACK:技能释放帧发出后,记录$pendingAcks[$clientId][$frameId] = time();客户端收到后回{"ack":128};服务端检查3秒未ack则重发该帧。











