Что хотят услышать интервьюеры:

MassTransit — это библиотека для построения обмена сообщениями в .NET-приложениях, чаще всего поверх брокеров вроде RabbitMQ, Azure Service Bus или ActiveMQ. Она помогает отделить отправителя от получателя и строить асинхронную, более устойчивую распределённую систему. Важно понимать, что это не сам брокер, а удобная абстракция над ним.

Определение:

MassTransit — это framework для message-driven архитектуры в экосистеме .NET. Он упрощает отправку и обработку сообщений, позволяет работать с очередями, подписками, consumers, saga и request/response без ручной работы с низкоуровневым API брокера.

На практике MassTransit берёт на себя инфраструктурные детали: сериализацию сообщений, маршрутизацию, ретраи, конкуррентную обработку, регистрацию consumers и интеграцию с DI-контейнером.

Пример использования:

Допустим, есть сервис заказов и сервис уведомлений. Когда создаётся заказ, сервис заказов публикует событие OrderCreated. Сервис уведомлений подписан на это событие и отправляет письмо или сообщение в мессенджер.

public record OrderCreated(Guid OrderId, string Email);

public class CreateOrderHandler
{
    private readonly IPublishEndpoint _publishEndpoint;

    public CreateOrderHandler(IPublishEndpoint publishEndpoint)
    {
        _publishEndpoint = publishEndpoint;
    }

    public async Task HandleAsync()
    {
        var message = new OrderCreated(Guid.NewGuid(), "user@example.com");
        await _publishEndpoint.Publish(message);
    }
}

public class OrderCreatedConsumer : IConsumer<OrderCreated>
{
    public Task Consume(ConsumeContext<OrderCreated> context)
    {
        var order = context.Message;
        Console.WriteLine($"Send notification for order {order.OrderId} to {order.Email}");
        return Task.CompletedTask;
    }
}

Пояснение кода:

В примере сервис создаёт сообщение OrderCreated и публикует его через IPublishEndpoint. Это означает, что сообщение отправляется всем подписчикам на этот тип события, а не конкретному получателю.

OrderCreatedConsumer реализует IConsumer<OrderCreated>, то есть подписывается на обработку сообщений этого типа. Когда сообщение приходит из брокера, MassTransit вызывает Consume.

Типичный поток такой:

В сервисе создаётся доменное событие.
Оно публикуется в брокер через MassTransit.
Брокер доставляет сообщение всем подписчикам.
Consumer получает сообщение и выполняет бизнес-логику.
При ошибке MassTransit может применить retry или отправить сообщение в dead-letter/ошибочную очередь, в зависимости от настройки.

Ключевые моменты:

MassTransit — это не брокер, а библиотека-абстракция для работы с брокерами сообщений.
Подходит для асинхронной интеграции между микросервисами и снижения связности.
Основные сценарии: publish/subscribe, send/receive, request/response, consumers, sagas.
Даёт готовую инфраструктуру: DI, ретраи, маршрутизацию, сериализацию, конкуррентность.
Удобен, когда важно сделать систему более устойчивой к сбоям и пикам нагрузки.
Для работы всё равно нужен транспорт: RabbitMQ, Azure Service Bus или другой поддерживаемый брокер.

Можно ли объяснить, что такое библиотека MassTransit и как она используется для обмена сообщениями в распределенных системах?