QoS1 与 QoS2 消息 - 在 Java 中使用 Paho MQTT 客户端处理它的区别

Question

参考 this article 我想我知道 QoS1 和 QoS2 消息之间的区别，但我不知道作为 Paho MQTT 客户端处理它们的区别。

假设我订阅了这样的主题：

MqttClient subscriber = new MqttClient(SERVER_URI, SUBSCRIBER_ID);
subscriber.subscribe(TOPIC);

然后我发布这样的消息：

publisher.publish(TOPIC, PAYLOAD, 1, false);

此刻我正在使用 MqttCallback 接口来处理到达订阅者的消息。

有一个方法可以覆盖：

public void messageArrived(String topic, MqttMessage mqttMessage) {
    if(mqttMessage.isDuplicate()) {
        // is it really the duplicate message from my perspective?
    } else {...}
}

在 MqttMessage 中我们可以找到一个 isDuplicate() 方法，但是我如何确定 returns true 的 mqttMessage 不是我的订阅者收到的第一条消息？

我非常有兴趣找到一个解决方案来说明如何处理 QoS1，但我们将不胜感激每一个能够澄清此处任何内容的答案。

来自 Cracow 的问候！

Answer 1

仅仅依赖重复标志是不够的，因为您可能错过了第一条消息。如果 QoS 1 消息不是幂等的，这里有一些如何进行重复检测的建议：

对有效负载 + 主题进行哈希处理，并获得一个 table，其中包含最后 X 条消息及其可用的哈希值，这样您就可以检查您是否已经收到该消息
在有效载荷中有一个唯一的 ID，并且有一个 table 最后 X 条消息及其 ID 可用
在有效载荷中有一个时间戳，并有一个 table 最后 X 条消息及其可用的时间戳

如果您确实需要确保消息到达一次且仅一次，则可以使用 QoS 2。QoS 1 意味着您的客户端可以处理重复消息（通过忽略重复消息或消息是幂等的）。

QoS1 与 QoS2 消息 - 在 Java 中使用 Paho MQTT 客户端处理它的区别

QoS1 vs QoS2 messages - difference in handling it with Paho MQTT client in Java

java

mqtt

paho