asyncio_mqtt 异步订阅三个topic 并持续发送topic

好的，让我来解答您的问题。

首先，您需要安装 `asyncio-mqtt` 库，可以使用以下命令进行安装：

pip install asyncio-mqtt

接下来，您可以使用以下代码进行异步订阅三个 topic，并持续发送 topic：

import asyncio
from asyncio_mqtt import Client, MqttError

async def on_message(client, topic, payload, qos, properties):
    print('Received message on topic "{}": {}'.format(topic, payload.decode()))

async def main():
    # 创建 MQTT 客户端
    client = Client('localhost')

    # 连接到 MQTT 代理
    await client.connect()

    # 订阅三个 topic
    await client.subscribe([
        ('topic1', 0),
        ('topic2', 0),
        ('topic3', 0)
    ])

    # 持续发送 topic
    while True:
        try:
            await client.publish('topic4', b'Hello, world!', qos=0)
            await asyncio.sleep(1) # 间隔 1 秒发送一次
        except MqttError as e:
            print('MQTT 发送消息出错：{}'.format(str(e)))

    # 断开连接
    await client.disconnect()

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

在上面的代码中，我们定义了一个 `on_message` 函数，用于处理接收到的消息。然后，我们创建了一个 MQTT 客户端，连接到 MQTT 代理，并订阅了三个 topic。最后，我们使用一个 while 循环来持续发送 topic4，并使用 `asyncio.sleep` 函数来控制发送间隔。当发送出错时，我们会捕获 `MqttError` 异常，并进行处理。最后，我们在 `main` 函数中使用 `asyncio.run` 来运行主循环。

希望这个回答能够帮到您！