import socket
import re
import multiprocessing
class WSGIServer(object):
? ? def _init_(self):
? ? ? ? # 1。創(chuàng)建套接字
? ? ? ? self.tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
? ? ? ? self.tcp_server_socket.setsockopt(socket.SOL_SOCJET, socket.SOCK_REUSEADDR,1)
? ? ? ? # 2。綁定
? ? ? ? self.tcp_server_socket.bind(('', 7890))
? ? ? ? # 3啊送。變?yōu)楸O(jiān)聽套接字(最大鏈接書128)
? ? ? ? self.tcp_server_socket.listen(128)
? ? def service_client(self,new_socket):
? ? # '''為這個客戶端返回數(shù)據(jù)'''
? ? # 1.接收瀏覽器發(fā)送出來的請求盗扇，即HTTP請求
? ? # GET/HTTP/1.1
? ? ? ? request = new_socket.recv(1024).decode('utf-8')
? ? ? ? request_lines = request.splotlines()
? ? ? ? print ('')
? ? ? ? print ('>>>' *30)
? ? ? ? print (request_lines)
? ? # 新客戶端鏈接
? ? # GET/index.html HTTP/1.
? ? # get post put del
? ? ? ? ret = ret.match(r'[^/]+（/[^ ]*）)', request_lines[0])
? ? ? ? file_name = ''
? ? ? ? if ret:
? ? ? ? ? ? file_name = ret.group(1)
? ? ? ? ? ? print ('*' *50, file_name)
? ? ? ? ? ? if file_name == '/':
? ? ? ? ? ? ? ? file_name = '/index.html'
? ? # 2.返回HTTP格式的數(shù)據(jù)給瀏覽器
? ? ? ? try:
? ? ? ? ? ? f =open('.../Desktop/項目/項目.html', 'rb')
? ? # f = open('.../Desktop/項目/項目.html' +file_name,'rb')
? ? ? ? except:
? ? ? ? ? ? ? ? response ='HTTP/1.1 404 NOT FOUND\r\n'
? ? ? ? ? ? ? ? response +='\r\n'
? ? ? ? ? ? ? ? response +='--FILE NOT FOUND---'
? ? ? ? ? ? ? ? new_socket.send(response.encode('utf-8'))
? ? else:
? ? ? ? html_content = f.read()
? ? ? ? f.close()
? ? # 2肉盹。1 準備發(fā)送給瀏覽器的Header
? ? ? ? response ='HTTP/1.1 200 OK\r\n'
? ? ? ? response +='\r\n'
? ? ? ? # 2.2? 準備發(fā)送給瀏覽器的Body
? ? # response += 'hahaha'
? ? # f = open('.../Desktop/項目/項目.html','rb')
? ? # html_content = f.read()
? ? # f.close()
? ? # 將Response Header 發(fā)送給瀏覽器
? ? ? ? new_socket.send(response.encode('utf-8'))
? ? # 將Response Body? 發(fā)送給瀏覽器
? ? ? ? new_socket.send(html_content)
? ? # 關(guān)閉客戶端套接字
? ? ? ? new_socket.close()
? ? def main():
? ? ? ? while True:
? ? # 4肾档。等待新客戶端的鏈接
? ? ? ? ? ? new_socket, client_addr = tcp_server_socket.accept()
? ? # 局部變量
? ? # 5聚唐。為這個客戶端服務
? ? # service_client()
? ? ? ? ? ? p = multiprocessing.Process(target=service_client,args=(new_socket,))
? ? ? ? ? ? p.start()
? ? ? ? ? ? new_socket.close()
? ? # 6庆锦。關(guān)閉監(jiān)聽套接字
? ? ? ? self.tcp_server_socket.close()
def main():
? ? #用來完成整體的控制捅位，創(chuàng)建一個web 服務器對象。調(diào)用run_forver方法運行
? ? wsgi_server = WSGIServer()
? ? wsgi_server.run_forver()
if __name__ =='__main__':
? ? main()
