spring - 如何在 Spring 中从 RabbitMQ 正确获取所有队列消息？

Question

我在我的应用程序中使用 Spring、Spring-Websocket、STOMP，并使用 RabbitMQ 作为代理。我需要将通过 RabbitMQ 的所有消息记录到 Postgresql 表中。
我知道我可以在 Spring 中编写 @MessageMapping 并在那里登录，但我的问题是一些客户端直接通过 MQTT 协议(protocol)与 RabbitMQ 通信，而 Spring 还不支持它( https://jira.spring.io/browse/SPR-12581 )。此外，浏览器客户端使用 STOMP 协议(protocol)通过 Spring 与 RabbitMQ 对话。

RabbitMQ 允许使用 Firehose 跟踪器跟踪所有消息。如何正确收听 Spring 中的 amq.rabbitmq.trace 主题？还是我需要编写单独的 Java 应用程序作为消费者？

Answer 1

Spring AMQP是给你的!

你绑定(bind)一些自定义queue到那个amq.rabbitmq.trace使用适当的模式(例如 publish.# )并配置 SimpleMessageListenerContainer从该队列接收消息。

即使使用非常简单的配置也可以完成:@EnableRabbit和 @RabbitListener关于一些 POJO 方法。无论如何Binding @Bean必须在那里将您的队列附加到该交换。