#### 服務器代碼 ~~~ #! /usr/bin/env python # -*- coding:utf-8 -*- ''' @Time: 5/1/187:55 PM @Author:haibo @File: MyWebServer.py ''' import socket import re import sys from multiprocessing import Process # 定義常量,所有字母全部大寫,設置靜態文件根目錄 HTML_ROOT_DIR = "./wwwroot" WSGI_ROOT_DIR = "./wsgipython" class HTTPServer(object): '''''' def __init__(self, application): '''構造函數,application:框架的的application''' # 導入框架對象 self.app = application # 創建socket套接字 self.server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 設置地址能夠重用 self.server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) def start(self): # 監聽 self.server_socket.listen(128) # 能夠不停收到客戶端發來的數據,while循環 while True: client_socket, client_adress = self.server_socket.accept() print("[%s,%s]" % (client_adress[0], client_adress[1])) handle_process = Process(target=self.handle_client, args=(client_socket,)) handle_process.start() client_socket.close() def start_response(self, status, headers): ''' status = headers = [ ("Content-Type", "text/plain") ] ''' # 框架內的status,header 重組新的報文頭部 response_headers = "HTTP/1.1 " + status + "\r\n" for header in headers: response_headers += "%s:%s\r\n" % header self.response_headers = response_headers def handle_client(self, client_socket): # 獲取客戶端請求 request_data = client_socket.recv(1024) # print("*1" * 20) # print("request_data:", request_data) # 獲取請求報文,按照(\r\n)分割,返回列表 request_lines = request_data.splitlines() # for line in request_lines: # print(line) # 解析請求報文 # "GET / HTTP/1.1" request_start_line = request_lines[0] # re.match(r"\w+\s+(/[^\s]*)\s", request_start_line) # 提取用戶請求的文件名字 file_name = re.match(r"\w+ +(/[^ ]*) ", request_start_line.decode("utf-8")).group(1) # method = re.match(r"\w+ +/[^ ]* ", request_start_line.decode("utf-8")).group(1) env = { "PATH_INFO": file_name, # "METHOD": method } # 獲取報文body,框架中返回了body response_body = self.app(env, self.start_response) response = self.response_headers + '\r\n' + response_body # print("*3" * 20) # print("response data:", response) client_socket.send(bytes(response, "utf-8")) client_socket.close() def bind(self, port): self.server_socket.bind(("", port)) def main(): sys.path.insert(1, WSGI_ROOT_DIR) if len(sys.argv) < 2: sys.exit("python3 MyWebServer.py Moudle:app") # python MyWebServer.py MyWebFramework:Application modle_name, app_name = sys.argv[1].split(":") m = __import__(modle_name) app = getattr(m, app_name) # app = Application() http_server = HTTPServer(app) http_server.bind(8001) http_server.start() if __name__ == '__main__': main() ~~~