#方法：sk.setblocking(False)

#服务器端：
import socket
sk=socket.socket()
sk.setblocking(False)
sk.bind(('127.0.0.1',8080))
sk.listen()
#定义空列表用于存放各个conn
Conn_List = []
#定义删除列表用于删除Conn_List中断开连接的客户端conn
Conn_Del = []

while 1:
    try:
        conn,addr = sk.accept() #如果是阻塞IO，此时程序会一直在这里等待
        Conn_List.append(conn)  #将监听到的conn对象放到conn列表中，即为多客户端连接
    except BlockingIOError:
        '''如果try中没有客户端连接，则执行该代码块，判断客户端是否向服务器发送数据'''
        #遍历conn列表，看看有没有客户端发送数据
        for conn in Conn_List:
            try:
                #尝试接收数据
                info = conn.recv(1024).decode('utf-8')
                #注意！如果客户端正常关闭，即客户端执行了close，服务器会接收到一个空
                if not info:
                    #如果收到空，证明客户端断开连接，将该conn添加到删除列表中，用于后面删除Conn_List中对应的conn
                    Conn_Del.append(conn)
                    print('客户端已经断开连接了')
                    #在服务器中关闭对应的conn
                    conn.close()
                else:
                    '''服务器逻辑层'''
                    # 如果收到客户端的数据，逻辑层返回数据给客户端
                    print('这是接收到来自客户端{}的数据:{}'.format(conn,info))
                    #返回数据给客户端(例如将客户端的数据小写转为大写返回给客户端)
                    conn.send(info.upper().encode('utf-8'))
            except BlockingIOError:
                '''如果本次循环中该conn没有发送数据，则执行该代码块，即对下一个conn通信'''
                continue
            except ConnectionResetError:
                '''如果本次循环中该conn强制退出，则不执行任何操作'''
                pass
        #删除列表删除Conn_List中已经正常断开连接的客户端conn
        if Conn_Del:
            for conn in Conn_Del:
                Conn_List.remove(conn)
            #在删除完正常关闭链接的客户端后，应该把删除列表清空，否则会报错
            Conn_Del = []
            
            
#客户端：
import socket
sk = socket.socket()
sk.connect(('127.0.0.1',8080))
while 1:
    msg_s = input('>>>')
    if not msg_s:continue
    if msg_s == 'q':break
    sk.send(msg_s.encode('utf-8'))
    print(sk.recv(1024).decode('utf-8'))
sk.close()