Workerman 4.0.10 心跳保活机制实现

云婷姑娘_5730

云婷姑娘_5730

2026-08-10

1040人浏览

原创

必须同时配置应用层心跳协议与tcp层keep-alive;仅启用其一将导致60~300秒内出现半开连接。tcp keep-alive需在onconnect中调用socket_set_option显式开启并调优参数,应用层心跳则通过lastmessagetime+定时器或时间轮实现连接活性检测。

workerman 4.0.10 心跳保活机制实现

要在 Workerman 4.0.10 中真正让长连接不被 NAT 或防火墙静默断开,必须同时配置应用层心跳协议与 TCP 层 Keep-Alive,缺一不可;只做一边会导致连接在 60~300 秒内无预警失效,客户端发包成功但服务端收不到,形成“半开连接”。

启用 TCP 层 Keep-Alive(必须在 onConnect 中操作)

Workerman 4.0.10 默认完全不启用 TCP Keep-Alive,底层 socket 继承系统默认值(Linux 通常为 7200 秒),远超游戏或 IM 场景容忍阈值。

第一步:在 onConnect 回调中获取原始 socket 资源,调用 socket_set_option 显式开启并调优参数:

$connection->getSocket() → socket_set_option($socket, SOL_SOCKET, SO_KEEPALIVE, 1);

第二步:设置探测起始时间(TCP_KEEPIDLE)、重试间隔(TCP_KEEPINTVL)和失败次数(TCP_KEEPCNT)。Linux 下需使用 socket_set_optionSOL_TCP 域:

socket_set_option($socket, IPPROTO_TCP, TCP_KEEPIDLE, 45); // 首次探测前空闲 45 秒
socket_set_option($socket, IPPROTO_TCP, TCP_KEEPINTVL, 15); // 每隔 15 秒重探
socket_set_option($socket, IPPROTO_TCP, TCP_KEEPCNT, 3); // 连续 3 次无响应则断连

【必须在 onConnect 中执行,不能放在 onWorkerStart 或全局初始化里;否则 socket 资源未创建,会报 Warning: socket_set_option(): unable to set socket option

注意:Windows 不支持 TCP_KEEPIDLE/TCP_KEEPINTVL,仅能设 SO_KEEPALIVE 开关;若需跨平台兼容,建议封装判断逻辑。

实现应用层心跳协议(PING/PONG)

TCP Keep-Alive 只能穿透中间设备,无法感知业务层“假活”——比如客户端进程卡死但 TCP 连接仍 ESTABLISHED。此时必须靠应用层心跳识别真实活跃状态。

方法一:基于 Connection 自定义属性 + 全局定时器检测

onConnect 中为每个连接初始化最后通信时间戳:
$connection->lastMessageTime = time();

onMessage 中更新该时间戳:
$connection->lastMessageTime = time();

onWorkerStart 中启动全局检测定时器(例如每 55 秒执行一次):

小报童
小报童

小报童是一款内容运营工具,flomo 团队推出的付费内容服务平台。

下载
Timer::add(55, function () {<br>  foreach ($worker->connections as $connection) {<br>    if (time() - $connection->lastMessageTime > 60) {<br>      $connection->close();<br>    }<br>  }<br>});

方法二:为每个连接单独绑定超时定时器(更精准,但内存占用略高)

onConnect 后立即为该连接添加专属心跳检测定时任务:

$connection->heartbeat_timer_id = Timer::add(60, function () use ($connection) {<br>  if (time() - $connection->lastMessageTime > 60) {<br>    $connection->close();<br>  }<br>});

当连接关闭时(onClose),务必清除该定时器:

if (isset($connection->heartbeat_timer_id)) {<br>  Timer::del($connection->heartbeat_timer_id);<br>}

处理客户端心跳请求(服务端响应 PONG)

客户端发送 {"type":"ping"} 或原始字节 0x01 时,服务端必须回传对应 {"type":"pong"}0x02,否则客户端无法确认服务端存活。

onMessage 中加入判断逻辑:

if ($data === "\x01" || $data === '{"type":"ping"}') {<br>  $connection->send('{"type":"pong"}');<br>  $connection->lastMessageTime = time();<br>  return;<br>}

这一步必须放在消息解析之前,避免被业务逻辑拦截或丢弃;【如果客户端发 ping 但服务端没响应 pong,客户端超时后会主动断连,此时服务端连接对象仍存在但已失效】

