Python/paho MQTT - 不接收消息

Question

我是使用 MQTT 的新手，我想同时运行两个 Python 程序：一个将消息发布到主题，另一个在消息发布到主题时打印出消息。但是，打印消息的回调函数对我不起作用。

这是我拥有的两个程序：

发布消息：

import paho.mqtt.client as mqtt

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

client = mqtt.Client(client_id="clientID")
client.on_connect = on_connect
client.username_pw_set(username="username", password="password")
client.loop_start()
client.connect("node02.myqtthub.com", 1883)

while True:
    client.publish("my/topic", "test")

订阅并打印消息：

import paho.mqtt.client as mqtt

def on_message(client, userdata, msg):
    print(msg.payload.decode())

def on_connect(client, userdata, flags, rc):
    print("Connected! Result code: " + str(rc))
    client.subscribe("my/topic")

client = mqtt.Client(client_id="clientID")
client.on_connect = on_connect
client.on_message = on_message
client.username_pw_set(username="username", password="password")
client.connect("node02.myqtthub.com", 1883)
client.loop_forever()

有人可以帮我解决这个问题吗？

Answer 1

两个程序都使用client_id="clientID"； mqtt spec 状态

如果 ClientId 代表一个已经连接到服务器的客户端，那么服务器必须断开现有的客户端 [MQTT-3.1.4-2]。

因此，无论哪个应用程序第二个连接，都会导致第一个应用程序断开连接。要解决此问题，请更改其中一个应用程序中的客户端 ID。

注意：这是对明显错误的评论。提问时，请说明您看到的情况（任何输出、错误、您尝试过的操作等），因为可能还有其他问题。