Python多线程静态Web服务器实现指南

沿途有光

发布时间：2026-10-15| 5人浏览过

原创

本文详细介绍如何使用Python的threading模块实现支持多任务处理的静态Web服务器。通过为每个客户端连接创建独立的子线程，有效避免主线程阻塞，提升并发处理能力。文中涵盖端口复用、线程创建、守护线程设置及启动等关键步骤，并提供完整代码示例，帮助开发者快速掌握多线程网络编程技巧。

概述

本方案利用多线程技术，使Web服务器能够同时响应多个客户端的访问请求。当客户端与服务端成功建立连接后，系统会立即创建一个子线程，由该子线程专门负责处理当前客户端的请求，从而避免主线程因等待处理而阻塞。此外，将创建的子线程设置为守护主线程，确保在主线程退出时，子线程也能随之终止，防止进程无法正常退出。

实现步骤

1. 导入threading模块

import threading

2. 配置端口号复用，确保程序退出后端口能立即释放

tcp_server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True)

3. 在客户端与服务器建立连接时，创建子线程

指定target参数名称，并通过元组形式传入new_socket参数

 sub_thread = threading.Thread(target=handle_client_request, args=(new_socket,))

4. 配置守护主线程

sub_thread.setDaemon(True)

5. 启动子线程

sub_thread.start()

代码实现

import socket
import threading
# 处理客户端的请求
def handle_client_request(new_socket):
    # 代码执行到此，说明连接建立成功
    recv_client_data = new_socket.recv(4096)
    if len(recv_client_data) == 0:
        print("关闭浏览器了")
        new_socket.close()
        return
    # 对二进制数据进行解码
    recv_client_content = recv_client_data.decode("utf-8")
    print(recv_client_content)
    # 根据指定字符串进行分割， 最大分割次数指定2
    request_list = recv_client_content.split(" ", maxsplit=2)
    # 获取请求资源路径
    request_path = request_list[1]
    print(request_path)
    # 判断请求的是否是根目录，如果条件成立，指定首页数据返回
    if request_path == "/":
        request_path = "/index.html"
    try:
        # 动态打开指定文件
        with open("static" + request_path, "rb") as file:
            # 读取文件数据
            file_data = file.read()
    except Exception as e:
        # 请求资源不存在，返回404数据
        # 响应行
        response_line = "HTTP/1.1 404 Not Found\r\n"
        # 响应头
        response_header = "Server: PWS1.0\r\n"
        with open("static/error.html", "rb") as file:
            file_data = file.read()
        # 响应体
        response_body = file_data
        # 拼接响应报文
        response_data = (response_line + response_header + "\r\n").encode("utf-8") + response_body
        # 发送数据
        new_socket.send(response_data)
    else:
        # 响应行
        response_line = "HTTP/1.1 200 OK\r\n"
        # 响应头
        response_header = "Server: PWS1.0\r\n"
        # 响应体
        response_body = file_data
        # 拼接响应报文
        response_data = (response_line + response_header + "\r\n").encode("utf-8") + response_body
        # 发送数据
        new_socket.send(response_data)
    finally:
        # 关闭服务与客户端的套接字
        new_socket.close()
# 程序入口函数
def main():
    # 创建tcp服务端套接字
    tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 设置端口号复用, 程序退出端口立即释放
    tcp_server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True)
    # 绑定端口号
    tcp_server_socket.bind(("", 9000))
    # 设置监听
    tcp_server_socket.listen(128)
    while True:
        # 等待接受客户端的连接请求
        new_socket, ip_port = tcp_server_socket.accept()
        print(ip_port)
        # 当客户端和服务器建立连接程，创建子线程
        sub_thread = threading.Thread(target=handle_client_request, args=(new_socket,))
        # 设置守护主线程
        sub_thread.setDaemon(True)
        # 启动子线程执行对应的任务
        sub_thread.start()
if __name__ == '__main__':
    main()

以上即为Python静态Web服务器多任务版本的完整实现示例。如需了解更多关于Python静态Web服务器多任务处理的相关内容，欢迎查阅本站其他技术文章。