@
1.介绍
epoll是一种解决方案，nginx就是用的这个
中心思想：不要再使用多进程，多线程了，使用单进程，单线程去实现并发
在上面博客实现的代码中使用过的轮询去查看套接字有没有数据，而epoll是主动通知
当使用多进程的时候，是复制一份资源去查看，epoll不用复制，直接来
优势：1.共享内存 2.事件通知
2.代码
import socket
import select
def tcp_server(new_tcp_socket, request):
request_lines = request.splitlines()
print(request_lines)
print(">" * 30)
try:
file = open("./test/login.html", "rb")
except:
# 构造响应头
response_header = "HTTP/1.1 404 NOT FOUND\r\n"
response_header += "\r\n"
response_header += "----file not found-----"
new_tcp_socket.send(response_header.encode("utf-8"))
else:
html_content = file.read()
file.close()
response_body = html_content
response_header = "HTTP/1.1 200 OK\r\n"
# 使用Content-Length实现长连接
response_header += "Content-Length:%d\r\n" % len(response_body)
response_header += "\r\n"
response = response_header.encode("utf-8") + response_body
# 发送响应数据
new_tcp_socket.send(response)
def main():
"""对大致流程进行控制"""
# 1.创建tcp套接字
tcp_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 设置当服务器先close()即服务器4次挥手之后资源立即释放
tcp_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
# 2.绑定端口
tcp_socket.bind(("", 7890))
# 3.监听套接字
tcp_socket.listen(128)
tcp_socket.setblocking(False)
# 创建一个epoll对象
epoll = select.epoll()
# 将监听套接字对应的fd注册到epoll中，并绑定事件 fd:文件描述符
epoll.register(tcp_socket.fileno(), select.EPOLLIN)
# 定义保存socket的字典
fd_event_dict = dict()
while True:
# 默认堵塞，直到OS检测到数据到来通过事件通知方式告诉程序，才会解堵塞 返回list
fd_event_list = epoll.poll()
# [(fd,event)] (套接字对应的文件描述符，这个文件描述符对应的到底是什么事件，例如可以调用recv接收等)
# 遍历元组
for fd, event in fd_event_list:
if fd == tcp_socket.fileno():
new_tcp_socket, client_addr = tcp_socket.accept()
epoll.register(new_tcp_socket.fileno(), select.EPOLLIN)
# 通过字典保存socket，键为fd,值为socket
fd_event_dict[new_tcp_socket.fileno()] = new_tcp_socket
elif event == select.EPOLLIN:
# 判断已经链接的客户端是否有数据发送过来
recv_data = fd_event_dict[fd].recv(1024).decode("utf-8")
if recv_data:
# 有数据操作
# 4.为这个客户端服务
tcp_server(fd_event_dict[fd], recv_data)
else:
# 无数据操作
fd_event_dict[fd].close()
epoll.unregister(fd)
del fd_event_dict[fd]
# 关闭监听套接字
tcp_socket.close()
if __name__ == '__main__':
main()
关于作者
web服务器-并发服务器2
阅读目录 1.Web静态服务器-5-非堵塞模式 2.Web静态服务器-6-epoll 3.Web静态服务器-7-gevent版 4.知识扩展-C10K问题 一.Web静态服务器-5-非堵塞模式 单进程 ...
14_Web服务器-并发服务器
1.服务器概述 1.硬件服务器(IBM,HP): 主机 集群 2.软件服务器(HTTPserver Django flask): 网络服务器,在后端提供网络功能逻辑处理数据处理的程序或者架构等 3.服 ...
Python复习笔记(十)Http协议--Web服务器-并发服务器
1. HTTP协议(超文本传输协议) 浏览器===>服务器发送的请求格式如下:(浏览器告诉服务器,浏览器的信息) GET / HTTP/1.1 Host: www.baidu.com Conne ...
Web服务器-并发服务器-长连接(3.4.4)
@ 目录 1.说明 2.代码 关于作者 1.说明 每次new_socket都被强制关闭,造成短连接 所提不要关闭套接字 但是不关闭的话,浏览器不知道发完没有啊 此时用到header的属性Content ...
Web服务器-并发服务器-单进程单线程非堵塞方式(3.4.3)
@ 目录 1.分析 2.代码 关于作者 1.分析 当socket去监听的时候,是堵塞的状态 通过tcp_sever_socket.setblocking(False)去设置不堵塞 当socket发现没 ...
Web服务器-并发服务器-协程 (3.4.2)
@ 目录 1.分析 2.代码 关于作者 1.分析 随着网站的用户量越来愈多,通过多进程多线程的会力不从心 使用协程可以缓解这一问题 只要使用gevent实现 2.代码 from socket impo ...
Web服务器-并发服务器-多进程(3.4.1)
@ 目录 1.优化分析 2.代码 3. 关于作者 1.优化分析 在单进程的时候,相当于 是来一个客户,派一个人去服务一下 效率低,现在使用多进程来服务 假设场景 100个人同时访问页面 单进程:一次处 ...
linux学习之多高并发服务器篇(一)
高并发服务器 高并发服务器 并发服务器开发 1.多进程并发服务器 使用多进程并发服务器时要考虑以下几点: 父最大文件描述个数(父进程中需要close关闭accept返回的新文件描述符) 系统内创建进程 ...
手把手让你实现开源企业级web高并发解决方案(lvs+heartbeat+varnish+nginx+eAccelerator+memcached)
原创作品,允许转载,转载时请务必以超链接形式标明文章 原始出处 .作者信息和本声明.否则将追究法律责任.http://freeze.blog.51cto.com/1846439/677348 此文凝聚 ...
随机推荐
linux查找日志常用命令
1.查找文件test中目标字符串(xxxx)出现的行数位置grep -n xxxx test 2.文件test从某一行(n)开始显示more +n test 3.查询文件test中出现目标字符串x ...
vector容器总结.xml
1 清空所有元素 m_itemVector.clear(); 2 遍历 vector::iterator iter=m_itemVector.b ...
SPI移位寄存器
spi移位寄存器即是spi的数据寄存器,在stm32中数据手册是这样描述的:
基于Node.js的实时推送 juggernaut
基于Node.js的实时推送 juggernaut Juggernaut 基于 Node.js 构建.为浏览器和服务器端提供一个实时的连接,可在客户端和服务器端进行数据的实时推送,适合多角色游戏.聊天 ...
C++输入输出缓冲区的刷新问题
当我们对文件流进行操作的时候,它们与一个streambuf 类型的缓存(buffer)联系在一起.这个缓存(buffer)实际是一块内存空间,作为流(stream)和物理文件的媒介.例如,对于一个输出 ...
exec 重定向
文件中常用的重定向: command > filename把把标准输出重定向到一个新文件中command >> filename 把把标准输出重定向到一个文件中 (追加)comman ...
hdu_1017(水水水，坑格式)
#include #include using namespace std; int main() { int T; scanf("%d ...
list.remove的使用分析
场景描述 在做需求中,有很多情况会出现 对一个list遍历并过滤掉其中特定的数据 这种场景 .但是按照平常的使用方式,发现报错了. public static void main(String[] a ...
ABP框架 配置权限、本地语言文件、左侧菜单项
1.Framework.Core>Authorization>PermissionNames.cs 这里新增权限项 namespace Framework.Authorization { ...
JavaScript 循环：如何处理 async/await
如何串行或者并行运行异步循环? 在使用循环处理异步的魔法之前,我们先来看下我们是怎么处理同步循环的. 同步循环 很久以前我写的循环是这样的: for (var i = 0; i < array. ...
