Пример простейшего асинхронного клиент сервера

import asyncio, socket
 
 
async def listener(client):
    request = (await loop.sock_recv(client, 255)).decode('utf8')
    print(f'клиент в сети: {request},port={client.getpeername()[1]}')
    try:
        while request != 'quit':
            request = (await loop.sock_recv(client, 255)).decode('utf8')
            response = f'{request}'
            print(client.getpeername()[1], response)
            # await loop.sock_sendall(client, response.encode('utf8'))
        client.close()
    except ConnectionResetError:
        print(f'клиент отключился: {request},port={client.getpeername()[1]}')
 
 
async def sender(client):
    command = None
    try:
        while command is not 'quit':
            await asyncio.sleep(5)
            # command = await loop.run_in_executor(None, input, '>> ')
            command = str(client.getpeername()[1])
            await loop.sock_sendall(client, command.encode('utf8'))
        client.close()
    except ConnectionResetError:
        pass
 
 
async def run_server():
    print(f'сервер запущен..')
    while True:
        client, mes = await loop.sock_accept(tcp_server)
        print(client)
        loop.create_task(sender(client))
        loop.create_task(listener(client))
 
 
tcp_server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
tcp_server.bind(('localhost', 15555))
tcp_server.listen(50)
tcp_server.setblocking(False)
 
# заготовка для видеопотока
udp_server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
udp_server.bind(('localhost', 15000))
 
loop = asyncio.get_event_loop()
loop.run_until_complete(run_server())

import socket
 
client_id = '1234'
client_name = 'Иванов Иван Иваныч'
authorization = f'id={client_id},name={client_name}'
 
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
print('Подключение к серверу...')
while True:
    try:
        client.connect(('localhost', 15555))
        break
    except ConnectionRefusedError:
        pass
print('Подключение к серверу установлено.')
 
request = None
 
try:
    client.send(authorization.encode('utf8'))
    while request != 'quit':
        # request = input('>> ')
        response = client.recv(255).decode('utf8')
        if response:
            client.send(response.encode('utf8'))
 
            print(response)
except ConnectionResetError:
    print('Удаленный хост принудительно разорвал существующее подключение')
    client.close()