python epoll多路复用技术_python IO 多路复用 epoll简单模型

IO多路复用就是我们说的select poll epoll

通过一种机制使一个进程能同时等待多个文件描述符,而这些文件描述符(套接字描述符)其中的任意一个进入读就绪状态,epoll()函数就可以返回。所以,IO多路复用,本质上不会有并发的功能,因为任何时候还是只有一个进程或线程进行工作,它之所以能提高效率是因为epoll把进来的socket放到他们的‘监视’列表里面,当任何socket有可读可写数据立马处理,那如果epoll手里同时检测着很多socket,一有动静马上返回给进程处理,总比一个一个socket过来,阻塞等待,处理高效率。

为什么要选择epoll而不使用select或者poll呢?

(1)epoll解决了前两者将fd集合从用户态拷贝到内核态时开销大的问题

(2)epoll和poll一样解决了select连接数受限的问题

(3)epoll不想前两者那样去边离轮询所有fd集合,而是将套接字添加到epoll的监听事件中

epoll常用事件

EPOLLIN   可读事件

EPOLLOUT    可写事件

EPOLLHUP    挂起事件

EPOLLET    ET模式

eopll对文件描述符的操作有两种模式:LT和ET。LT模式是默认模式,LT模式与ET模式的区别如下:

LT模式:当epoll检测到描述符事件发生并将此事件通知应用程序,应用程序可以不立即处理该事件。下次调用epoll时,会再次响应应用程序通知此事件

ET模式:当epoll检测到描述符事件发生并将此事件通知应用程序,应用程序必须立即处理该事件。如果不处理,下次调用epoll时,不会再次响应应用程序并通知此事件

importsocketimportselect

server_socket=socket.socket(socket.AF_INET, socket.SOCK_STREAM)

server_socket.bind(("", 8000))

server_socket.listen(128)#创建一个epoll对象

epoll =select.epoll()#将套接字添加到epoll的事件监听中

epoll.register(server_socket.fileno(), select.EPOLLIN|select.EPOLLET)#创建字典用来存储客户端套接字信息

connections ={}

addresses={}whileTrue:#epoll进行fd扫描

epoll_list =epoll.poll()#对事件进行判断

for fd, events inepoll_list:#如果是server socket被激活

if fd ==server_socket.fileno():

new_socket, new_addr=server_socket.accept()print('有新的客户端到来%s' %str(new_addr))#将客户端套接字信息存放在字典中

connections[new_socket.fileno()] =new_socket

addresses[new_socket.fileno()]=new_addr#将客户端套接字添加到epoll的时间监听中

epoll.register(new_socket.fileno(), select.EPOLLIN)#如果客户端套接字发送数据

elif events ==select.EPOLLIN:#接收数据

revcData = connections[fd].recv(1024).decode()ifrevcData:print("recv:%s"%revcData)#修改当前套接字的文件描述符

epoll.modify(fd, select.EPOLLOUT)#如果客户端套接字为写数据时

elif events ==select.EPOLLOUT:#发送数据

content = "

hello world

"response= "HTTP/1.1 200 OK\r\nContent-Length:%d\r\n\r\n%s"%(len(content), content)

connections[fd].send(response.encode())#修改当前套接字的文件描述符

epoll.modify(fd, 0)#禁止该套接字收发数据

connections[fd].shutdown(socket.SHUT_RDWR)#当客户端套接字处于挂起时

elif events ==select.EPOLLHUP:#注销文件描述符

epoll.unregister(fd)#关闭套接字

connections[fd].close()print("%s----offline----"%str(addresses[fd]))#删除字典中的信息

delconnections[fd]del addresses[fd]

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/340511.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

python3多线程协程_python3-----多进程、多线程、多协程

目前计算机程序一般会遇到两类I/O:硬盘I/O和网络I/O。我就针对网络I/O的场景分析下python3下进程、线程、协程效率的对比。进程采用multiprocessing.Pool进程池,线程是自己封装的进程池,协程采用gevent的库。用python3自带的urlllib.request和…

Apache CXF 3.0:CDI 1.1支持替代Spring

几周前刚刚发布了Apache CXF 3.0 ,该项目又迈出了满足JAX-RS 2.0规范要求的又一个重要步骤:与CDI 1.1集成。 在此博客文章中,我们将看几个有关Apache CXF 3.0和Apache CXF 3.0如何协同工作的示例。 从3.0版开始, Apache CXF包含一…

java varbinary_SQL 中存放 varbinary型数据

使用带有 BULK 选项的 OPENROWSET以下 Transact-SQL 增强功能支持 OPENROWSET(BULK...)函数:与 SELECT 一起使用的 FROM 子句可以调用 OPENROWSET(BULK...)而非表名,同时可以实现完整的 SELECT 功能。带有 BULK 选项的 OPENROWSET 在 FROM 子句中需要有一…

python矩阵左除_matlab学习笔记

Matlab学习笔记运算:1. 算术运算(在矩阵意义下进行):要求矩阵同型,对应元素相加减,如果用标量和矩阵相加减,不同型就凉凉提示错误,那就将矩阵每个元素和数字相加减-:同上*:A*B要求左行右列,…

只读副本和Spring Data第1部分:配置数据库

这是有关我们为利用只读副本来提高应用程序性能而寻求的一系列博客文章。 对于这个项目,我们的目标是建立我们的spring数据应用程序,并使用read仓库进行写操作,并基于read副本进行读操作。 为了模拟这种环境,我们将通过Docker使…

java结构体系_java io结构体系

