asyncio_mqtt 异步持续订阅三个topic

您好！可以使用 asyncio_mqtt 库来异步持续订阅三个 topic。以下是一个简单的示例代码：

import asyncio
import asyncio_mqtt

async def handle_message(client, topic, payload):
    print(f"Received message on topic '{topic}': {payload.decode()}")

async def main():
    client = asyncio_mqtt.Client("mqtt://localhost")

    # 连接 MQTT 服务器
    await client.connect()

    # 订阅三个 topic
    await client.subscribe("topic1")
    await client.subscribe("topic2")
    await client.subscribe("topic3")

    # 循环接收消息
    async with client.unfiltered_messages() as messages:
        async for message in messages:
            await handle_message(client, message.topic, message.payload)

    # 断开连接
    await client.disconnect()

if __name__ == "__main__":
    asyncio.run(main())

在上面的代码中，我们首先创建了一个 asyncio_mqtt.Client 对象，并使用它连接到本地 MQTT 服务器。接下来，我们订阅了三个 topic，然后使用 client.unfiltered_messages() 方法获取一个消息流，循环接收消息并调用 handle_message() 函数进行处理。最后，我们在 main() 函数末尾断开了连接。

注意，上面的示例代码中使用了 asyncio.run() 函数来运行主函数。这需要 Python 3.7 或更高版本。如果您使用的是早期版本的 Python，请使用以下代码替换最后一行：

loop = asyncio.get_event_loop()
loop.run_until_complete(main())

希望这可以帮助您开始使用 asyncio_mqtt 订阅多个 topic。如果您有任何问题，请随时问我。