Làm thế nào để có được đúng tất cả các tin nhắn xếp hàng từ RabbitMQ trong mùa xuân?

Question

Tôi đang sử dụng Spring, Spring-Websocket, STOMP cho ứng dụng của tôi và RabbitMQ làm môi giới. Tôi cần phải đăng nhập tất cả các tin nhắn đi qua các bảng RabbitMQ tới Postgresql. Tôi biết rằng tôi có thể viết @MessageMapping vào mùa xuân và đăng nhập ở đó, nhưng vấn đề của tôi là một số khách hàng nói chuyện trực tiếp với RabbitMQ thông qua giao thức MQTT và Spring không hỗ trợ nó (https://jira.spring.io/browse/SPR-12581). Hơn nữa, các trình duyệt trình duyệt nói chuyện qua Spring tới RabbitMQ bằng giao thức STOMP.

RabbitMQ cho phép theo dõi tất cả thư bằng trình theo dõi Firehose. Làm thế nào để lắng nghe đúng chủ đề amq.rabbitmq.trace từ Spring? Hay tôi cần phải viết ứng dụng Java riêng biệt làm người tiêu dùng?

Answer 1

Spring AMQP là dành cho bạn!

Bạn ràng buộc một số tùy chỉnh queue đến với amq.rabbitmq.trace với mô hình thích hợp (ví dụ publish.#) và cấu hình SimpleMessageListenerContainer để nhận tin nhắn từ hàng đợi đó.

Có thể thực hiện ngay cả với cấu hình khá đơn giản: @EnableRabbit và @RabbitListener trên một số phương thức POJO. Dù sao, Binding@Bean phải ở đó để thỏa hiệp hàng đợi của bạn với cuộc trao đổi đó.