#select模拟socketserver
import select,queue,socket
server=socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind(('localhost',2223))
server.listen(5)
server.setblocking(False)
inputs=[server,]#一开始要先监测server，知道是否建立连接
outputs=[]
msg_dic={}
while True:readable, writable, excetional = select.select(inputs, outputs, inputs)  # select 进行监听for r in readable:if r is server:#表示建立连接conn,addr=server.accept()conn.setblocking(False)#非阻塞inputs.append(conn)#select监测连接过来的实例'''新建立的连接还没发数据过来，现在就接收数据的话是空的，会报错，因此要让select监测每一个连接过来的连接，这样才知道客户端发送数据过来'''msg_dic[conn]=queue.Queue()#初始化一个队列，用于存放每一个连接的数据print('建立连接',addr)else:try:data=r.recv(1024)#不可以直接判断数据是否为空，因为客户端断开时服务器已经接收不到数据了#有数据发送过来print(data.decode())msg_dic[r].put(data)if r not in outputs:outputs.append(r)  # 放入返回的连接队列里,下一次循环select检测的时候发给客户端except ConnectionResetError as e:#处理没有数据的情况，即服务器断开print(addr,' is close...')if r in outputs:#移除连接
                    outputs.remove(r)inputs.remove(r)r.close()del msg_dic[r]breakfor w in writable:try:next_msg = msg_dic[w].get_nowait()#从队列中取元素，不等待except queue.Empty:# print('output queue for', w.getpeername(), 'is empty')
            outputs.remove(w)else:# print('sending "%s" to %s' % (next_msg, w.getpeername()))
            w.send(next_msg)# outputs.remove(w)#从outputs中移除旧的连接for e in excetional:#发生异常就将连接移除
        inputs.remove(e)if e in outputs:outputs.remove(e)e.close()del msg_dic[e]#从队列中移除连接

import socket
client=socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client.connect(('localhost',2223))
while True:cmd=input(">>>")if cmd=='':continueclient.send(cmd.encode())data=client.recv(1024)print(data.decode())