持久会话在 MQTT 中如何工作？

Question

我使用 MQTT 和 QOS 1。

我有一个消费者和一个生产者。它们相互通信（HiveMQ 作为客户端）。他们使用 VerneMQ 作为代理。我使用持久会话。

如果消费者离线，后来又上线，他应该成为他离线的所有消息。但这只有在消费者在另一台计算机上并且我没有停止微服务但我关闭 WiFi 然后再打开时才有效。但是，如果我关闭了一个微服务，然后重新启动它，它就不适用于离线消息。

如果我再次启动微服务，我认为这就是它再次订阅该主题的原因。是这个原因吗？或不？

更新： 我只是在消费者第二次开始时没有订阅就测试了它。那也行不通。 所以订阅并不是消费者收不到消息的原因。

Answer 1

对于持久化会话，让你在离线时成为所有消息，你需要满足一些条件：

1) 在连接时关闭 CleanStart：

Mqtt5Connect.builder()
            .cleanStart(false)
            .noSessionExpiry()
            .build()

2) 收集与发布

连接的剩余消息

  mqttClient.publishes(MqttGlobalPublishFilter.REMAINING) {
        mqtt5Publish -> handleMessage(mqtt5Publish.topic.toString(), mqtt5Publish.payload.decodeContent())
    }

3) QOS 1+

这就像一块瑞士手表。