0

以下のコードを実行しようとすると、画面が空白のままになり、クライアントがブローカーに接続されていることが示されません。

#! /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 上にあることを忘れていました。

4

1 に答える 1