select(rlist, wlist, xlist, timeout=None)

#建立两个列表，比如想让内核去检测50个连接，需要传给它一个列表，就是这个inputs（列表中里面存放的是需要被内核监控的链接），然后交给select，就相当于交给内核了
inputs = [server,] #输入列表，监控所有输入数据outputs = []  #输入列表，监控所有输出数据#把两个列表传给select方法通过内核去监控，生成三个实例
readable,writeable,exceptional = select.select(inputs,outputs,inputs)  # 这里select方法的第三个参数同样传入input列表是因为，input列表中存放着所有的链接，比如之前放入的50被监控链接中有5个断了，出现了异常，就会输入到exceptional里面，但这5链接本身是放在inputs列表中

import select,socket,queue
server = socket.socket()
server.bind(("localhost",9000))
server.listen(1000)
server.setblocking(False) #设置为非阻塞
msg_dic = dict() #定义一个队列字典
inputs = [server,]  #由于设置成非阻塞模式，accept和recive都不阻塞了，没有值就会报错，因此最开始需要最开始需要监控服务端本身，等待客户端连接
outputs = []
while True:#exceptional表示如果inputs列表中出现异常，会输出到这个exceptional中readable,writeable,exceptional = select.select(inputs,outputs,inputs)#如果没有任何客户端连接，就会阻塞在这里 for r in readable:# 没有个r代表一个socket链接if r is server:  #如果这个socket是server的话，就说明是是新客户端连接了conn,addr = r.accept() #新连接进来了,接受这个连接，生成这个客户端实例print("来了一个新连接",addr)inputs.append(conn)#为了不阻塞整个程序,我们不会立刻在这里开始接收客户端发来的数据, 把它放到inputs里, 下一次loop时,这个新连接#就会被交给select去监听msg_dic[conn] = queue.Queue() #初始化一个队列，后面存要返回给这个客户端的数据else: #如果不是server，就说明是之前建立的客户端来数据了data = r.recv(1024)print("收到数据：",data)msg_dic[r].put(data)#收到的数据先放到queue里,一会返回给客户端outputs.append(r)#为了不影响处理与其它客户端的连接 , 这里不立刻返回数据给客户端# r.send(data)# print("send done....")for w in writeable:  #要返回给客户端的链接列表data_to_client = msg_dic[w].get()w.send(data_to_client)   #返回给客户端的源数据outputs.remove(w)  #确保下次循环的时候writeable,不返回这个已经处理完的这个连接了for e in exceptional:  #处理异常的连接if e in outputs:   #因为e不一定在outputs，所以先要判断
            outputs.remove(e)inputs.remove(e)   #删除inputs中异常连接del msg_dic[e]   #删除此连接对应的队列

#定义一个对象
sel = selectors.DefaultSelector()#注册一个事件
sel.register(server,selectors.EVENT_READ,accept) #注册事件，只要来一个连接就调accept这个函数，就相当于之前select的用法，sel.register(server,selectors.EVENT_READ,accept) ==  inputs=[server,]，readable,writeable,exceptional = select.select(inputs,outputs,inputs)意思是一样的。

import selectors,socketsel = selectors.DefaultSelector()def accept(sock,mask):"接收客户端信息实例"conn,addr = sock.accept()print("accepted",conn,'from',addr)conn.setblocking(False)sel.register(conn,selectors.EVENT_READ,read)  #新连接注册read回调函数def read(conn,mask):"接收客户端的数据"data = conn.recv(1024)if data:print("echoing",repr(data),'to',conn)conn.send(data)else:print("closing",conn)sel.unregister(conn)conn.close()server = socket.socket()
server.bind(('localhost',9999))
server.listen(500)
server.setblocking(False)
sel.register(server,selectors.EVENT_READ,accept)  #注册事件，只要来一个连接就调accept这个函数,
#sel.register(server,selectors.EVENT_READ,accept) == inputs=[server,]while True:events = sel.select()  #这个select,看起来是select，有可能调用的是epoll，看你操作系统是Windows的还是Linux的#默认阻塞，有活动连接就返回活动连接列表print("事件：",events)for key,mask in events:callback = key.data #相当于调accept了callback(key.fileobj,mask)  #key.fileobj=文件句柄

 [(SelectorKey(fileobj=<socket.socket fd=436, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('127.0.0.1', 2222)>, fd=436, events=1, data=<function accept at 0x0000022296063E18>), 1)]
accepted <socket.socket fd=508, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('127.0.0.1', 2222), raddr=('127.0.0.1', 50281)> from ('127.0.0.1', 50281)
事件： [(SelectorKey(fileobj=<socket.socket fd=508, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('127.0.0.1', 2222), raddr=('127.0.0.1', 50281)>, fd=508, events=1, data=<function read at 0x00000222980501E0>), 1)]
echoing b'adas' to <socket.socket fd=508, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('127.0.0.1', 2222), raddr=('127.0.0.1', 50281)>
事件： [(SelectorKey(fileobj=<socket.socket fd=508, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('127.0.0.1', 2222), raddr=('127.0.0.1', 50281)>, fd=508, events=1, data=<function read at 0x00000222980501E0>), 1)]
echoing b'HA' to <socket.socket fd=508, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('127.0.0.1', 2222), raddr=('127.0.0.1', 50281)>
事件： [(SelectorKey(fileobj=<socket.socket fd=508, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('127.0.0.1', 2222), raddr=('127.0.0.1', 50281)>, fd=508, events=1, data=<function read at 0x00000222980501E0>), 1)]
echoing b'asdHA' to <socket.socket fd=508, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('127.0.0.1', 2222), raddr=('127.0.0.1', 50281)>

import socket,sysmessages = [ b'This is the message. ',b'It will be sent ',b'in parts.',]
server_address = ('localhost', 9999)# 创建100个 TCP/IP socket实例
socks = [ socket.socket(socket.AF_INET, socket.SOCK_STREAM) for i in range(100)]# 连接服务端
print('connecting to %s port %s' % server_address)
for s in socks:s.connect(server_address)for message in messages:# 发送消息至服务端for s in socks:print('%s: sending "%s"' % (s.getsockname(), message) )s.send(message)# 从服务端接收消息for s in socks:data = s.recv(1024)print( '%s: received "%s"' % (s.getsockname(), data) )if not data:print(sys.stderr, 'closing socket', s.getsockname() )