1
import paho.mqtt.client as mqtt
2
import time
3

4
# MQTT服务器配置
5
broker = "test.mosquitto.org"  # 公共测试服务器
6
port = 1883
7
topic = "test/topic/cloudsir"
8

9
# 连接回调
10
def on_connect(client, userdata, flags, reason_code, properties):
11
    print("连接结果: " + str(reason_code))
12
    client.subscribe(topic)
13
    client.publish(topic, "Hello MQTT", qos=1, retain=False)
14

15
# 接收到消息的回调
16
def on_message(client, userdata, msg):
17
    print(f"收到消息: {msg.topic} -> {msg.payload.decode()}")
18

19
# 创建客户端实例
20
client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2, client_id="test-client")
21

22
# 设置账户名和密码
23
# client.username_pw_set("your_username", "your_password")
24

25
# 绑定回调函数
26
client.on_connect = on_connect
27
client.on_message = on_message
28

29
# 连接
30
client.connect(broker, port, keepalive=60)
31

32
# 启动后台消息循环线程
33
client.loop_start()
34

35
# 50s后关闭连接
36
time.sleep(60)
37
client.loop_stop()
38
client.disconnect()