python 建立mqtt服务器

要在Python中建立MQTT服务器，您可以使用paho-mqtt库。以下是一个简单的示例：

import paho.mqtt.server as mqtt

def on_connect(client, userdata, flags, rc):
    print("Connected with result code " + str(rc))
    client.subscribe("topic/test")

def on_message(client, userdata, msg):
    print(msg.topic + " " + str(msg.payload))

def on_publish(client, userdata, mid):
    print("Message published")

def on_subscribe(client, userdata, mid, granted_qos):
    print("Subscribed")

def on_disconnect(client, userdata, rc):
    if rc != 0:
        print("Unexpected disconnection")

mqtt_server = mqtt.Mosquitto()
mqtt_server.on_connect = on_connect
mqtt_server.on_message = on_message
mqtt_server.on_publish = on_publish
mqtt_server.on_subscribe = on_subscribe
mqtt_server.on_disconnect = on_disconnect

mqtt_server.connect("localhost", 1883, 60)

mqtt_server.loop_forever()

这个例子创建了一个MQTT服务器并监听本地主机的1883端口。当客户端连接到服务器并发布、订阅或收到消息时，定义的回调函数会被调用。

请确保您已经安装了paho-mqtt库，可以使用以下命令安装：

pip install paho-mqtt

这只是一个简单的示例，您可以根据自己的需求进行扩展和定制。更多关于paho-mqtt库的详细信息，请查阅官方文档。