• 機器人專題(114學年)

客戶端接收訊息

• 講義

• 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 主機。

  import paho.mqtt.client as mqtt
  
  # MQTT Broker 設定
  broker = "200.1.1.22"
  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()