select()를 호출할 때:
1. 커널 상태로 컨텍스트 전환
2. fd를 사용자 공간에서 커널 공간으로 복사
3. 커널은 해당 이벤트가 발생하는지 확인하기 위해 모든 fd를 순회합니다
4. 이벤트가 발생하지 않으면 프로세스가 차단되고 장치 드라이버가 인터럽트를 생성하거나 타임아웃이 발생하면 프로세스가 깨어나서 다시 순회됩니다. 🎜>
5. 탐색된 fd를 반환합니다 6. 커널 공간에서 사용자 공간으로 fd를 복사합니다. fd:file descriptor 파일 설명자 fd_r_list, fd_w_list, fd_e_list = select.select(rlist, wlist, xlist, [timeout])매개변수: 4개의 매개변수 허용(처음 3개는 필수)rlist: 읽을 준비가 될 때까지 기다립니다wlist: 쓰기 준비가 될 때까지 대기xlist: “예외 조건” 대기timeout: 타임아웃 시간반환 값: 세 개의 목록select 메소드는 파일 디스크립터를 모니터링하는 데 사용됩니다(파일 디스크립터 조건이 충족되지 않으면 select가 차단됩니다). 파일 디스크립터의 상태가 변경되면 세 개의 목록이 반환됩니다 1. fd 매개변수 1 시퀀스에서 "읽기 가능" 조건을 충족하면 변경된 fd를 가져와 fd_r_list 에 추가합니다. 2. 매개변수 2 시퀀스에 fd가 포함되면 시퀀스의 모든 fd가 fd에 추가됩니다. fd_w_list 3. 매개변수 3의 순서에서 fd에 오류가 발생하면 오류가 있는 fd가 fd_e_list 에 추가됩니다. 4. 시간 제한이 비어 있으면 다음을 선택합니다. 모니터링되는 핸들이 변경될 때까지 차단됩니다. 시간 제한 = n(양의 정수)일 때 모니터링되는 핸들에 변화가 없으면 선택은 n 초 동안 차단한 다음 3개의 null을 반환합니다. 모니터링되는 경우 목록 변경 사항을 처리하면 직접 실행됩니다.예:
import socket
import select
s = socket.socket()
s.bind(('127.0.0.1',8888))
s.listen(5)
r_list = [s,]
num = 0
while True:
rl, wl, error = select.select(r_list,[],[],10)
num+=1
print('counts is %s'%num)
print("rl's length is %s"%len(rl))
for fd in rl:
if fd == s:
conn, addr = fd.accept()
r_list.append(conn)
msg = conn.recv(200)
conn.sendall(('first----%s'%conn.fileno()).encode())
else:
try:
msg = fd.recv(200)
fd.sendall('second'.encode())
except ConnectionAbortedError:
r_list.remove(fd)
s.close()import socket flag = 1 s = socket.socket() s.connect(('127.0.0.1',8888)) while flag: input_msg = input('input>>>') if input_msg == '0': break s.sendall(input_msg.encode()) msg = s.recv(1024) print(msg.decode()) s.close()
를 구현합니다. 서버 측에서는 select를 계속 호출해야 한다는 것을 알 수 있습니다. 이는 다음을 의미합니다.
select .epoll(sizehint=-1, flags=0) epoll 객체 생성
EPOLLIN 읽기 가능 읽기 가능 상태 기호는 1
EPOLLET Set Edge Trigger behavior, the default is Level Trigger behavior 默认为水平触发，设置该事件后则边缘触发
EPOLLONESHOT Set one-shot behavior. After one event is pulled out, the fd is internally disabled
EPOLLRDNORM Equivalent to EPOLLIN
EPOLLRDBAND Priority data band can be read.
EPOLLWRNORM Equivalent to EPOLLOUT
EPOLLWRBAND Priority data may be written.
EPOLLMSG Ignored.
水平触发和边缘触发：
Level_triggered(水平触发，有时也称条件触发)：当被监控的文件描述符上有可读写事件发生时，epoll.poll()会通知处理程序去读写。如果这次没有把数据一次性全部读写完(如读写缓冲区太小)，那么下次调用 epoll.poll()时，它还会通知你在上没读写完的文件描述符上继续读写，当然如果你一直不去读写，它会一直通知你！！！如果系统中有大量你不需要读写的就绪文件描述符，而它们每次都会返回，这样会大大降低处理程序检索自己关心的就绪文件描述符的效率！！！ 优点很明显：稳定可靠
Edge_triggered(边缘触发，有时也称状态触发)：当被监控的文件描述符上有可读写事件发生时，epoll.poll()会通知处理程序去读写。如果这次没有把数据全部读写完(如读写缓冲区太小)，那么下次调用epoll.poll()时，它不会通知你，也就是它只会通知你一次，直到该文件描述符上出现第二次可读写事件才会通知你！！！这种模式比水平触发效率高，系统不会充斥大量你不关心的就绪文件描述符！！！缺点：某些条件下不可靠
import socket
import select
s = socket.socket()
s.bind(('127.0.0.1',8888))
s.listen(5)
epoll_obj = select.epoll()
epoll_obj.register(s,select.EPOLLIN)
connections = {}
while True:
events = epoll_obj.poll()
for fd, event in events:
print(fd,event)
if fd == s.fileno():
conn, addr = s.accept()
connections[conn.fileno()] = conn
epoll_obj.register(conn,select.EPOLLIN)
msg = conn.recv(200)
conn.sendall('ok'.encode())
else:
try:
fd_obj = connections[fd]
msg = fd_obj.recv(200)
fd_obj.sendall('ok'.encode())
except BrokenPipeError:
epoll_obj.unregister(fd)
connections[fd].close()
del connections[fd]
s.close()
epoll_obj.close()import socket flag = 1 s = socket.socket() s.connect(('127.0.0.1',8888)) while flag: input_msg = input('input>>>') if input_msg == '0': break s.sendall(input_msg.encode()) msg = s.recv(1024) print(msg.decode()) s.close()
위 내용은 Python의 선택 모듈 예제 튜토리얼의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
