python连接mqtt

要连接MQTT服务器，您可以使用Python的paho-mqtt库。以下是一个简单的示例代码，演示如何连接到MQTT服务器并发布和订阅主题。

首先，您需要安装paho-mqtt库。您可以使用以下命令来安装它：

pip install paho-mqtt

然后，您可以使用以下代码连接到MQTT服务器并发布和订阅主题：

import time
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.server.com", 1883, 60)

# 循环监听网络活动和事件
client.loop_start()

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

# 等待3秒钟，以接收消息
time.sleep(3)

# 断开连接
client.loop_stop()
client.disconnect()

请将上述代码中的mqtt.server.com替换为实际的MQTT服务器地址