1.線程、進(jìn)程實(shí)現(xiàn)多任務(wù)HTTP服務(wù)器

import re import socket import multiprocessing import threadingdef service_client(new_socket):"""為這個(gè)客戶端返回?cái)?shù)據(jù)"""# 接收瀏覽器發(fā)送過來的請(qǐng)求，即HTTP請(qǐng)求request=new_socket.recv(1024)request=request.decode("utf-8") # 解碼request_lines=request.splitlines() # 按照行('\r', '\r\n', \n')分隔，返回一個(gè)包含各行作為元素的列表print(request_lines)# GET /index.html HTTP/1.1# [^/]表示除了/都可以file_name=""ret=re.match(r"[^/]+(/[^ ]*)",request_lines[0])if ret:file_name=ret.group(1)if file_name=="/":file_name="/index.html"# 2.返回HTTP格式的數(shù)據(jù)，給瀏覽器try:# 準(zhǔn)備發(fā)送的body，打開HTML文件f=open("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()# 準(zhǔn)備發(fā)送的headerresponse="HTTP/1.1 200 OK\r\n"response+="\r\n" # header與body之間必須隔一行# 發(fā)送headernew_socket.send(response.encode("utf-8"))# 發(fā)送HTMLnew_socket.send(html_content)new_socket.close()def main():tcp_sever_socket=socket.socket(socket.AF_INET,socket.SOCK_STREAM)# 服務(wù)器先關(guān)閉，保證重新開啟不占用端口tcp_sever_socket.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)tcp_sever_socket.bind(("",7890))tcp_sever_socket.listen(128)while True:# 等待新客戶端的鏈接new_socket,client_addr=tcp_sever_socket.accept()#p=multiprocessing.Process(target=service_client,args=(new_socket,))p=threading.Thread(target=service_client,args=(new_socket,))p.start()# 子進(jìn)程關(guān)閉一次主進(jìn)程還需關(guān)閉一次，Linux下文件硬鏈接的原因，兩個(gè)名字指向同一個(gè)文件，因此要關(guān)閉兩次#new_socket.close()# 關(guān)閉監(jiān)聽套接字tcp_sever_socket.close() if __name__ == '__main__':main()

2.gevent協(xié)程實(shí)現(xiàn)多任務(wù)HTTP服務(wù)器

import re import socket import gevent from gevent import monkeymonkey.patch_all() def service_client(new_socket):"""為這個(gè)客戶端返回?cái)?shù)據(jù)"""# 接收瀏覽器發(fā)送過來的請(qǐng)求，即HTTP請(qǐng)求request=new_socket.recv(1024)request=request.decode("utf-8") # 解碼request_lines=request.splitlines() # 按照行('\r', '\r\n', \n')分隔，返回一個(gè)包含各行作為元素的列表print(request_lines)# GET /index.html HTTP/1.1# [^/]表示除了/都可以file_name=""ret=re.match(r"[^/]+(/[^ ]*)",request_lines[0])if ret:file_name=ret.group(1)if file_name=="/":file_name="/index.html"# 2.返回HTTP格式的數(shù)據(jù)，給瀏覽器try:# 準(zhǔn)備發(fā)送的body，打開HTML文件f=open("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()# 準(zhǔn)備發(fā)送的headerresponse="HTTP/1.1 200 OK\r\n"response+="\r\n" # header與body之間必須隔一行# 發(fā)送headernew_socket.send(response.encode("utf-8"))# 發(fā)送HTMLnew_socket.send(html_content)new_socket.close()def main():tcp_sever_socket=socket.socket(socket.AF_INET,socket.SOCK_STREAM)# 服務(wù)器先關(guān)閉，保證重新開啟不占用端口tcp_sever_socket.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)tcp_sever_socket.bind(("",7890))tcp_sever_socket.listen(128)while True:# 等待新客戶端的鏈接new_socket,client_addr=tcp_sever_socket.accept()gevent.spawn(service_client,new_socket)# 關(guān)閉監(jiān)聽套接字tcp_sever_socket.close() if __name__ == '__main__':main()

總結(jié)

以上是生活随笔為你收集整理的Python实现HTTP服务器（三）线程、进程、协程实现多任务的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。