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



我有一个web服务,它处理请求并将消息发布到RabbitMQ(在春季启动中编写(。问题是,当没有连接时,我无法立即检测到它,并且我会丢失所有的消息。我该如何处理这个问题?30秒后我出现AMQP连接错误。在那段时间里,我无法处理这个问题。我想知道消息何时传递到RabbitMQ。如果它没有送达,我需要存储所有消息,当rabbitmq启动时,重新发送所有这些消息。顺便说一句,性能很重要。我已经阅读了以下文件。我认为这可以通过OperationsCallback解决,但我不知道如何解决。。

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

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

提前感谢

与java或spring相比,它更像是一个rabbit MQ功能,它允许将发布的任何消息确认回发布者,请参阅以下链接以获取有关如何操作的参考:https://www.rabbitmq.com/confirms.html

最新更新