python怎么使用mqtt协议

使用Python实现MQTT协议可以使用paho-mqtt包。

首先需要安装paho-mqtt包：

pip install paho-mqtt

然后可以使用以下代码来连接MQTT服务器，并订阅一个主题：

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))

client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message

client.connect("mqtt.eclipse.org", 1883, 60)

client.loop_forever()

这个代码会连接到一个公共的MQTT服务器（这里使用了mqtt.eclipse.org），并订阅了"test/topic"主题。当有消息发布到该主题时，on_message函数会被调用，并打印出消息的内容。

你也可以使用client.publish()函数来发布消息：

client.publish("test/topic", "Hello, world!")

这个代码会向"test/topic"主题发布一条消息，内容为"Hello, world!"。

当然，你也可以使用其他MQTT服务器，只需要将connect()函数的参数改为对应的服务器地址、端口号和超时时间即可。