需要 python websockets 消费者和生产者示例

Question

http://websockets.readthedocs.io/en/stable/intro.html#consumer包含以下示例:

async def consumer_handler(websocket, path):
    while True:
        message = await websocket.recv()
        await consumer(message)

和http://websockets.readthedocs.io/en/stable/intro.html#producer

async def producer_handler(websocket, path):
    while True:
        message = await producer()
        await websocket.send(message)

但是没有consumer() 和producer() 实现的例子，也没有任何解释。有人可以为此提供任何简单的示例吗？

Answer 1

在第一个示例中，consumer_handler 监听来自 websocket 连接的消息。然后它将消息传递给 消费者。在最简单的形式中，消费者可以如下所示:

async def consumer(message):
    # do something with the message 
    

---

在第二个示例中，producer_handler 从 producer 接收消息并将其发送到 websocket 连接。生产者可以是这样的:

async def producer():
    message = "Hello, World!"
    await asyncio.sleep(5) # sleep for 5 seconds before returning message
    return message