python 实现MQTT

Python可以使用paho-mqtt库来实现MQTT协议。paho-mqtt是一个Python实现的MQTT客户端库，支持多种MQTT协议版本，包括3.1、3.1.1和5.0版本。下面是一个简单的示例代码：

import paho.mqtt.client as mqtt

# 连接回调函数
def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))
    # 订阅主题
    client.subscribe("test/topic")

# 消息回调函数
def on_message(client, userdata, msg):
    print(msg.topic+" "+str(msg.payload))

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

# 设置连接回调函数
client.on_connect = on_connect

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

# 连接MQTT服务器
client.connect("mqtt.eclipse.org", 1883, 60)

# 开始循环处理网络流量和调用回调函数
client.loop_forever()

在这个示例中，我们使用paho-mqtt库创建了一个MQTT客户端，并连接到了一个公共的MQTT服务器。我们还定义了两个回调函数，一个用于在连接成功后订阅主题，另一个用于在接收到消息时打印消息内容。最后，我们使用`loop_forever()`方法开始循环处理网络流量和调用回调函数。