比较MQTT topi上以前和当前发布的值

Question

我的问题是如何比较每个主题的当前发布值与以前发布的值，并决定是否向设备发送命令以打开/关闭。 如果状态从以前的状态改变了，我想把命令发送到light，否则不会发送任何命令。 我有以下代码。在

import paho.mqtt.client as mqtt #import the client1
import time
def on_message(client, userdata, message):
    print("message received " ,str(message.payload.decode("utf-8")))    
    print("message topic=", message.topic)
    print("message qos=",message.qos)
    print("message retain flag=",message.retain)

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

broker_address="127.0.0.1"
print("creating new instance")
client = mqtt.Client("P1") 
client.on_connect=on_connect
client.on_message=on_message 
print("connecting to broker")
client.connect(broker_address) #connect to broker
client.loop_start()
print("Subscribing to all topics")
client.subscribe("#")
print("Publishing message to topic","house/bulbs/bulb1")
client.publish("house/bulbs/bulb1","OFF",qos=0,retain=true)
client.publish("house/bulbs/bulb1","ON",qos=0,retain=true)

print("Publishing message to topic", "house/bulbs/bulb2")
client.publish("house/bulbs/bulb2", "ON")
client.publish("house/bulbs/bulb2", "ON")
time.sleep(4) # wait
client.loop_stop() #stop the loop

Answer 1

唯一的方法是在代码中存储状态，并将传入的消息与存储的值进行比较。在

import paho.mqtt.client as mqtt #import the client1

bulb1 = OFF
bulb2 = OFF

def on_message(client, userdata, message):
    global bulb1
    global bulb2
    print("message received " ,str(message.payload.decode("utf-8")))    
    print("message topic=", message.topic)
    print("message qos=",message.qos)
    print("message retain flag=",message.retain)

    if message.topic == 'house/bulbs/bulb1':
      if bulb1 != str(message.payload.decode("utf-8")):
          #State changed
          bulb1 = str(message.payload.decode("utf-8"))

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

broker_address="127.0.0.1"
print("creating new instance")
client = mqtt.Client("P1") 
client.on_connect=on_connect
client.on_message=on_message 
print("connecting to broker")
client.connect(broker_address) #connect to broker
client.loop_start()


print("Publishing message to topic","house/bulbs/bulb1")
client.publish("house/bulbs/bulb1","OFF",qos=0,retain=true)
client.publish("house/bulbs/bulb1","ON",qos=0,retain=true)

print("Publishing message to topic", "house/bulbs/bulb2")
client.publish("house/bulbs/bulb2", "ON")
client.publish("house/bulbs/bulb2", "ON")
time.sleep(4) # wait
client.loop_stop() #stop the loop