1

ラズベリーパイにpaho mqttクライアントをインストールし、Androidアプリケーションとarduinoをブローカーに接続した後。アプリケーションまたはarduinoクライアントからメッセージを受信した後、このメッセージをこのクライアントに再発行したいたとえば、「OFF」を受け取った後に「ON」を受け取った場合、次の発行は「ON」「OFF」「ON」「OFF」になります「...または、「オン」または「オフ」にする必要があります

import paho.mqtt.client as mqtt
message = 'ON'
def on_connect(mosq, obj, rc):
    print("rc: " + str(rc))

def on_message(mosq, obj, msg):
    global message
    print(msg.topic + " " + str(msg.qos) + " " + str(msg.payload))
    message = msg.payload

def on_publish(mosq, obj, mid):
    print("mid: " + str(mid))

def on_subscribe(mosq, obj, mid, granted_qos):
    print("Subscribed: " + str(mid) + " " + str(granted_qos))

def on_log(mosq, obj, level, string):
    print(string)

mqttc = mqtt.Client()
# Assign event callbacks
mqttc.on_message = on_message
mqttc.on_connect = on_connect
mqttc.on_publish = on_publish
mqttc.on_subscribe = on_subscribe
# Connect
mqttc.connect("localhost", 1883,60)

# Start subscribe, with QoS level 0
mqttc.subscribe("f", 0)

# Publish a message
#mqttc.publish("hello/world", "my message")

# Continue the network loop, exit when an error occurs
rc = 0
while rc == 0:
   rc = mqttc.loop()
   mqttc.publish("f",message)
print("rc: " + str(rc))
4

3 に答える 3

2

このコードを学習して自分で使用できます。

import RPi.GPIO as GPIO
import time
import paho.mqtt.client as mqtt

GPIO.setmode(GPIO.BOARD)

GPIO.setup(13,GPIO.IN)

mqttc=mqtt.Client()
mqttc.connect("iot.eclipse.org",1883,60)
mqttc.loop_start()

def reading1():
    a=GPIO.input(13)
    print(a)
    return a

while 1:
    t=reading1()
    (result,mid)=mqttc.publish("paho/temp_ab",t,2)
    time.sleep(1)

mqttc.loop_stop()
mqttc.disconnect()
于 2016-01-25T13:32:11.933 に答える
1

わかった、

次のコードは、トピック f でサブスクライブし、トピックf2で再発行します。

import paho.mqtt.client as mqtt
message = 'ON'
def on_connect(mosq, obj, rc):
    mqttc.subscribe("f", 0)
    print("rc: " + str(rc))

def on_message(mosq, obj, msg):
    global message
    print(msg.topic + " " + str(msg.qos) + " " + str(msg.payload))
    message = msg.payload
    mqttc.publish("f2",msg.payload);

def on_publish(mosq, obj, mid):
    print("mid: " + str(mid))

def on_subscribe(mosq, obj, mid, granted_qos):
    print("Subscribed: " + str(mid) + " " + str(granted_qos))

def on_log(mosq, obj, level, string):
    print(string)

mqttc = mqtt.Client()
# Assign event callbacks
mqttc.on_message = on_message
mqttc.on_connect = on_connect
mqttc.on_publish = on_publish
mqttc.on_subscribe = on_subscribe
# Connect
mqttc.connect("localhost", 1883,60)


# Continue the network loop
mqttc.loop_forever()
于 2015-08-03T14:12:02.173 に答える