使用Python描述mqtt收发端

MQTT（Message Queuing Telemetry Transport）是一种轻量级的通信协议，常用于物联网（IoT）设备之间的通信。在 Python 中，我们可以使用 Eclipse Paho MQTT 客户端库来实现 MQTT 的收发端。以下是一个简单的示例代码：

收端：

import paho.mqtt.client as mqtt

# 定义回调函数，用于处理收到的消息
def on_message(client, userdata, message):
    print("Received message: ", message.payload.decode())

# 创建 MQTT 客户端对象
client = mqtt.Client()

# 连接到 MQTT 代理服务器
client.connect("broker.hivemq.com", 1883)

# 订阅主题
client.subscribe("test/topic")

# 设置消息回调函数
client.on_message = on_message

# 开始循环监听消息
client.loop_forever()

发端：

import paho.mqtt.client as mqtt

# 创建 MQTT 客户端对象
client = mqtt.Client()

# 连接到 MQTT 代理服务器
client.connect("broker.hivemq.com", 1883)

# 发布消息
client.publish("test/topic", "Hello, MQTT!")

# 断开连接
client.disconnect()

在这个示例中，我们使用了 HiveMQ 的公共 MQTT 代理服务器，当然你也可以使用自己的代理服务器。在收端中，我们首先定义了一个回调函数 `on_message`，用于处理收到的消息。然后我们创建了 MQTT 客户端对象，连接到代理服务器，订阅主题，设置消息回调函数，并开始循环监听消息。在发端中，我们同样创建了 MQTT 客户端对象，连接到代理服务器，发布一条消息，然后断开连接。