了解了IO多路复用，我们就来看看python中是如何使用的。Python中有一个select模块，其中提供了：select、poll、epoll三个方法，分别调用系统的 select，poll，epoll 从而实现IO多路复用。（下面以select方法为例）
Windows Python：
提供： select
Mac Python：
提供： select
Linux Python：
提供： select、poll、epoll
注意：网络操作、文件操作、终端操作等均属于IO操作，对于windows只支持Socket操作，其他系统支持其他IO操作，但是无法检测 普通文件操作 自动上次读取是否已经变化。
对于select方法：
句柄列表11, 句柄列表22, 句柄列表33=select.select(句柄序列1, 句柄序列2, 句柄序列3, 超时时间)
参数： 可接受四个参数（前三个必须）
返回值：三个列表
select方法用来监视文件句柄，如果句柄发生变化，则获取该句柄。
1、当 参数1序列中的句柄发生可读时（accetp和read），则获取发生变化的句柄并添加到 返回值1序列中
2、当 参数2序列中含有句柄时，则将该序列中所有的句柄添加到 返回值2序列中
3、当 参数3序列中的句柄发生错误时，则将该发生错误的句柄添加到 返回值3序列中
4、当 超时时间 未设置，则select会一直阻塞，直到监听的句柄发生变化(时间设置)
当 超时时间 ＝1时，那么如果监听的句柄均无任何变化，则select会阻塞1秒，之后返回三个空列表，如果监听的句柄有变化，则直接执行。
利用select实现伪同时处理多个Socket客户端请求：服务端
!/usr/bin/python
-- coding: utf-8 --
"""
@version: ??
@author: Guanjie Zhou
@license: Apache Licence
@file: server.py
@time: 17-5-25 下午9:50
"""
'''
服务器的实现 采用select的方式
'''
import select
import socket
import sys
import Queue
创建套接字并设置该套接字为非阻塞模式
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.setblocking(0)
绑定套接字
server_address = ('localhost', 10000)
server.bind(server_address)
将该socket变成服务模式
backlog等于5，表示内核已经接到了连接请求，但服务器还没有调用accept进行处理的连接个数最大为5
这个值不能无限大，因为要在内核中维护连接队列
server.listen(5)
初始化读取数据的监听列表,最开始时希望从server这个套接字上读取数据
inputs = [server]
初始化写入数据的监听列表，最开始并没有客户端连接进来，所以列表为空
outputs = []
要发往客户端的数据
message_queues = {}
while inputs:
print('waiting for the next event')
# 调用select监听所有监听列表中的套接字，并将准备好的套接字加入到对应的列表中
readable, writable, exceptional = select.select(inputs, outputs, inputs) # 列表中的socket 套接字 如果是文件呢？
# 监控文件句柄有某一处发生了变化 可写 可读 异常属于Linux中的网络编程
# 属于同步I/O操作，属于I/O复用模型的一种
# rlist--等待到准备好读
# wlist--等待到准备好写
# xlist--等待到一种异常
# 处理可读取的套接字
'''
如果server这个套接字可读，则说明有新链接到来
此时在server套接字上调用accept,生成一个与客户端通讯的套接字
并将与客户端通讯的套接字加入inputs列表，下一次可以通过select检查连接是否可读
然后在发往客户端的缓冲中加入一项，键名为:与客户端通讯的套接字，键值为空队列
select系统调用是用来让我们的程序监视多个文件句柄(file descrīptor)的状态变化的。程序会停在select这里等待，
直到被监视的文件句柄有某一个或多个发生了状态改变
'''
'''
若可读的套接字不是server套接字,有两种情况:一种是有数据到来，另一种是链接断开
如果有数据到来,先接收数据,然后将收到的数据填入往客户端的缓存区中的对应位置，最后
将于客户端通讯的套接字加入到写数据的监听列表:
如果套接字可读.但没有接收到数据，则说明客户端已经断开。这时需要关闭与客户端连接的套接字
进行资源清理
'''
print ('111')
for s in readable:
if s is server:
connection, client_address = s.accept()
print('connection from', client_address)
connection.setblocking(0) # 设置非阻塞
inputs.append(connection)
# 将新连接的套接字链接通话建立到一个队列中去
message_queues[connection] = Queue.Queue()
else:
data = s.recv(1024).decode()
if data:
print('received "%s" from %s' % \
(data, s.getpeername()))
message_queues[s].put(data)
if s not in outputs:
# 不存在ｏｕｔｐｕｔｓ列表中的，加入到ｏｕｔｐｕｔｓ中
outputs.append(s)
else:
print('closing', client_address)
if s in outputs:
outputs.remove(s)
inputs.remove(s)
s.close()
del message_queues[s]
# 处理可写的套接字
'''
在发送缓冲区中取出响应的数据，发往客户端。
如果没有数据需要写，则将套接字从发送队列中移除，select中不再监视
'''
for s in writable:
try:
next_msg = message_queues[s].get_nowait()
except Queue.Empty:
print(' ', s.getpeername(), 'queue empty')
outputs.remove(s)
else:
print('sending "%s" to %s' % \
(next_msg, s.getpeername()))
s.send(next_msg)
# 处理异常情况
for s in exceptional:
for s in exceptional:
print('exception condition on', s.getpeername())
inputs.remove(s)
if s in outputs:
outputs.remove(s)
s.close()
del message_queues[s]
利用select监听终端操作实例
!/usr/bin/python
-- coding: utf-8 --
"""
@version: ??
@author: Guanjie Zhou
@license: Apache Licence
@file: client.py
@time: 17-5-26 下午1:11
"""
import socket
ip_port= ('127.0.0.1',10000)
sk = socket.socket()
sk.connect(ip_port)
while True:
inp = raw_input("please input:").encode()
sk.sendall(inp)
data = sk.recv(1024).decode()
print data+'hello'
sk.close()
