Example of the asynchronous socket server with asyncio

asyncio-socket-server.py

# David Beazley async socket server example
# Loops very similar to a 'regular' threaded socket server
# Except we create an event loop and use async/await syntax

import asyncio
import socket

loop = asyncio.get_event_loop()

async def server(address):
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    sock.bind(address)
    sock.listen(5)
    sock.setblocking(False)

    while True:
        client, addr = await loop.sock_accept(sock)
        print('Connection from: ', addr)
        loop.create_task(echo_handler(client))


async def echo_handler(client):
    with client:
        while True:
            data = await loop.sock_recv(client, 10000)
            if not data:
                break
            await loop.sock_sendall(client, data)
    print('Connection closed')

loop.create_task(server(('', 8000)))
loop.run_forever()