Python Socket与Subprocess通信长时间闲置后无响应问题求助

我之前在做类似B<->C架构的Socket通信时，也碰到过一模一样的问题——刚启动时通信顺畅，停几个小时再测就完全没响应。结合你提到的EOF问题，核心原因其实是客户端异常断开后，服务端没有正确清理资源，导致子进程卡住，后续新连接无法被正常处理。下面是我亲测有效的解决方法：

1. 第一时间检测EOF并清理资源 #

当客户端断开（不管是正常断开还是异常断连），conn.recv()会返回空字符串（也就是EOF）。这时候绝对不能再往子进程的stdin里写空内容，而是要立刻终止子进程、关闭Socket连接，释放所有相关资源：

import subprocess
import socket

def handle_client(conn):
    # 启动子进程（示例，根据你的实际业务调整）
    p = subprocess.Popen(["your_backend_service"], stdin=subprocess.PIPE, stdout=subprocess.PIPE, text=True)
    
    try:
        while True:
            data = conn.recv(1024).decode()
            if not data:  # 检测到EOF，客户端已断开
                print("客户端连接已断开，清理资源")
                # 终止子进程（如果还在运行）
                if p.poll() is None:
                    p.terminate()
                    p.wait()
                conn.close()
                break
            # 正常发送数据给子进程
            p.stdin.write(data)
            p.stdin.flush()
            # 读取子进程响应并返回给客户端
            response = p.stdout.readline()
            if response:
                conn.sendall(response.encode())
            else:
                # 子进程输出为空，可能已退出，直接断开
                conn.close()
                break
    except Exception as e:
        print(f"处理连接时出错: {e}")
        # 异常情况下也要确保资源被清理
        if p.poll() is None:
            p.terminate()
            p.wait()
        conn.close()

2. 给子进程IO加超时，避免永久阻塞 #

有时候子进程可能因为业务逻辑卡住，或者输出缓冲导致长时间无响应，这会连累整个Socket连接线程。用select模块给子进程的stdout监听加超时，就能避免这种情况：

import select

# 在读取子进程输出时替换成这段代码
ready, _, _ = select.select([p.stdout], [], [], 5)  # 设置5秒超时
if ready:
    response = p.stdout.readline()
    conn.sendall(response.encode())
else:
    # 超时处理：终止子进程，返回错误给客户端
    print("子进程处理超时")
    p.terminate()
    p.wait()
    conn.sendall(b"Error: Service timeout")
    conn.close()
    break

3. 开启TCP保活，主动检测死连接 #

默认情况下TCP不会主动检测死连接，导致服务端以为客户端还在线，一直占用资源。开启Socket的TCP保活机制，就能让系统主动发送心跳包检测连接状态：

server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 开启TCP保活
server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1)
# 以下参数以Linux为例，不同系统可能有差异
server_socket.setsockopt(socket.IPPROTO_TCP, socket.TCP_KEEPIDLE, 300)  # 5分钟无数据就发心跳包
server_socket.setsockopt(socket.IPPROTO_TCP, socket.TCP_KEEPINTVL, 60)  # 每隔60秒发一次
server_socket.setsockopt(socket.IPPROTO_TCP, socket.TCP_KEEPCNT, 3)     # 3次没回应就断开连接

server_socket.bind(("0.0.0.0", 8888))
server_socket.listen(5)

4. 避免子进程复用的坑 #

如果你是用同一个子进程处理多个连接，很容易因为前一个连接的EOF导致子进程的输入流异常。建议每个客户端连接对应一个独立的子进程，或者在复用子进程前，彻底清空输入输出缓冲，确保没有残留的EOF或无效数据。

调试小技巧 #

• 用netstat -anp | grep 8888（Linux）或netstat -ano | findstr 8888（Windows）查看连接状态，看看是不是有大量CLOSE_WAIT或TIME_WAIT的连接没释放。
• 在服务端关键节点加日志，比如连接建立、断开、数据收发、子进程状态变化，方便定位问题出在哪一步。

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