MQTT 在 messageArrived 方法中出现异常时重试

Question

我有一个 MQTT 回调，它转发通过 SOAP 端点接收的消息中的部分数据，但是当 SOAP 端点出现故障时，这些消息会丢失并且永远不会到达最终消费者。

我知道不同的 QOS 和传递令牌，但我不确定其中是否真的可以帮助我在触发异常后重试发送这些消息。是否可以将消息“返回”到主题以供以后重试或类似的方式以确保正确处理完整的消​​息？

在客户端，我通过 Maven 使用 Eclipse-Paho：

    <dependency>
        <groupId>org.eclipse.paho</groupId>
        <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
        <version>1.0.1</version>
    </dependency>

从此存储库： https://repo.eclipse.org/content/repositories/paho-releases

在服务器端：

Debian GNU/Linux 8.5 (jessie)
mosquitto 1.3.4-2 (MQTT version 3.1/3.1.1 compatible)

我还应该提供什么？

Answer 1

不，一旦传递给客户端，一条消息就完全从 MQTT 系统中消失了。

您可以在 MQTT 客户端应用程序中构建任何存储和重试逻辑，以处理下游系统中的任何故障。