import socket
import re
import multiprocessing
import time
import dynamic.mini_frame
import sys
class WSGIServer(object):
? ? def _init_(self，port,app,static_path):
? ? ? ? # 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)
? ? ? ? self.application = app
? ? ? ? self.static_path = static_path
? ? def service_client(self,new_socket):
? ? # '''為這個(gè)客戶端返回?cái)?shù)據(jù)'''
? ? # 1.接收瀏覽器發(fā)送出來的請(qǐng)求槽畔，即HTTP請(qǐng)求
? ? # 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('self.static_path + file_name', '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)
? ? ? ? ? ? else:#如果是以闰挡。py 結(jié)尾举娩，就認(rèn)為是動(dòng)態(tài)資源的請(qǐng)求
? ? ? ? ? ? ? ? env = dict()
? ? ? ? ? ? ? ? env['PATH_INFO'] = file_name
? ? ? ? ? ? ? ? body = self.application(env,self.set_response_header)
? ? ? ? ? ? ? ? header = 'HTTP/1.1 %s\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'))
# 關(guān)閉客戶端套接字
? ? ? ? ? ? new_socket.close()
? ? def set_response_header(self,status,headers):
? ? self.status = status
? ? self.headers = headers
? ? ? ? self.headers += headers
? ? def run_forver(self):
? ? ? ? while True:
? ? # 4析校。等待新客戶端的鏈接
? ? ? ? ? ? new_socket, client_addr = self.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ù)器對(duì)象。調(diào)用run_forver方法運(yùn)行
? ? if len(sys.argv) == 3:
? ? ? ? try:
? ? ? ? ? ? port = int(sys.argv[1])
? ? ? ? ? ? frame_app_name = sys.argv[2]# 接收下面的mini_frame:appliction
? ? ? ? except Exception as ret:
? ? ? ? ? ? print('端口輸入錯(cuò)誤')
? ? ? ? ? ? return
? ? else:
? ? ? ? print('請(qǐng)按照以下方式運(yùn)行')
? ? ? ? print('python web_server.py 7890 mini_frame:application')
? ? ? ? return
#正則匹配芙代。? （ 吊奢。*都要）
? ? ret = re.match(r '([^:]):(.*)',frame_app_name)
? ? if ret:
? ? ? ? frame_name = ret.group(1)
? ? ? ? app_name = ret.group(2)
? ? else:
? ? ? ? print('請(qǐng)按照以下方式運(yùn)行')
? ? ? ? print('python web_server.py 7890 mini_frame:application')
? ? ? ? ? ? ? ? ? ? #需要重啟時(shí)執(zhí)行該命令
? ? ? ? return
? ? with open('./web_server.conf') as f :
? ? ? ? conf_info = eval(f.read()) # 讀取配置文件，轉(zhuǎn)為字典
? ? #此時(shí)con_info 是一個(gè)字典纹烹，里面數(shù)據(jù)為
# {
#? ? 'static_path:'./static',
#? ? 'dynamic_path':'./dynamic'
# }
? ? sys.path.append(conf_info['dynamic_path'])? # 選擇其他方法尋找 mini——frame
? # 相當(dāng)于創(chuàng)建軟連接
? ? # import xxx
? ? frame = __import__(frame_name) #返回值標(biāo)記著導(dǎo)入的模塊
? ? app = getattr(frame,app_name)? # 此時(shí)app就指向dynamic/miniframe 模塊中的applictaion函數(shù)
#app 指application函數(shù)
#app_name 指上面 else 中的 application
? ? print(app)
? ? wsgi_server = WSGIServer(port,app,conf_info['static_path'])
? ? wsgi_server.run_forver()
if __name__ =='__main__':
? ? main()
