RabbitMQ

RabbitMQ#

Общее#

RabbitMQ — это брокер сообщений, обеспечивающий обмен данными между различными частями системы по принципу «издатель-подписчик». Он позволяет приложениям отправлять и получать сообщения асинхронно.

В приложении RabbitMQ используется для обмена сообщениями между модулями и уведомлений пользователя о событиях, таких как:

  • Создание новых задач.

  • Результаты фоновых процессов.

  • Трассировка операций.

  • Перехваты вызовов серверных методов.

  • Общие уведомления.

Как реализовано взаимодействие с RabbitMQ#

Обмен сообщениями#

  • Создаются exchange’ы (точки обмена) по пользователям: btk.service.user.<userID>.

    Примечание

    При запуске приложения по умолчанию создается точка обмена на пользователе

  • Сообщения публикуются в exchange с указанием типа (type) и содержимого (body).

Получение сообщений#

  • Подписка на exchange выполняется методом startConsume(exchangeName) в (Btk_RabbitLib).

  • Все входящие сообщения на текущий момент обрабатываются через onReceiveMessage(...), где по type определяется нужный обработчик:

    • Btk_AcTrace;

    • Btk_BackgroundRun;

    • Btk_ServerMethodIntercept;

    • Прочие — обрабатываются через Btk_Ept.

Удаление exchange#

Метод deleteRabbitExchange в (Btk_RabbitPkg) позволяет удалить ненужные точки обмена.

Жизненный цикл подписки на сообщения#

  • При запуске приложения:

    • В ApplicationAvi.onShow() вызывается Btk_ApplicationLib().onStartApplication().

    • Это инициирует Btk_RabbitLib().onStartApplication(), которая автоматически подписывает пользователя на его exchange.

  • При завершении приложения:

    • Вызывается Btk_RabbitLib().onCloseApplication(), отписывая пользователя от exchange.

Пример отправки сообщения по RabbitMQ#

Пример: Отправка сообщения от трассировки прав (Btk_AcTracePkg.createAcTraceMessageHandler)#

def createAcTraceMessageHandler(
                                sid: NString,
                                sUserCluster: NString,
                                sFlag: NString,
                                sUser: NString,
                                sSidUser: NString,
                                sUserClusterStarted: NString
                               ): Unit = {
    try app {
      // Формируем JSON-объект
      val jObj = createAcTraceJsonObject(sid, sUserCluster, sFlag, sUser, sSidUser, sUserClusterStarted)
      val exchangeName = Btk_RabbitPkg().getServiceExchangeNameByUser(Btk_UserApi().getByMnemoCode(sUser).get.get(_.id))

      // Отправляем сообщение в exchange с указанием типа "Btk_AcTrace"
      rabbitPkg.sendMessageWithType(jObj.toPrettyNString, TYPE_AC_TRACE, exchangeName)
    } catch {
      case e: AppException =>
        throw e
    }
  }

Обобщенный способ отправки сообщения#

Btk_RabbitPkg().sendMessageWithType(messageText, messageType, exchangeName)

  • messageText – JSON-строка с содержимым;

  • messageType – строка, идентифицирующая тип сообщения;

  • exchangeName – имя точки обмена, куда отправляется сообщение.

Содержание