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服务器的起点。