paho-mqtt不会给我排队的消息

Question

使用paho-mqtt并尝试让它接收排队的消息。我使用的代理是emqx 4.2.2，这是我的脚本：

from paho.mqtt.client import Client, MQTTv5


def on_connect(mqttc, obj, flags, rc, other):
    print("    Session present: " + str(flags['session present']))
    print("    Connection result: " + str(rc))
    mqttc.subscribe([
        ('/message/1', 1)
    ])


def on_message(*args, **kwargs):
    print("received a message")


client = Client(
    client_id='test-client-id',
    protocol=MQTTv5,
)


client.username_pw_set(
    username="test-user-2",
    password="test"
)

client.on_connect = on_connect
client.on_message = on_message

client.connect(
    host='localhost',
    port=1883,
    keepalive=60,
    clean_start=False,
)

client.loop_forever()

现在，我将向代理发布一条消息：

mosquitto_pub -u test-user-2 -P test -t '/message/1' -m 'this is a message' -q 1 -V mqttv5

当客户机连接到代理时，它确实会接收消息，但如果我是用QoS1订阅的，并且消息是用QoS1发布的，我希望如果我断开客户机与代理的连接，然后发布更多的QoS1消息到该主题，然后使用相同的固定client_id将客户机重新连接到代理，那么客户机将接收在客户机不在时排队的消息。好吧，这并没有发生，用带有-c标志的mosquitto_sub模拟相同的功能，一切都像预期的那样工作，这让我问自己...paho-MQTT有问题吗？我做错什么了吗？

Answer 1

QOS只有在客户机被订阅的情况下才起作用...如果您想在订阅之前接收消息，您需要发布设置了保留标志的消息...然后您只获得最后发送的消息。如果您真的需要获取多条消息，那么您需要使用AMQ，而不是MQTT。