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

Question

我有一个 Web 服务，可以处理请求并将消息发布到 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

提前致谢

Answer 1

它比 java 或 spring 更具有rabbit MQ 功能，它允许发布的任何消息都被确认回发布者，请参阅下面的链接以获取有关如何操作的引用: https://www.rabbitmq.com/confirms.html