Инструкция по установке Брокер сообщений

1. Назначение документа

В настоящем документе приведено руководство системного администратора по установке и настройке системного ПО Брокер сообщений Q.Artemis (Q.Integration, Интеграционная платформа).

2. Общие положения

Функциональный блок Q.Integration, Интеграционная платформа (Брокер сообщений) (далее – Функциональный блок или Брокер сообщений) предназначен для безопасного и надежного обмена данными между приложениями.

Ключевыми свойствами функционального блока являются:

поддержка распространенных протоколов передачи сообщений (AMQP, OpenWire, MQTT, STOMP, HornetQ);
поддержка паттернов «точка-точка» и «публикация-подписка»;
поддержка JMS-транзакций и, следовательно, возможность группировки нескольких операций отправки или получения сообщений в одну атомарную операцию;
поддержка транзакций и гарантированной доставки;
декларативное управление правами доступа к объектам брокера.

Взаимодействующие системы могут отправлять подтверждения о получении сообщений, что гарантирует, что Брокер сообщений имеет информацию об успешной доставке. Если подтверждение не получено, программный продукт в соответствии с настройками может выполнять повторную отправку сообщения.

Если сообщение не может быть доставлено после определенного количества попыток, оно может быть перенаправлено в специальную очередь Dead Letter Queue.

При типе обмена сообщениями «точка-точка» сообщение отправляется в очередь. Затем сообщение сохраняется, чтобы обеспечить гарантию доставки, а через некоторое время система обмена сообщениями доставляет сообщение потребителю. Затем потребитель обрабатывает сообщение и после этого подтверждает его. Как только сообщение подтверждено, оно исчезает из очереди и становится недоступным для повторной доставки. Если система выйдет из строя до того, как сервер обмена сообщениями получит подтверждение от потребителя, то после восстановления сообщение будет доступно для повторной доставки потребителю.

При обмене сообщениями «точка-точка» в очереди может быть много потребителей, но конкретное сообщение может быть использовано только одним из них.

При обмене сообщениями «публикация-подписка» сообщения объекту на сервере, называемому «топик», могут отправлять несколько пользователей.

Один топик может включать много подписок. Каждая подписка получает копию каждого сообщения, отправленного в топик. Это является отличием от шаблона очереди сообщений, где каждое сообщение потребляется только одним потребителем.

Брокер сообщений дает возможность создавать группы серверов обмена сообщениями, называемые кластерами. Кластеры позволяют распределить нагрузку по отправке и приему сообщений на множество серверов. Брокер сообщений предоставляет гибко настраиваемую модель кластеризации, в которой сообщения могут интеллектуально балансировать между серверами в кластере в зависимости от количества потребителей на каждом узле и их готовности к обмену сообщениями. Брокер сообщений также имеет возможность автоматически перераспределять сообщения между узлами кластера.

3. Термины, сокращения, определения

Термин/сокращение	Определение
MQ	Message Queue, Брокер сообщений
БД	База данных
Кластер	Группа серверов обмена сообщениями
Сообщение	Данные, передаваемые между отправителем и приложением-получателем
Очередь	Последовательность сообщений, ожидающих обработки в порядке очереди, начиная с первого

4. Основные сущности Продукта

5.1 Адрес

Сообщения отправляются на адрес. Адресу присваивается уникальное имя, тип маршрутизации и ноль или более очередей.

5.2 Очередь

Сообщения потребляются из очереди. Очередь привязана к адресу. Ему присваивается уникальное имя и тип маршрутизации. К одному адресу может быть привязано ноль или более очередей. Когда сообщение отправляется по адресу, оно попадает в одну или несколько очередей в зависимости от настроенного типа маршрутизации.

Имя очереди должно быть глобально уникальным. Например, нельзя создавать очередь с именем q1 по адресу a1, а также очередь с именем q1 по адресу a2.

5.3 Тип маршрутизации

Тип маршрутизации определяет, как сообщения направляются с адреса в очереди, привязанные к этому адресу. Поддерживаются два типа маршрутизации: Anycast и Multicast.

Если требуется отправка сообщения в…	Используемый тип маршрутизации
одну очередь по адресу	Anycast
во все очереди по адресу	Multicast

6. Основные команды

Для успешного выполнения команды, необходимо запустить брокер сообщений. У пользователя должен быть доступ к утилите artemis из командной строки. Также необходимо убедиться в использовании правильных параметров команд в соответствии с конфигурацией брокера и требованиями приложения пользователя.

6.1 Создание инстанса брокера сообщений

Для создания инстанса необходимо использовать команду:

artemis create <INSTANCE_DIR> --user <USER_NAME> --password <USER_PASSWOED> --silent -
-require-login --http-host 0.0.0.0 --relax-jolokia
где <INSTANCE_DIR> – путь к каталогу инстанса, а <USER_NAME> и <USER_PASSWOED> –
имя и пароль пользователя соответственно.

6.2 Запуск брокера сообщений

Необходимо открыть консоль командной строки, перейти в каталог <INSTANCE_DIR> и выполнить команду:

artemis run