Опубликованны NuGet-пакеты и Docker-образы версий 1.2.0.

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

В дополнении к основному направлению, были начаты работы по проектированию и реализации новых версий интерфейсов для клиентов Flexberry Service Bus. Перепроектирование этих интерфейсов, было начато, с целью четко разделить операции отправки и получения сообщений, и, операции управления маршрутизацией. Предыдущие версии интерфейсов помечены как устаревшие и не рекомендуются к использованию.

Что нового в версии Flexberry Service Bus 1.2.0

• Для интеграции с RabbitMQ создан пакет NewPlatform.Flexberry.ServiceBus.RabbitMQ с реализацией следующих компонентов:
  • ReceivingManager - позволяет получать сообщения хранящиеся в RabbitMQ привычным для клиентов Flexberry Service Bus способом
  • SendingManager - позволяет отправлять сообщения в RabbitMQ привычным для клиентов Flexberry Service Bus способом
  • StatisticsService - собирает статистику сообщений RabbitMQ и преобразует ее в статистику Flexberry Service Bus
  • SubscriptionsManager - позволяет управлять маршрутизацией сообщений в RabbitMQ
  • SubscriptionsSynchronizer - актуализирует настройки маршрутизации сообщений в RabbitMQ
  • MessageConverter - преобразует сообщения в формат Flexberry Service Bus
  • MessageManager - позволяет управлять сообщениями хранящимися в RabbitMQ
• Исправлена ошибка параллельного приема сообщений с группой
• Обновлены зависимости до последних версий
• Создан Docker-образ RabbitMQ настроенный для использования с Flexberry Service Bus

Интеграция Flexberry Service Bus и RabbitMQ

По умолчанию, Flexberry Service Bus, хранит получаемые сообщения, вместе с настройками маршрутизации, в базе данных. Использование RabbitMQ позволяет увеличить пропускную способность, когда поток сообщений велик, и скорости базы данных недостаточно. Обработка сообщений выполняется RabbitMQ, настройки маршрутизации, создаются и храняться, в базе данных, а Flexberry Service Bus переводит их в понятия RabbitMQ. При этом, для получения и отправки сообщений, можно использовать как интерфейсы Flexberry Service Bus так и интерфейсы RabbitMQ.

Для настройки интеграции Flexberry Service Bus и RabbitMQ необходимо:

• Экземпляр RabbitMQ с которым будет интегрированна Flexberry Service Bus
• Сконфигурировать компоненты Flexberry Service Bus, пример конфигруции можно найти в репозитории, ключевые моменты:
  • Регистрации компонентов отправки и получения сообщений заменить реализациями для RabbitMQ
  • Добавить регистрации компонентов:
    • SubscriptionsManager
    • SubscriptionsSynchronizer
    • MessageConverter
  • Добавить регистрации дополнительных классов:
    • ConnectionFactory
    • ManagementClient

Поделиться в: ВКонтакте, Twitter, Facebook.

Перейти к другим записям блога