静态web服务器-多任务版

分析步骤

1. 当客户端和服务端建立连接成功，创建子线程，使用子线程专门处理客户端的请求，防止主线程阻塞

import socket
# 1. 获取用户请求资源的路径
# 2. 根据请求资源的路径，读取指定文件的数据
# 3. 组装指定文件数据的响应报文，发送给浏览器
# 4. 判断请求的文件在服务端是否存在，不存在，组装404状态的响应报文，发送给浏览器
import threading

def handle_client_request(client_socket):
    # 获取浏览器的请求信息
    client_request_data = client_socket.recv(1024).decode()
    print(client_request_data)
    # 获取用户请求资源的路径
    request_data = client_request_data.split(' ')
    # 判断客户端是否关闭
    if len(request_data) == 1:
        client_socket.close()
        return
    
    request_path = request_data[1]
    if request_path == '/':
        request_path = '/index.html'
    # 3. 读取固定页面数据，把页面数据组装成HTTP响应报文数据发送给浏览器
    try:
        with open('./static' + request_path, 'rb') as f:
            file_data = f.read()
    except Exception as e:
        # 返回404错误数据
        # 应答行
        response_line = "HTTP/1.1 404 Not Found\r\n"
        # 应答头
        response_header = "Server:pwb\r\n"
        # 应答体
        response_body = "404 Not Found sorry"
        # 应答数据
        # 组装指定文件数据的响应报文，发送给浏览器
        response_data = (response_line + response_header + '\r\n' + response_body).encode()

        client_socket.send(response_data)
    else:
        # 应答行
        response_line = "HTTP/1.1 200 OK\r\n"
        # 应答头
        response_header = "Server:pwb\r\n"
        # 应答体
        response_body = file_data
        # 应答数据
        # 组装指定文件数据的响应报文，发送给浏览器
        response_data = (response_line + response_header + '\r\n').encode() + response_body

        client_socket.send(response_data)
    finally:
        # 4. HTTP响应报文数据发送完成以后，关闭服务于客户端的套接字
        client_socket.close()

if __name__ == '__main__':
    # 1. 编写一个TCP服务端程序
    # 创建socket
    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(("127.0.0.1", 8080))
    # 设置监听
    tcp_server_socket.listen(128)
    while True:
        # 2. 获取浏览器发送的HTTP请求报文数据
        # 建立连接
        client_socket, client_addr = tcp_server_socket.accept()
        # 创建子线程
        sub_thread = threading.Thread(target=handle_client_request, args=(client_socket,))
        sub_thread.start()