Python多工版靜態Web伺服器實現範例

2022-06-17 18:03:08

概述

使用多執行緒，讓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 Foundrn"
        # 響應頭
        response_header = "Server: PWS1.0rn"
        with open("static/error.html", "rb") as file:
            file_data = file.read()
        # 響應體
        response_body = file_data
        # 拼接響應報文
        response_data = (response_line + response_header + "rn").encode("utf-8") + response_body
        # 傳送資料
        new_socket.send(response_data)
    else:
        # 響應行
        response_line = "HTTP/1.1 200 OKrn"
        # 響應頭
        response_header = "Server: PWS1.0rn"
        # 響應體
        response_body = file_data
        # 拼接響應報文
        response_data = (response_line + response_header + "rn").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伺服器多工的資料請關注it145.com其它相關文章！