1

使用 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

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

4

3 回答 3

1

在 MQTT v5 中，干净启动仅意味着会话是否在开始时被删除。要控制断开连接后会话持续多长时间，您需要设置会话到期间隔：

import paho.mqtt.properties as properties
...
connect_properties = properties.Properties(properties.PacketTypes.CONNECT)
connect_properties.SessionExpiryInterval = 3600

client.connect("localhost", 1883, 60, properties=connect_properties)
于 2020-12-20T13:27:19.403 回答
0

QOS 仅在客户端订阅时才有效...如果您想在订阅之前接收消息，您需要发布设置了保留标志的消息...然后您只会收到最后发送的消息。如果你真的需要获取多条消息，那么你需要使用 AMQ 之类的东西，而不是 MQTT。

于 2020-12-18T04:56:38.790 回答
0

clean_session它不应该clean_start，它需要传递给Client构造函数而不是connect()函数：

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


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
)
...
于 2020-12-18T14:18:16.073 回答