python socket 服务在 docker 网络中无法及时感知客户端 abrupt disconnect（如 `docker kill`），源于 tcp 连接状态的延迟探测机制；通过引入双向心跳确认（client 回复 + server 主动 recv 检查），可跨环境（本地、docker、k8s）统一、实时检测连接失效。
在本地回环（localhost）环境下，当客户端被强制终止（如 Ctrl+C 或 kill -9），内核通常能快速触发 RST 包或关闭 FIN 流程，导致服务端下次调用 sendall() 时立即抛出 BrokenPipeError 或 ConnectionResetError。但在 Docker 用户定义网络（如 bridge 网络）中，由于网络栈中间层（如 docker-proxy、iptables 规则、容器网络命名空间隔离）及 TCP 的“静默失败”特性（即对端无声消失时，发送方不会立刻得知），服务端可能长时间处于 ESTABLISHED 状态，sendall() 成功返回（数据暂存于内核发送缓冲区），而 recv() 也因无数据不阻塞——从而造成“连接仍存活”的假象。
根本原因在于：TCP 是面向连接的可靠协议，但“可靠性”仅保证已确认数据的送达，并不主动探测对端存活状态。操作系统默认不启用保活（keepalive），且 Docker 网络可能进一步延迟 RST 传递或丢弃异常包。
✅ 正确解法：服务端必须主动探测连接有效性，而非被动等待错误。最轻量、普适的方式是引入应用层心跳确认机制：
- 客户端每次成功接收数据后，向服务端发送一个简短确认（如 b"ok"）；
- 服务端在每次发送后，调用 recv() 等待该确认，并设置合理超时（推荐显式 settimeout()）；
- 若 recv() 返回空字节（b""），说明对端已关闭连接（FIN）；
- 若 recv() 抛出 socket.timeout 或 ConnectionResetError，说明连接异常中断；
- 若长期无响应，可主动断连，避免资源泄漏。
以下是改进后的健壮实现（含超时防护，适用于 Docker/K8s/本地）：
import socket
import time
def main():
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
server_socket.bind(("0.0.0.0", 12345))
server_socket.listen(1)
print('Server bound and listening.')
try:
print('Waiting for a connection...')
connection, client_address = server_socket.accept()
print('Connection established from:', client_address)
# 启用非阻塞 recv 超时，防止无限挂起
connection.settimeout(5.0) # 关键：5秒无确认即视为失效
current_byte = 0
while True:
try:
connection.sendall(bytes([current_byte]))
print(f'Sent byte: {current_byte}')
# 等待客户端确认（心跳）
confirm = connection.recv(2)
if not confirm: # 对端优雅关闭
print("Client closed connection gracefully.")
break
if confirm.strip() != b"ok":
print(f"Unexpected confirmation: {confirm!r}")
break
current_byte = (current_byte + 1) % 256
time.sleep(1)
except socket.timeout:
print("⚠️ No confirmation from client within timeout — disconnecting.")
break
except ConnectionResetError:
print("⚠️ Client reset connection abruptly.")
break
except BrokenPipeError:
print("⚠️ Broken pipe — client gone.")
break
except OSError as e:
if e.errno == 107: # ENOTCONN
print("⚠️ Socket not connected.")
break
raise
except KeyboardInterrupt:
print('Server interrupted.')
finally:
connection.close()
print('Connection closed.')
server_socket.close()
print('Server socket closed.')
if __name__ == '__main__':
main()对应客户端需同步发送确认：
import socket
import time
import os
SERVER_HOST = os.getenv("SERVER_HOST", "localhost")
def main():
time.sleep(1) # 简单等待服务端就绪
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect((SERVER_HOST, 12345))
try:
while True:
data = sock.recv(1)
if not data:
break
print(f"Received bytes: {data!r}")
sock.send(b"ok") # 心跳响应
finally:
sock.close()
if __name__ == "__main__":
main()? 关键注意事项：
- ❌ 避免依赖 sendall() 的异常作为断连信号——它不可靠，尤其在容器网络中；
- ✅ 始终对 recv() 设置 timeout，否则服务端可能永久阻塞；
- ✅ recv() 返回空字节（b""）是 对端已调用 close() 的明确信号；
- ✅ 在生产环境，建议结合 TCP Keepalive（setsockopt(SO_KEEPALIVE)）+ 应用层心跳，双保险；
- ✅ Docker Compose 中确保服务启动顺序（可用 depends_on + 健康检查），但心跳机制本身不依赖启动时序。
该方案不修改网络配置、无需 root 权限、兼容所有 Python 版本，是构建高可用 socket 服务的必备实践。
