Swoole通过心跳机制实现连接保活，客户端定时发送“ping”心跳包，服务器记录连接最后活动时间并定期检查超时（如60秒未活动则关闭连接），结合TCP Keep-Alive可提升可靠性。
Swoole实现连接保活，核心在于利用心跳检测机制。客户端定期向服务器发送心跳包，服务器如果在一定时间内没有收到心跳，就认为连接已经断开，从而关闭连接，释放资源。
解决方案：
-
客户端心跳发送： 客户端需要设置一个定时器，定期（例如每30秒）向服务器发送一个特定的心跳包。这个心跳包可以是一个简单的字符串，比如 "ping"。
// 客户端代码示例 (假设使用TCP) $client = new Swoole\Client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC); $client->on("connect", function (Swoole\Client $cli) { echo "连接成功\n"; // 设置定时器，定期发送心跳 swoole_timer_tick(30000, function () use ($cli) { $cli->send("ping\n"); echo "发送心跳\n"; }); }); $client->on("receive", function (Swoole\Client $cli, string $data) { echo "收到: ".$data."\n"; }); $client->on("error", function (Swoole\Client $cli) { echo "连接失败\n"; }); $client->on("close", function (Swoole\Client $cli) { echo "连接关闭\n"; }); $client->connect('127.0.0.1', 9501, 0.5); -
服务器端心跳检测： 服务器端需要记录每个连接的最后活动时间。当收到客户端的心跳包时，更新该连接的最后活动时间。同时，服务器端也需要设置一个定时器，定期检查是否有连接超过设定的超时时间（例如60秒）没有活动，如果有，就关闭该连接。
// 服务器端代码示例 $server = new Swoole\Server("0.0.0.0", 9501); $server->on("connect", function (Swoole\Server $server, int $fd) { echo "连接： {$fd}\n"; // 初始化连接的最后活动时间 $server->connections[$fd] = time(); }); $server->on("receive", function (Swoole\Server $server, int $fd, int $from_id, string $data) { echo "收到 {$fd}: {$data}\n"; // 收到心跳包，更新最后活动时间 if (trim($data) == "ping") { $server->connections[$fd] = time(); $server->send($fd, "pong\n"); // 可选：回复pong } else { // 处理其他业务数据 } }); $server->on("close", function (Swoole\Server $server, int $fd) { echo "关闭： {$fd}\n"; unset($server->connections[$fd]); }); // 设置定时器，定期检查连接超时 $server->tick(10000, function ($timer_id) use ($server) { $now = time(); foreach ($server->connections as $fd => $lastActiveTime) { if ($now - $lastActiveTime > 60) { // 60秒超时 echo "连接 {$fd} 超时，关闭\n"; $server->close($fd); } } }); $server->start(); 数据结构选择： 在服务器端，可以使用一个数组来存储连接的最后活动时间，例如
$server->connections[$fd] = time();
。 其中$fd
是连接的文件描述符，time()
是当前时间戳。 这种方式简单直接，但当连接数非常大时，可能会占用较多内存。 可以考虑使用更高效的数据结构，比如 Redis 的 Hash 结构，将$fd
作为 key，time()
作为 value 存储。 这样做的好处是可以利用 Redis 的过期时间特性，简化超时检测的逻辑。
为什么需要连接保活机制？
在长时间连接的应用场景中，例如 IM、游戏等，客户端和服务器之间需要保持长连接。由于网络环境复杂，可能会出现各种原因导致连接中断，例如网络波动、客户端或服务器重启等。如果没有连接保活机制，客户端就无法及时感知连接断开，从而影响用户体验。此外，如果服务器不主动关闭长时间不活动的连接，可能会导致资源浪费，甚至出现连接耗尽的情况。
如何选择合适的心跳间隔和超时时间？
心跳间隔和超时时间的设置需要根据具体的应用场景进行权衡。心跳间隔太短，会增加服务器的负担；心跳间隔太长，可能无法及时发现连接断开。超时时间也需要根据实际情况进行调整。一般来说，超时时间应该大于心跳间隔的2-3倍。例如，如果心跳间隔设置为30秒，那么超时时间可以设置为60-90秒。
可以考虑根据网络状况动态调整心跳间隔。例如，客户端可以根据网络延迟和丢包率，自动调整心跳间隔。如果网络状况良好，可以适当延长心跳间隔；如果网络状况较差，则缩短心跳间隔。
除了心跳检测，还有哪些保活方式？
除了心跳检测，还可以使用 TCP Keep-Alive 机制。TCP Keep-Alive 是 TCP 协议自带的一种保活机制。开启 TCP Keep-Alive 后，TCP 协议栈会自动定期向对端发送探测报文，以检测连接是否存活。
Swoole 可以通过修改 Socket 选项来开启 TCP Keep-Alive。
$server = new Swoole\Server("0.0.0.0", 9501);
$server->set([
'open_tcp_keepalive' => 1, // 开启 TCP Keep-Alive
'tcp_keepidle' => 60, // 连接在空闲 60 秒后开始发送 keepalive
'tcp_keepinterval' => 30, // 探测的间隔时间为 30 秒
'tcp_keepcount' => 3, // 探测尝试的次数，如 3 次都没收到响应，则判定连接失效
]);
$server->on("connect", function (Swoole\Server $server, int $fd) {
echo "连接： {$fd}\n";
});
$server->on("receive", function (Swoole\Server $server, int $fd, int $from_id, string $data) {
echo "收到 {$fd}: {$data}\n";
});
$server->on("close", function (Swoole\Server $server, int $fd) {
echo "关闭： {$fd}\n";
});
$server->start();TCP Keep-Alive 的优点是实现简单，不需要应用程序自己发送心跳包。缺点是配置较为底层，不够灵活，无法自定义心跳内容和超时策略。因此，在实际应用中，通常会结合心跳检测和 TCP Keep-Alive 两种方式，以达到更好的保活效果。例如，可以使用心跳检测来发送应用层的心跳包，同时开启 TCP Keep-Alive 来检测连接的底层状态。
