Как заставить публикацию получать сообщения?

#java #python #rabbitmq #queue #publish-subscribe

#java #python #rabbitmq #очередь #опубликовать-подписаться

Вопрос:

У меня есть школьное задание, которое нужно выполнить с помощью RabbitMQ. Это проект фондовой биржи, использующий темы для отправки сообщений только тем, кто заинтересован в этих сообщениях. Итак, например, брокер хочет купить некоторые акции, скажем, у Apple, поэтому он собирается отправить сообщение об их покупке, есть формат сообщения для отправки, он собирается отправить это сообщение в очередь, фондовая биржа получит это сообщение и обработает его, чтобы узнать, продает ли какой-либо другой клиент от Apple, в данном случае Apple является темой, если значение совпадает, тогда он обработает транзакцию. Хорошо здесь. Я сомневаюсь, как заставить брокера, который покупает, также получать сообщения? Потому что одним из требований назначения является то, что каждый брокер должен получать все сообщения по интересующей их теме. Итак, клиент, который отправляет сообщение для покупки, также будет получать сообщения.

Я выполнил руководство по RabbitMQ, я выполнил 5 из них. RabbitMQ Приступает. В руководстве я узнал, как отправлять сообщения на подписку, но в нем не говорится, как публикация также может получать сообщения.

Ответ №1:

Используйте spring-messaging! https://spring.io/guides/gs/messaging-rabbitmq /

В документах должно быть достаточно ясно указано, как отправлять / получать сообщения. Это аккуратная маленькая библиотека. Конечно, ваш проект должен быть приложением Spring.

Комментарии:

1. В этом назначении это не может быть spring app XD.

2. Использовать официальную библиотеку rabbitmq? rabbitmq.com/api-guide.html

3. Это то, что я должен использовать. Вопрос в том, как заставить публикацию получать сообщения.