import socket
import re
import multiprocessing
import time
import mini_frame
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):
? ? # '''為這個(gè)客戶端返回?cái)?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ù)給瀏覽器
? ? ? ? if not file_name.endswith('.py')
? ? ? ? ? ? try:
? ? ? ? ? ? ? ? f =open('.../Desktop/項(xiàng)目/項(xiàng)目.html', 'rb')
? ? ? ? # f = open('.../Desktop/項(xiàng)目/項(xiàng)目.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 準(zhǔn)備發(fā)送給瀏覽器的Header
? ? ? ? ? ? ? ? response ='HTTP/1.1 200 OK\r\n'
? ? ? ? ? ? ? ? response +='\r\n'
? ? ? ? ? ? # 2.2? 準(zhǔn)備發(fā)送給瀏覽器的Body
? ? ? ? # response += 'hahaha'
? ? ? ? # f = open('.../Desktop/項(xiàng)目/項(xiàng)目.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()
? ? ? ? ? ? else:#如果是以。py 結(jié)尾后频，就認(rèn)為是動(dòng)態(tài)資源的請求
? ? ? ? ? ? ? ? env = dict()
? ? ? ? ? ? ? ? env['PATH_INFO'] = file_name
? ? ? ? ? ? ? ? body = mini_frame.application(env,self.set_response_header)
? ? ? ? ? ? ? ? header = 'HTTP/1.1 200 OK\r\n'% self.status
? ? ? ? ? ? ? ? for temp in self.headers:
? ? ? ? ? ? ? ? header += '%s:%s\r\n'%(temp[0],temp[1])
? ? ? ? ? ? ? ? header += '\r\n'
? ? ? ? ? ? ? ? response = header + body
? ? ? ? ? ? ? ? new_socket.send(response.encode('utf-8'))
? ? ? ? ? ? new_socket.close()
? ? def set_response_header(self,status,headers):
? ? self.status = status
? ? self.headers =headers
? ? def run_forver(self):
? ? ? ? while True:
? ? # 4。等待新客戶端的鏈接
? ? ? ? ? ? new_socket, client_addr = tcp_server_socket.accept()
? ? # 局部變量
? ? # 5。為這個(gè)客戶端服務(wù)
? ? # 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)建一個(gè)web 服務(wù)器對象。調(diào)用run_forver方法運(yùn)行
? ? wsgi_server = WSGIServer()
? ? wsgi_server.run_forver()
if __name__ =='__main__':
? ? main()
