多线程TCP服务器可并发处理客户端连接，利用threading模块为每个客户端创建独立线程，结合socket实现基础通信，通过线程池控制资源并优化性能，适用于I/O密集型网络服务场景。
在Python中实现多线程网络服务器，可以有效处理多个客户端并发连接。虽然Python的全局解释器锁（GIL）限制了多线程在CPU密集型任务中的并行能力，但在I/O密集型场景（如网络通信）中，多线程依然表现良好。下面是一个实用的多线程TCP服务器搭建教程，适合初学者和中级开发者快速上手。
1. 基础TCP服务器结构
使用socket模块创建一个基本的TCP服务器，监听指定端口等待客户端连接。
示例代码：
import socket创建socket对象
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM) server.bind(('localhost', 8888)) server.listen(5) print("服务器启动，等待连接...")
while True: client_sock, addr = server.accept() print(f"客户端 {addr} 已连接")
接收数据
data = client_sock.recv(1024) print(f"收到: {data.decode()}") # 回传响应 client_sock.send(b"Hello from server") client_sock.close()
这个版本只能逐个处理客户端，无法并发。接下来引入多线程提升并发能力。
立即学习“Python免费学习笔记（深入）”；
2. 引入多线程处理客户端请求
每次有新客户端连接时，启动一个新线程处理该连接，主线程继续监听新连接。
关键点：
- 导入threading模块
- 将客户端处理逻辑封装成函数
- 为每个客户端创建独立线程
改进后的代码：
import socket import threadingdef handle_client(client_sock, addr): print(f"线程处理客户端 {addr}") try: while True: data = client_sock.recv(1024) if not data: break print(f"来自 {addr}: {data.decode()}") client_sock.send(data) # 回显数据 except Exception as e: print(f"客户端 {addr} 出现错误: {e}") finally: client_sock.close() print(f"客户端 {addr} 连接关闭")
主服务器逻辑
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM) server.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) server.bind(('localhost', 8888)) server.listen(10) print("多线程服务器启动，监听8888端口...")
try: while True: client_sock, addr = server.accept()
启动新线程处理客户端
client_thread = threading.Thread(target=handle_client, args=(client_sock, addr)) client_thread.daemon = True # 主线程退出时，子线程也退出 client_thread.start()except KeyboardInterrupt: print("\n服务器关闭") finally: server.close()
3. 客户端测试脚本
编写一个简单客户端用于测试服务器并发能力。
import socketdef test_client(): client = socket.socket(socket.AF_INET, socket.SOCK_STREAM) client.connect(('localhost', 8888))
for i in range(3): msg = f"消息 {i+1}" client.send(msg.encode()) response = client.recv(1024) print(f"收到回显: {response.decode()}") time.sleep(1) client.close()使用多个线程运行多个客户端
import threading import time
for i in range(3): t = threading.Thread(target=test_client) t.start() time.sleep(0.5)
运行后可以看到服务器同时处理多个客户端的消息，每个客户端由独立线程处理。
4. 注意事项与优化建议
多线程服务器虽简单易用，但需注意以下几点：
- 资源管理：确保每个线程正确关闭socket，避免文件描述符泄漏
- 线程安全：若多个线程访问共享数据（如用户列表），需使用锁机制（threading.Lock）
- 线程数量控制：大量并发连接可能耗尽系统资源，可使用线程池（concurrent.futures.ThreadPoolExecutor）限制最大线程数
- 异常处理：网络中断、客户端异常断开等都要捕获并妥善处理
例如使用线程池优化：
from concurrent.futures import ThreadPoolExecutorexecutor = ThreadPoolExecutor(max_workers=10)
在accept后：
executor.submit(handle_client, client_sock, addr)
基本上就这些。这套方案适合中小规模并发场景，代码简洁，易于理解和维护。对于更高性能需求，可考虑异步IO（asyncio）方案，但多线程仍是入门网络编程的首选方式。
