#同步：提交一个任务之后，要等待这个任务执行完毕
       #比如去银行存钱，要取完号才能存钱
#异步：只管提交任务，不等待这个任务执行完毕，就可以做其他事情
        #可以边存钱，边玩手机
#阻塞：recv recvfrom accpt    取号的时候，等待人很多
#非阻塞： #很多种情况了


#recv 等待数据准备，等待数据从内核拷贝到进程
#send 讲用户要发送的信息copy到操作系统  发送的时候的网络延迟
        #主动方所以阻塞很小

import socket
sk = socket.socket()
sk.bind((‘127.0.0.1‘,8088))
sk.setblocking(False) #~~~~~~~~~~~~~~将阻塞设置为不阻塞
sk.listen()
conn_lst = []
del_lst = []
while True:
    try:
        conn,addr = sk.accept()
        print(‘建立了连接‘,addr)
        conn_lst.append(conn)
        # msg = conn.recv(1024).decode(‘utf8‘) #注释1
        # print(msg)
    except BlockingIOError:
        for con in conn_lst: #循环反复的获取con
            try:
                msg = con.recv(1024)  # 这里还是非阻塞，还是会报错
                if msg == b‘‘:                       # 但是如果一直从一个关闭的client获取数据，会一直打印空
                    del_lst.append(con)  #不能 conn_lst.remove(con) 不能再for循环中列表里的元素，index会错误
                    continue #当con传过来为空，就不执行后面的语句了，要进行下一个循环
                print(msg)
                con.send(b‘bye‘)
            except BlockingIOError:pass
        for con in del_lst:
            con.close()
            conn_lst.remove(con)
        del_lst.clear()

#注释1：
    #此处有两种情况，第一种由于我此时是不阻塞的（setblocking）client端以非常快速的和我聊天，导致while循环就没效果了，别人接收不了请求了
    #但是如果只快速的发了一句，然后server就只能接收这一句，接下来就会因为非阻塞，然后这个conn就被内存给冲掉了
    #第二种由于此时是阻塞的，client如果慢了一点给我传消息，我马上会跳过，并且报错BlockingIOError

#解决方法：
    #建立一个conn列表，把每次连接成功的conn，放到列表里。并且把recv放到 except语句后，因为没信息就会报错。
    #然后for循环这个conn列表，一直去尝试获取，conn是否发了消息过来
    #从而让本来本内存刷掉的conn，可以一直被尝试获取
    #但是此是for循环的列表里，recv还是非阻塞的，所以要继续异常处理

import time
import socket
import threading

def func():
    sk = socket.socket()
    sk.connect((‘127.0.0.1‘, 8088))
    sk.send(b‘hello‘)
    time.sleep(0.1)
    print(sk.recv(1024))
    sk.close()

for i in range(20):
    threading.Thread(target=func).start()

import socket
import select

sk = socket.socket()
sk.bind((‘127.0.0.1‘,8080))
sk.setblocking(False)
sk.listen()

read_lst = [sk]

while True:
    r_lst,w_lst,x_lst = select.select(read_lst,[],[]) #read_lst中的监听对象，只有有回应的，才会出现在 r_lst
    print(‘***‘,r_lst) # 注释1
    for i in r_lst:
        if i is sk:
            conn,addr = sk.accept()
            read_lst.append(conn)
        else:
            ret = i.recv(1024)
            if ret == b‘‘:
                i.close()
                read_lst.remove(i)  # 此时 r_lst和read_lst是两个不同内存空间，可以remove
                continue
            print(ret)
            i.send(b‘goodbye‘)

#注释1
    #此时经历过一次连接后，read_lst本来是有着 [conn,sk], 然后此时如果有人给我发消息，也就是我此时 conn.recv了
    #由于 select模块， 此时的r_lst只有 conn了，因为没有人连接我，sk也就不会出现在 r_lst里

import time
import socket
import threading

def func():
    sk = socket.socket()
    sk.connect((‘127.0.0.1‘,8080))
    sk.send(b‘hello‘)
    time.sleep(3)
    print(sk.recv(1024))
    sk.close()

for i in range(20):
    threading.Thread(target=func).start()