如何在Spring Boot中发送并确认传递到RabbitMQ的消息？

Question

我有rest控制器，用于处理请求并将消息发布到RabbitMQ（写在spring boot中）。问题是当没有连接时，我无法立即检测到它，并且我丢失了所有消息。我该如何解决这个问题？ 30秒后出现AMQP连接错误。在此间隔内，我无法处理此问题。我想知道消息何时传递到RabbitMQ。如果没有发送，我需要存储所有消息，而当rabbitmq启动时，重新发送所有这些消息。顺便说一句，性能很重要。我已阅读以下文档。我认为可以通过OperationsCallback解决，但我不知道如何。

• https://docs.spring.io/spring-amqp/docs/current/reference/html/#scoped-operations

• https://docs.spring.io/spring-amqp/docs/current/reference/html/#cf-pub-conf-ret

预先感谢

我有rest控制器，用于处理请求并将消息发布到RabbitMQ（写在spring boot中）。问题是当没有连接时，我无法立即检测到它，而我丢失了所有...

Answer 1

与其说是Java或spring之外，还不如说它是一个兔子MQ功能，它允许将发布的任何消息确认回发布者，有关以下内容的参考，请参见下面的链接：https://www.rabbitmq.com/confirms.html