Python WebSockets消费者和生产者示例需求。

Question

3

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

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

但是没有consumer()和producer()实现的示例或解释。是否有人可以提供任何简单的示例呢?

- shalakhin

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- xyres · Accepted Answer

在第一个例子中，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