Python Web静态服务器非堵塞模式实现方法示例
本文实例讲述了PythonWeb静态服务器非堵塞模式实现方法。分享给大家供大家参考,具体如下:
单进程非堵塞模型
#coding=utf-8 fromsocketimport* importtime #用来存储所有的新链接的socket g_socket_list=list() defmain(): server_socket=socket(AF_INET,SOCK_STREAM) server_socket.setsockopt(SOL_SOCKET,SO_REUSEADDR,1) server_socket.bind(('',7890)) server_socket.listen(128) #将套接字设置为非堵塞 #设置为非堵塞后,如果accept时,恰巧没有客户端connect,那么accept会 #产生一个异常,所以需要try来进行处理 server_socket.setblocking(False) whileTrue: #用来测试 time.sleep(0.5) try: newClientInfo=server_socket.accept() exceptExceptionasresult: pass else: print("一个新的客户端到来:%s"%str(newClientInfo)) newClientInfo[0].setblocking(False)#设置为非堵塞 g_socket_list.append(newClientInfo) forclient_socket,client_addring_socket_list: try: recvData=client_socket.recv(1024) ifrecvData: print('recv[%s]:%s'%(str(client_addr),recvData)) else: print('[%s]客户端已经关闭'%str(client_addr)) client_socket.close() g_socket_list.remove((client_socket,client_addr)) exceptExceptionasresult: pass print(g_socket_list)#fortest if__name__=='__main__': main()
web静态服务器-单进程非堵塞
importtime importsocket importsys importre classWSGIServer(object): """定义一个WSGI服务器的类""" def__init__(self,port,documents_root): #1.创建套接字 self.server_socket=socket.socket(socket.AF_INET,socket.SOCK_STREAM) #2.绑定本地信息 self.server_socket.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1) self.server_socket.bind(("",port)) #3.变为监听套接字 self.server_socket.listen(128) self.server_socket.setblocking(False) self.client_socket_list=list() self.documents_root=documents_root defrun_forever(self): """运行服务器""" #等待对方链接 whileTrue: #time.sleep(0.5)#fortest try: new_socket,new_addr=self.server_socket.accept() exceptExceptionasret: print("-----1----",ret)#fortest else: new_socket.setblocking(False) self.client_socket_list.append(new_socket) forclient_socketinself.client_socket_list: try: request=client_socket.recv(1024).decode('utf-8') exceptExceptionasret: print("------2----",ret)#fortest else: ifrequest: self.deal_with_request(request,client_socket) else: client_socket.close() self.client_socket_list.remove(client_socket) print(self.client_socket_list) defdeal_with_request(self,request,client_socket): """为这个浏览器服务器""" ifnotrequest: return request_lines=request.splitlines() fori,lineinenumerate(request_lines): print(i,line) #提取请求的文件(index.html) #GET/a/b/c/d/e/index.htmlHTTP/1.1 ret=re.match(r"([^/]*)([^]+)",request_lines[0]) ifret: print("正则提取数据:",ret.group(1)) print("正则提取数据:",ret.group(2)) file_name=ret.group(2) iffile_name=="/": file_name="/index.html" #读取文件数据 try: f=open(self.documents_root+file_name,"rb") except: response_body="filenotfound,请输入正确的url" response_header="HTTP/1.1404notfound\r\n" response_header+="Content-Type:text/html;charset=utf-8\r\n" response_header+="Content-Length:%d\r\n"%(len(response_body)) response_header+="\r\n" #将header返回给浏览器 client_socket.send(response_header.encode('utf-8')) #将body返回给浏览器 client_socket.send(response_body.encode("utf-8")) else: content=f.read() f.close() response_body=content response_header="HTTP/1.1200OK\r\n" response_header+="Content-Length:%d\r\n"%(len(response_body)) response_header+="\r\n" #将header返回给浏览器 client_socket.send(response_header.encode('utf-8')+response_body) #设置服务器服务静态资源时的路径 DOCUMENTS_ROOT="./html" defmain(): """控制web服务器整体""" #python3xxxx.py7890 iflen(sys.argv)==2: port=sys.argv[1] ifport.isdigit(): port=int(port) else: print("运行方式如:python3xxx.py7890") return print("http服务器使用的port:%s"%port) http_server=WSGIServer(port,DOCUMENTS_ROOT) http_server.run_forever() if__name__=="__main__": main()
更多关于Python相关内容可查看本站专题:《PythonSocket编程技巧总结》、《Python数据结构与算法教程》、《Python函数使用技巧总结》、《Python字符串操作技巧汇总》、《Python入门与进阶经典教程》及《Python文件与目录操作技巧汇总》
希望本文所述对大家Python程序设计有所帮助。
声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:czq8825#qq.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。