Что такое MassTransit?

Ну что за день сегодня, блядь, опять про MassTransit спрашивают. Ладно, слушай сюда, разберём эту штуку, чтобы ты наконец перестал путать её с автобусом до работы.

MassTransit — это такая библиотека для .NET, которая делает из тебя, грубо говоря, ленивого гения. Вместо того чтобы вручную ебаться с RabbitMQ, Azure Service Bus или Amazon SQS, ты пишешь код на шарпе, а она за тебя всю грязную работу делает: соединяется, слушает очереди, шлёт сообщения. Представь, что ты не сам везешь кирпичи на стройку, а нанимаешь грузчиков, которые сами знают, куда и как их таскать.

Зачем это вообще нужно, спросишь?

1. Чтобы не привязываться к одному брокеру. Написал логику под RabbitMQ, а завтра начальство говорит: «Всё, переезжаем в облако Азура!». Ты не переписываешь половину приложения, а меняешь пару строк в конфигурации — и библиотека уже общается с Azure Service Bus. Магия, епта!
2. Чтобы не изобретать велосипед. Паттерны типа «Опубликовал-Подписался» или «Запрос-Ответ» уже встроены. Хочешь сделать отложенную повторную отправку при ошибке? Не надо городить костыли — есть встроенные политики повтора.
3. Чтобы было надёжно. Само восстанавливает соединение, если брокер упал и поднялся. Сам управляет потоками сообщений. В общем, берёт на себя всю рутину, оставляя тебе только бизнес-логику.

Основные понятия, без которых нихуя не поймёшь:

• Сообщение (Message) — это просто твои данные, упакованные в класс или интерфейс. Как посылка с наклейкой.
• Потребитель (Consumer) — это работяга, который сидит и ждёт, когда ему в очередь упадёт сообщение определённого типа, чтобы его обработать.
• Шина (Bus) — главный диспетчер. Через него всё настраивается, соединяется и управляется.

Смотри, как это выглядит в жизни. Допустим, у нас интернет-магазин и кто-то оформил заказ.

1. Создаём контракт — что за событие произошло.

   public record OrderSubmitted
   {
       public Guid OrderId { get; init; }
       public string CustomerName { get; init; }
       public DateTime SubmittedAt { get; init; }
   }

2. Пишем потребителя, который это событие будет жрать и обрабатывать. Например, чтобы слать письмо клиенту.

   public class OrderSubmittedConsumer : IConsumer<OrderSubmitted>
   {
       private readonly ILogger<OrderSubmittedConsumer> _logger;
       public OrderSubmittedConsumer(ILogger<OrderSubmittedConsumer> logger) => _logger = logger;
   
       public async Task Consume(ConsumeContext<OrderSubmitted> context)
       {
           var message = context.Message;
           // Вот тут твоя логика, блядь!
           _logger.LogInformation("Прилетел заказ {OrderId} от {CustomerName}", 
                                  message.OrderId, message.CustomerName);
           // Тут можешь, например, дернуть сервис нотификаций
           // await _emailService.SendConfirmationAsync(message.OrderId);
       }
   }

3. Настраиваем всю эту карусель в Program.cs.

   builder.Services.AddMassTransit(x =>
   {
       // Говорим: «Найди всех потребителей в моей сборке и зарегистрируй».
       x.AddConsumers(typeof(Program).Assembly);
   
       // Говорим, на чём будем ездить. Допустим, RabbitMQ на локалхосте.
       x.UsingRabbitMq((context, cfg) =>
       {
           cfg.Host("localhost", "/", h =>
           {
               h.Username("guest");
               h.Password("guest"); // Красиво, безопасно, мать его.
           });
   
           // Эта волшебная строка сама создаст нужные очереди и привяжет потребителей.
           cfg.ConfigureEndpoints(context);
       });
   });

4. А теперь, когда заказ создался, мы его публикуем из контроллера (или откуда угодно).

   public class OrderController : ControllerBase
   {
       private readonly IPublishEndpoint _publishEndpoint;
       public OrderController(IPublishEndpoint publishEndpoint) => _publishEndpoint = publishEndpoint;
   
       [HttpPost]
       public async Task<IActionResult> SubmitOrder(OrderDto order)
       {
           // Сохранили заказ в свою БД...
           // И ПУБЛИКУЕМ событие! Все подписчики (наши потребители) его получат.
           await _publishEndpoint.Publish(new OrderSubmitted
           {
               OrderId = Guid.NewGuid(),
               CustomerName = order.CustomerName,
               SubmittedAt = DateTime.UtcNow
           });
           return Accepted();
       }
   }

Что в этом хорошего?

• Не нужно быть семи пядей во лбу, чтобы начать работать с очередями.
• Всё аккуратно интегрируется с Dependency Injection из коробки.
• Есть даже такие мощные штуки, как Saga для координации сложных процессов между сервисами. Это когда нужно сделать что-то вроде «забронировать отель, а потом билеты, а если билетов нет — отменить отель».

А где подвох?

• Абстракция — она как одеяло: греет, но может и задушить.** Если ты не понимаешь базовых принципов messaging (очереди, обменники, routing keys), то, когда что-то пойдёт не так, ты будешь плакать, глядя в логи, и не понимать, где искать проблему.
• Надо учиться. Чтобы выжать из неё всё, а не просто кидать сообщения туда-сюда, придётся почитать документацию и понять, как она работает внутри. Иначе получится «работает, но не очень».

Короче, MassTransit — это как крутой автомат для приготовления кофе. Нажал кнопку — получил результат. Но если он сломается, чинить его будет сложнее, чем простую турку. Выбирай с умом.