建立了连接，但无法在PAHO MQTT客户端检索消息有效载荷

Question

我的客户端无法从 MQTT 服务器接收消息负载。我在我的电脑上设置了 mosquitto 作为服务器和发布者，并执行以下命令：

mosquitto_pub -h 192.168.1.2 -t topic/test -m "testing" -i simulator -d

我自己订阅有效并收到有效负载。

但是，我使用 paho mqtt 的客户端仅收到成功的连接，而没有有效负载消息。所以我这里有以下代码：

def on_connect(client, userdata, flags, rc):
    print("connection ok")
    client.subscribe("topic/test")

def on_message(client, userdata, msg):
    print("Message received! " + str(msg.payload))
    
    if msg.payload == "testing":
        print("Message received")
        # Do something
        ...

def main():
    #MQTT 
    broker = "192.168.1.2"  #broker ip
    client = mqtt.Client("simulator") 
    client.on_connect = on_connect
    client.on_message = on_message

    client.connect(broker, 1883, 60)
    client.loop_start() 

    while(1):
        ...

所以它确实设法打印“连接正常”，但不是“已收到消息！...”

Answer 1

您在 mosquitto_pub 和 Python 中使用相同的 client-id（simulator）。根据规范：

如果 ClientId 表示客户端已连接到服务器，则服务器必须断开现有客户端的连接

所以发生的情况是：

• Python 客户端连接并订阅。
• mosquitto_pub 连接，代理断开 python 客户端连接。
• mosquitto_pub 发布消息（但由于没有订阅任何内容，QOS 0 消息将被代理丢弃）。
• Python客户端重新连接并再次订阅。

尝试在 mosquitto_pub 中使用不同的客户端 ID（当我以这种方式测试时，您的代码工作正常 - 在 while 中添加了 time.sleep(1) (1))。