mqtt server python_Python使用mqtt极简例子

下面是一个使用Python实现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()

在这个例子中，我们使用paho-mqtt库来实现MQTT客户端的连接。首先，我们定义了两个回调函数on_connect和on_message。on_connect函数在连接到MQTT服务器时被调用，on_message函数在接收到MQTT消息时被调用。
接下来，我们创建一个MQTT客户端对象，然后将on_connect和on_message回调函数赋值给客户端的on_connect和on_message属性。然后我们使用connect方法连接到MQTT服务器，并使用loop_forever方法保持连接。
在on_connect函数中，我们使用subscribe方法订阅了一个主题test/topic。在on_message函数中，我们打印出收到的消息的主题和负载。
这个例子非常简单，但可以作为使用Python连接MQTT服务器的起点。