PHP中如何关闭半开（已断开）的TCP/IP Socket连接？

这个问题我之前也碰到过——客户端突然拔网线，没给服务端发FIN断开包，TCP连接就变成了半开状态，服务端还以为连接正常。在PHP里有几种靠谱的办法能检测并关闭这类死连接，我给你梳理下：

1. 开启TCP层保活机制（SO_KEEPALIVE） #

这是最省心的方案，利用TCP协议本身的保活功能，让操作系统自动检测死连接。PHP可以通过socket_set_option开启这个选项，还能自定义探测参数：

// 当接受新客户端连接后
$clientSocket = socket_accept($this->socket);

// 开启TCP保活
socket_set_option($clientSocket, SOL_SOCKET, SO_KEEPALIVE, 1);

// 自定义保活参数（仅Linux等类Unix系统支持，Windows可能无效）
// 10秒无数据后开始第一次探测
socket_set_option($clientSocket, SOL_TCP, TCP_KEEPIDLE, 10);
// 每次探测间隔5秒
socket_set_option($clientSocket, SOL_TCP, TCP_KEEPINTVL, 5);
// 连续3次探测失败就关闭连接
socket_set_option($clientSocket, SOL_TCP, TCP_KEEPCNT, 3);

开启后，系统会自动帮你检测死连接，一旦发现客户端失联，就会主动关闭socket，服务端后续操作就能感知到连接断开了。

2. 实现应用层心跳机制 #

如果需要更灵活的控制（比如自定义心跳逻辑、兼容不同系统），可以在应用层自己实现心跳包：

核心思路是：服务端定期给客户端发送心跳请求，客户端收到后回复心跳应答；如果服务端连续几次没收到应答，就主动关闭连接。

示例代码片段：

// 保存每个客户端的最后活跃时间
$clientLastActive = [];
// 心跳间隔（30秒发一次心跳）
$heartbeatInterval = 30;
// 最大超时时间（90秒没响应就关闭）
$maxTimeout = 90;

while (true) {
    // 用socket_select监听客户端socket的可读事件，超时1秒
    $readSockets = $this->clientSockets;
    socket_select($readSockets, $writeSockets, $exceptSockets, 1);

    foreach ($readSockets as $socket) {
        $data = trim(socket_read($socket, 1024));
        if ($data === false) {
            // 读取失败，直接关闭连接
            $this->closeClientSocket($socket);
            unset($clientLastActive[(int)$socket]);
            continue;
        }

        if ($data === 'HEARTBEAT') {
            // 收到心跳应答，更新活跃时间
            $clientLastActive[(int)$socket] = time();
            socket_write($socket, 'HEARTBEAT_ACK');
            continue;
        }

        // 处理业务数据...
        $clientLastActive[(int)$socket] = time();
    }

    // 检查所有客户端的活跃状态
    foreach ($this->clientSockets as $socket) {
        $lastActive = $clientLastActive[(int)$socket] ?? 0;
        $elapsed = time() - $lastActive;

        if ($elapsed > $maxTimeout) {
            // 超时未响应，关闭连接
            $this->closeClientSocket($socket);
            unset($clientLastActive[(int)$socket]);
        } elseif ($elapsed > $heartbeatInterval) {
            // 发送心跳请求
            @socket_write($socket, 'HEARTBEAT');
            // 如果write失败，说明连接已断，直接关闭
            if (socket_last_error($socket) !== 0) {
                $this->closeClientSocket($socket);
                unset($clientLastActive[(int)$socket]);
            }
        }
    }
}

这个方案的优势是完全可控，不管什么系统都能兼容，还能把心跳逻辑和业务逻辑结合起来。

3. 非阻塞模式+错误码检测 #

把客户端socket设置为非阻塞模式，在读写操作时通过错误码判断连接是否已断开：

// 接受新连接后设置为非阻塞
$clientSocket = socket_accept($this->socket);
socket_set_nonblock($clientSocket);

// 在循环处理中
foreach ($this->clientSockets as $socket) {
    // 用@屏蔽非阻塞下的无数据警告，或者用socket_last_error判断
    $data = @socket_read($socket, 1024);
    if ($data === false) {
        $errorCode = socket_last_error($socket);
        // 常见的连接断开错误码
        $disconnectErrors = [10054, 10053, 32, 110];
        if (in_array($errorCode, $disconnectErrors)) {
            // 10054=对方重置连接；10053=连接被中止；32=Broken pipe；110=连接超时
            $this->closeClientSocket($socket);
        }
        // 如果是EAGAIN(11)或者EWOULDBLOCK(10035)，说明只是暂时没数据，不用处理
        continue;
    }

    // 处理数据...
}

这种方法适合已经用非阻塞模式的服务端，能及时捕捉到连接断开的错误。

总结 #

• 如果追求简单，优先用TCP保活，系统层面自动处理；
• 如果需要灵活控制，推荐应用层心跳，兼容性和可控性更强；
• 非阻塞模式下可以配合错误码检测，作为补充手段。

内容的提问来源于stack exchange，提问作者rahul