无需额外记录 ping 时间戳——只要收到 ping 就说明连接活跃,直接刷新 lastMessageTime 即可。

避免定时器性能瓶颈(时间轮优化)

当连接数超过 1 万时,全局遍历所有连接的定时器(方法一)会产生明显 CPU 压力;最小堆定时器管理虽高效,但大量短周期任务会频繁触发堆重排。

推荐改用时间轮(Timing Wheel)结构替代默认最小堆:引入第三方扩展 workerman/timing-wheel 或自行实现单层时间轮,将超时检查从 O(N) 降为 O(1) 平摊复杂度。

初始化时间轮(精度 1 秒,总槽位 3600):

$wheel = new TimingWheel(3600, 1);<br>$wheel->start();

为每个连接注册超时任务:

$wheel->add($connection->id, 60, function () use ($connection) {<br>  if (time() - $connection->lastMessageTime > 60) {<br>    $connection->close();<br>  }<br>});

连接关闭时移除任务:
$wheel->remove($connection->id);

相关文章

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

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

下载

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

相关专题

更多
php文件怎么打开
php文件怎么打开

打开php文件步骤:1、选择文本编辑器;2、在选择的文本编辑器中,创建一个新的文件,并将其保存为.php文件;3、在创建的PHP文件中,编写PHP代码;4、要在本地计算机上运行PHP文件,需要设置一个服务器环境;5、安装服务器环境后,需要将PHP文件放入服务器目录中;6、一旦将PHP文件放入服务器目录中,就可以通过浏览器来运行它。

2023.09.01

8884

6

php怎么取出数组的前几个元素
php怎么取出数组的前几个元素

取出php数组的前几个元素的方法有使用array_slice()函数、使用array_splice()函数、使用循环遍历、使用array_slice()函数和array_values()函数等。本专题为大家提供php数组相关的文章、下载、课程内容,供大家免费下载体验。

2023.10.11

5421

5

php反序列化失败怎么办
php反序列化失败怎么办

php反序列化失败的解决办法检查序列化数据。检查类定义、检查错误日志、更新PHP版本和应用安全措施等。本专题为大家提供php反序列化相关的文章、下载、课程内容,供大家免费下载体验。

2023.10.11

1995

5

php怎么连接mssql数据库
php怎么连接mssql数据库

连接方法:1、通过mssql_系列函数;2、通过sqlsrv_系列函数;3、通过odbc方式连接;4、通过PDO方式;5、通过COM方式连接。想了解php怎么连接mssql数据库的详细内容,可以访问下面的文章。

2023.10.23

3348

4

php连接mssql数据库的方法
php连接mssql数据库的方法

php连接mssql数据库的方法有使用PHP的MSSQL扩展、使用PDO等。想了解更多php连接mssql数据库相关内容,可以阅读本专题下面的文章。

2023.10.23

4014

6

html怎么上传
html怎么上传

html通过使用HTML表单、JavaScript和PHP上传。更多关于html的问题详细请看本专题下面的文章。php中文网欢迎大家前来学习。

2023.11.03

3151

9

PHP出现乱码怎么解决
PHP出现乱码怎么解决

PHP出现乱码可以通过修改PHP文件头部的字符编码设置、检查PHP文件的编码格式、检查数据库连接设置和检查HTML页面的字符编码设置来解决。更多关于php乱码的问题详情请看本专题下面的文章。php中文网欢迎大家前来学习。

2023.11.09

4457

8

php文件怎么在手机上打开
php文件怎么在手机上打开

php文件在手机上打开需要在手机上搭建一个能够运行php的服务器环境,并将php文件上传到服务器上。再在手机上的浏览器中输入服务器的IP地址或域名,加上php文件的路径,即可打开php文件并查看其内容。更多关于php相关问题,详情请看本专题下面的文章。php中文网欢迎大家前来学习。

2023.11.13

3482

8

sprintf函数用法详解
sprintf函数用法详解

sprintf函数的用法:1、格式化字符串;2、指定输出宽度和精度;3、返回值。更多关于sprintf函数用法详解的内容,大家可以阅读下面的文章。

2023.11.27

11542

4

热门下载

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

精品课程

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

共0课时 | 0人学习

Workerman官方手册
Workerman官方手册

共0课时 | 0人学习

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

共0课时 | 0人学习