Как написать функцию службы пикапа на Java

#java #mongodb #rabbitmq

#java #mongodb #rabbitmq

Вопрос:

Я использую RabbitMQ и MongoDB. Мне нужно написать сервисную функцию на Java для хранения данных в MongoDB, когда RabbitMQ запускает сообщение из очереди.

Архитектура будет похожа

введите описание изображения здесь

Есть ли у RabbitMQ возможность передавать XML-файл из очереди в службу доставки? Пожалуйста, помогите. Я новичок во всех этих технологиях.

Ответ №1:

Вам PickupService нужно будет подписаться на соответствующую тему RMQ, чтобы получать сообщения из очереди. Сообщения передаются подписчикам асинхронным способом. RMQ не может отправить файл, но может отправить содержимое файла в виде обычного текста — xml в вашем примере.

Поскольку вы заявили, что вы «новичок» в этом, если вы знакомы с приложениями Swing, то трансляция сообщений похожа на прослушиватели действий в Swing. Вы не можете зарегистрировать несколько actionListener s для события нажатия кнопки, и все слушатели будут уведомлены при нажатии кнопки.

То же самое и здесь, у вас может быть несколько подписчиков (ActionListeners) на тему (кнопка), и они получат сообщение (событие нажатия кнопки), когда производитель отправит его в очередь (пользователь нажимает кнопку)