如何解决PAHO：虽然已定义但未调用 on_message
使用 Python 的 Paho，我尝试在通过 MQTT 从代理接收到字符串后将字符串打印到控制台。我这样做是因为我想稍后处理这些数据，即我想在达到指定温度的情况下触发一个函数。我的代码与我在互联网上看到的许多示例一样，但与这些教程不同的是，我的 on_message 方法甚至没有被调用，因此没有任何内容打印到控制台。
由于我是 Python 和 MQTT 的新手，我的问题是我是否遗漏了代码中的一些重要内容。为什么不调用 on_message？
感谢您的帮助！
import paho.mqtt.client as mqtt
import time
import json
def on_connect(client,userdata,flags,rc):
if rc == 0:
print("Connected - OK\n")
client.subscribe("temperature/sensor1")
else:
print("Failed to connect to MQTT broker,return code ",rc)
print("\n")
#problem: never invoked
def on_message(client,msg):
print("calling on_message:\n")
print(msg.topic + " " + str(msg.payload))
#in future: add global variable here
def on_log(client,level,buf):
print("log: ",buf)
def on_disconnect(client,rc=0):
print("Disconnected result code "+str(rc))
#Connecting to MQTT broker
MQTT_BROKER_HOST = 'brokeraddress.org'
MQTT_BROKER_PORT = 18330
MQTT_KEEP_ALIVE_INTERVAL = 60
client = mqtt.Client("testName")
client.tls_set()
client.on_connect = on_connect
client.on_disconnect = on_disconnect
client.on_log = on_log
client.on_message = on_message
#alternative I found to on_message; however it also doesn't solve the issue
#client.message_callback_add('rootTopic/topic/uplink',on_message)
client.username_pw_set(username="user",password="password")
client.connect(MQTT_BROKER_HOST,MQTT_BROKER_PORT,MQTT_KEEP_ALIVE_INTERVAL)
client.subscribe("rootTopic/topic/uplink")
client.loop_start()
client.publish("temperature/sensor1","test message")
time.sleep(5)
client.loop_stop()
client.disconnect()
控制台当前打印出以下内容：
log: 发送 CONNECT (u1,p1,wr0,wq0,wf0,c1,k60) client_id=b'testName'
log: 发送订阅 (d0,m1) [(b'rootTopic/topic/uplink',0)]
log：发送 PUBLISH (d0,q0,r0,m2),'b'temperature/sensor1'',...（11 字节）
log：收到 CONNACK (0,0) 已连接 - 确定
log: 发送订阅 (d0,m3) [(b'temperature/sensor1',0)]
订阅主题温度/传感器1
日志：收到 SUBACK
日志：收到 SUBACK
日志：发送断开连接
断开连接的结果代码 0
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com(将#修改为@）