Workerman Timer怎么做心跳检测

浅杰君_1000

浅杰君_1000

2026-09-09

805人浏览

原创

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

workerman timer怎么做心跳检测

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 秒,等发现时连接早被掐了。

凡科AI抠图
凡科AI抠图

一款简单易用的在线AI智能抠图工具,可自动识别图片主体并快速移除背景,适合处理日常图片素材。

下载

推荐组合:

  • 客户端心跳间隔 ≤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 延迟,客户端提前断连

复杂点不在数据结构,而在每个数据入口是否都覆盖了时间戳更新——包括 onMessageonWebSocketConnect(如有)、甚至自定义协议解析入口。漏掉任意一个,就会出现“连接明明发了 ping,服务端却说超时”的现象。

相关文章

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

workerman

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
Workerman安装配置教程
Workerman安装配置教程

Workerman安装配置教程专题提供Workerman安装配置、WebSocket开发、TCP通信、异步编程、高并发服务搭建与PHP实时通信开发教程。

2026.05.20

126

15

Workerman实时通信与长连接开发教程
Workerman实时通信与长连接开发教程

WWorkerman实时通信与长连接开发教程聚合实时通信、聊天室、长连接、消息推送、AI流式输出等Workerman高并发开发内容。

2026.05.20

162

12

Workerman异步通信与TCP服务器开发
Workerman异步通信与TCP服务器开发

Workerman异步通信与TCP服务器开发专题整理Workerman异步通信、TCP服务、HTTP服务、WebSocket开发与高并发PHP服务器教程。

2026.05.20

127

13

AI视频生成软件推荐
AI视频生成软件推荐

本专题汇总了当前主流的AI视频生成软件推荐与排行榜单,涵盖seko、AniShort、剧云、Lovart、LiblibAI及立刻mv等热门工具。同时整理了各软件在文生视频、图生视频、时长限制、画质表现及免费额度等方面的差异对比,助您快速选对适合创作需求的AI视频生成工具。

2026.09.16

140

9

ai生成视频的工具免费版合集
ai生成视频的工具免费版合集

本专题汇总了当前免费AI生成视频工具的排行榜与推荐清单,涵盖seko、讯飞智作、AniShort及剧云、Lovart等多模型集成平台。同时整理了各工具的免费额度、输出时长、水印政策及适用场景差异,助您快速选择合适工具开启AI视频创作。

2026.09.16

60

10

Pandas时间序列分析与可视化报表
Pandas时间序列分析与可视化报表

本专题整理Pandas日期转换、时间索引、重采样、滚动窗口、时区处理、plot绘图、Styler表格样式和报表输出方法。

2026.09.16

60

23

Pandas数据筛选索引与清洗处理
Pandas数据筛选索引与清洗处理

本专题整理Pandas中的loc、iloc、条件筛选、query查询、缺失值处理、重复值删除、类型转换和字符串列清洗方法。

2026.09.16

40

25

Pandas数据读取导入与文件导出处理
Pandas数据读取导入与文件导出处理

本专题整理Pandas读取CSV、Excel、JSON、SQL、Parquet等文件的方法,以及to_csv、to_excel、to_sql和to_parquet等常用数据导出流程。

2026.09.16

40

27

GDB怎么设置断点
GDB怎么设置断点

本专题介绍GDB按照函数名、源代码行号和文件位置设置断点的方法,详细说明run、continue、next、step等命令的配合使用,帮助定位程序崩溃、逻辑异常及代码未按预期执行的问题。

2026.09.11

360

28

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Webman中文手册
Webman中文手册

共0课时 | 0人学习

Workerman官方手册
Workerman官方手册

共0课时 | 0人学习

ThinkPHP5.1完全开发手册
ThinkPHP5.1完全开发手册

共0课时 | 0人学习