В этой главе мы узнаем об ActiveMQ и о том, как он действует как посредник сообщений, позволяя приложениям взаимодействовать друг с другом.
Что такое AMQ?
ActiveMQ — это брокер сообщений с открытым исходным кодом, написанный на Java. Он полностью соответствует стандартам JMS 1.1.
JMS — это спецификация, которая позволяет разрабатывать систему, основанную на сообщениях. ActiveMQ действует как посредник сообщений, который находится между приложениями и позволяет им общаться асинхронно и надежно.
Типы сообщений
Для лучшего понимания ниже приведены два типа сообщений.
Точка-точка
При таком типе связи брокер отправляет сообщения только одному потребителю, в то время как другие потребители будут ждать получения сообщений от брокера. Ни один потребитель не получит такое же сообщение.
Если нет потребителей, Брокер будет хранить сообщения, пока не получит потребителя. Этот тип связи также называется связью на основе очереди, когда источник отправляет сообщения в очередь, и только один потребитель получает одно сообщение из очереди. Если имеется более одного потребителя, они могут получить следующее сообщение, но они не получат того же сообщения, что и другой потребитель.
Публикация / подписка
При таком типе связи Брокер отправляет одну и ту же копию сообщений всем активным потребителям. Этот тип связи также известен как тематическая связь, где брокер отправляет одно и то же сообщение всем активным потребителям, которые подписались на конкретную тему. Эта модель поддерживает одностороннюю связь, при которой не требуется проверка переданных сообщений.
Создание очереди и тем
Предохранитель поставляется в комплекте с ActiveMQ. Мы можем получить доступ к ActiveMQ с помощью консоли FMC (интерфейс на основе браузера для работы с AMQ).
Войдите в FMC с помощью localhost: 8181 и выберите вкладку ActiveMQ .
- Нажмите на + Создать
- Введите очередь / название темы
- Выберите очередь / тему из переключателя
- Нажмите на Создать очередь / Создать тему
Теперь вы сможете увидеть TestQ, созданный под root → Queue →
Чтобы проверить созданную тему, следуйте root → Topic.
Войдите в FMC используя localhost: 8181
Выберите вкладку ActiveMQ
Root → Queue → TestQ <выберите очередь, которую вы хотите просмотреть> → Обзор
Вы можете удалить конкретное сообщение, нажав на кнопку Удалить, показанную в правом верхнем углу.