-
Notifications
You must be signed in to change notification settings - Fork 0
/
server.py
31 lines (24 loc) · 840 Bytes
/
server.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
import os
import asyncio
HOST = "127.0.0.1"
PORT = int(os.environ['SERVER_PORT'])
async def handle_client(reader: asyncio.StreamReader, writer: asyncio.StreamWriter):
client_addr = writer.get_extra_info('peername')
print(f'Cliente conectado: {client_addr}')
while True:
data = await reader.read(1024)
if not data:
break
print(f'Dados recebidos de {client_addr}: {data.decode()}')
writer.write(data)
await writer.drain()
print(f'Cliente {client_addr} desconectado.')
writer.close()
async def main():
server = await asyncio.start_server(handle_client, HOST, PORT)
addr = server.sockets[0].getsockname()
print(f'Servidor rodando em {addr}')
async with server:
await server.serve_forever()
if __name__ == '__main__':
asyncio.run(main())