客戶端發佈訊息
-
1.建立 Python 虛擬環境。
Raspberry Pi
cd Desktop mkdir mqtt cd mqtt python3 -m venv venv cd venv cd bin source activate cd .. cd ..
2.確認你的電腦上已經安裝 paho-mqtt:
python3 -m pip install paho-mqtt
3.確認 Mosquitto 或其他 MQTT Broker 已啟動並且可以連線。
從客戶端發送一段「how are you」訊息給 MQTT 主機,,而且每隔 5 秒重複發送。
將以下程式碼儲存成檔案「publish.py」。
import paho.mqtt.client as mqtt import time # MQTT Broker 設定 broker = "200.1.1.22" # 如果有 Mosquitto,可以改成 IP,例如 "192.168.1.100" port = 1883 topic = "test/topic" # 建立 MQTT Client client = mqtt.Client() # 連線到 MQTT Broker client.connect(broker, port, 60) try: while True: message = "how are you?" client.publish(topic, message) print(f"已發佈訊息: {message}") time.sleep(5) # 每 5 秒發佈一次 except KeyboardInterrupt: print("停止發佈") client.disconnect()
4.執行程式
python3 publish.py
5.執行結果
Mac