客戶端接收訊息
-
從客戶端接收一段「how are you」訊息給 MQTT 主機。
import paho.mqtt.client as mqtt # MQTT Broker 設定 broker = "192.168.1.116" port = 1883 topic = "test/topic" # 當收到訊息時的回呼函數 def on_message(client, userdata, msg): print(f"收到訊息: {msg.topic} -> {msg.payload.decode()}") # 建立 MQTT Client 並設定回呼 client = mqtt.Client() client.on_message = on_message # 連線到 MQTT Broker 並訂閱 client.connect(broker, port, 60) client.subscribe(topic) # 永久保持連線等待訊息 client.loop_forever()