ESV RabbitMq via MassTransit. Сервисная шина предприятия. Брокер сообщений

Содержание
Сервисная шина предприятия
Брокер сообщений
RabbitMq
MassTransit
Примеры

Enterprise Service Bus
Сервисная шина предприятия – это, в первую очередь, концепция, которая позволяет интегрировать разрозненные системы в единый комплекс с централизованным управлением.

Основные возможности ESB
Масштабируемость соединений и маршрутизации
Преобразование протоколов
Преобразование форматов сообщений/данных

Брокер сообщений
Проблему Масштабируемости соединений и маршрутизации можно решить брокером сообщений. Он обеспечивает гарантированную доставку сообщения от поставщика к подписчику
Основные протоколы:
Advanced Message Queuing Protocol (AMQP)
STOMP
MQ Telemetry Transport
Брокеры:
RabbitMQ
Kafka
Amazon SQS
Apache ActiveMQ
WebSphere MQ
Java Message Service

RabbitMQ
RabbitMQ – брокер сообщений, основанный на протоколе AMQP (Advanced Message Queuing Protocol)
Базовые понятия
Exchange – получает сообщение от поставщика и отправляет его в очередь.
Queue - буфер который хранит сообщения
Binding – связь между очередью и обработчиком сообщений
Routing key – ключ на который смотрит обработчик и решает куда отправить

MassTransit
MassTransit - это библиотека с открытым исходным кодом, разработанная на языке C# для .NET платформы, упрощающая работу с шиной данных.
Поддерживаемые шины данных:
RabbitMq
Azure Service Bus
ActiveMQ
Amazon SQS
Возможности:
Управление подключением
Обработка ошибок и пропущенных сообщений
Сериализация (JSON, BSON и XML) + шифрование (AES-256)
Управление жизненным циклом потребителей
Сага
Планирование
Мониторинг
Модульное тестирование

Инициализация MassTransit

Потребитель сообщения
Публикация сообщения

Saga consumer

Saga state machine

Activity