timer::add不能用于每个连接的独立心跳定时器,因其全局单例特性导致回调中引用的$connection可能已失效;应统一用单个定时器扫描所有连接,配合isconnected()检查和统一时间戳更新机制。

Timer::add 不能直接用于每个连接的独立心跳定时器
Workerman 的 Timer::add 是全局单例,回调中无法安全持有某个特定 $connection 对象——因为连接可能在定时器触发前已关闭,而回调仍会执行,导致 $connection->close() 报错或静默失败。这不是 bug,而是事件循环与对象生命周期不匹配的必然结果。
常见错误是这样写:
$connection->timerId = Timer::add(30, function() use ($connection) {
if (time() - $connection->lastMessageTime > 60) {
$connection->close();
}
});
问题在于:$connection 在闭包中被引用,但 Workerman 不保证该对象在定时器触发时仍有效;且大量连接 = 大量定时器 = 堆内存和调度开销线性增长。
- 定时器必须统一管理,不能 per-connection 创建
- 所有连接状态(如
lastMessageTime)必须可被遍历访问 - 清理逻辑必须加
if ($connection->isConnected())防止对已断连接操作
onMessage 第一行必须无条件更新 lastMessageTime
很多开发者只在成功解析 JSON 后才写 $connection->lastMessageTime = time(),结果客户端发的原始 ping 帧(空字符串或 {"type":"ping"})因 JSON decode 失败被 return,时间戳完全没更新,30 秒后就被误判离线。
正确做法是:不管 $data 是什么,只要进了 onMessage,第一行就重置时间戳。
-
$connection->lastMessageTime = time()必须是onMessage回调的第一句 - 匿名连接(未
bindUid())也必须初始化该字段,否则遍历时会触发 PHP Notice - 即使
$data === ''(标准 WebSocket Ping 帧),也要更新,再调用$connection->pong()
全局定时扫描频率要大于心跳间隔但小于 NAT 超时阈值
运营商 NAT、4G 基站、Nginx proxy_read_timeout 等中间设备超时普遍在 60–120 秒之间。服务端检测周期若设为 1 秒,CPU 白耗;若设为 120 秒,等发现时连接早被掐了。
推荐组合:
- 客户端心跳间隔 ≤45 秒(如 25s 或 30s)
- 服务端扫描周期设为 40–50 秒(即 1.5× 心跳间隔)
- 超时判定阈值设为 ≤90 秒(容忍一次心跳丢失)
- 农业传感器等低功耗设备可放宽至心跳 90s + 检查周期 120s + 阈值 150s
示例代码片段(放在 onWorkerStart 中):
Timer::add(45, function() use ($worker) {
$now = time();
foreach ($worker->connections as $conn) {
if (!$conn->isConnected()) continue;
$last = $conn->lastMessageTime ?? $now;
if ($now - $last > 90) {
$conn->close();
}
}
});
为什么不用最小堆或时间轮?Workerman 默认 Timer 就是堆,但你不需要自己实现
Workerman 底层 Timer 类确实基于最小堆,支持 O(log N) 插入和 O(1) 取最早任务。但你**不该也不需要**手动构造时间轮或替换底层结构——它已经足够支撑万级连接的心跳检查。
真正容易出问题的是业务层逻辑嵌入点:
- 没在
onConnect初始化lastMessageTime,导致新连接首次扫描就触发 close - 扫描定时器频率过高(如 1 秒),在高并发下引发 CPU 尖刺
- 忘记判断
$conn->isConnected(),对已关闭连接重复 close 报 warning - 把心跳响应写成异步任务或协程,导致
pong延迟,客户端提前断连
复杂点不在数据结构,而在每个数据入口是否都覆盖了时间戳更新——包括 onMessage、onWebSocketConnect(如有)、甚至自定义协议解析入口。漏掉任意一个,就会出现“连接明明发了 ping,服务端却说超时”的现象。











