py写一个mqtt服务器代码
时间: 2023-03-25 09:01:13 浏览: 83
以下是一个简单的 Python MQTT 服务器代码示例:
```python
import paho.mqtt.server 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))
def on_publish(client, userdata, mid):
print("Message published")
def on_subscribe(client, userdata, mid, granted_qos):
print("Subscribed to topic")
def on_unsubscribe(client, userdata, mid):
print("Unsubscribed from topic")
def on_disconnect(client, userdata, rc):
print("Disconnected with result code "+str(rc))
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_unsubscribe = on_unsubscribe
mqtt_server.on_disconnect = on_disconnect
mqtt_server.connect("localhost", 1883, 60)
mqtt_server.loop_forever()
```
这个代码使用 Paho MQTT 库创建了一个 MQTT 服务器,并订阅了一个名为 "test/topic" 的主题。当有消息发布到这个主题时,服务器会打印出消息的主题和内容。