Сервер Asyncio Streams обнаруживает отключение ⇐ Python

[Anonymous]

Я переписываю старый сервер с использованием Streams, и одной из проблем, которую мне так и не удалось решить, была проблема с отключением.
Я сделал этот очень простой пример сервера:

Код: Выделить всё

import asyncio

async def handle_client(reader, writer):
address = writer.get_extra_info('peername')
print(f"Connection: {address}")

try:
while True:
data = await reader.read(1024)
if not data:
print(f"Disconnected: {address}.")
break
print(f"{address} Send: {data.decode()}")

writer.write('👍\n'.encode())
await writer.drain()
except Exception as e:
print(f"Something bad happened: {e}")
finally:
print(f"Closed: {address}")
writer.close()
await writer.wait_closed()

async def main():
server = await asyncio.start_server(handle_client, '0.0.0.0', 5678)

async with server:
await server.serve_forever()

asyncio.run(main())

Если я подключаюсь с помощью netcat, все работает, если я закрываю netcat или терминал, он знает, что соединение разорвано. Но если я отключу свою клиентскую сеть, она никогда не узнает, что мой клиент отключен. Я знаю, что это ограничение более низкого уровня, но я думаю о том, как решить эту проблему.
В настоящее время моим лучшим подходом было использование таймаута для принудительного отключения, как в этом примере:
р>

Код: Выделить всё

import asyncio

async def handle_client(reader, writer):
address = writer.get_extra_info('peername')
print(f"Connection: {address}")

try:
while True:
data = await asyncio.wait_for(reader.read(1024), timeout=10.0)
if not data:
print(f"Disconnected: {address}.")
break
print(f"{address} Send: {data.decode()}")

writer.write('👍\n'.encode())
await writer.drain()
except asyncio.TimeoutError:
print(f"Timeout: {address}")
except Exception as e:
print(f"Something bad happened: {e}")
finally:
print(f"Closed: {address}")
writer.close()
await writer.wait_closed()

async def main():
server = await asyncio.start_server(handle_client, '0.0.0.0', 5678)

async with server:
await server.serve_forever()

asyncio.run(main())

Это работает, но мне нужно будет точно настроить свое приложение, чтобы оно подходило ко всем устройствам (и, к сожалению, большинство тех устройств, которые отправляют мне данные, были созданы в то время, когда вы платили за байт). send, поэтому их интервал поддержания активности смехотворно длинный).
Есть ли лучший способ узнать, когда произошло отключение, без необходимости ждать несколько минут тайм-аута?Спасибо за внимание.

Подробнее здесь: https://stackoverflow.com/questions/787 ... connection