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

Question

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

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

Какой тип системы / технологии обмена сообщениями spring-amqp мне следует использовать для этой схемы и как (например, Spring Remoting с AMQP или корреляция сообщений с очередью ответов и идентификатором корреляции)

Answer 1

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

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

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