python 创建mqtt服务器

要在Python中创建MQTT服务器，你可以使用Eclipse Paho MQTT库。以下是一个简单的示例代码来创建一个基本的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.Server()
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.start()

上面的代码创建了一个简单的MQTT服务器，并订阅了名为 "topic/test" 的主题。当有新的消息到达时，`on_message` 函数将会被调用，并打印出消息的主题和内容。

你可以根据你的需求来自定义其他的回调函数，比如 `on_publish`、`on_subscribe` 和 `on_disconnect`。

请注意，这只是一个简单的示例，你可以根据你的实际需求进行扩展和修改。