溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Python面向?qū)ο笕绾螌崿F(xiàn)靜態(tài)Web服務器處理客戶端請求

發(fā)布時間:2022-06-18 09:29:35 來源:億速云 閱讀:132 作者:iii 欄目:開發(fā)技術(shù)

這篇文章主要講解了“Python面向?qū)ο笕绾螌崿F(xiàn)靜態(tài)Web服務器處理客戶端請求”,文中的講解內(nèi)容簡單清晰,易于學習與理解,下面請大家跟著小編的思路慢慢深入,一起來研究和學習“Python面向?qū)ο笕绾螌崿F(xiàn)靜態(tài)Web服務器處理客戶端請求”吧!

    概述

    把Web服務器抽象成一個類,方法初始化,在初始化中建立套接字對線。提供一個開啟Web服務器的方法,讓Web服務器處理客戶端的請求。

    實現(xiàn)步驟

    1.定義web服務器類

    初始化類
    class HttpWebServer(object):
        def __init__(self):
            # 創(chuàng)建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))
            # 設置監(jiān)聽
            tcp_server_socket.listen(128)
            # 保存創(chuàng)建成功的服務器套接字
            self.tcp_server_socket = tcp_server_socket
    處理客戶端請求
    @staticmethod
        def handle_client_request(new_socket):
            # 代碼執(zhí)行到此,說明連接建立成功
            recv_client_data = new_socket.recv(4096)
            if len(recv_client_data) == 0:
                print("關(guān)閉瀏覽器了")
                new_socket.close()
                return
            # 對二進制數(shù)據(jù)進行解碼
            recv_client_content = recv_client_data.decode("utf-8")
            print(recv_client_content)
            # 根據(jù)指定字符串進行分割, 最大分割次數(shù)指定2
            request_list = recv_client_content.split(" ", maxsplit=2)
            # 獲取請求資源路徑
            request_path = request_list[1]
            print(request_path)
            # 判斷請求的是否是根目錄,如果條件成立,指定首頁數(shù)據(jù)返回
            if request_path == "/":
                request_path = "/index.html"
            try:
                # 動態(tài)打開指定文件
                with open("static" + request_path, "rb") as file:
                    # 讀取文件數(shù)據(jù)
                    file_data = file.read()
            except Exception as e:
                # 請求資源不存在,返回404數(shù)據(jù)
                # 響應行
                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
                # 發(fā)送數(shù)據(jù)
                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
                # 發(fā)送數(shù)據(jù)
                new_socket.send(response_data)
            finally:
                # 關(guān)閉服務與客戶端的套接字
                new_socket.close()
    啟動web服務器進行工作
    def start(self):
            while True:
                # 等待接受客戶端的連接請求
                new_socket, ip_port = self.tcp_server_socket.accept()
                # 當客戶端和服務器建立連接程,創(chuàng)建子線程
                sub_thread = threading.Thread(target=self.handle_client_request, args=(new_socket,))
                # 設置守護主線程
                sub_thread.setDaemon(True)
                # 啟動子線程執(zhí)行對應的任務
                sub_thread.start()

    代碼實現(xiàn)

    import socket
    import threading
    # 定義web服務器類
    class HttpWebServer(object):
        def __init__(self):
            # 創(chuàng)建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))
            # 設置監(jiān)聽
            tcp_server_socket.listen(128)
            # 保存創(chuàng)建成功的服務器套接字
            self.tcp_server_socket = tcp_server_socket
        # 處理客戶端的請求
        @staticmethod
        def handle_client_request(new_socket):
            # 代碼執(zhí)行到此,說明連接建立成功
            recv_client_data = new_socket.recv(4096)
            if len(recv_client_data) == 0:
                print("關(guān)閉瀏覽器了")
                new_socket.close()
                return
            # 對二進制數(shù)據(jù)進行解碼
            recv_client_content = recv_client_data.decode("utf-8")
            print(recv_client_content)
            # 根據(jù)指定字符串進行分割, 最大分割次數(shù)指定2
            request_list = recv_client_content.split(" ", maxsplit=2)
            # 獲取請求資源路徑
            request_path = request_list[1]
            print(request_path)
            # 判斷請求的是否是根目錄,如果條件成立,指定首頁數(shù)據(jù)返回
            if request_path == "/":
                request_path = "/index.html"
            try:
                # 動態(tài)打開指定文件
                with open("static" + request_path, "rb") as file:
                    # 讀取文件數(shù)據(jù)
                    file_data = file.read()
            except Exception as e:
                # 請求資源不存在,返回404數(shù)據(jù)
                # 響應行
                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
                # 發(fā)送數(shù)據(jù)
                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
                # 發(fā)送數(shù)據(jù)
                new_socket.send(response_data)
            finally:
                # 關(guān)閉服務與客戶端的套接字
                new_socket.close()
        # 啟動web服務器進行工作
        def start(self):
            while True:
                # 等待接受客戶端的連接請求
                new_socket, ip_port = self.tcp_server_socket.accept()
                # 當客戶端和服務器建立連接程,創(chuàng)建子線程
                sub_thread = threading.Thread(target=self.handle_client_request, args=(new_socket,))
                # 設置守護主線程
                sub_thread.setDaemon(True)
                # 啟動子線程執(zhí)行對應的任務
                sub_thread.start()
    # 程序入口函數(shù)
    def main():
        # 創(chuàng)建web服務器對象
        web_server = HttpWebServer()
        # 啟動web服務器進行工作
        web_server.start()
    if __name__ == '__main__':
        main()

    感謝各位的閱讀,以上就是“Python面向?qū)ο笕绾螌崿F(xiàn)靜態(tài)Web服務器處理客戶端請求”的內(nèi)容了,經(jīng)過本文的學習后,相信大家對Python面向?qū)ο笕绾螌崿F(xiàn)靜態(tài)Web服務器處理客戶端請求這一問題有了更深刻的體會,具體使用情況還需要大家實踐驗證。這里是億速云,小編將為大家推送更多相關(guān)知識點的文章,歡迎關(guān)注!

    向AI問一下細節(jié)

    免責聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。

    AI