io多路复用

#coding=utf-8
#IO多路复用
#必须在非阻塞状态下才能使用socket的多路复用
import select
import socket
import sys
import Queue

sever = socket.socket()
sever.bind((‘localhost‘,9000))
sever.listen(1000)

sever.setblocking(False)   #设置非阻塞模式
inputs = [sever]
outputs = []
msg_dict = dict()
while True:
    readable,writeable,exceptionable = select.select(inputs,outputs,inputs)   #检测到的链接放到inputs里面
    print readable,writeable,exceptionable
    for r in readable:
        if r is sever:
            con,addr=sever.accept()
            inputs.append(con)#因为新建立的链接没有发数据，因为是非阻塞，所以会出错，因此要把con加入select的监测列表
            print ‘有新的连接接入‘,con,addr
            msg_dict[con] = Queue.Queue()
        else:
            try:
                data = r.recv(1024)
                print ‘收到数据：‘,data
            except socket.error:
                print ‘客户端断开了：‘,
                inputs.remove(r)
                continue
            r.send(data)
            msg_dict[r].put(data)
            outputs.append(r)#放入返回的链接

    for w in writeable:    #要返回给客户端的了链接列表
        data1 = msg_dict[w].get()
        w.send(data1)    #返回给客户端数据
        outputs.remove(w) #确保斜刺循环的时候不返回已经处理的列表
    # sever.accept()
        for e in exceptionable:
            if e in outputs:
                outputs.remove(e)
            inputs.remove()
            del msg_dict[e]

#selector模块
import selectors
import socket

sel = selectors.DefaultSelector()


def accept(sock, mask):
    conn, addr = sock.accept()  # Should be ready
    print(‘accepted‘, conn, ‘from‘, addr,mask)
    conn.setblocking(False)
    sel.register(conn, selectors.EVENT_READ, read) #新连接注册read回调函数，一调用read说明conn有数据接受了


def read(conn, mask):
    data = conn.recv(1024)  # Should be ready
    if data:
        print(‘echoing‘, repr(data), ‘to‘, conn)  #repr？？
        conn.send(data)  # Hope it won‘t block
    else:
        print(‘closing‘, conn)
        sel.unregister(conn)
        conn.close()


sock = socket.socket()
sock.bind((‘localhost‘, 9999))
sock.listen(100)
sock.setblocking(False)
sel.register(sock, selectors.EVENT_READ, accept)   #让select监听。回调函数accept。有活动就调此函数

while True:
    events = sel.select() #默认阻塞，有活动连接就返回活动的连接列表
    for key, mask in events:
        callback = key.data #accept
        callback(key.fileobj, mask) #key.fileobj=  文件句柄