是否可以向未来发送消息？

Question

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

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

最好通过发布消息“请立即执行维护”来解决用例，并在消息中标记“不早于 15 分钟后交付”。

Answer 1

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

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

Answer 2

不，订阅主题的所有已连接客户端会立即发送消息，并在重新连接时为具有持久订阅的已断开连接的客户端发送消息。

如果您想处理延迟消息，则必须在将它们发布到代理之前实现自己的存储和转发机制。