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

Question

我有处理请求并将消息发布到 RabbitMQ 的 Web 服务（在 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

提前致谢

Answer 1

它更像是一个兔子 MQ 功能，而不是 java 或 spring，它允许任何已发布的消息被确认回发布者，请参阅以下链接以获取有关如何参考的参考： https://www.rabbitmq.com/confirms.html