Python의 선택 모듈 예제 튜토리얼-파이썬 튜토리얼-php.cn

Python의 선택 모듈 예제 튜토리얼

PHPz

풀어 주다： 2017-05-01 09:36:18

원래의

1494명이 탐색했습니다.

select method

프로세스는 파일 설명자 이벤트가 발생하지 않을 때 커널이 수신하는 파일 설명자(최대 1024 fds)와 이벤트를 지정합니다. , 프로세스가 차단되고 하나 이상의 파일 설명자 이벤트가 발생하면 프로세스가 활성화됩니다.

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을 반환합니다. 모니터링되는 경우 목록 변경 사항을 처리하면 직접 실행됩니다.

예:

Select를 사용하여 On the On에서 동시 서버

import socket
import select
 
s = socket.socket()
s.bind((&#39;127.0.0.1&#39;,8888))
s.listen(5)
r_list = [s,]
num = 0
while True:
 rl, wl, error = select.select(r_list,[],[],10)
 num+=1
 print(&#39;counts is %s&#39;%num)
 print("rl&#39;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((&#39;first----%s&#39;%conn.fileno()).encode())
  else:
   try:
    msg = fd.recv(200)
    fd.sendall(&#39;second&#39;.encode())
   except ConnectionAbortedError:
    r_list.remove(fd)
 
s.close()

로그인 후 복사

import socket
 
flag = 1
s = socket.socket()
s.connect((&#39;127.0.0.1&#39;,8888))
while flag:
 input_msg = input(&#39;input>>>&#39;)
 if input_msg == &#39;0&#39;:
  break
 s.sendall(input_msg.encode())
 msg = s.recv(1024)
 print(msg.decode())
 
s.close()

로그인 후 복사

를 구현합니다. 서버 측에서는 select를 계속 호출해야 한다는 것을 알 수 있습니다. 이는 다음을 의미합니다.

　1 파일 설명자가 너무 많으면 사용자 공간과 커널 공간 간에 파일 설명자를 복사하는 데 시간이 많이 걸립니다.

　2 파일 설명자가 너무 많으면 커널이 파일 설명자를 순회하는 것도 시간 낭비입니다

　3 Select는 최대 1024개의 파일 설명자만 지원합니다

poll 은 select Large와 거의 동일하므로 이 글에서는 소개하지 않겠습니다

epoll 방식:

epoll이 select를 매우 잘 개선했습니다:

　1. epoll의 솔루션은 다음과 같습니다. epoll_ctl 함수. epoll 핸들에 새 이벤트가 등록될 때마다 epoll_wait 동안 반복되는 복사 대신 모든 fd가 커널에 복사됩니다. epoll은 각 fd가 전체 프로세스 동안 한 번만 복사되도록 보장합니다.

2. epoll은 epoll_ctl 중에 지정된 fd를 순회하고(이번은 필수) 각 fd에 대한 콜백 함수를 지정합니다. 장치가 준비되고 대기 대기열에 있는 웨이터를 깨우면 이 콜백 함수는 이 콜백 함수는 준비된 fd를 준비된 연결 목록에 추가합니다. epoll_wait의 작업은 실제로 이 준비된 목록에 준비된 fd가 있는지 확인하는 것입니다

3. epoll에는 파일 설명자에 대한 추가 제한이 없습니다

select .epoll(sizehint=-1, flags=0) epoll 객체 생성

epoll.close()

epoll 객체의 제어 파일 설명자를 닫습니다. epoll 개체 파일 설명자

epoll.closed

epoll 개체가 닫혀 있는지 여부를 감지합니다.

epoll.fileno()

컨트롤 fd의 파일 설명자 번호를 반환합니다. epoll 개체의 파일 설명자를 반환합니다

epoll.fromfd(fd)

지정된 파일 설명자에서 epoll 개체를 만듭니다.

epoll.register(fd[, eventmask])

epoll 개체에 fd 설명자를 등록합니다. epoll 개체에 fd 및 해당 이벤트를 등록합니다.

epoll.modify(fd, eventmask)

등록된 파일 수정 descriptor.fd 이벤트 수정

epoll.unregister(fd)

epoll 개체에서 등록된 파일 설명자를 제거합니다.Unregister

epoll.poll(timeout=-1, maxevents=-1)

등록된 fd 이벤트가 발생할 때까지 초(float) 블록 단위의 시간 초과를 기다리면 다음 형식으로 dict가 반환됩니다. {(fd1 ,event1),(fd2,event2),…(fdn,eventn)}

이벤트:

EPOLLIN 읽기 가능 읽기 가능 상태 기호는 1

EPOLLOUT 쓰기 가능 상태 코드는 4

EPOLLPRI 읽기용 긴급 데이터

EPOLLERR assoc에서 오류 조건이 발생했습니다. 오류 상태 코드는 다음과 같습니다. 8

EPOLLHUP 연결 끊김 상태

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()时，它不会通知你，也就是它只会通知你一次，直到该文件描述符上出现第二次可读写事件才会通知你！！！这种模式比水平触发效率高，系统不会充斥大量你不关心的就绪文件描述符！！！缺点：某些条件下不可靠

epoll实例：

import socket
import select
 
s = socket.socket()
s.bind((&#39;127.0.0.1&#39;,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(&#39;ok&#39;.encode())
  else:
   try:
    fd_obj = connections[fd]
    msg = fd_obj.recv(200)
    fd_obj.sendall(&#39;ok&#39;.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((&#39;127.0.0.1&#39;,8888))
while flag:
 input_msg = input(&#39;input>>>&#39;)
 if input_msg == &#39;0&#39;:
  break
 s.sendall(input_msg.encode())
 msg = s.recv(1024)
 print(msg.decode())
 
s.close()

로그인 후 복사

위 내용은 Python의 선택 모듈 예제 튜토리얼의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!