import socket
import re
import multiprocessing
# Http伺服器類
class HttpServer:
# 初始化屬性
def __init__(self):
# 建立套接字
self.tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 設定位址重用
self.tcp_server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True)
# 綁定端口
self.tcp_server_socket.bind(("", 8080))
# 設定監聽，最多建立128個連接配接
self.tcp_server_socket.listen(128)
def start(self):
while True:
# 接收用戶端資訊
client_socket, ip_port = self.tcp_server_socket.accept()
print('新使用者:', ip_port, '已連接配接')
# 建立新程序，給用戶端傳回響應封包
t1 = multiprocessing.Process(target=self.recv_msg, args=(client_socket, ip_port))
# 啟動程序
t1.start()
# 關閉用戶端套接字(多程序不共享資源，故先後需要關閉兩次套接字)
client_socket.close()
# 發送消息方法
@staticmethod
def recv_msg(client_socket, ip_port):
# 接收用戶端請求封包
client_text = client_socket.recv(1024)
if not client_text:
print("用戶端", ip_port, "已下線")
client_socket.close()
return
# 請求封包解碼
client_text_str = client_text.decode()
print(client_text_str)
# 将請求封包切割
client_list = client_text_str.split("rn")
# 正則比對出請求路徑
ret = re.search(r"s(.*)s", client_list[0])
print(ret.group())
# 比對不到則請求封包錯誤
if not ret:
print("使用者請求封包格式錯誤!")
client_socket.close()
return
# 得到路徑
path_info = ret.group(1)
# 設定預設路徑
if path_info == '/':
path_info = '/index.html'
print("接收到使用者請求：", path_info)
# 響應頭
response_header = "Server:Python-Web1.0rn"
# 響應空行
response_blank = "rn"
try:
# 讀取指定路徑檔案，并且傳回
with open('web'+path_info, "rb") as file:
# 讀取檔案的二進制資料
response_content = file.read()
# 找不到路徑則傳回404錯誤
except Exception as e:
# 開始拼接響應資料
response_line = "HTTP/1.1 404 Not Foundrn"
response_content = "Error !!! %s" % str(e)
response_content = response_content.encode()
else:
# 開始拼接響應資料
response_line = "HTTP/1.1 200 OKrn"