以下のコードを実行しようとすると、画面が空白のままになり、クライアントがブローカーに接続されていることが示されません。
#! /usr/bin/python
import paho.mqtt.client as mqtt
broker = "localhost"
#define what happens after connection
def on_connect(rc):
print "Connection returned result: "+str(rc)
#On recipt of a message do action
def on_message(msg):
n = msg.payload
t = msg.topic
print t+" "+str(n)
# create broker
mqttc = mqtt.Client()
#define callbacks
mqttc.on_message = on_message
mqttc.on_connect = on_connect
#connect
mqttc.connect(broker, 1883, 60)
#Subscribe to topic
mqttc.subscribe("/sensor/rfid", 2)
#keep connected
mqttc.loop_forever()
実行できたので、ブローカーが適切に実行されていることを確認できます
mosquitto_sub -t /sensor/rfid
AndroidフォンのMyMQTTアプリから送信されたメッセージを取得します。また、これはすべて、mosquitto、mosquitto-clients、および paho-mqtt がインストールされたラズベリー pi 上にあることを忘れていました。