python asyncio Telnet連接斷開：服務器端阻塞問題的解析與解決方案
在使用Python的asyncio庫構建網絡服務器時，經常會遇到Telnet客戶端連接后立即斷開的問題。本文將分析此問題，并提供有效的解決方案。
問題描述：
一個簡單的asyncio TCP服務器，使用telnet客戶端連接后，立即顯示“connection closed by foreign host.”錯誤，表明服務器主動關閉了連接。 問題根源在于服務器端的處理函數阻塞。
立即學習“Python免費學習筆記（深入）”；
原始代碼（存在問題）：
import asyncio from asyncio.base_events import server async def handle_client(reader, writer): while True: data = await reader.readline() if not data: break writer.write(data) writer.close() async def main(): server: server = await asyncio.get_running_loop().create_server( handle_client, '127.0.0.1', 8888) async with server: await server.serve_forever() asyncio.run(main())
reader.readline()方法會阻塞，直到讀取到換行符(‘n’)。Telnet客戶端連接成功后不會立即發送數據，導致reader.readline()無限期阻塞，最終導致連接超時并被服務器關閉。
解決方案：
改進后的handle_client函數，在連接建立后立即發送歡迎信息，并使用reader.read(100)代替reader.readline()，避免阻塞等待換行符。await writer.drain()確保數據被正確發送。
改進后的代碼：
async def handle_client(reader, writer): welcome_message = "Welcome to the server!n" writer.write(welcome_message.encode()) await writer.drain() while True: data = await reader.read(100) if not data: break writer.write(data) await writer.drain() writer.close()
通過這些修改，Telnet客戶端可以成功連接到服務器并進行正常的交互。 reader.read(100) 讀取最多100字節的數據，即使客戶端沒有發送換行符，也能繼續執行，避免了阻塞。 await writer.drain() 確保數據被完全發送到客戶端，避免數據丟失。
通過以上分析和代碼改進，我們可以有效解決Python asyncio Telnet連接立即斷開的問題，構建更穩定可靠的網絡服務器。
? 版權聲明
文章版權歸作者所有，未經允許請勿轉載。
THE END
