python mqtt服务器

您可以使用 Eclipse Paho 或者 Mosquitto 来搭建 Python MQTT 服务器。以下是使用 Eclipse Paho 搭建 MQTT 服务器的简单示例代码：

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

# 创建 MQTT 客户端
client = mqtt.Client()

# 设置连接成功和接收消息的回调函数
client.on_connect = on_connect
client.on_message = on_message

# 连接 MQTT 服务器
client.connect("mqtt.eclipse.org", 1883, 60)

# 保持连接
client.loop_start()

try:
    while True:
        # 发布消息
        client.publish("test/topic", "Hello, MQTT!")
        time.sleep(1)
except KeyboardInterrupt:
    pass

# 断开连接
client.loop_stop()
client.disconnect()

这个例子连接到公共 MQTT 测试服务器 "mqtt.eclipse.org"，并订阅 "test/topic" 主题。在循环中，每秒发布一条消息，并通过回调函数打印接收到的消息。

您可以根据实际需求修改服务器地址、端口和主题等信息。记得在使用之前安装 `paho-mqtt` 包。