java - 在 RabbitMQ 中删除或更新消息

Question

我做了一些研究，但无法找到任何解决方案来删除或修改队列中已存在的消息。(RabbitMQ)。

用例:我尝试使用 RabbitMQ 中的延迟消息功能 (headers.put("x-delay", 5000)) 发送通知(假设 30 分钟后)。我想发送一个可以删除/修改消息内容的事件。 RabbitMQ 有什么办法可以做到这一点吗？

替代方法是使用数据库和调度程序，如果不可能的话我将实现它。

提前致谢

Answer 1

不太确定您的情况。假设您要删除或修改 RabbitMQ 上的现有消息。

如果你有 FIFO 的情况，你可以检查这个 How to selectively delete messages from an AMQP (RabbitMQ) queue?

我可以建议的是，您可以使用插入和删除方法，将具有唯一ID的修改消息推送到数据库/缓存和您的消息队列。每当您进行修改或删除时，请将其从数据库/缓存中删除。当消费者消费该消息时，如果该消息不存在于 db/cache 中，它可以忽略。