selor模块

import selectors, socket

sel = selectors.DefaultSelector()


def accept(sock, mask):
    coon, addr = sock.accept()
    print('accepted', coon, 'from', addr)
    coon.setblocking(False)
    sel.register(coon, selectors.EVENT_READ, read)


def read(coon, mask):
    try:
        data = coon.recv(1000)
        if data:
            print('echoing', repr(data), 'to', coon)
            coon.sendall(data)
        else:
            raise Exception
    except:
        print('closing', coon)
        sel.unregister(coon)
        coon.close()


sock = socket.socket()
sock.bind(('127.0.0.1', 8090))
sock.listen(100)
sock.setblocking(False)
sel.register(sock, selectors.EVENT_READ, accept)  # 注册一个对象，和触发该对象后要执行的函数。
print('server..............')
while True:

    events = sel.select()
    for key, mask in events:
        callback = key.data
        callback(key.fileobj, mask)  # key.fileobj是响应的那个对象，比如是socket

客户端

import socket

client_socket = socket.socket()

client_socket.connect(('127.0.0.1',8090))
while True:
    a = input('....')

    client_socket.sendall(a.encode())
    data = client_socket.recv(1024)
    print(data.decode())

阻塞IO      非阻塞IO     IO多路复用