From 873c041b3f6fa4a961c7d28a3852ae6f87ac6fbe Mon Sep 17 00:00:00 2001 From: "Ziheng He (hez40)" Date: Wed, 29 May 2024 10:17:09 +0800 Subject: [PATCH] Update Heziheng --- Heziheng | 31 +++++++++++++++++++++++++++++++ 1 file changed, 31 insertions(+) diff --git a/Heziheng b/Heziheng index 8b13789..8a4c20c 100644 --- a/Heziheng +++ b/Heziheng @@ -1 +1,32 @@ +import time +from paho.mqtt import client as mqtt_client +# MQTT Broker设置 +broker = "your_mqtt_broker_address" +port = 1883 +topic = "your_topic" + +# MQTT客户端设置 +client = mqtt_client.Client() +client.on_connect = on_connect +client.on_publish = on_publish + +# 连接到MQTT Broker +client.connect(broker, port) + +# 运行MQTT客户端 +client.loop_start() + +# 发布消息 +def publish_message(): + result = client.publish(topic, "Hello, MQTT!") + if result[0] == 0: + print("消息发布成功!") + else: + print("消息发布失败!") + +# 发布消息 +publish_message() + +# 断开MQTT连接 +client.loop_stop()