Python select
Python的select()方法直接调用操作系统的IO接口，它监控sockets,open files, and pipes(所有带fileno()方法的文件句柄)何时变成readable 和writeable, 或者通信错误，select()使得同时监控多个连接变的简单，并且这比写一个长循环来等待和监控多客户端连接要高效，因为select直接通过操作系统提供的C的网络接口进行操作，而不是通过Python的解释器。
注：使用Python的文件对象选择()为Unix工作，但在Windows下不支持。
select实现socketserver
注：接下来通过echo server例子要以了解select 是如何通过单进程实现同时处理多个非阻塞的socket连接的
注：必须在非阻塞情况下。
服务端：
import select
import socket
import queue server = socket.socket()
server.bind(('localhost' ,9000))
server.listen(1000) # 设置非阻塞模式
server.setblocking(False)
msg_dic = {} # 内核检测并发链接
inputs = [server,] # outputs存放链接需要返回的数据
outputs = [] # 为了循环调入select加入while
while True: # 1,需要内核检测哪些链接，有一个活动就返回所有链接循环。
# 2,处理返回数据。
# 3,如果有并发的链接断开，内核会返回报错到inputs内，有哪几个有问题。
# 有链接进入会返回三个数据：
# readable：返回一个列表，活动的，可读数据的
# writeable：存放需要返回的数据。
# exceptional：返回出现异常的活动链接
readable,writeables,exceptional = select.select(inputs,outputs,inputs)
print(readable,writeables,exceptional) # 收处理
for r in readable:
# 代表来了一个新连接
if r is server: # 等待客户端生成实例
conn,addr = server.accept() # 打印客户端IP地址
print("来了个新连接",addr) # 因为这个新建里的链接还没发数据过来，现在就收数据的话程序就报错了
#所以要想实现客户端发数据来时server端能知道，就需要让select在检测这
#个conn。
inputs.append(conn) # 初始化一个队列，后面存要返回这个客户端的数据
msg_dic[conn] = queue.Queue() # 接收新连接数据
else:
# 获取数据
data = r.recv(1024)
# 打印数据
print("收到数据:",data) # 将返回的数据排列到队列中
msg_dic[r].put(data) # 放入返回的链接队列
outputs.append(r) # 发数据：要返回给客户端的链接列表
for w in writeables:
# 重链接列表中取出队列的实例
data_to_client = msg_dic[w].get()
# 返回给客户端数据
w.send(data_to_client)
# 确保下次循环的时候writeable，不返回这个已经处理完的链接
outputs.remove(w) # 删除：错误链接
for e in exceptional:
# 查找错误链接是否存在outputs
if e in outputs:
# 如果有就删除错误链接
outputs.remove(e)
# 删除inputs下的错误链接
inputs.remove(e)
# 删除队列中的错误链接
del msg_dic[e]
客户端：
import socket
client = socket.socket()
#client.connect(('192.168.1.177',9999))
client.connect(('localhost',9000))
while True:
msg = input(">>:").strip()
if len(msg) == 0:continue
client.send(msg.encode("utf-8"))
data = client.recv(1024)
print("recv:",data.decode())
client.close()
select实现socketserver并发（完整版）
import select
import socket
import sys
import queue server = socket.socket()
server.setblocking(0) server_addr = ('localhost',10000) print('starting up on %s port %s' % server_addr)
server.bind(server_addr) server.listen(5) inputs = [server, ] #自己也要监测呀,因为server本身也是个fd
outputs = [] message_queues = {} while True:
print("waiting for next event...") readable, writeable, exeptional = select.select(inputs,outputs,inputs) #如果没有任何fd就绪,那程序就会一直阻塞在这里 for s in readable: #每个s就是一个socket if s is server: #别忘记,上面我们server自己也当做一个fd放在了inputs列表里,传给了select,如果这个s是server,代表server这个fd就绪了,
#就是有活动了, 什么情况下它才有活动? 当然 是有新连接进来的时候 呀
#新连接进来了,接受这个连接
conn, client_addr = s.accept()
print("new connection from",client_addr)
conn.setblocking(0)
inputs.append(conn) #为了不阻塞整个程序,我们不会立刻在这里开始接收客户端发来的数据, 把它放到inputs里, 下一次loop时,这个新连接
#就会被交给select去监听,如果这个连接的客户端发来了数据 ,那这个连接的fd在server端就会变成就续的,select就会把这个连接返回,返回到
#readable 列表里,然后你就可以loop readable列表,取出这个连接,开始接收数据了, 下面就是这么干 的 message_queues[conn] = queue.Queue() #接收到客户端的数据后,不立刻返回 ,暂存在队列里,以后发送 else: #s不是server的话,那就只能是一个 与客户端建立的连接的fd了
#客户端的数据过来了,在这接收
data = s.recv(1024)
if data:
print("收到来自[%s]的数据:" % s.getpeername()[0], data)
message_queues[s].put(data) #收到的数据先放到queue里,一会返回给客户端
if s not in outputs:
outputs.append(s) #为了不影响处理与其它客户端的连接 , 这里不立刻返回数据给客户端 else:#如果收不到data代表什么呢? 代表客户端断开了呀
print("客户端断开了",s) if s in outputs:
outputs.remove(s) #清理已断开的连接 inputs.remove(s) #清理已断开的连接 del message_queues[s] ##清理已断开的连接 for s in writeable:
try :
next_msg = message_queues[s].get_nowait() except queue.Empty:
print("client [%s]" %s.getpeername()[0], "queue is empty..")
outputs.remove(s) else:
print("sending msg to [%s]"%s.getpeername()[0], next_msg)
s.send(next_msg.upper()) for s in exeptional:
print("handling exception for ",s.getpeername())
inputs.remove(s)
if s in outputs:
outputs.remove(s)
s.close() del message_queues[s]