单进程非堵塞 模型
#coding=utf-8from socket import *import time# 用来存储所有的新链接的socketg_socket_list = list()def main(): ???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) ???while True: ???????# 用来测试 ???????time.sleep(0.5) ???????try: ???????????newClientInfo = server_socket.accept() ???????except Exception as result: ???????????pass ???????else: ???????????print("一个新的客户端到来:%s" % str(newClientInfo)) ???????????newClientInfo[0].setblocking(False) ?# 设置为非堵塞 ???????????g_socket_list.append(newClientInfo) ???????for client_socket, client_addr in g_socket_list: ???????????try: ???????????????recvData = client_socket.recv(1024) ???????????????if recvData: ???????????????????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)) ???????????except Exception as result: ???????????????pass ???????print(g_socket_list) ?# for testif __name__ == ‘__main__‘: ???main()web静态服务器-单进程非堵塞
import timeimport socketimport sysimport reclass WSGIServer(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 ???def run_forever(self): ???????"""运行服务器""" ???????# 等待对方链接 ???????while True: ???????????# time.sleep(0.5) ?# for test ???????????try: ???????????????new_socket, new_addr = self.server_socket.accept() ???????????except Exception as ret: ???????????????print("-----1----", ret) ?# for test ???????????else: ???????????????new_socket.setblocking(False) ???????????????self.client_socket_list.append(new_socket) ???????????for client_socket in self.client_socket_list: ???????????????try: ???????????????????request = client_socket.recv(1024).decode(‘utf-8‘) ???????????????except Exception as ret: ???????????????????print("------2----", ret) ?# for test ???????????????else: ???????????????????if request: ???????????????????????self.deal_with_request(request, client_socket) ???????????????????else: ???????????????????????client_socket.close() ???????????????????????self.client_socket_list.remove(client_socket) ???????????print(self.client_socket_list) ???def deal_with_request(self, request, client_socket): ???????"""为这个浏览器服务器""" ???????if not request: ???????????return ???????request_lines = request.splitlines() ???????for i, line in enumerate(request_lines): ???????????print(i, line) ???????# 提取请求的文件(index.html) ???????# GET /a/b/c/d/e/index.html HTTP/1.1 ???????ret = re.match(r"([^/]*)([^ ]+)", request_lines[0]) ???????if ret: ???????????print("正则提取数据:", ret.group(1)) ???????????print("正则提取数据:", ret.group(2)) ???????????file_name = ret.group(2) ???????????if file_name == "/": ???????????????file_name = "/index.html" ???????# 读取文件数据 ???????try: ???????????f = open(self.documents_root+file_name, "rb") ???????except: ???????????response_body = "file not found, 请输入正确的url" ???????????response_header = "HTTP/1.1 404 not found\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.1 200 OK\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"def main(): ???"""控制web服务器整体""" ???# python3 xxxx.py 7890 ???if len(sys.argv) == 2: ???????port = sys.argv[1] ???????if port.isdigit(): ???????????port = int(port) ???else: ???????print("运行方式如: python3 xxx.py 7890") ???????return ???print("http服务器使用的port:%s" % port) ???http_server = WSGIServer(port, DOCUMENTS_ROOT) ???http_server.run_forever()if __name__ == "__main__": ???main()Web静态服务器-5-非堵塞模式
原文地址：https://www.cnblogs.com/jyue/p/10468706.html