как создать систему, которая будет прослушивать один кролик очередь MQ, а затем выполнить ряд задач по кроличьим квадратным метрам, то ответ

Question

Я хочу, чтобы разработать такую ​​систему, которая будет слушать кролик MQ #queue1

1. он примет сообщение от кролика квадратных метров
2. о проверке сообщения для типа запроса
3. это создаст тот тип пакета
4. он будет посылать запрос на другом RabbitMQ # Queue2
5. ждать ответа
6. получить ответ и в зависимости от ответа он поместит запросить # queue3
7. снова ждать ответа
8. получить ответ
9. он будет посылать сводный ответ на первый запрос пришел на queue1

Какой тип пружинного AMQP системы обмена сообщениями/технике я должен использовать для этой конструкции и как? (как Spring Remoting с AMQP или Корреляция сообщения с ответом Queue и корреляционного ID)

Answer 1

Почему у НУ хотят потребители #queue1 ждать ответа, а затем отправить его на #queue2

Вы можете разработать шаги

1. Потребителя примет сообщение от #queue1
2. На проверке сообщения для типа запроса
3. создаст сообщение этого типа
4. он будет посылать запрос на различных RabbitMQ #Queue2
5. Потребитель #Queue2 будет потреблять сообщение. в зависимости от результата обработки (который вы отправили бы в ответ), он поместил бы запрос на #queue3
6. Потребитель #Queue3 будет потреблять сообщение. Консолидируйте предыдущий результат с текущим результатом, Он поместит запрос в #queue4 с консолидированным результатом.
7. Потребитель #Queue4 будет потреблять сообщение. Консолидируйте предыдущий результат с текущим результатом, Он поместит запрос в #queue5 с консолидированным результатом.
8. Предполагая, что окончательная обработка будет выполнена по адресу #queue5. Объединить текущие результаты с предыдущим результатом и отправить его сводный ответ на #replyQueue