單進(jìn)程-單線程-非阻塞-長(zhǎng)鏈接
import socket
import re
def service_client(new_socket):
# '''為這個(gè)客戶端返回?cái)?shù)據(jù)'''
# 1.接收瀏覽器發(fā)送出來(lái)的請(qǐng)求屋休，即HTTP請(qǐng)求
# GET/HTTP/1.1
#.....
? ? request_lines = request.splotlines()
print ('')
print ('>>>' *30)
print (request_lines)
ret = re.match(r'[^/]+（/[^ ]*)', request_lines[0])#正則提取
? ? file_name =''
? ? if ret:
file_name = ret.group(1)
print ('*' *50, file_name)# !!!!!!!!網(wǎng)頁(yè)名字
? ? ? ? if file_name ='/index.html'
? ? # 2.返回HTTP格式的數(shù)據(jù)給瀏覽器
? ? try:
f =open('.../Desktop/項(xiàng)目/項(xiàng)目.html', '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_header ='HTTP/1.1 200 OK\r\n'
? ? ? ? response_header +='\r\n'
? ? ? ? response_header ='Content-Length : %d\r\n'%len(response_body)
response_header +='\r\n'
? ? ? ? response = response_header.encode('utf-8')+ response_body
#將 Response發(fā)送給瀏覽器
? ? ? ? new_socket.send(response)
def main():
? ? #用來(lái)完成整提的控制
? ? # 1.創(chuàng)建套接字
? ? tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
tcp_server_socket.setsockopt(socket.SOCK_STREAM, socket.SO_REUSEADDR,1)
# 2.綁定
? ? tcp_server_socket.bind(('', 7890))
# 3.變?yōu)楸O(jiān)聽套接字(最大鏈接書128)
? ? tcp_server_socket.listen(128)
while True:
# 4.等待新客戶端的鏈接
? ? ? ? try:
new_socket, client_addr = tcp_server_socket.accept()
# 局部變量
? ? ? ? except Exception as ret:
pass
? ? ? ? else:
new_socket.setblocking(False)
client_socket_list.append(new_socket)
for client_socketin client_socket_list:
try:
recv_data = client_socket.recv(1024).dacode('utf-8')
except Exception as ret:
pass
? ? ? ? ? ? else:
if recv_data:
# 5.為這個(gè)客戶端服務(wù)
? ? ? ? ? ? ? ? ? ? service_client(client_socket,recv_data)
else:
client_socket.close()
client_socket_list.remove(client_socket)
# 6.關(guān)閉監(jiān)聽套接字
? ? tcp_server_socket.close()
if __name__ =='__main__':
main()
epoll實(shí)現(xiàn)http服務(wù)器
import socket
import re
import select
def service_client(new_socket):
# '''為這個(gè)客戶端返回?cái)?shù)據(jù)'''
# 1.接收瀏覽器發(fā)送出來(lái)的請(qǐng)求周崭，即HTTP請(qǐng)求
# GET/HTTP/1.1
#......
request_lines = request.splotlines()
print ('')
print ('>>>' *30)
print (request_lines)
ret = re.match(r'[^/]+（/[^ ]*)', request_lines[0])#正則提取
file_name =''
if ret:
file_name = ret.group(1)
print ('*' *50, file_name)# !!!!!!!!網(wǎng)頁(yè)名字
if file_name ='/index.html'
# 2.返回HTTP格式的數(shù)據(jù)給瀏覽器
try:
f =open('.../Desktop/項(xiàng)目/項(xiàng)目.html', '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_header ='HTTP/1.1 200 OK\r\n'
response_header +='\r\n'
response_header ='Content-Length : %d\r\n'%len(response_body)
response_header +='\r\n'
response = response_header.encode('utf-8')+ response_body
#將 Response發(fā)送給瀏覽器
new_socket.send(response)
def main():
#用來(lái)完成整提的控制
# 1.創(chuàng)建套接字
tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
tcp_server_socket.setsockopt(socket.SOCK_STREAM, socket.SO_REUSEADDR,1)
# 2.綁定
tcp_server_socket.bind(('', 7890))
# 3.變?yōu)楸O(jiān)聽套接字(最大鏈接書128)
tcp_server_socket.listen(128)
tcp_server_socket.setblocking(False)#將套接字變?yōu)榉亲枞?/p>
#創(chuàng)建一個(gè)epoll對(duì)象
epl = select.epoll()
#將監(jiān)聽套接字對(duì)應(yīng)的FD注冊(cè)到epoll中
epl.register(tcp_server_socket.fileno(),select.EPOLLIN)
client_socket_list =list()
while True:
fd_event_list = epl.poll()#默認(rèn)會(huì)阻塞，直到os檢測(cè)到數(shù)據(jù)到來(lái)棺克，
# 通過(guò)事件通知的方式告訴程序刊棕，此時(shí)才會(huì)解阻塞
# [(fd ,event),(...)]
#參數(shù)fd：套接字對(duì)應(yīng)的文件描述符
#參數(shù)event：這個(gè)fd是什么事件捏鱼，例如可以調(diào)用recv 接收等
for fd,eventin fd_event_list:
# 4.等待新客戶端的鏈接
if fd == tcp_server_socket.fileno():
new_socket,client_addr = tcp_server_socket.accept()
epl.register(new_socket.fileno(),select.EPOLLIN)
elif event == select.EPOLLIN:
#判斷已經(jīng)連接的客戶端是否有數(shù)據(jù)發(fā)送過(guò)來(lái)
recv_data = client_socket.recv(1024).decode('utf-8')
if recv_data:
#為這個(gè)客戶端服務(wù)
service_client(fd_event_dict[fd],recv_data)
else:
fd_event_list[fd].close()
epl.unregister(fd)
del fd_event_dict[fd]
# 6.關(guān)閉監(jiān)聽套接字
tcp_server_socket.close()
if __name__ =='__main__':
main()
epoll的原理
使用了內(nèi)存映射技術(shù) mmap
epoll采用基于事件的就緒通知方式
