Может ли MassTransit отправлять сообщения не через брокер?

Краткий ответ

Да, MassTransit может отправлять сообщения без использования традиционных брокеров сообщений (RabbitMQ, Azure Service Bus, Kafka и т.д.). Это достигается через встроенные транспортные механизмы In-Memory и Direct.

Основные механизмы отправки без брокера

1. In-Memory Transport (внутрипроцессный транспорт)

Самый распространенный сценарий — обмен сообщениями внутри одного процесса (приложения). Сообщения передаются через память, что исключает сетевые задержки и сериализацию.

// Конфигурация In-Memory транспорта
services.AddMassTransit(x =>
{
    x.UsingInMemory((context, cfg) =>
    {
        cfg.ReceiveEndpoint("order-queue", ep =>
        {
            ep.Handler<SubmitOrder>(async context =>
            {
                await context.Publish(new OrderSubmitted { OrderId = context.Message.OrderId });
            });
        });
    });
});

Преимущества:

• Максимальная производительность — отсутствие сетевых вызовов и сериализации.
• Идеален для тестирования — изоляция тестов без зависимостей от внешних систем.
• Упрощенная разработка — можно разрабатывать и тестировать взаимодействия компонентов локально.

Ограничения:

• Сообщения существуют только пока жив процесс.
• Нет персистентности — при падении приложения сообщения теряются.
• Только для внутрипроцессного взаимодействия.

2. Direct Transport (прямой обмен)

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

// Конфигурация Direct транспорта
services.AddMassTransit(x =>
{
    x.UsingDirect((context, cfg) =>
    {
        cfg.Host("direct://localhost/"); // Использует файловую систему
        cfg.ReceiveEndpoint("direct-queue", ep =>
        {
            ep.Handler<ProcessData>(async context =>
            {
                // Обработка сообщения
            });
        });
    });
});

Преимущества:

• Межпроцессное взаимодействие — обмен между разными процессами на одном сервере.
• Проще сетевой инфраструктуры — не требует установки и поддержки брокера.
• Подходит для Windows-сервисов — эффективное взаимодействие служб на одной машине.

Ограничения:

• Привязан к одной физической машине.
• Ограниченная масштабируемость по сравнению с сетевыми брокерами.
• Менее надежен, чем промышленные брокеры сообщений.

3. Loopback Transport (тестовый режим)

Специальный транспорт для юнит-тестирования, который имитирует работу брокера в памяти.

// Использование в тестах
[Test]
public async Task Should_publish_order_submitted_event()
{
    var harness = new InMemoryTestHarness();
    var consumerHarness = harness.Consumer<OrderSubmittedConsumer>();
    
    await harness.Start();
    try
    {
        await harness.Bus.Publish(new SubmitOrder { OrderId = NewId.NextGuid() });
        
        Assert.IsTrue(await harness.Published.Any<OrderSubmitted>());
        Assert.IsTrue(await consumerHarness.Consumed.Any<SubmitOrder>());
    }
    finally
    {
        await harness.Stop();
    }
}

Практические сценарии использования

Разработка и тестирование

• Юнит-тестирование потребителей и саг без зависимостей от инфраструктуры.
• Интеграционные тесты с полным циклом обработки сообщений.
• Локальная разработка сложных взаимодействий между сервисами.

Специализированные архитектуры

• Модульные приложения — обмен сообщениями между модулями внутри одного процесса.
• Микросервисы на одном хосте — для сред с жесткими требованиями к изоляции сети.
• Высокопроизводительные вычисления — когда накладные расходы на сеть неприемлемы.

Ограничения и рекомендации

Когда НЕ стоит использовать транспорт без брокера:

1. Распределенные системы — если сервисы работают на разных серверах.
2. Требования к надежности — когда нужны гарантии доставки, персистентность, dead-letter очереди.
3. Масштабирование — горизонтальное масштабирование потребителей требует брокера.
4. Интеграция между технологиями — брокеры поддерживают межплатформенное взаимодействие.

Рекомендации по переходу:

// Паттерн "много транспортов" - постепенный переход
services.AddMassTransit(x =>
{
    // Локальное взаимодействие
    x.UsingInMemory();
    
    // Внешнее взаимодействие
    x.AddRabbitMqBus("rabbit", (provider, cfg) =>
    {
        cfg.Host("rabbitmq://localhost");
    });
});

Заключение

MassTransit предоставляет гибкую транспортную абстракцию, которая не ограничивается только сетевыми брокерами. In-Memory и Direct транспорты — это полноценные механизмы обмена сообщениями, которые идеально подходят для:

• Тестирования и локальной разработки
• Внутрипроцессного взаимодействия в модульных приложениях
• Специализированных сценариев с повышенными требованиями к производительности

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