mqtt - 是否可以向 future 发送消息？

Question

是否有使用 MQTT 发布计划/延迟消息的最佳实践，例如，使用 Mosquitto 或 HiveMQ 代理？

用例是:告诉订阅者在 15 分钟内执行一些维护。

最佳情况下，用例将通过发布消息“请立即执行维护”来解决，并将消息标记为“从现在开始不早于 15 分钟交付”。

Answer 1

虽然我不建议在任何具有高吞吐量的情况下这样做，但至少对于 HiveMQ，您可以执行以下操作:

1. 实现 OnPublishReceivedCallback .
2. 安排一个使用 PublishService 的 Runnable到某种共享的 ScheduledExecutorService。 Runnable 通过 PublishService 重新发布 publish
3. OnPublishReceivedCallback 需要通过抛出 OnPublishReceivedException 来丢弃原始发布(使用 false 作为构造函数参数，这样您就不会断开发布客户端)