如何确保Python Socket TCP服务器支持至少50个并发客户端连接？

基于你采用的「单客户端单线程+无限循环接受连接」架构，只需针对Socket配置、线程管理和系统资源做少量调整，就能轻松支持50个以上并发客户端，具体实现方案如下：

核心配置与代码调整 #

1. Socket基础配置优化 #

修改服务器Socket的选项，解决端口复用和连接队列限制问题：

• 设置SO_REUSEADDR与SO_REUSEPORT：避免服务器重启后因TIME_WAIT状态无法绑定端口，同时允许多个进程/线程复用端口（单进程场景下主要解决TIME_WAIT问题）。
• 调整监听队列大小：listen()方法的参数设为大于50的值（比如128），这个值代表等待服务器处理的待连接队列长度，确保短时间内大量客户端发起连接时不会被拒绝。

2. 线程管理优化 #

每个客户端连接对应一个线程的架构完全能支撑50并发（Python线程的内存开销约几MB，50个线程仅占用数百MB内存，普通服务器完全能承受），只需注意：

• 设置线程为守护线程：让线程随主线程退出自动结束，避免主线程关闭后残留僵尸线程。
• 确保Socket正确关闭：在客户端线程中用try-finally块保证连接断开时关闭Socket，避免资源泄漏。

3. 系统资源适配（可选但推荐） #

Linux/macOS系统默认的文件描述符软限制通常为1024，每个Socket连接占用一个文件描述符，50个连接远低于这个值，但如果后续需要扩展，可以提前调整：

• 代码中用resource模块动态调整限制。

完整示例代码 #

import socket
import threading
import resource

# 调整系统文件描述符限制，确保支持足够连接（可选）
resource.setrlimit(resource.RLIMIT_NOFILE, (1024, 4096))

HOST = '0.0.0.0'
PORT = 65432

def handle_client(client_socket, client_address):
    print(f"新连接来自 {client_address}")
    try:
        # 循环处理客户端消息
        while True:
            data = client_socket.recv(1024)
            if not data:  # 客户端断开连接
                break
            # 这里替换为你的业务逻辑，示例为回显消息
            client_socket.sendall(data)
    except Exception as e:
        print(f"处理 {client_address} 时出错: {e}")
    finally:
        # 确保Socket关闭
        client_socket.close()
        print(f"与 {client_address} 的连接已关闭")

def main():
    # 创建TCP Socket
    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 设置Socket复用选项
    server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT, 1)
    # 绑定地址和端口
    server_socket.bind((HOST, PORT))
    # 设置监听队列大小，大于预期并发数
    server_socket.listen(128)
    print(f"服务器监听于 {HOST}:{PORT}")

    # 无限循环接受客户端连接
    while True:
        client_sock, addr = server_socket.accept()
        # 创建线程处理客户端
        client_thread = threading.Thread(target=handle_client, args=(client_sock, addr))
        # 设置为守护线程
        client_thread.daemon = True
        client_thread.start()
        # 可选：打印当前活跃连接数
        print(f"当前活跃连接数: {threading.active_count() - 1}")

if __name__ == "__main__":
    main()

关键注意事项 #

• 避免在handle_client中执行长时间阻塞操作（比如耗时的数据库查询、文件读写），如果有此类需求，建议使用线程池（concurrent.futures.ThreadPoolExecutor）或者异步IO（asyncio）优化。
• 测试并发连接时，可以编写批量客户端脚本，或者使用nc、telnet等工具模拟多客户端连接，验证服务器的承载能力。

内容的提问来源于stack exchange，提问作者Вадим Башкарев