Python多线程网络编程实战 Python多线程服务器搭建教程

看不見的法師

发布： 2025-11-03 18:11:29

原创

993人浏览过

多线程TCP服务器可并发处理客户端连接，利用threading模块为每个客户端创建独立线程，结合socket实现基础通信，通过线程池控制资源并优化性能，适用于I/O密集型网络服务场景。

python多线程网络编程实战 python多线程服务器搭建教程

在Python中实现多线程网络服务器，可以有效处理多个客户端并发连接。虽然Python的全局解释器锁（GIL）限制了多线程在CPU密集型任务中的并行能力，但在I/O密集型场景（如网络通信）中，多线程依然表现良好。下面是一个实用的多线程TCP服务器搭建教程，适合初学者和中级开发者快速上手。

1. 基础TCP服务器结构

使用socket模块创建一个基本的TCP服务器，监听指定端口等待客户端连接。

示例代码：

import socket
<h1>创建socket对象</h1><p>server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind(('localhost', 8888))
server.listen(5)
print("服务器启动，等待连接...")</p><p>while True:
client_sock, addr = server.accept()
print(f"客户端 {addr} 已连接")</p><h1>接收数据</h1><pre class='brush:python;toolbar:false;'>data = client_sock.recv(1024)
print(f"收到: {data.decode()}")
# 回传响应
client_sock.send(b"Hello from server")
client_sock.close()

登录后复制

这个版本只能逐个处理客户端，无法并发。接下来引入多线程提升并发能力。

立即学习“Python免费学习笔记（深入）”；

2. 引入多线程处理客户端请求

每次有新客户端连接时，启动一个新线程处理该连接，主线程继续监听新连接。

关键点：

导入threading模块
将客户端处理逻辑封装成函数
为每个客户端创建独立线程

改进后的代码：

豆包AI编程

豆包推出的AI编程助手

483

查看详情

import socket
import threading
<p>def 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} 连接关闭")</p><h1>主服务器逻辑</h1><p>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端口...")</p><p>try:
while True:
client_sock, addr = server.accept()</p><h1>启动新线程处理客户端</h1><pre class='brush:python;toolbar:false;'>    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 socket
<p>def test_client():
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client.connect(('localhost', 8888))</p><pre class='brush:python;toolbar:false;'>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 ThreadPoolExecutor
<p>executor = ThreadPoolExecutor(max_workers=10)</p><h1>在accept后：</h1><p>executor.submit(handle_client, client_sock, addr)</p>

登录后复制

基本上就这些。这套方案适合中小规模并发场景，代码简洁，易于理解和维护。对于更高性能需求，可考虑异步IO（asyncio）方案，但多线程仍是入门网络编程的首选方式。

以上就是Python多线程网络编程实战 Python多线程服务器搭建教程的详细内容，更多请关注php中文网其它相关文章！