单进程-单线程-非阻塞-长链接;epoll实现http服务器;epoll的原理

单进程-单线程-非阻塞-长链接

import socket

import re

def service_client(new_socket):

# '''为这个客户端返回数据'''

# 1.接收浏览器发送出来的请求,即HTTP请求

# 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)# !!!!!!!!网页名字

        if file_name ='/index.html'

    # 2.返回HTTP格式的数据给浏览器

    try:

f =open('.../Desktop/项目/项目.html', 'rb')

# f = open('.../Desktop/项目/项目.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 准备发送给浏览器的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发送给浏览器

        new_socket.send(response)

def main():

    #用来完成整提的控制

    # 1.创建套接字

    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.变为监听套接字(最大链接书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.为这个客户端服务

                    service_client(client_socket,recv_data)

else:

client_socket.close()

client_socket_list.remove(client_socket)

# 6.关闭监听套接字

    tcp_server_socket.close()

if __name__ =='__main__':

main()



epoll实现http服务器

import socket

import re

import select

def service_client(new_socket):

# '''为这个客户端返回数据'''

# 1.接收浏览器发送出来的请求,即HTTP请求

# 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)# !!!!!!!!网页名字

if file_name ='/index.html'

# 2.返回HTTP格式的数据给浏览器

try:

f =open('.../Desktop/项目/项目.html', 'rb')

# f = open('.../Desktop/项目/项目.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 准备发送给浏览器的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发送给浏览器

new_socket.send(response)

def main():

#用来完成整提的控制

# 1.创建套接字

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.变为监听套接字(最大链接书128)

tcp_server_socket.listen(128)

tcp_server_socket.setblocking(False)#将套接字变为非阻塞

#创建一个epoll对象

epl = select.epoll()

#将监听套接字对应的FD注册到epoll中

epl.register(tcp_server_socket.fileno(),select.EPOLLIN)

client_socket_list =list()

while True:

fd_event_list = epl.poll()#默认会阻塞,直到os检测到数据到来,

# 通过事件通知的方式告诉程序,此时才会解阻塞

# [(fd ,event),(...)]

#参数fd:套接字对应的文件描述符

#参数event:这个fd是什么事件,例如可以调用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:

#判断已经连接的客户端是否有数据发送过来

recv_data = client_socket.recv(1024).decode('utf-8')

if recv_data:

#为这个客户端服务

service_client(fd_event_dict[fd],recv_data)

else:

fd_event_list[fd].close()

epl.unregister(fd)

del fd_event_dict[fd]

# 6.关闭监听套接字

tcp_server_socket.close()

if __name__ =='__main__':

main()


epoll的原理

使用了内存映射技术 mmap

epoll采用基于事件的就绪通知方式

(共享内存,事件通知)

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 212,383评论 6 493
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,522评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 157,852评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,621评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,741评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,929评论 1 290
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,076评论 3 410
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,803评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,265评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,582评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,716评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,395评论 4 333
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,039评论 3 316
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,798评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,027评论 1 266
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,488评论 2 361
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,612评论 2 350

推荐阅读更多精彩内容