Java IO体系结构看似庞大复杂,其实有规律可循,要弄清楚其结构,需要明白两点:1. 其对称性质:InputStream 与 OutputStream, Reader 与 Writer,他们分别是一套字节输入-输出,字符输入-输出体系2. 原始处理器(适配器)与链接流处理器(装饰器)其结构图如下:Reader-Writer体系1. 基类…

python turtle应用实例_turtle库应用实例2-六芒星的绘制

‪‬‪‬‪‬‪‬‪‬‮‬‪‬‮‬‪‬‪‬‪‬‪‬‪‬‮‬‪‬‪‬‪‬‪‬‪‬‪‬‪‬‮‬‭‬‫‬‪‬‪‬‪‬‪‬‪‬‮‬‫‬‪‬‪‬‪‬‪‬‪‬‪‬‮‬‫‬‭‬‪‬‪‬‪‬‪‬‪‬‮‬‪‬‭‬描述使用turtle库绘制一个六角形,效果如下:‪…

java按钮改变窗口大小_布局似乎有问题,JButton在调整窗口大小时显示出意外的行为。...

很好的例子的问题可能与平台有关,但我可以提供一些观察:您没有添加或删除组件,所以您不需要revalidate().由于背景色是按钮的绑定属性,因此不需要后续调用repaint().你,你们做需要repaint()在你的习惯里DrawingArea&am…

JUnit 5和Selenium –使用Selenium内置的`PageFactory`实现页面对象模式

Selenium是一组支持浏览器自动化的工具和库,主要用于Web应用程序测试。 Selenium的组件之一是Selenium WebDriver,它提供客户端库,JSON有线协议(与浏览器驱动程序进行通信的协议)和浏览器驱动程序。 Selenium WebDrive…

python 配置文件中密码不能是明文_配置文件中明文密码改为密文密码的方法

我们用java链接数据库,不管是web项目还是小程序,都需要把数据库密码写在配置文件中(当然你要写死在程序里也没有办法),或者数据库中,通常源代码漏洞扫描都会告诉你不能有明文密码,那么有什么办法可以变为密文呢&#x…

java.lang 源码剖析_java.lang.Void类源码解析

在一次源码查看ThreadGroup的时候,看到一段代码,为以下:/** throws NullPointerException if the parent argument is {code null}* throws SecurityException if the current thread cannot create a* thread in the specified thread group…

vant按需引入没样式_vue vant-ui样式出不来的问题

第一步:安装vantnpm i vant -S // 或 yarn add vant第二步:配置按需引入// 在 babel.config.js 中配置 module.exports {plugins: [[import, {libraryName: vant,libraryDirectory: es,style: true}, vant]] };第三步:配置vue.config.js&…

javaserver_如何在JavaServer Pages中使用Salesforce REST API

javaserver摘要:本教程提供了一个JSP示例以及如何将其与Salesforce REST API集成。 我们将逐步完成创建外部客户端以使用Force.com (同时使用HTTP(S)和JSON)管理数据的分步过程。 在此示例中,我将Mac OS X…

jmeter线程数并发数区别_如何确定Kafka的分区数、key和consumer线程数、以及不消费问题解决...

在Kafak中国社区的qq群中,这个问题被提及的比例是相当高的,这也是Kafka用户最常碰到的问题之一。本文结合Kafka源码试图对该问题相关的因素进行探讨。希望对大家有所帮助。怎么确定分区数?“我应该选择几个分区?”——如果你在Kaf…

简述java规范要注意哪些问题_JAVA学习:JAVA基础面试题(经典)

第一阶段题库基础知识部分:1. JDK是什么?JRE是什么?a) 答:JDK:java开发工具包。JRE:java运行时环境。2. 什么是java的平台无关性?a) 答:Java源文件被编译成字节码的形式,…

我可以/应该在事务上下文中使用并行流吗?

介绍 长话短说,您不应在并行流中使用事务。 这是因为并行流中的每个线程都有其自己的名称,因此它确实参与了事务。 Streams API旨在在某些准则下正常工作。 实际上,为了受益于并行性,不允许每个操作更改共享对象的状态&#xff0…

插入排序java_「Java」各类排序算法

排序大的分类可以分为两种:内排序和外排序。在排序过程中,全部记录存放在内存,则称为内排序,如果排序过程中需要使用外存,则称为外排序。下面讲的排序都是属于内排序。内排序有可以分为以下几类:(1) 插入排…

java object... arguments_Java面试之基础题---对象Object

参数传递:Java支持两种数据类型:基本数据类型和引用数据类型。原始数据类型是一个简单的数据结构,它只有一个与之相关的值。引用数据类型是一个复杂的数据结构,它表示一个对象。原始数据类型的变量将该值直接存储在其存储器地址处…

华为光伏usb适配器_华为系列原装充电器拆解第三弹:比亚迪版华为10W充电器

在对华为18W充电器的比亚迪版和赛尔康版进行拆解之后,充电头网今天继续为大家带来华为10W充电器的比亚迪版和达宏版的拆解。这两种10W规格的华为充电器外观延续了华为原装充电器的风格,而且型号也是一样的。那么,我们先一起来看看比亚迪版华为…

JMetro版本11.5.10和8.5.10发布

在这里,我们再次使用JMetro的另一个版本。 此版本中的新增功能: 工具栏内控件的新样式 新的可编辑组合框样式 对其他样式的一些调整 一些修复 继续阅读以获取详细信息。 可编辑的ComboBox新样式 JMetro早期版本的可编辑ComboBox看起来非常糟糕&am…