Python3.8 asyncio Streams 和读取

Question

这可能是一个愚蠢的问题，但我遗漏了一些我认为可能很明显的东西：

我正在使用 Python 3.8 异步流：

import asyncio

async def client_handler():
    reader, writer = await asyncio.open_connection('127.0.0.1', 9128)

    server_name = writer.get_extra_info('peername')[0]
    print(f"Connecting to: { server_name }")
    data = b''
    close_client = False
    try:
        while not close_client:
            print(data)
            data = await reader.read(1024)
            print(data)
            if data != b'':
                print(data.decode('utf-8'))
                data = b''
        writer.close()
    except:
        pass
    finally:
        writer.close()
        await writer.wait_closed()

asyncio.run(client_handler())

我想我预计它会尝试读取 1024 字节，但如果那里什么都没有，那么它只会返回 None 或空字节字符串或其他东西，但它只是坐在那里直到接收到数据。

我是否误解了 read 应该做什么？是否可以使用另一种方法来查看缓冲区或轮询以查看是否有任何数据实际传入？

例如，假设我正在编写一个示例聊天程序服务器和客户端，它们需要能够同时动态发送和接收数据......我如何使用 asyncio 流实现它？我应该只构建自己的 asyncio.Protocol 子类吗？

Answer 1

您可以使用asyncio.gather()、asyncio.wait(return_when=FIRST_COMPLETED) 和asyncio.wait_for() 等工具在不同的操作之间进行多路复用，例如从不同的流中读取或读取和写入。如果没有关于您的用例的更多详细信息，很难给您具体的建议如何继续。

构建asyncio.Protocol 或直接使用feed_eof() 几乎肯定是错误的方法，除非您正在编写非常专业的软件并且确切地知道自己在做什么。