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（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。