Removed the old main.py
gelöscht: main.py
This commit is contained in:
@@ -1,38 +0,0 @@
|
|||||||
import asyncio
|
|
||||||
|
|
||||||
HOST = "127.0.0.1"
|
|
||||||
PORT = 8888
|
|
||||||
|
|
||||||
async def handle_client(reader: asyncio.StreamReader, writer: asyncio.StreamWriter):
|
|
||||||
addr = writer.get_extra_info('peername')
|
|
||||||
print(f'Connection to {addr}')
|
|
||||||
|
|
||||||
try:
|
|
||||||
while True:
|
|
||||||
data = await reader.read(1024)
|
|
||||||
if not data:
|
|
||||||
break
|
|
||||||
|
|
||||||
message = data.decode().strip()
|
|
||||||
print(f'Received from {addr}: {message}')
|
|
||||||
|
|
||||||
writer.write(data)
|
|
||||||
|
|
||||||
await writer.drain()
|
|
||||||
finally:
|
|
||||||
print(f'Connection closed: {addr}')
|
|
||||||
writer.close()
|
|
||||||
await writer.wait_closed()
|
|
||||||
|
|
||||||
|
|
||||||
async def main():
|
|
||||||
server = await asyncio.start_server(handle_client, HOST, PORT)
|
|
||||||
addr = ', '.join(str(sock.getsockname()) for sock in server.sockets)
|
|
||||||
print(f'Listening on {addr}')
|
|
||||||
|
|
||||||
async with server:
|
|
||||||
await server.serve_forever()
|
|
||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
|
||||||
asyncio.run(main())
|
|
||||||
Reference in New Issue
Block a user