Veröffentlichen und Abonnieren mit Paho Mqtt-Client

Nach der Installation von paho mqtt-client auf meinem raspberry pi und die Verbindung zu meinem android-Anwendung und arduino mit meinem broker. Ich möchte nach Erhalt der Nachricht von der Anwendung oder dem arduino-client veröffentlichen diese Nachricht, um diese Kunden zum Beispiel, wenn ich erhalten "ON", nachdem ich erhalten, "AUS", die nächste Veröffentlichung wird es "ON" "OFF" "ON" "OFF"... oder muss ich nur "ON" oder "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))
Können Sie bitte erklären, ein wenig mehr darüber, was genau Sie versuchen zu erreichen, es ist nicht völlig klar.
Bitte stellen Sie sicher, zu abonnieren, in der on_connect Rückruf, ansonsten ist es ein bug. Siehe den Abschnitt erste Schritte hier: eclipse.org/paho/clients/python
ich versuchte dies vor und die gleiche Sache, die ich hatte , mein problem ist in der publish-methode ist nicht die abonnieren
ich möchte zu veröffentlichen, jede Nachricht erhielt von dem Thema, das ich bin subsribed in

InformationsquelleAutor Mohamed | 2015-08-02

  1. 2

    kann man studieren, was dieser code und verwenden Sie es für sich selbst,

    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()

    InformationsquelleAutor Anurag Vijayvargiya

  2. 1

    OK,

    Den folgenden code anmelden, Thema f und veröffentlichen auf Thema 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()
    sorry bro aber ich will es mit dem gleichen Thema, weil mein Ziel ist, zu teilen th empfangene Nachricht an meine clients(android,arduino), die abonniert sind, f nicht f2
    Es gibt keinen Punkt, veröffentlichen den gleichen Wert auf das gleiche Thema, wie Sie nur am Ende in einer kontinuierlichen feedback-Schleife. Es gibt nichts zu stoppen Sie sowohl die android und arduino Anmeldung zu dem gleichen Thema.
    also du meinst, nur muss ich abonnieren, um Thema und zu veröffentlichen, um andere in mein broker und alle meine Kunden
    Sie sollte wohl getrennte Befehle aus den Status zu verschiedenen Themen
    gemacht bro, danke 🙂

    InformationsquelleAutor hardillb

  3. 0

    ich denke, das könnte dir helfen . 

    import threading
import paho.mqtt.client as mqtt

def publish_1(client,topic):
    message="on"
    print("publish data")
    client.publish(topic,message)
    publish_1(client,topic)


broker="test.mosquitto.org"
topic_pub='/temperature123'
topic_sub='$SYS/#'

def on_connect(client, userdata, rc):
    print("Connected with result code "+str(rc))
    client.subscribe(topic_sub)


def on_message(client, userdata, msg):
    print(msg.topic+" "+str(msg.payload))

client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message

client.connect(broker, 1883, 60)
thread1=threading.Thread(target=publish_1,args=(client,topic_pub))
thread1.start()

client.loop_forever()

    nutzt dieses Programm Gewinde-und pass-client-Objekt.
    aber das problem mit dieser, diese zu veröffentlichen rekursiv.

    InformationsquelleAutor rishav

Schreibe einen Kommentar