需要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连接的消息。然后它将消息传递给consumer。最简单的形式，它看起来像这样：

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