asyncio_mqtt 异步订阅三个topic 并发送一个topic

好的，您想了解如何使用asyncio_mqtt异步订阅三个topic并发送一个topic。首先，您需要安装asyncio_mqtt模块：

pip install asyncio_mqtt

然后，您可以使用以下代码来异步订阅三个topic：

import asyncio
from asyncio_mqtt import Client, MqttError

async def subscribe():
    # create an MQTT client instance
    client = Client("mqtt://broker.hivemq.com")

    # connect to the MQTT broker
    await client.connect()

    # subscribe to three topics
    await client.subscribe("topic1")
    await client.subscribe("topic2")
    await client.subscribe("topic3")

    # handle incoming messages
    async with client.filtered_messages("topic1", "topic2", "topic3") as messages:
        async for message in messages:
            print(message.topic, message.payload.decode())

    # disconnect from the MQTT broker
    await client.disconnect()

asyncio.run(subscribe())

在上面的代码中，我们创建了一个MQTT客户端实例，并连接到了MQTT代理。然后，我们使用``await client.subscribe()``方法订阅了三个主题。使用``async with client.filtered_messages()``方法过滤订阅的主题并处理接收到的消息。最后，我们使用``await client.disconnect()``方法断开与MQTT代理的连接。

接下来，您可以使用以下代码来发送一个topic：

import asyncio
from asyncio_mqtt import Client, MqttError

async def publish():
    # create an MQTT client instance
    client = Client("mqtt://broker.hivemq.com")

    # connect to the MQTT broker
    await client.connect()

    # publish a message to a topic
    await client.publish("topic4", "Hello, world!")

    # disconnect from the MQTT broker
    await client.disconnect()

asyncio.run(publish())

在上面的代码中，我们创建了一个MQTT客户端实例，并连接到了MQTT代理。然后，我们使用``await client.publish()``方法发布了一个消息到``topic4``主题。最后，我们使用``await client.disconnect()``方法断开与MQTT代理的连接。

希望以上代码对您有所帮助！