epoll是对select、poll模型的改进，提高了网络编程的性能，广泛应用于大规模并发请求的C/S架构中。
原理图
epoll
一般步骤
- Create an epoll object——创建1个epoll对象
- Tell the epoll object to monitor specific events on specific sockets——告诉epoll对象，在指定的socket上监听指定的事件
- Ask the epoll object which sockets may have had the specified event since the last query——询问epoll对象，从上次查询以来，哪些socket发生了哪些指定的事件
- Perform some action on those sockets——在这些socket上执行一些操作
- Tell the epoll object to modify the list of sockets and/or events to monitor——告诉epoll对象，修改socket列表和（或）事件，并监控
- Repeat steps 3 through 5 until finished——重复步骤3-5，直到完成
- Destroy the epoll object——销毁epoll对象
相关用法
import select //导入select模块
epoll = select.epoll() //创建一个epoll对象
epoll.register //(文件句柄,事件类型) 注册要监控的文件句柄和事件
事件类型:
select.EPOLLIN 可读事件
select.EPOLLOUT 可写事件
select.EPOLLERR 错误事件
select.EPOLLHUP 客户端断开事件
epoll.unregister //(文件句柄) 销毁文件句柄
epoll.poll(timeout) //当文件句柄发生变化，则会以列表的形式主动报告给用户进程,timeout为超时时间，默认为-1，即一直等待直到文件句柄发生变化，如果指定为1那么epoll每1秒汇报一次当前文件句柄的变化情况，如果无变化则返回空
epoll.fileno() //返回epoll的控制文件描述符(Return the epoll control file descriptor)
epoll.modfiy(fineno,event) //fineno为文件描述符 event为事件类型 作用是修改文件描述符所对应的事件
epoll.fromfd(fileno) //从1个指定的文件描述符创建1个epoll对象
epoll.close() //关闭epoll对象的控制文件描述符
实例：客户端发送数据 服务端将接收的数据返回给客户端
服务端代码
1 #!/usr/bin/env python
2 #-*- coding:utf-8 -*-
3
4 import socket
5 import select
6 import Queue
7
8 #创建socket对象
9 serversocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
10 #设置IP地址复用
11 serversocket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
12 #ip地址和端口号
13 server_address = ("127.0.0.1", 8888)
14 #绑定IP地址
15 serversocket.bind(server_address)
16 #监听，并设置最大连接数
17 serversocket.listen(10)
18 print "服务器启动成功，监听IP：" , server_address
19 #服务端设置非阻塞
20 serversocket.setblocking(False)
21 #超时时间
22 timeout = 10
23 #创建epoll事件对象，后续要监控的事件添加到其中
24 epoll = select.epoll()
25 #注册服务器监听fd到等待读事件集合
26 epoll.register(serversocket.fileno(), select.EPOLLIN)
27 #保存连接客户端消息的字典，格式为{}
28 message_queues = {}
29 #文件句柄到所对应对象的字典，格式为{句柄：对象}
30 fd_to_socket = {serversocket.fileno():serversocket,}
31
32 while True:
33 print "等待活动连接......"
34 #轮询注册的事件集合，返回值为[(文件句柄，对应的事件)，(...),....]
35 events = epoll.poll(timeout)
36 if not events:
37 print "epoll超时无活动连接，重新轮询......"
38 continue
39 print "有" , len(events), "个新事件，开始处理......"
40
41 for fd, event in events:
42 socket = fd_to_socket[fd]
43 #如果活动socket为当前服务器socket，表示有新连接
44 if socket == serversocket:
45 connection, address = serversocket.accept()
46 print "新连接：" , address
47 #新连接socket设置为非阻塞
48 connection.setblocking(False)
49 #注册新连接fd到待读事件集合
50 epoll.register(connection.fileno(), select.EPOLLIN)
51 #把新连接的文件句柄以及对象保存到字典
52 fd_to_socket[connection.fileno()] = connection
53 #以新连接的对象为键值，值存储在队列中，保存每个连接的信息
54 message_queues[connection] = Queue.Queue()
55 #关闭事件
56 elif event & select.EPOLLHUP:
57 print 'client close'
58 #在epoll中注销客户端的文件句柄
59 epoll.unregister(fd)
60 #关闭客户端的文件句柄
61 fd_to_socket[fd].close()
62 #在字典中删除与已关闭客户端相关的信息
63 del fd_to_socket[fd]
64 #可读事件
65 elif event & select.EPOLLIN:
66 #接收数据
67 data = socket.recv(1024)
68 if data:
69 print "收到数据：" , data , "客户端：" , socket.getpeername()
70 #将数据放入对应客户端的字典
71 message_queues[socket].put(data)
72 #修改读取到消息的连接到等待写事件集合(即对应客户端收到消息后，再将其fd修改并加入写事件集合)
73 epoll.modify(fd, select.EPOLLOUT)
74 #可写事件
75 elif event & select.EPOLLOUT:
76 try:
77 #从字典中获取对应客户端的信息
78 msg = message_queues[socket].get_nowait()
79 except Queue.Empty:
80 print socket.getpeername() , " queue empty"
81 #修改文件句柄为读事件
82 epoll.modify(fd, select.EPOLLIN)
83 else :
84 print "发送数据：" , data , "客户端：" , socket.getpeername()
85 #发送数据
86 socket.send(msg)
87
88 #在epoll中注销服务端文件句柄
89 epoll.unregister(serversocket.fileno())
90 #关闭epoll
91 epoll.close()
92 #关闭服务器socket
93 serversocket.close()
客户端代码
1 #!/usr/bin/env python
2 #-*- coding:utf-8 -*-
3
4 import socket
5
6 #创建客户端socket对象
7 clientsocket = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
8 #服务端IP地址和端口号元组
9 server_address = ('127.0.0.1',8888)
10 #客户端连接指定的IP地址和端口号
11 clientsocket.connect(server_address)
12
13 while True:
14 #输入数据
15 data = raw_input('please input:')
16 #客户端发送数据
17 clientsocket.sendall(data)
18 #客户端接收数据
19 server_data = clientsocket.recv(1024)
20 print '客户端收到的数据：'server_data
21 #关闭客户端socket
22 clientsocket.close()
网友评论