0

参考这篇文章，我想我知道 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() 方法，但是我如何确定返回 true 的 mqttMessage 不是我的订阅者收到的第一条消息？

我对找到一个显示如何处理 QoS1 的解决方案非常感兴趣，但是每一个能澄清这里任何事情的答案都将不胜感激。

来自克拉科夫的问候！

4

1 回答 1

2

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

  • 对有效负载 + 主题进行哈希处理，并有一个包含最后 X 条消息及其哈希值的表格，以便您检查是否已经收到该消息
  • 在有效负载中具有唯一 ID，并具有包含最后 X 条消息及其可用 ID 的表
  • 在有效负载中有一个时间戳，并有一个表，其中包含最后 X 条消息及其可用的时间戳

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

于 2015-07-15T11:05:49.767 回答