Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import asyncio
- import random
- async def handle_echo(reader, writer):
- while True:
- data = await reader.readline()
- message = data.decode()
- addr = writer.get_extra_info('peername')
- print(f"Received {message!r} from {addr!r}")
- message = f'pong{random.randint(0,10)}\n'
- response = message.encode()
- writer.write(response)
- await writer.drain()
- if reader.at_eof():
- break
- print("Close the connection")
- writer.close()
- async def main():
- server = await asyncio.start_server(
- handle_echo, '127.0.0.1', 8888)
- addr = server.sockets[0].getsockname()
- print(f'Serving on {addr}')
- async with server:
- await server.serve_forever()
- asyncio.run(main())
Add Comment
Please, Sign In to add comment